Home
last modified time | relevance | path

Searched refs:tcp_server (Results 1 – 25 of 34) sorted by relevance

12

/third_party/boost/libs/asio/test/latency/
Dtcp_server.cpp25 class tcp_server : boost::asio::coroutine class
28 tcp_server(tcp::acceptor& acceptor, std::size_t buf_size) : in tcp_server() function in tcp_server
61 explicit ref(tcp_server* p) in ref()
72 tcp_server* p_;
101 std::vector<boost::shared_ptr<tcp_server> > servers; in main()
105 boost::shared_ptr<tcp_server> s(new tcp_server(acceptor, buf_size)); in main()
DJamfile.v233 exe tcp_server : tcp_server.cpp ;
/third_party/libuv/test/
Dtest-ipc.c29 static uv_tcp_t tcp_server; variable
72 ASSERT_PTR_EQ(&tcp_server, server); in on_connection()
181 r = uv_tcp_init(uv_default_loop(), &tcp_server); in on_read()
184 r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server); in on_read()
187 r = uv_listen((uv_stream_t*)&tcp_server, BACKLOG, on_connection); in on_read()
250 r = uv_tcp_init(uv_default_loop(), &tcp_server); in on_read_listen_after_bound_twice()
253 r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server); in on_read_listen_after_bound_twice()
256 r = uv_listen((uv_stream_t*)&tcp_server, BACKLOG, on_connection); in on_read_listen_after_bound_twice()
270 uv_close((uv_handle_t*)&tcp_server, NULL); in on_read_listen_after_bound_twice()
551 uv_close((uv_handle_t*)&tcp_server, close_cb); in conn_notify_write_cb()
[all …]
Dtest-tcp-write-to-half-open-connection.c35 static uv_tcp_t tcp_server; variable
48 ASSERT(server == (uv_stream_t*)&tcp_server); in connection_cb()
82 uv_close((uv_handle_t*)&tcp_server, NULL); in read_cb()
115 r = uv_tcp_init(loop, &tcp_server); in TEST_IMPL()
118 r = uv_tcp_bind(&tcp_server, (const struct sockaddr*) &addr, 0); in TEST_IMPL()
121 r = uv_listen((uv_stream_t*)&tcp_server, 1, connection_cb); in TEST_IMPL()
Dblackhole-server.c33 static uv_tcp_t tcp_server; variable
47 ASSERT(stream == (uv_stream_t*)&tcp_server); in connection_cb()
108 r = uv_tcp_init(loop, &tcp_server); in HELPER_IMPL()
111 r = uv_tcp_bind(&tcp_server, (const struct sockaddr*) &addr, 0); in HELPER_IMPL()
114 r = uv_listen((uv_stream_t*)&tcp_server, 128, connection_cb); in HELPER_IMPL()
Dtest-tcp-close-accept.c32 static uv_tcp_t tcp_server; variable
106 uv_close((uv_handle_t*) &tcp_server, close_cb); in read_cb()
121 ASSERT(server == (uv_stream_t*) &tcp_server); in connection_cb()
167 ASSERT(0 == uv_tcp_init(loop, &tcp_server)); in TEST_IMPL()
168 ASSERT(0 == uv_tcp_bind(&tcp_server, (const struct sockaddr*) &addr, 0)); in TEST_IMPL()
169 ASSERT(0 == uv_listen((uv_stream_t*) &tcp_server, in TEST_IMPL()
Dtest-tcp-close-reset.c29 static uv_tcp_t tcp_server; variable
73 uv_close((uv_handle_t*) &tcp_server, NULL); in do_close()
189 start_server(loop, &tcp_server); in TEST_IMPL()
216 start_server(loop, &tcp_server); in TEST_IMPL()
243 start_server(loop, &tcp_server); in TEST_IMPL()
270 start_server(loop, &tcp_server); in TEST_IMPL()
Dtest-tcp-close.c103 uv_tcp_t tcp_server; in TEST_IMPL() local
112 start_server(loop, &tcp_server); in TEST_IMPL()
Dtest-spawn.c51 static uv_tcp_t tcp_server; variable
698 r = uv_tcp_init_ex(uv_default_loop(), &tcp_server, AF_INET); in TEST_IMPL()
700 r = uv_tcp_bind(&tcp_server, (const struct sockaddr*) &addr, 0); in TEST_IMPL()
703 r = uv_fileno((uv_handle_t*) &tcp_server, &handle); in TEST_IMPL()
706 r = uv_fileno((uv_handle_t*) &tcp_server, &fd); in TEST_IMPL()
/third_party/boost/libs/asio/example/cpp03/tutorial/daytime3/
Dserver.cpp69 class tcp_server class
72 tcp_server(boost::asio::io_context& io_context) in tcp_server() function in tcp_server
86 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
110 tcp_server server(io_context); in main()
/third_party/grpc/test/core/util/
Dtest_tcp_server.cc68 nullptr, &server->tcp_server); in test_tcp_server_start()
71 grpc_tcp_server_add_port(server->tcp_server, &resolved_addr, &port_added); in test_tcp_server_start()
75 grpc_tcp_server_start(server->tcp_server, &server->pollset, in test_tcp_server_start()
100 grpc_tcp_server_unref(server->tcp_server); in test_tcp_server_destroy()
Dreconnect_server.cc99 test_tcp_server_init(&server->tcp_server, on_connect, server); in reconnect_server_init()
107 test_tcp_server_start(&server->tcp_server, port); in reconnect_server_start()
111 test_tcp_server_poll(&server->tcp_server, 1000 * seconds); in reconnect_server_poll()
128 test_tcp_server_destroy(&server->tcp_server); in reconnect_server_destroy()
Dreconnect_server.h32 test_tcp_server tcp_server; member
Dtest_tcp_server.h30 grpc_tcp_server* tcp_server = nullptr; member
/third_party/boost/libs/asio/example/cpp03/tutorial/daytime7/
Dserver.cpp68 class tcp_server class
71 tcp_server(boost::asio::io_context& io_context) in tcp_server() function in tcp_server
85 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
150 tcp_server server1(io_context); in main()
/third_party/mindspore/mindspore/ccsrc/ps/core/communicator/
Dtcp_server.cc398 auto tcp_server = reinterpret_cast<TcpServer *>(arg); in TimerCallback() local
399 if (tcp_server->on_timer_callback_) { in TimerCallback()
400 tcp_server->on_timer_callback_(); in TimerCallback()
406 auto tcp_server = reinterpret_cast<TcpServer *>(arg); in TimerOnceCallback() local
407 if (tcp_server->on_timer_once_callback_) { in TimerOnceCallback()
408 tcp_server->on_timer_once_callback_(*tcp_server); in TimerOnceCallback()
/third_party/python/Lib/test/test_asyncio/
Dtest_sslproto.py274 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
337 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
434 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
495 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:
629 with self.tcp_server(server,
669 with self.tcp_server(server,
707 with self.tcp_server(server,
749 with self.tcp_server(server,
Dfunctional.py45 def tcp_server(self, server_prog, *, member in FunctionalTestCaseMixin
87 return self.tcp_server(*args, family=socket.AF_UNIX, **kwargs)
/third_party/pulseaudio/src/modules/dbus/
Dmodule-dbus-protocol.c69 struct server *tcp_server; member
548 if (u->remote_access && !(u->tcp_server = start_tcp_server(u))) { in pa__init()
597 if (u->tcp_server) in pa__done()
598 server_free(u->tcp_server); in pa__done()
/third_party/grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc522 grpc_tcp_server* tcp_server; in Orphan() local
526 tcp_server = tcp_server_; in Orphan()
528 grpc_tcp_server_shutdown_listeners(tcp_server); in Orphan()
529 grpc_tcp_server_unref(tcp_server); in Orphan()
/third_party/boost/libs/asio/doc/
Dtutorial.qbk1193 ``''''''`` tcp_server server(io_context);
1213 [heading The tcp_server class]
1216 ``''''''``class tcp_server
1225 ``''''''`` tcp_server(boost::asio::io_context& io_context)
1245 ``''''''`` boost::bind(&tcp_server::handle_accept, this, new_connection,
1440 ``''''''``class tcp_server
1443 ``''''''`` tcp_server(boost::asio::io_context& io_context)
1457 ``''''''`` boost::bind(&tcp_server::handle_accept, this, new_connection,
1481 ``''''''`` tcp_server server(io_context);
2056 ``''''''`` tcp_server server1(io_context);
[all …]
/third_party/python/Lib/test/
Dtest_largefile.py201 def tcp_server(self, sock): member in TestSocketSendfile
226 self.tcp_server(sock)
/third_party/boost/libs/asio/example/cpp03/tutorial/
Ddaytime_dox.txt153 \until tcp_server
161 \section tutdaytime3classtcp_server The tcp_server class
164 \skip class tcp_server
459 \until tcp_server
470 \section tutdaytime7classtcp The tcp_connection and tcp_server classes
/third_party/mindspore/mindspore/ccsrc/ps/
DCMakeLists.txt14 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/tcp_server.cc")
/third_party/grpc/
DgRPC-Core.podspec788 'src/core/lib/iomgr/tcp_server.cc',
789 'src/core/lib/iomgr/tcp_server.h',
1383 'src/core/lib/iomgr/tcp_server.h',

12