Bug #9039 ยป 0001-socket-avoid-unnecessary-ppoll-select-on-Linux-part-.patch
| ext/socket/basicsocket.c | ||
|---|---|---|
|
GetOpenFile(sock, fptr);
|
||
|
arg.fd = fptr->fd;
|
||
|
arg.flags = NUM2INT(flags);
|
||
|
while (rb_thread_fd_writable(arg.fd),
|
||
|
while (rsock_maybe_fd_writable(arg.fd),
|
||
|
(n = (int)BLOCKING_REGION_FD(func, &arg)) < 0) {
|
||
|
if (rb_io_wait_writable(arg.fd)) {
|
||
|
continue;
|
||
| ext/socket/init.c | ||
|---|---|---|
|
rb_obj_hide(str);
|
||
|
while (rb_io_check_closed(fptr),
|
||
|
rb_thread_wait_fd(arg.fd),
|
||
|
rsock_maybe_wait_fd(arg.fd),
|
||
|
(slen = BLOCKING_REGION_FD(recvfrom_blocking, &arg)) < 0) {
|
||
|
if (!rb_io_wait_readable(fptr->fd)) {
|
||
|
rb_sys_fail("recvfrom(2)");
|
||
| ... | ... | |
|
arg.sockaddr = sockaddr;
|
||
|
arg.len = len;
|
||
|
retry:
|
||
|
rb_thread_wait_fd(fd);
|
||
|
rsock_maybe_wait_fd(fd);
|
||
|
fd2 = (int)BLOCKING_REGION_FD(accept_blocking, &arg);
|
||
|
if (fd2 < 0) {
|
||
|
switch (errno) {
|
||
| ext/socket/rubysocket.h | ||
|---|---|---|
|
NORETURN(void rsock_sys_fail_raddrinfo(const char *, VALUE rai));
|
||
|
NORETURN(void rsock_sys_fail_raddrinfo_or_sockaddr(const char *, VALUE addr, VALUE rai));
|
||
|
/*
|
||
|
* It is safe on Linux to attempt using a socket without waiting on it in
|
||
|
* all cases. For some syscalls (e.g. accept/accept4), blocking on the
|
||
|
* syscall instead of relying on select/poll allows the kernel to use
|
||
|
* "wake-one" behavior and avoid the thundering herd problem.
|
||
|
* This is likely safe on all other *nix-like systems, so this whitelist
|
||
|
* can be expanded by interested parties.
|
||
|
*/
|
||
|
#if defined(__linux__)
|
||
|
static inline int rsock_maybe_fd_writable(int fd) { return 1; }
|
||
|
static inline void rsock_maybe_wait_fd(int fd) { }
|
||
|
#else /* some systems (mswin/mingw) need these. ref: r36946 */
|
||
|
# define rsock_maybe_fd_writable(fd) rb_thread_fd_writable((fd))
|
||
|
# define rsock_maybe_wait_fd(fd) rb_thread_wait_fd((fd))
|
||
|
#endif
|
||
|
#endif
|
||
| ext/socket/udpsocket.c | ||
|---|---|---|
|
retry:
|
||
|
arg.to = res->ai_addr;
|
||
|
arg.tolen = res->ai_addrlen;
|
||
|
rb_thread_fd_writable(arg.fd);
|
||
|
rsock_maybe_fd_writable(arg.fd);
|
||
|
n = (int)BLOCKING_REGION_FD(rsock_sendto_blocking, &arg);
|
||
|
if (n >= 0) {
|
||
|
freeaddrinfo(res0);
|
||