Home
last modified time | relevance | path

Searched refs:pipe_fd (Results 1 – 25 of 545) sorted by relevance

12345678910>>...22

/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Dmysqld_daemon.cc42 int pipe_fd[2]; in mysqld_daemonize() local
43 if (pipe(pipe_fd) < 0) in mysqld_daemonize()
50 close(pipe_fd[0]); in mysqld_daemonize()
51 close(pipe_fd[1]); in mysqld_daemonize()
58 close(pipe_fd[1]); in mysqld_daemonize()
72 close(pipe_fd[0]); in mysqld_daemonize()
73 close(pipe_fd[1]); in mysqld_daemonize()
79 close(pipe_fd[0]); in mysqld_daemonize()
97 close(pipe_fd[0]); in mysqld_daemonize()
102 close(pipe_fd[1]); in mysqld_daemonize()
[all …]
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Dmysqld_daemon.cc42 int pipe_fd[2]; in mysqld_daemonize() local
43 if (pipe(pipe_fd) < 0) in mysqld_daemonize()
50 close(pipe_fd[0]); in mysqld_daemonize()
51 close(pipe_fd[1]); in mysqld_daemonize()
58 close(pipe_fd[1]); in mysqld_daemonize()
72 close(pipe_fd[0]); in mysqld_daemonize()
73 close(pipe_fd[1]); in mysqld_daemonize()
79 close(pipe_fd[0]); in mysqld_daemonize()
97 close(pipe_fd[0]); in mysqld_daemonize()
102 close(pipe_fd[1]); in mysqld_daemonize()
[all …]
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Dmysqld_daemon.cc42 int pipe_fd[2]; in mysqld_daemonize() local
43 if (pipe(pipe_fd) < 0) in mysqld_daemonize()
50 close(pipe_fd[0]); in mysqld_daemonize()
51 close(pipe_fd[1]); in mysqld_daemonize()
58 close(pipe_fd[1]); in mysqld_daemonize()
72 close(pipe_fd[0]); in mysqld_daemonize()
73 close(pipe_fd[1]); in mysqld_daemonize()
79 close(pipe_fd[0]); in mysqld_daemonize()
97 close(pipe_fd[0]); in mysqld_daemonize()
102 close(pipe_fd[1]); in mysqld_daemonize()
[all …]
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Dmysqld_daemon.cc42 int pipe_fd[2]; in mysqld_daemonize() local
43 if (pipe(pipe_fd) < 0) in mysqld_daemonize()
50 close(pipe_fd[0]); in mysqld_daemonize()
51 close(pipe_fd[1]); in mysqld_daemonize()
58 close(pipe_fd[1]); in mysqld_daemonize()
72 close(pipe_fd[0]); in mysqld_daemonize()
73 close(pipe_fd[1]); in mysqld_daemonize()
79 close(pipe_fd[0]); in mysqld_daemonize()
97 close(pipe_fd[0]); in mysqld_daemonize()
102 close(pipe_fd[1]); in mysqld_daemonize()
[all …]
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/
H A Dmysqld_daemon.cc65 int pipe_fd[2]; in mysqld_daemonize() local
71 close(pipe_fd[0]); in mysqld_daemonize()
72 close(pipe_fd[1]); in mysqld_daemonize()
78 close(pipe_fd[1]); in mysqld_daemonize()
88 close(pipe_fd[0]); in mysqld_daemonize()
89 close(pipe_fd[1]); in mysqld_daemonize()
98 close(pipe_fd[0]); in mysqld_daemonize()
111 close(pipe_fd[0]); in mysqld_daemonize()
115 close(pipe_fd[1]); in mysqld_daemonize()
125 return pipe_fd[1]; in mysqld_daemonize()
[all …]
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Dmysqld_daemon.cc42 int pipe_fd[2]; in mysqld_daemonize() local
43 if (pipe(pipe_fd) < 0) in mysqld_daemonize()
50 close(pipe_fd[0]); in mysqld_daemonize()
51 close(pipe_fd[1]); in mysqld_daemonize()
58 close(pipe_fd[1]); in mysqld_daemonize()
72 close(pipe_fd[0]); in mysqld_daemonize()
73 close(pipe_fd[1]); in mysqld_daemonize()
79 close(pipe_fd[0]); in mysqld_daemonize()
97 close(pipe_fd[0]); in mysqld_daemonize()
102 close(pipe_fd[1]); in mysqld_daemonize()
[all …]
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Dmysqld_daemon.cc42 int pipe_fd[2]; in mysqld_daemonize() local
43 if (pipe(pipe_fd) < 0) in mysqld_daemonize()
50 close(pipe_fd[0]); in mysqld_daemonize()
51 close(pipe_fd[1]); in mysqld_daemonize()
58 close(pipe_fd[1]); in mysqld_daemonize()
72 close(pipe_fd[0]); in mysqld_daemonize()
73 close(pipe_fd[1]); in mysqld_daemonize()
79 close(pipe_fd[0]); in mysqld_daemonize()
97 close(pipe_fd[0]); in mysqld_daemonize()
102 close(pipe_fd[1]); in mysqld_daemonize()
[all …]
/dports/sysutils/tmux23/tmux-2.3/
H A Dcmd-pipe-pane.c65 old_fd = wp->pipe_fd; in cmd_pipe_pane_exec()
66 if (wp->pipe_fd != -1) { in cmd_pipe_pane_exec()
68 close(wp->pipe_fd); in cmd_pipe_pane_exec()
69 wp->pipe_fd = -1; in cmd_pipe_pane_exec()
106 close(pipe_fd[0]); in cmd_pipe_pane_exec()
112 close(pipe_fd[1]); in cmd_pipe_pane_exec()
128 close(pipe_fd[1]); in cmd_pipe_pane_exec()
130 wp->pipe_fd = pipe_fd[0]; in cmd_pipe_pane_exec()
137 setblocking(wp->pipe_fd, 0); in cmd_pipe_pane_exec()
151 close(wp->pipe_fd); in cmd_pipe_pane_error_callback()
[all …]
/dports/sysutils/tmate/tmate-2.4.0/
H A Dcmd-pipe-pane.c65 old_fd = wp->pipe_fd; in cmd_pipe_pane_exec()
66 if (wp->pipe_fd != -1) { in cmd_pipe_pane_exec()
68 close(wp->pipe_fd); in cmd_pipe_pane_exec()
69 wp->pipe_fd = -1; in cmd_pipe_pane_exec()
106 close(pipe_fd[0]); in cmd_pipe_pane_exec()
112 close(pipe_fd[1]); in cmd_pipe_pane_exec()
128 close(pipe_fd[1]); in cmd_pipe_pane_exec()
130 wp->pipe_fd = pipe_fd[0]; in cmd_pipe_pane_exec()
137 setblocking(wp->pipe_fd, 0); in cmd_pipe_pane_exec()
151 close(wp->pipe_fd); in cmd_pipe_pane_error_callback()
[all …]
/dports/sysutils/tmate-ssh-server/tmate-ssh-server-97d2024/
H A Dcmd-pipe-pane.c68 old_fd = wp->pipe_fd; in cmd_pipe_pane_exec()
69 if (wp->pipe_fd != -1) { in cmd_pipe_pane_exec()
71 close(wp->pipe_fd); in cmd_pipe_pane_exec()
72 wp->pipe_fd = -1; in cmd_pipe_pane_exec()
109 close(pipe_fd[0]); in cmd_pipe_pane_exec()
115 close(pipe_fd[1]); in cmd_pipe_pane_exec()
131 close(pipe_fd[1]); in cmd_pipe_pane_exec()
133 wp->pipe_fd = pipe_fd[0]; in cmd_pipe_pane_exec()
140 setblocking(wp->pipe_fd, 0); in cmd_pipe_pane_exec()
155 close(wp->pipe_fd); in cmd_pipe_pane_error_callback()
[all …]
/dports/devel/dev86/dev86-0.16.20/libc/misc/
H A Dpopen.c9 int pipe_fd[2]; local
12 if( pipe(pipe_fd) < 0 ) return NULL;
16 if( pid < 0 ) { close(pipe_fd[0]); close(pipe_fd[1]); return NULL; }
19 close(pipe_fd[!reading]);
21 if( pipe_fd[reading] != reading )
23 dup2(pipe_fd[reading], reading);
24 close(pipe_fd[reading]);
31 close(pipe_fd[reading]);
32 return fdopen(pipe_fd[!reading], rw);
/dports/sysutils/tmux/tmux-3.2a/
H A Dcmd-pipe-pane.c71 old_fd = wp->pipe_fd; in cmd_pipe_pane_exec()
72 if (wp->pipe_fd != -1) { in cmd_pipe_pane_exec()
74 close(wp->pipe_fd); in cmd_pipe_pane_exec()
75 wp->pipe_fd = -1; in cmd_pipe_pane_exec()
131 close(pipe_fd[0]); in cmd_pipe_pane_exec()
145 close(pipe_fd[1]); in cmd_pipe_pane_exec()
159 close(pipe_fd[1]); in cmd_pipe_pane_exec()
161 wp->pipe_fd = pipe_fd[0]; in cmd_pipe_pane_exec()
164 setblocking(wp->pipe_fd, 0); in cmd_pipe_pane_exec()
219 close(wp->pipe_fd); in cmd_pipe_pane_error_callback()
[all …]
/dports/multimedia/gstreamer1/gstreamer-1.16.2/tests/check/elements/
H A Dfdsrc.c80 gint pipe_fd[2]; in GST_START_TEST() local
84 fail_if (pipe (pipe_fd) < 0); in GST_START_TEST()
100 flags = fcntl (pipe_fd[1], F_GETFL, 0); in GST_START_TEST()
107 int ret = write (pipe_fd[1], data, 4096); in GST_START_TEST()
118 close (pipe_fd[0]); in GST_START_TEST()
119 close (pipe_fd[1]); in GST_START_TEST()
130 gint pipe_fd[2]; in GST_START_TEST() local
135 fail_if (pipe (pipe_fd) < 0); in GST_START_TEST()
148 fail_if (write (pipe_fd[1], data, 4096) < 0); in GST_START_TEST()
163 close (pipe_fd[0]); in GST_START_TEST()
[all …]
/dports/net/freerdp/freerdp-2.5.0/winpr/libwinpr/synch/
H A Dsemaphore.c61 return sem->pipe_fd[0]; in SemaphoreGetFd()
92 if (semaphore->pipe_fd[0] != -1) in SemaphoreCloseHandle()
94 close(semaphore->pipe_fd[0]); in SemaphoreCloseHandle()
95 semaphore->pipe_fd[0] = -1; in SemaphoreCloseHandle()
97 if (semaphore->pipe_fd[1] != -1) in SemaphoreCloseHandle()
99 close(semaphore->pipe_fd[1]); in SemaphoreCloseHandle()
100 semaphore->pipe_fd[1] = -1; in SemaphoreCloseHandle()
146 semaphore->pipe_fd[0] = -1; in CreateSemaphoreW()
147 semaphore->pipe_fd[1] = -1; in CreateSemaphoreW()
163 close(semaphore->pipe_fd[0]); in CreateSemaphoreW()
[all …]
/dports/net/freerdp/freerdp-2.5.0/server/Mac/
H A Dmf_event.c42 FD_SET(event_queue->pipe_fd[0], &rfds); in mf_is_event_set()
53 length = write(event_queue->pipe_fd[1], "sig", 4); in mf_signal_event()
188 event_queue->pipe_fd[0] = -1; in mf_event_queue_new()
189 event_queue->pipe_fd[1] = -1; in mf_event_queue_new()
195 if (pipe(event_queue->pipe_fd) < 0) in mf_event_queue_new()
209 if (event_queue->pipe_fd[0] != -1) in mf_event_queue_free()
211 close(event_queue->pipe_fd[0]); in mf_event_queue_free()
212 event_queue->pipe_fd[0] = -1; in mf_event_queue_free()
215 if (event_queue->pipe_fd[1] != -1) in mf_event_queue_free()
217 close(event_queue->pipe_fd[1]); in mf_event_queue_free()
[all …]
/dports/net/wireshark-lite/wireshark-3.6.1/
H A Dsync_pipe_write.c27 pipe_write_header(int pipe_fd, char indicator, int length) in pipe_write_header() argument
41 return ws_write(pipe_fd, header, sizeof header); in pipe_write_header()
50 pipe_write_block(int pipe_fd, char indicator, const char *msg) in pipe_write_block() argument
64 ret = pipe_write_header(pipe_fd, indicator, len); in pipe_write_block()
72 ret = ws_write(pipe_fd, msg, len); in pipe_write_block()
85 sync_pipe_errmsg_to_parent(int pipe_fd, const char *error_msg, in sync_pipe_errmsg_to_parent() argument
89 …pipe_write_header(pipe_fd, SP_ERROR_MSG, (int) (strlen(error_msg) + 1 + 4 + strlen(secondary_error… in sync_pipe_errmsg_to_parent()
90 pipe_write_block(pipe_fd, SP_ERROR_MSG, error_msg); in sync_pipe_errmsg_to_parent()
91 pipe_write_block(pipe_fd, SP_ERROR_MSG, secondary_error_msg); in sync_pipe_errmsg_to_parent()
/dports/net/wireshark/wireshark-3.6.1/
H A Dsync_pipe_write.c27 pipe_write_header(int pipe_fd, char indicator, int length) in pipe_write_header() argument
41 return ws_write(pipe_fd, header, sizeof header); in pipe_write_header()
50 pipe_write_block(int pipe_fd, char indicator, const char *msg) in pipe_write_block() argument
64 ret = pipe_write_header(pipe_fd, indicator, len); in pipe_write_block()
72 ret = ws_write(pipe_fd, msg, len); in pipe_write_block()
85 sync_pipe_errmsg_to_parent(int pipe_fd, const char *error_msg, in sync_pipe_errmsg_to_parent() argument
89 …pipe_write_header(pipe_fd, SP_ERROR_MSG, (int) (strlen(error_msg) + 1 + 4 + strlen(secondary_error… in sync_pipe_errmsg_to_parent()
90 pipe_write_block(pipe_fd, SP_ERROR_MSG, error_msg); in sync_pipe_errmsg_to_parent()
91 pipe_write_block(pipe_fd, SP_ERROR_MSG, secondary_error_msg); in sync_pipe_errmsg_to_parent()
/dports/net/tshark-lite/wireshark-3.6.1/
H A Dsync_pipe_write.c27 pipe_write_header(int pipe_fd, char indicator, int length) in pipe_write_header() argument
41 return ws_write(pipe_fd, header, sizeof header); in pipe_write_header()
50 pipe_write_block(int pipe_fd, char indicator, const char *msg) in pipe_write_block() argument
64 ret = pipe_write_header(pipe_fd, indicator, len); in pipe_write_block()
72 ret = ws_write(pipe_fd, msg, len); in pipe_write_block()
85 sync_pipe_errmsg_to_parent(int pipe_fd, const char *error_msg, in sync_pipe_errmsg_to_parent() argument
89 …pipe_write_header(pipe_fd, SP_ERROR_MSG, (int) (strlen(error_msg) + 1 + 4 + strlen(secondary_error… in sync_pipe_errmsg_to_parent()
90 pipe_write_block(pipe_fd, SP_ERROR_MSG, error_msg); in sync_pipe_errmsg_to_parent()
91 pipe_write_block(pipe_fd, SP_ERROR_MSG, secondary_error_msg); in sync_pipe_errmsg_to_parent()
/dports/net/tshark/wireshark-3.6.1/
H A Dsync_pipe_write.c27 pipe_write_header(int pipe_fd, char indicator, int length) in pipe_write_header() argument
41 return ws_write(pipe_fd, header, sizeof header); in pipe_write_header()
50 pipe_write_block(int pipe_fd, char indicator, const char *msg) in pipe_write_block() argument
64 ret = pipe_write_header(pipe_fd, indicator, len); in pipe_write_block()
72 ret = ws_write(pipe_fd, msg, len); in pipe_write_block()
85 sync_pipe_errmsg_to_parent(int pipe_fd, const char *error_msg, in sync_pipe_errmsg_to_parent() argument
89 …pipe_write_header(pipe_fd, SP_ERROR_MSG, (int) (strlen(error_msg) + 1 + 4 + strlen(secondary_error… in sync_pipe_errmsg_to_parent()
90 pipe_write_block(pipe_fd, SP_ERROR_MSG, error_msg); in sync_pipe_errmsg_to_parent()
91 pipe_write_block(pipe_fd, SP_ERROR_MSG, secondary_error_msg); in sync_pipe_errmsg_to_parent()
/dports/net-p2p/uhub/uhub-a8ee6e7/src/network/
H A Dnotify.c27 int pipe_fd[2]; member
52 int ret = read(handle->pipe_fd[0], &buf, 1); in notify_callback()
68 int ret = pipe(handle->pipe_fd); in net_notify_create()
77 net_con_initialize(handle->con, handle->pipe_fd[0], notify_callback, handle, NET_EVENT_READ); in net_notify_create()
88 close(handle->pipe_fd[0]); in net_notify_destroy()
89 close(handle->pipe_fd[1]); in net_notify_destroy()
90 handle->pipe_fd[0] = -1; in net_notify_destroy()
91 handle->pipe_fd[0] = -1; in net_notify_destroy()
100 write(handle->pipe_fd[1], &data, 1); in net_notify_signal()
/dports/mail/masqmail/masqmail-0.3.5/src/
H A Dpeopen.c65 int pipe_fd[2]; in peidopen() local
82 if (pipe(pipe_fd) == -1) in peidopen()
94 if ((i != pipe_fd[0]) && (i != pipe_fd[1])) in peidopen()
97 if (close(pipe_fd[mode == Read ? 0 : 1]) != -1 && in peidopen()
98 dup2(pipe_fd[mode == Read ? 1 : 0], in peidopen()
126 close(pipe_fd[mode == Read ? 1 : 0]); in peidopen()
127 return fdopen(pipe_fd[mode == Read ? 0 : 1], type); in peidopen()
130 close(pipe_fd[0]); in peidopen()
131 close(pipe_fd[1]); in peidopen()
/dports/dns/bind911/bind-9.11.37/contrib/dnsperf-2.1.0.0-1/
H A Dos.c61 perf_os_waituntilreadable(int fd, int pipe_fd, int64_t timeout) in perf_os_waituntilreadable() argument
70 FD_SET(pipe_fd, &read_fds); in perf_os_waituntilreadable()
71 maxfd = pipe_fd > fd ? pipe_fd : fd; in perf_os_waituntilreadable()
86 } else if (FD_ISSET(pipe_fd, &read_fds)) { in perf_os_waituntilreadable()
94 perf_os_waituntilanyreadable(int *fds, unsigned int nfds, int pipe_fd, in perf_os_waituntilanyreadable() argument
110 FD_SET(pipe_fd, &read_fds); in perf_os_waituntilanyreadable()
111 if (pipe_fd > maxfd) in perf_os_waituntilanyreadable()
112 maxfd = pipe_fd; in perf_os_waituntilanyreadable()
128 } else if (FD_ISSET(pipe_fd, &read_fds)) { in perf_os_waituntilanyreadable()
/dports/sysutils/tmux/tmux-3.2a/compat/
H A Dforkpty-aix.c35 int slave = -1, fd, pipe_fd[2]; in forkpty() local
39 if (pipe(pipe_fd) == -1) in forkpty()
60 close(pipe_fd[1]); in forkpty()
61 while (read(pipe_fd[0], &dummy, 1) == -1) { in forkpty()
65 close(pipe_fd[0]); in forkpty()
106 close(pipe_fd[0]); in forkpty()
107 close(pipe_fd[1]); in forkpty()
116 close(pipe_fd[0]); in forkpty()
117 close(pipe_fd[1]); in forkpty()
/dports/sysutils/tmate-ssh-server/tmate-ssh-server-97d2024/compat/
H A Dforkpty-aix.c31 int slave = -1, fd, pipe_fd[2]; in forkpty() local
35 if (pipe(pipe_fd) == -1) in forkpty()
56 close(pipe_fd[1]); in forkpty()
57 while (read(pipe_fd[0], &dummy, 1) == -1) { in forkpty()
61 close(pipe_fd[0]); in forkpty()
102 close(pipe_fd[0]); in forkpty()
103 close(pipe_fd[1]); in forkpty()
112 close(pipe_fd[0]); in forkpty()
113 close(pipe_fd[1]); in forkpty()
/dports/sysutils/tmux23/tmux-2.3/compat/
H A Dforkpty-aix.c31 int slave = -1, fd, pipe_fd[2]; in forkpty() local
35 if (pipe(pipe_fd) == -1) in forkpty()
56 close(pipe_fd[1]); in forkpty()
57 while (read(pipe_fd[0], &dummy, 1) == -1) { in forkpty()
61 close(pipe_fd[0]); in forkpty()
102 close(pipe_fd[0]); in forkpty()
103 close(pipe_fd[1]); in forkpty()
112 close(pipe_fd[0]); in forkpty()
113 close(pipe_fd[1]); in forkpty()

12345678910>>...22