| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/thrift/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 71 TPipeServer pipeServer("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
72 pipeServer.listen(); in BOOST_AUTO_TEST_CASE()
73 boost::thread acceptThread(std::bind(acceptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); 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 | 71 TPipeServer pipeServer("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
72 pipeServer.listen(); in BOOST_AUTO_TEST_CASE()
73 boost::thread acceptThread(stdcxx::bind(acceptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
74 boost::thread interruptThread(stdcxx::bind(interruptWorker, &pipeServer)); 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 | 71 TPipeServer pipeServer("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
72 pipeServer.listen(); in BOOST_AUTO_TEST_CASE()
73 boost::thread acceptThread(stdcxx::bind(acceptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
74 boost::thread interruptThread(stdcxx::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/thrift-c_glib/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 71 TPipeServer pipeServer("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
72 pipeServer.listen(); in BOOST_AUTO_TEST_CASE()
73 boost::thread acceptThread(std::bind(acceptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/thrift-cpp/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 71 TPipeServer pipeServer("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
72 pipeServer.listen(); in BOOST_AUTO_TEST_CASE()
73 boost::thread acceptThread(std::bind(acceptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 71 TPipeServer pipeServer("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
72 pipeServer.listen(); in BOOST_AUTO_TEST_CASE()
73 boost::thread acceptThread(std::bind(acceptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); 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 | 71 TPipeServer pipeServer("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
72 pipeServer.listen(); in BOOST_AUTO_TEST_CASE()
73 boost::thread acceptThread(std::bind(acceptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/node-thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 71 TPipeServer pipeServer("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
72 pipeServer.listen(); in BOOST_AUTO_TEST_CASE()
73 boost::thread acceptThread(std::bind(acceptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/py-thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 71 TPipeServer pipeServer("TPipeInterruptTest"); in BOOST_AUTO_TEST_CASE() local
72 pipeServer.listen(); in BOOST_AUTO_TEST_CASE()
73 boost::thread acceptThread(std::bind(acceptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/dbus-sharp/dbus-sharp-0.8.1/src/ |
| H A D | Server.cs | 468 …using (NamedPipeServerStream pipeServer = new NamedPipeServerStream (pipePath, PipeDirection.InOut… in DoListen()
470 pipeServer.WaitForConnection (); in DoListen()
475 if (!AcceptClient (pipeServer, out conn)) { in DoListen()
477 pipeServer.Disconnect (); in DoListen()
481 pipeServer.Flush (); in DoListen()
482 pipeServer.WaitForPipeDrain (); in DoListen()
490 pipeServer.Disconnect (); in DoListen()
|
| /dports/archivers/maxcso/maxcso-1.10.0/libuv/test/ |
| H A D | echo-server.c | 38 static uv_pipe_t pipeServer; variable
312 server = (uv_handle_t*)&pipeServer; in pipe_echo_start()
315 r = uv_pipe_init(loop, &pipeServer, 0); in pipe_echo_start()
321 r = uv_pipe_bind(&pipeServer, pipeName); in pipe_echo_start()
327 r = uv_listen((uv_stream_t*)&pipeServer, SOMAXCONN, on_connection); in pipe_echo_start()
|
| H A D | benchmark-pump.c | 50 static uv_pipe_t pipeServer; variable
406 server = (uv_stream_t*)&pipeServer; in HELPER_IMPL()
407 r = uv_pipe_init(loop, &pipeServer, 0); in HELPER_IMPL()
409 r = uv_pipe_bind(&pipeServer, TEST_PIPENAME); in HELPER_IMPL()
411 r = uv_listen((uv_stream_t*)&pipeServer, MAX_WRITE_HANDLES, connection_cb); in HELPER_IMPL()
|
| /dports/net/cjdns/cjdns-cjdns-v21.1/node_build/dependencies/libuv/test/ |
| H A D | echo-server.c | 38 static uv_pipe_t pipeServer; variable
318 server = (uv_handle_t*)&pipeServer; in pipe_echo_start()
321 r = uv_pipe_init(loop, &pipeServer, 0); in pipe_echo_start()
327 r = uv_pipe_bind(&pipeServer, pipeName); in pipe_echo_start()
333 r = uv_listen((uv_stream_t*)&pipeServer, SOMAXCONN, on_connection); in pipe_echo_start()
|
| H A D | benchmark-pump.c | 50 static uv_pipe_t pipeServer; variable
400 server = (uv_stream_t*)&pipeServer; in HELPER_IMPL()
401 r = uv_pipe_init(loop, &pipeServer, 0); in HELPER_IMPL()
403 r = uv_pipe_bind(&pipeServer, TEST_PIPENAME); in HELPER_IMPL()
405 r = uv_listen((uv_stream_t*)&pipeServer, MAX_WRITE_HANDLES, connection_cb); in HELPER_IMPL()
|
| /dports/www/R-cran-httpuv/httpuv/src/libuv/test/ |
| H A D | echo-server.c | 38 static uv_pipe_t pipeServer; variable
337 server = (uv_handle_t*)&pipeServer; in pipe_echo_start()
340 r = uv_pipe_init(loop, &pipeServer, 0); in pipe_echo_start()
346 r = uv_pipe_bind(&pipeServer, pipeName); in pipe_echo_start()
352 r = uv_listen((uv_stream_t*)&pipeServer, SOMAXCONN, on_connection); in pipe_echo_start()
|
| H A D | benchmark-pump.c | 50 static uv_pipe_t pipeServer; variable
406 server = (uv_stream_t*)&pipeServer; in HELPER_IMPL()
407 r = uv_pipe_init(loop, &pipeServer, 0); in HELPER_IMPL()
409 r = uv_pipe_bind(&pipeServer, TEST_PIPENAME); in HELPER_IMPL()
411 r = uv_listen((uv_stream_t*)&pipeServer, MAX_WRITE_HANDLES, connection_cb); in HELPER_IMPL()
|
| /dports/devel/py-uvloop/uvloop-0.16.0/vendor/libuv/test/ |
| H A D | echo-server.c | 38 static uv_pipe_t pipeServer; variable
361 server = (uv_handle_t*)&pipeServer; in pipe_echo_start()
364 r = uv_pipe_init(loop, &pipeServer, 0); in pipe_echo_start()
370 r = uv_pipe_bind(&pipeServer, pipeName); in pipe_echo_start()
376 r = uv_listen((uv_stream_t*)&pipeServer, SOMAXCONN, on_connection); in pipe_echo_start()
|
| H A D | benchmark-pump.c | 50 static uv_pipe_t pipeServer; variable
407 server = (uv_stream_t*)&pipeServer; in HELPER_IMPL()
408 r = uv_pipe_init(loop, &pipeServer, 0); in HELPER_IMPL()
410 r = uv_pipe_bind(&pipeServer, TEST_PIPENAME); in HELPER_IMPL()
412 r = uv_listen((uv_stream_t*)&pipeServer, MAX_WRITE_HANDLES, connection_cb); in HELPER_IMPL()
|
| /dports/devel/libuv/libuv-v1.42.0/test/ |
| H A D | echo-server.c | 38 static uv_pipe_t pipeServer; variable
361 server = (uv_handle_t*)&pipeServer; in pipe_echo_start()
364 r = uv_pipe_init(loop, &pipeServer, 0); in pipe_echo_start()
370 r = uv_pipe_bind(&pipeServer, pipeName); in pipe_echo_start()
376 r = uv_listen((uv_stream_t*)&pipeServer, SOMAXCONN, on_connection); in pipe_echo_start()
|
| H A D | benchmark-pump.c | 50 static uv_pipe_t pipeServer; variable
407 server = (uv_stream_t*)&pipeServer; in HELPER_IMPL()
408 r = uv_pipe_init(loop, &pipeServer, 0); in HELPER_IMPL()
410 r = uv_pipe_bind(&pipeServer, TEST_PIPENAME); in HELPER_IMPL()
412 r = uv_listen((uv_stream_t*)&pipeServer, MAX_WRITE_HANDLES, connection_cb); in HELPER_IMPL()
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.elastic.co/apm/module/apmlambda/ |
| H A D | lambda.go | 149 pipeClient, pipeServer := net.Pipe()
151 go rpc.DefaultServer.ServeConn(pipeServer)
|
| /dports/print/lyx/lyx-2.3.4.2/src/ |
| H A D | Server.h | 139 bool pipeServer();
|
| H A D | Server.cpp | 126 if (!lyxcomm->pipeServer()) { in pipeServerWrapper()
152 bool LyXComm::pipeServer() in pipeServer() function in lyx::LyXComm
|