Home
last modified time | relevance | path

Searched refs:notify_pipe (Results 1 – 25 of 36) sorted by relevance

12

/dports/security/openssh-portable/openssh-8.8p1/openbsd-compat/
H A Dbsd-pselect.c77 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 Dpoller.cpp69 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 Dwatchdir-win32.c49 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 Dwatchdir-win32.c49 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 Dwatchdir-win32.c49 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 Dwatchdir-win32.c49 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 Dwatchdir-win32.c49 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 Dwatchdir-win32.c49 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 Dchannel.cc72 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 Dserverloop.c128 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 Dcapture.c77 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 Dpoll.rs86 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 Dpoll.rs86 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 Dpoll.rs86 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 Dserverloop.c122 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 Doss-input.c58 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 Dmdnsd.c77 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 Dcapture.c205 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 Dmain.c163 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 Dtinysvcmdns.c1158 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 *)&notify_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 Drun-command.c742 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 Drun-command.c750 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 Drun-command.c750 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 Drun-command.c750 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 Drun-command.c750 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()

12