| /dports/www/gstreamer1-plugins-neon/gst-plugins-bad-1.16.2/tests/examples/webrtc/ |
| H A D | webrtctransceiver.c | 8 static GstElement *pipe1, *webrtc1, *webrtc2; variable
178 pipe1 = in main()
183 bus1 = gst_pipeline_get_bus (GST_PIPELINE (pipe1)); in main()
184 gst_bus_add_watch (bus1, (GstBusFunc) _bus_watch, pipe1); in main()
186 webrtc1 = gst_bin_get_by_name (GST_BIN (pipe1), "send"); in main()
191 webrtc2 = gst_bin_get_by_name (GST_BIN (pipe1), "recv"); in main()
193 pipe1); in main()
202 gst_element_set_state (GST_ELEMENT (pipe1), GST_STATE_PLAYING); in main()
206 gst_element_set_state (GST_ELEMENT (pipe1), GST_STATE_NULL); in main()
213 gst_object_unref (pipe1); in main()
|
| /dports/multimedia/gstreamer1-plugins-ttml/gst-plugins-bad-1.16.2/tests/examples/webrtc/ |
| H A D | webrtctransceiver.c | 8 static GstElement *pipe1, *webrtc1, *webrtc2; variable
178 pipe1 = in main()
183 bus1 = gst_pipeline_get_bus (GST_PIPELINE (pipe1)); in main()
184 gst_bus_add_watch (bus1, (GstBusFunc) _bus_watch, pipe1); in main()
186 webrtc1 = gst_bin_get_by_name (GST_BIN (pipe1), "send"); in main()
191 webrtc2 = gst_bin_get_by_name (GST_BIN (pipe1), "recv"); in main()
193 pipe1); in main()
202 gst_element_set_state (GST_ELEMENT (pipe1), GST_STATE_PLAYING); in main()
206 gst_element_set_state (GST_ELEMENT (pipe1), GST_STATE_NULL); in main()
213 gst_object_unref (pipe1); in main()
|
| /dports/mail/courier/courier-0.65.3/courier/libs/ |
| H A D | comsubmitclient.c | 101 int pipe0[2], pipe1[2]; in submit_fork() local
114 if (pipe(pipe1)) in submit_fork()
130 close(pipe1[0]); in submit_fork()
132 dup2(pipe1[1], 1); in submit_fork()
134 close(pipe1[1]); in submit_fork()
149 close(pipe1[1]); in submit_fork()
157 close(pipe1[0]); in submit_fork()
167 close(pipe1[0]); in submit_fork()
172 if (fcntl(pipe1[0], F_SETFD, FD_CLOEXEC) || in submit_fork()
173 (fromsubmit=fdopen(pipe1[0], "r")) == NULL) in submit_fork()
[all …]
|
| /dports/games/openclonk/openclonk-release-8.1-src/planet/Objects.ocd/Libraries.ocd/LiquidControl.ocd/LiquidTank.ocd/ |
| H A D | Script.c | 175 public func GetConnectedPipeMessage(string base_msg, object pipe1, object pipe2) in GetConnectedPipeMessage() argument
177 var connected1 = (pipe1->GetConnectedObject(this) ?? pipe1->GetConnectedObject(pipe1)) ?? pipe1; in GetConnectedPipeMessage()
181 var connected2 = (pipe2->GetConnectedObject(this) ?? pipe2->GetConnectedObject(pipe1)) ?? pipe2; in GetConnectedPipeMessage()
187 public func GetConnectedPipeDescription(string base_desc, object pipe1, object pipe2) in GetConnectedPipeDescription() argument
189 var connected1 = (pipe1->GetConnectedObject(this) ?? pipe1->GetConnectedObject(pipe1)) ?? pipe1; in GetConnectedPipeDescription()
193 var connected2 = (pipe2->GetConnectedObject(this) ?? pipe2->GetConnectedObject(pipe1)) ?? pipe2; in GetConnectedPipeDescription()
|
| /dports/editors/hexer/hexer-1.0.3/ |
| H A D | exh.c | 106 int pipe1[2], pipe2[2]; in exh_shell_command() local
130 pipe1[0] = pipe1[1] = -1; in exh_shell_command()
133 if (pipe1[0] > 0) { close(pipe1[0]); close(pipe1[1]); } in exh_shell_command()
139 close(pipe1[0]); in exh_shell_command()
147 close(pipe1[1]); in exh_shell_command()
153 close(pipe1[1]); in exh_shell_command()
183 close(pipe1[1]); in exh_shell_command()
189 close(pipe1[0]); in exh_shell_command()
201 close(pipe1[1]); in exh_shell_command()
204 close(pipe1[1]); in exh_shell_command()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/most/ |
| H A D | core.c | 58 struct pipe pipe1; member
481 if (c->pipe1.comp) { in print_links()
706 c->pipe1.comp = NULL; in most_remove_link()
855 if (c->pipe1.refs && c->pipe1.comp->tx_completion) in arm_mbo()
965 (comp == c->pipe1.comp && c->pipe1.num_buffers <= 0))) in channel_has_mbo()
998 (comp == c->pipe1.comp && c->pipe1.num_buffers <= 0))) in most_get_mbo()
1072 if (c->pipe1.refs && c->pipe1.comp->rx_completion && in most_read_completion()
1143 c->pipe1.refs++; in most_start_channel()
1209 c->pipe1.refs--; in most_stop_channel()
1391 if (c->pipe1.comp) in most_deregister_interface()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/most/ |
| H A D | core.c | 58 struct pipe pipe1; member
481 if (c->pipe1.comp) { in print_links()
706 c->pipe1.comp = NULL; in most_remove_link()
855 if (c->pipe1.refs && c->pipe1.comp->tx_completion) in arm_mbo()
965 (comp == c->pipe1.comp && c->pipe1.num_buffers <= 0))) in channel_has_mbo()
998 (comp == c->pipe1.comp && c->pipe1.num_buffers <= 0))) in most_get_mbo()
1072 if (c->pipe1.refs && c->pipe1.comp->rx_completion && in most_read_completion()
1143 c->pipe1.refs++; in most_start_channel()
1209 c->pipe1.refs--; in most_stop_channel()
1391 if (c->pipe1.comp) in most_deregister_interface()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/most/ |
| H A D | core.c | 58 struct pipe pipe1; member
481 if (c->pipe1.comp) { in print_links()
706 c->pipe1.comp = NULL; in most_remove_link()
855 if (c->pipe1.refs && c->pipe1.comp->tx_completion) in arm_mbo()
965 (comp == c->pipe1.comp && c->pipe1.num_buffers <= 0))) in channel_has_mbo()
998 (comp == c->pipe1.comp && c->pipe1.num_buffers <= 0))) in most_get_mbo()
1072 if (c->pipe1.refs && c->pipe1.comp->rx_completion && in most_read_completion()
1143 c->pipe1.refs++; in most_start_channel()
1209 c->pipe1.refs--; in most_stop_channel()
1391 if (c->pipe1.comp) in most_deregister_interface()
[all …]
|
| /dports/sysutils/R-cran-processx/processx/tests/testthat/ |
| H A D | test-extra-connections.R | 64 pipe1 <- conn_create_pipepair(nonblocking = c(FALSE, FALSE)) globalVar
69 connections = list(pipe1[[1]], pipe2[[2]])
72 close(pipe1[[1]])
77 conn_write(pipe1[[2]], msg)
81 close(pipe1[[2]])
|
| /dports/ftp/ncftp3/ncftp-3.2.6/libncftp/ |
| H A D | io_gettar.c | 23 int pipe1[2]; in OpenTar() local
35 if (pipe(pipe1) < 0) { in OpenTar()
42 (void) close(pipe1[0]); in OpenTar()
43 (void) close(pipe1[1]); in OpenTar()
51 (void) close(pipe1[1]); /* close write end */ in OpenTar()
52 (void) dup2(pipe1[0], 0); /* use read end on stdin */ in OpenTar()
53 (void) close(pipe1[0]); in OpenTar()
70 (void) close(pipe1[0]); /* close read end */ in OpenTar()
71 return (pipe1[1]); /* use write end */ in OpenTar()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/thrift/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 44 TPipeServer pipe1("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
45 pipe1.listen(); in BOOST_AUTO_TEST_CASE()
46 pipe1.interrupt(); in BOOST_AUTO_TEST_CASE()
47 BOOST_CHECK_THROW(pipe1.accept(), TTransportException); in BOOST_AUTO_TEST_CASE()
|
| /dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 44 TPipeServer pipe1("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
45 pipe1.listen(); in BOOST_AUTO_TEST_CASE()
46 pipe1.interrupt(); in BOOST_AUTO_TEST_CASE()
47 BOOST_CHECK_THROW(pipe1.accept(), TTransportException); in BOOST_AUTO_TEST_CASE()
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 44 TPipeServer pipe1("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
45 pipe1.listen(); in BOOST_AUTO_TEST_CASE()
46 pipe1.interrupt(); in BOOST_AUTO_TEST_CASE()
47 BOOST_CHECK_THROW(pipe1.accept(), TTransportException); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/thrift-c_glib/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 44 TPipeServer pipe1("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
45 pipe1.listen(); in BOOST_AUTO_TEST_CASE()
46 pipe1.interrupt(); in BOOST_AUTO_TEST_CASE()
47 BOOST_CHECK_THROW(pipe1.accept(), TTransportException); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/thrift-cpp/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 44 TPipeServer pipe1("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
45 pipe1.listen(); in BOOST_AUTO_TEST_CASE()
46 pipe1.interrupt(); in BOOST_AUTO_TEST_CASE()
47 BOOST_CHECK_THROW(pipe1.accept(), TTransportException); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 44 TPipeServer pipe1("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
45 pipe1.listen(); in BOOST_AUTO_TEST_CASE()
46 pipe1.interrupt(); in BOOST_AUTO_TEST_CASE()
47 BOOST_CHECK_THROW(pipe1.accept(), TTransportException); in BOOST_AUTO_TEST_CASE()
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/apache/thrift/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 44 TPipeServer pipe1("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
45 pipe1.listen(); in BOOST_AUTO_TEST_CASE()
46 pipe1.interrupt(); in BOOST_AUTO_TEST_CASE()
47 BOOST_CHECK_THROW(pipe1.accept(), TTransportException); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/node-thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 44 TPipeServer pipe1("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
45 pipe1.listen(); in BOOST_AUTO_TEST_CASE()
46 pipe1.interrupt(); in BOOST_AUTO_TEST_CASE()
47 BOOST_CHECK_THROW(pipe1.accept(), TTransportException); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/py-thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 44 TPipeServer pipe1("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
45 pipe1.listen(); in BOOST_AUTO_TEST_CASE()
46 pipe1.interrupt(); in BOOST_AUTO_TEST_CASE()
47 BOOST_CHECK_THROW(pipe1.accept(), TTransportException); in BOOST_AUTO_TEST_CASE()
|
| /dports/mail/courier/courier-0.65.3/courier/ |
| H A D | cddrvinfo.C | 146 int pipe0[2], pipe1[2]; in init() local
148 if (pipe(pipe0) || pipe(pipe1)) in init()
164 close(pipe1[0]); in init()
166 dup2(pipe1[1], 1); in init()
168 close(pipe1[1]); in init()
222 close(pipe1[1]); in init()
225 fcntl(pipe1[0], F_SETFD, FD_CLOEXEC)) in init()
231 mybuf_init( &modules[cnt].module_from, pipe1[0] ); in init()
|
| /dports/shells/klish/klish-2.1.4/clish/shell/ |
| H A D | shell_execute.c | 207 int pipe1[2], pipe2[2]; in clish_shell_exec_oaction() local
211 if (pipe(pipe1)) in clish_shell_exec_oaction()
233 close(pipe1[1]); in clish_shell_exec_oaction()
244 ret = readv(pipe1[0], iov, 1); in clish_shell_exec_oaction()
258 close(pipe1[0]); in clish_shell_exec_oaction()
276 dup2(pipe1[1], STDOUT_FILENO); in clish_shell_exec_oaction()
277 close(pipe1[0]); in clish_shell_exec_oaction()
278 close(pipe1[1]); in clish_shell_exec_oaction()
298 close(pipe1[0]); in clish_shell_exec_oaction()
299 close(pipe1[1]); in clish_shell_exec_oaction()
|
| /dports/devel/p5-Pipeline/Pipeline-3.12/t/ |
| H A D | 15nestedstore.t | 9 my $pipe1 = Pipeline->new();
13 $pipe1->add_segment( MySegmentPlacer->new(), $pipe2 );
14 $pipe1->dispatch();
|
| /dports/devel/capnproto/capnproto-0.9.0/c++/src/capnp/compat/ |
| H A D | websocket-rpc-test.c++ | 85 auto pipe1 = kj::newWebSocketPipe(); variable
88 auto msgStreamA = capnp::WebSocketMessageStream(*pipe1.ends[0]);
91 auto pumpTask = pipe1.ends[1]->pumpTo(*pipe2.ends[0]);
109 KJ_EXPECT(pipe1.ends[0]->sentByteCount() == 2585);
110 KJ_EXPECT(pipe1.ends[1]->receivedByteCount() == 2585);
|
| /dports/games/trackballs/trackballs-1.3.3/share/levels/ |
| H A D | child5.scm | 35 (define pipe1(pipe 240.2 252.0 2.5 243.7 252. 2.5 0.5)) unknown
36 (set-primary-color pipe1 .3 .7 .9 .4)
44 (trigger 240 249 0.5 (lambda() (set-primary-color pipe1 .3 .7 .9 .0)))
48 (trigger 240 252 0.5 (lambda() (set-primary-color pipe1 .3 .7 .9 .0)))
49 (trigger 240 251 0.5 (lambda() (set-primary-color pipe1 .3 .7 .9 .5)))
|
| /dports/mail/cvsmail/mailutils-2.2/ |
| H A D | rotatemail.c | 413 int pipe1[2], pipe2[2]; in mbox_rotate() local
416 if (pipe(pipe1) < 0) in mbox_rotate()
424 close(pipe1[0]); in mbox_rotate()
433 if (pipe1[1] != STDOUT_FILENO) { in mbox_rotate()
434 dup2(pipe1[1], STDOUT_FILENO); in mbox_rotate()
435 close(pipe1[1]); in mbox_rotate()
442 close(pipe1[1]); in mbox_rotate()
457 if (pipe1[0] != STDIN_FILENO) { in mbox_rotate()
458 dup2(pipe1[0], STDIN_FILENO); in mbox_rotate()
459 close(pipe1[0]); in mbox_rotate()
[all …]
|