/dports/security/openssh-portable/openssh-8.8p1/openbsd-compat/ |
H A D | bsd-pselect.c | 77 static int notify_pipe[2]; variable 89 if (notify_pipe[0] != -1) in pselect_notify_setup() 90 close(notify_pipe[0]); in pselect_notify_setup() 91 if (notify_pipe[1] != -1) in pselect_notify_setup() 92 close(notify_pipe[1]); in pselect_notify_setup() 99 close(notify_pipe[0]); in pselect_notify_setup() 100 close(notify_pipe[1]); in pselect_notify_setup() 106 notify_pid, notify_pipe[0], notify_pipe[1]); in pselect_notify_setup() 116 if (notify_pipe[1] != -1) in pselect_notify_parent() 122 if (notify_pipe[0] != -1) in pselect_notify_prepare() [all …]
|
/dports/www/tntnet/tntnet-2.2.1/framework/common/ |
H A D | poller.cpp | 69 fcntl(notify_pipe.getReadFd(), F_SETFL, O_NONBLOCK); in PollerImpl() 70 addFd(notify_pipe.getReadFd()); in PollerImpl() 106 notify_pipe.write('A'); in doStop() 113 notify_pipe.write('A'); in addIdleJob() 212 notify_pipe.read(buffer, sizeof(buffer)); in run() 251 addFd(notify_pipe.getReadFd()); in run() 265 fcntl(notify_pipe.getReadFd(), F_SETFL, O_NONBLOCK); in PollerImpl() 268 pollfds.back().fd = notify_pipe.getReadFd(); in PollerImpl() 324 notify_pipe.read(buffer, sizeof(buffer)); in run() 340 notify_pipe.write('A'); in doStop() [all …]
|
/dports/net-p2p/transmission-cli/transmission-3.00/libtransmission/ |
H A D | watchdir-win32.c | 49 evutil_socket_t notify_pipe[2]; member 117 send(backend->notify_pipe[1], (char const*)backend->buffer, bytes_transferred, 0); in tr_watchdir_win32_thread() 235 if (backend->notify_pipe[0] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 237 evutil_closesocket(backend->notify_pipe[0]); in tr_watchdir_win32_free() 240 if (backend->notify_pipe[1] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 242 evutil_closesocket(backend->notify_pipe[1]); in tr_watchdir_win32_free() 262 backend->notify_pipe[0] = backend->notify_pipe[1] = TR_BAD_SOCKET; in tr_watchdir_win32_new() 289 if (evutil_socketpair(AF_INET, SOCK_STREAM, 0, backend->notify_pipe) == -1) in tr_watchdir_win32_new() 295 … = bufferevent_socket_new(tr_watchdir_get_event_base(handle), backend->notify_pipe[0], 0)) == NULL) in tr_watchdir_win32_new()
|
/dports/net-p2p/transmission-qt/transmission-3.00/libtransmission/ |
H A D | watchdir-win32.c | 49 evutil_socket_t notify_pipe[2]; member 117 send(backend->notify_pipe[1], (char const*)backend->buffer, bytes_transferred, 0); in tr_watchdir_win32_thread() 235 if (backend->notify_pipe[0] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 237 evutil_closesocket(backend->notify_pipe[0]); in tr_watchdir_win32_free() 240 if (backend->notify_pipe[1] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 242 evutil_closesocket(backend->notify_pipe[1]); in tr_watchdir_win32_free() 262 backend->notify_pipe[0] = backend->notify_pipe[1] = TR_BAD_SOCKET; in tr_watchdir_win32_new() 289 if (evutil_socketpair(AF_INET, SOCK_STREAM, 0, backend->notify_pipe) == -1) in tr_watchdir_win32_new() 295 … = bufferevent_socket_new(tr_watchdir_get_event_base(handle), backend->notify_pipe[0], 0)) == NULL) in tr_watchdir_win32_new()
|
/dports/net-p2p/transmission-daemon/transmission-3.00/libtransmission/ |
H A D | watchdir-win32.c | 49 evutil_socket_t notify_pipe[2]; member 117 send(backend->notify_pipe[1], (char const*)backend->buffer, bytes_transferred, 0); in tr_watchdir_win32_thread() 235 if (backend->notify_pipe[0] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 237 evutil_closesocket(backend->notify_pipe[0]); in tr_watchdir_win32_free() 240 if (backend->notify_pipe[1] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 242 evutil_closesocket(backend->notify_pipe[1]); in tr_watchdir_win32_free() 262 backend->notify_pipe[0] = backend->notify_pipe[1] = TR_BAD_SOCKET; in tr_watchdir_win32_new() 289 if (evutil_socketpair(AF_INET, SOCK_STREAM, 0, backend->notify_pipe) == -1) in tr_watchdir_win32_new() 295 … = bufferevent_socket_new(tr_watchdir_get_event_base(handle), backend->notify_pipe[0], 0)) == NULL) in tr_watchdir_win32_new()
|
/dports/net-p2p/transmission-gtk/transmission-3.00/libtransmission/ |
H A D | watchdir-win32.c | 49 evutil_socket_t notify_pipe[2]; member 117 send(backend->notify_pipe[1], (char const*)backend->buffer, bytes_transferred, 0); in tr_watchdir_win32_thread() 235 if (backend->notify_pipe[0] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 237 evutil_closesocket(backend->notify_pipe[0]); in tr_watchdir_win32_free() 240 if (backend->notify_pipe[1] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 242 evutil_closesocket(backend->notify_pipe[1]); in tr_watchdir_win32_free() 262 backend->notify_pipe[0] = backend->notify_pipe[1] = TR_BAD_SOCKET; in tr_watchdir_win32_new() 289 if (evutil_socketpair(AF_INET, SOCK_STREAM, 0, backend->notify_pipe) == -1) in tr_watchdir_win32_new() 295 … = bufferevent_socket_new(tr_watchdir_get_event_base(handle), backend->notify_pipe[0], 0)) == NULL) in tr_watchdir_win32_new()
|
/dports/net-p2p/transmission-utils/transmission-3.00/libtransmission/ |
H A D | watchdir-win32.c | 49 evutil_socket_t notify_pipe[2]; member 117 send(backend->notify_pipe[1], (char const*)backend->buffer, bytes_transferred, 0); in tr_watchdir_win32_thread() 235 if (backend->notify_pipe[0] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 237 evutil_closesocket(backend->notify_pipe[0]); in tr_watchdir_win32_free() 240 if (backend->notify_pipe[1] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 242 evutil_closesocket(backend->notify_pipe[1]); in tr_watchdir_win32_free() 262 backend->notify_pipe[0] = backend->notify_pipe[1] = TR_BAD_SOCKET; in tr_watchdir_win32_new() 289 if (evutil_socketpair(AF_INET, SOCK_STREAM, 0, backend->notify_pipe) == -1) in tr_watchdir_win32_new() 295 … = bufferevent_socket_new(tr_watchdir_get_event_base(handle), backend->notify_pipe[0], 0)) == NULL) in tr_watchdir_win32_new()
|
/dports/www/transmission-web/transmission-3.00/libtransmission/ |
H A D | watchdir-win32.c | 49 evutil_socket_t notify_pipe[2]; member 117 send(backend->notify_pipe[1], (char const*)backend->buffer, bytes_transferred, 0); in tr_watchdir_win32_thread() 235 if (backend->notify_pipe[0] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 237 evutil_closesocket(backend->notify_pipe[0]); in tr_watchdir_win32_free() 240 if (backend->notify_pipe[1] != TR_BAD_SOCKET) in tr_watchdir_win32_free() 242 evutil_closesocket(backend->notify_pipe[1]); in tr_watchdir_win32_free() 262 backend->notify_pipe[0] = backend->notify_pipe[1] = TR_BAD_SOCKET; in tr_watchdir_win32_new() 289 if (evutil_socketpair(AF_INET, SOCK_STREAM, 0, backend->notify_pipe) == -1) in tr_watchdir_win32_new() 295 … = bufferevent_socket_new(tr_watchdir_get_event_base(handle), backend->notify_pipe[0], 0)) == NULL) in tr_watchdir_win32_new()
|
/dports/devel/pecl-swoole/swoole-4.8.5/src/core/ |
H A D | channel.cc | 72 object->notify_pipe = new Pipe(true); in arcan_shmifext_defaults() 73 if (!object->notify_pipe->ready()) { in arcan_shmifext_defaults() 75 delete object->notify_pipe; in arcan_shmifext_defaults() 162 return notify_pipe->read(&value, sizeof(value)); in arcan_shmifext_defaults() 171 return notify_pipe->write(&value, sizeof(value)); in arcan_shmifext_defaults() 193 notify_pipe->close(); in arcan_shmifext_defaults() 194 delete notify_pipe; in arcan_shmifext_defaults()
|
/dports/security/gnome-ssh-askpass/openssh-6.6p1/ |
H A D | serverloop.c | 128 static int notify_pipe[2]; variable 132 if (pipe(notify_pipe) < 0) { in notify_setup() 137 close(notify_pipe[0]); in notify_setup() 138 close(notify_pipe[1]); in notify_setup() 140 set_nonblock(notify_pipe[0]); in notify_setup() 141 set_nonblock(notify_pipe[1]); in notify_setup() 144 notify_pipe[0] = -1; /* read end */ in notify_setup() 150 if (notify_pipe[1] != -1) in notify_parent() 156 if (notify_pipe[0] != -1) in notify_prepare() 157 FD_SET(notify_pipe[0], readset); in notify_prepare() [all …]
|
/dports/multimedia/libdc1394/libdc1394-2.2.6/dc1394/usb/ |
H A D | capture.c | 77 if (write (craw->notify_pipe[1], "+", 1)!=1) { in callback() 205 if (pipe (craw->notify_pipe) < 0) { in dc1394_usb_capture_setup() 211 capture->socket = CFSocketCreateWithNative (NULL, craw->notify_pipe[0], in dc1394_usb_capture_setup() 405 if (craw->notify_pipe[0] != 0 || craw->notify_pipe[1] != 0) { in dc1394_usb_capture_stop() 406 close (craw->notify_pipe[0]); in dc1394_usb_capture_stop() 407 close (craw->notify_pipe[1]); in dc1394_usb_capture_stop() 409 craw->notify_pipe[0] = 0; in dc1394_usb_capture_stop() 410 craw->notify_pipe[1] = 0; in dc1394_usb_capture_stop() 451 if (read (craw->notify_pipe[0], &ch, 1)!=1) { in dc1394_usb_capture_dequeue() 505 if (craw->notify_pipe[0] == 0 && craw->notify_pipe[1] == 0) in dc1394_usb_capture_get_fileno() [all …]
|
/dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/polling-2.2.0/src/ |
H A D | poll.rs | 86 let mut notify_pipe = [0; 2]; 87 syscall!(pipe(notify_pipe.as_mut_ptr()))?; 90 let notify_read_flags = syscall!(fcntl(notify_pipe[0], libc::F_GETFL))?; 92 notify_pipe[0], 99 notify_pipe[0], 100 notify_pipe[1] 106 fd: notify_pipe[0], 112 notify_read: notify_pipe[0], 113 notify_write: notify_pipe[1],
|
/dports/textproc/jql/jql-3.0.6/cargo-crates/polling-2.2.0/src/ |
H A D | poll.rs | 86 let mut notify_pipe = [0; 2]; in new() localVariable 87 syscall!(pipe(notify_pipe.as_mut_ptr()))?; in new() 90 let notify_read_flags = syscall!(fcntl(notify_pipe[0], libc::F_GETFL))?; in new() 92 notify_pipe[0], in new() 99 notify_pipe[0], in new() 100 notify_pipe[1] in new() 106 fd: notify_pipe[0], in new() 112 notify_read: notify_pipe[0], in new() 113 notify_write: notify_pipe[1], in new()
|
/dports/audio/ncspot/ncspot-0.9.3/cargo-crates/polling-2.2.0/src/ |
H A D | poll.rs | 86 let mut notify_pipe = [0; 2]; in new() localVariable 87 syscall!(pipe(notify_pipe.as_mut_ptr()))?; in new() 90 let notify_read_flags = syscall!(fcntl(notify_pipe[0], libc::F_GETFL))?; in new() 92 notify_pipe[0], in new() 99 notify_pipe[0], in new() 100 notify_pipe[1] in new() 106 fd: notify_pipe[0], in new() 112 notify_read: notify_pipe[0], in new() 113 notify_write: notify_pipe[1], in new()
|
/dports/security/pam_ssh/pam_ssh-8.0/openssh/ |
H A D | serverloop.c | 122 static int notify_pipe[2]; variable 126 if (pipe(notify_pipe) < 0) { in notify_setup() 131 close(notify_pipe[0]); in notify_setup() 132 close(notify_pipe[1]); in notify_setup() 134 set_nonblock(notify_pipe[0]); in notify_setup() 135 set_nonblock(notify_pipe[1]); in notify_setup() 138 notify_pipe[0] = -1; /* read end */ in notify_setup() 144 if (notify_pipe[1] != -1) in notify_parent() 150 if (notify_pipe[0] != -1) in notify_prepare() 151 FD_SET(notify_pipe[0], readset); in notify_prepare() [all …]
|
/dports/multimedia/obs-studio/obs-studio-27.1.3/plugins/oss-audio/ |
H A D | oss-input.c | 58 int notify_pipe[2]; member 226 fds[1].fd = handle->notify_pipe[0]; in oss_reader_thr() 302 handle->notify_pipe[0] = pfd[0]; in oss_start_reader() 303 handle->notify_pipe[1] = pfd[1]; in oss_start_reader() 316 if (handle->notify_pipe[0] != -1) { in oss_stop_reader() 317 close(handle->notify_pipe[0]); in oss_stop_reader() 318 close(handle->notify_pipe[1]); in oss_stop_reader() 320 handle->notify_pipe[0] = -1; in oss_stop_reader() 321 handle->notify_pipe[1] = -1; in oss_stop_reader() 359 handle->notify_pipe[0] = -1; in oss_create() [all …]
|
/dports/audio/clementine-player/Clementine-1.4.0rc1/3rdparty/tinysvcmdns/ |
H A D | mdnsd.c | 77 int notify_pipe[2]; member 411 if (svr->notify_pipe[0] > max_fd) in main_loop() 412 max_fd = svr->notify_pipe[0]; in main_loop() 420 FD_SET(svr->notify_pipe[0], &sockfd_set); in main_loop() 600 write_pipe(svr->notify_pipe[1], ".", 1); in mdnsd_register_svc() 622 if (create_pipe(server->notify_pipe) != 0) { in mdnsd_start_bind() 659 write_pipe(s->notify_pipe[1], ".", 1); in mdnsd_stop() 665 closesocket(s->notify_pipe[0]); in mdnsd_stop() 666 closesocket(s->notify_pipe[1]); in mdnsd_stop() 668 close(s->notify_pipe[0]); in mdnsd_stop() [all …]
|
/dports/multimedia/libdc1394/libdc1394-2.2.6/dc1394/macosx/ |
H A D | capture.c | 205 write (capture->notify_pipe[1], "+", 1); in callback() 376 pipe (capture->notify_pipe); in dc1394_macosx_capture_setup() 378 capture->socket = CFSocketCreateWithNative (NULL, capture->notify_pipe[0], in dc1394_macosx_capture_setup() 578 if (capture->notify_pipe[0] != 0 || capture->notify_pipe[1] != 0) { in dc1394_macosx_capture_stop() 579 close (capture->notify_pipe[0]); in dc1394_macosx_capture_stop() 580 close (capture->notify_pipe[1]); in dc1394_macosx_capture_stop() 582 capture->notify_pipe[0] = capture->notify_pipe[1] = 0; in dc1394_macosx_capture_stop() 637 read (capture->notify_pipe[0], &ch, 1); in dc1394_macosx_capture_dequeue() 722 if (capture->notify_pipe[0] == 0 && capture->notify_pipe[1] == 0) in dc1394_macosx_capture_get_fileno() 725 return capture->notify_pipe[0]; in dc1394_macosx_capture_get_fileno()
|
/dports/audio/moc/moc-2.5.2/ |
H A D | main.c | 163 int notify_pipe[2]; in start_moc() local 170 if (pipe(notify_pipe)) in start_moc() 177 rc = write (notify_pipe[1], &i, sizeof(i)); in start_moc() 181 close (notify_pipe[0]); in start_moc() 182 close (notify_pipe[1]); in start_moc() 195 close (notify_pipe[1]); in start_moc() 196 if (read(notify_pipe[0], &i, sizeof(i)) != sizeof(i)) in start_moc() 198 close (notify_pipe[0]); in start_moc()
|
/dports/audio/shairport-sync/shairport-sync-3.3.9/ |
H A D | tinysvcmdns.c | 1158 int notify_pipe[2]; member 1477 if (svr->notify_pipe[0] > max_fd) in main_loop() 1478 max_fd = svr->notify_pipe[0]; in main_loop() 1489 FD_SET(svr->notify_pipe[0], &sockfd_set); in main_loop() 1492 if (FD_ISSET(svr->notify_pipe[0], &sockfd_set)) { in main_loop() 1494 read_pipe(svr->notify_pipe[0], (char *)¬ify_buf, 1); in main_loop() 1688 write_pipe(svr->notify_pipe[1], ".", 1); in mdnsd_register_svc() 1709 if (create_pipe(server->notify_pipe) != 0) { in mdnsd_start() 1746 write_pipe(s->notify_pipe[1], ".", 1); in mdnsd_stop() 1751 close_pipe(s->notify_pipe[0]); in mdnsd_stop() [all …]
|
/dports/devel/cgit/cgit-1.2.3/git/ |
H A D | run-command.c | 742 int notify_pipe[2]; in start_command() local 757 if (pipe(notify_pipe)) in start_command() 758 notify_pipe[0] = notify_pipe[1] = -1; in start_command() 791 close(notify_pipe[0]); in start_command() 792 set_cloexec(notify_pipe[1]); in start_command() 793 child_notifier = notify_pipe[1]; in start_command() 876 close(notify_pipe[1]); in start_command() 877 if (xread(notify_pipe[0], &cerr, sizeof(cerr)) == sizeof(cerr)) { in start_command() 887 close(notify_pipe[0]); in start_command()
|
/dports/devel/git-gui/git-2.34.1/ |
H A D | run-command.c | 750 int notify_pipe[2]; in start_command() local 765 if (pipe(notify_pipe)) in start_command() 766 notify_pipe[0] = notify_pipe[1] = -1; in start_command() 797 close(notify_pipe[0]); in start_command() 798 set_cloexec(notify_pipe[1]); in start_command() 799 child_notifier = notify_pipe[1]; in start_command() 882 close(notify_pipe[1]); in start_command() 883 if (xread(notify_pipe[0], &cerr, sizeof(cerr)) == sizeof(cerr)) { in start_command() 893 close(notify_pipe[0]); in start_command()
|
/dports/devel/git-p4/git-2.34.1/ |
H A D | run-command.c | 750 int notify_pipe[2]; in start_command() local 765 if (pipe(notify_pipe)) in start_command() 766 notify_pipe[0] = notify_pipe[1] = -1; in start_command() 797 close(notify_pipe[0]); in start_command() 798 set_cloexec(notify_pipe[1]); in start_command() 799 child_notifier = notify_pipe[1]; in start_command() 882 close(notify_pipe[1]); in start_command() 883 if (xread(notify_pipe[0], &cerr, sizeof(cerr)) == sizeof(cerr)) { in start_command() 893 close(notify_pipe[0]); in start_command()
|
/dports/devel/git-svn/git-2.34.1/ |
H A D | run-command.c | 750 int notify_pipe[2]; in start_command() local 765 if (pipe(notify_pipe)) in start_command() 766 notify_pipe[0] = notify_pipe[1] = -1; in start_command() 797 close(notify_pipe[0]); in start_command() 798 set_cloexec(notify_pipe[1]); in start_command() 799 child_notifier = notify_pipe[1]; in start_command() 882 close(notify_pipe[1]); in start_command() 883 if (xread(notify_pipe[0], &cerr, sizeof(cerr)) == sizeof(cerr)) { in start_command() 893 close(notify_pipe[0]); in start_command()
|
/dports/devel/git/git-2.34.1/ |
H A D | run-command.c | 750 int notify_pipe[2]; in start_command() local 765 if (pipe(notify_pipe)) in start_command() 766 notify_pipe[0] = notify_pipe[1] = -1; in start_command() 797 close(notify_pipe[0]); in start_command() 798 set_cloexec(notify_pipe[1]); in start_command() 799 child_notifier = notify_pipe[1]; in start_command() 882 close(notify_pipe[1]); in start_command() 883 if (xread(notify_pipe[0], &cerr, sizeof(cerr)) == sizeof(cerr)) { in start_command() 893 close(notify_pipe[0]); in start_command()
|