Searched refs:tcp_server (Results 1 – 21 of 21) sorted by relevance
49 grpc_tcp_server* tcp_server; member163 grpc_tcp_server_unref(connection_state->svr_state->tcp_server); in on_handshake_done()182 grpc_tcp_server_ref(state->tcp_server); in on_accept()214 grpc_tcp_server_start(state->tcp_server, pollsets, pollset_count, on_accept, in server_start_listener()247 grpc_tcp_server* tcp_server = state->tcp_server; in server_destroy_listener() local249 grpc_tcp_server_shutdown_listeners(tcp_server); in server_destroy_listener()250 grpc_tcp_server_unref(tcp_server); in server_destroy_listener()257 grpc_tcp_server* tcp_server = nullptr; in grpc_chttp2_server_add_port() local278 &tcp_server); in grpc_chttp2_server_add_port()284 state->tcp_server = tcp_server; in grpc_chttp2_server_add_port()[all …]
46 server->tcp_server = nullptr; in test_tcp_server_init()68 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, 1, in test_tcp_server_start()100 grpc_tcp_server_unref(server->tcp_server); in test_tcp_server_destroy()
100 test_tcp_server_init(&server->tcp_server, on_connect, server); in reconnect_server_init()108 test_tcp_server_start(&server->tcp_server, port); in reconnect_server_start()112 test_tcp_server_poll(&server->tcp_server, seconds); in reconnect_server_poll()129 test_tcp_server_destroy(&server->tcp_server); in reconnect_server_destroy()
26 grpc_tcp_server* tcp_server; member
32 test_tcp_server tcp_server; member
154 tcp_server = LogRecordSocketReceiver()157 port.value = tcp_server.port158 tcp_server.serve_until_stopped()
69 tcp_server = log_socket_server.LogRecordSocketReceiver(73 tcp_server.serve_until_stopped()
269 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:359 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:421 with self.tcp_server(serve, timeout=self.TIMEOUT) as srv:550 with self.tcp_server(server,585 with self.tcp_server(server,624 with self.tcp_server(server,667 with self.tcp_server(server,
49 def tcp_server(self, server_prog, *, member in FunctionalTestCaseMixin99 return self.tcp_server(*args, family=socket.AF_UNIX, **kwargs)
133 netstress -R 3 -g $port > tcp_server.log 2>&1 &
817 static int tcp_server(const char *cgroup, void *arg) in tcp_server() function954 pid = cg_run_nowait(memcg, tcp_server, &args); in test_memcg_sock()
442 'src/core/lib/iomgr/tcp_server.h',632 'src/core/lib/iomgr/tcp_server.h',
451 'src/core/lib/iomgr/tcp_server.h',605 'src/core/lib/iomgr/tcp_server.cc',1056 'src/core/lib/iomgr/tcp_server.h',
364 'src/core/lib/iomgr/tcp_server.cc',727 'src/core/lib/iomgr/tcp_server.cc',963 'src/core/lib/iomgr/tcp_server.cc',1177 'src/core/lib/iomgr/tcp_server.cc',
759 "src/core/lib/iomgr/tcp_server.cc",907 "src/core/lib/iomgr/tcp_server.h",
172 src/core/lib/iomgr/tcp_server.cc \
147 "src\\core\\lib\\iomgr\\tcp_server.cc " +
387 s.files += %w( src/core/lib/iomgr/tcp_server.h )541 s.files += %w( src/core/lib/iomgr/tcp_server.cc )
1028 src/core/lib/iomgr/tcp_server.cc1437 src/core/lib/iomgr/tcp_server.cc1832 src/core/lib/iomgr/tcp_server.cc2143 src/core/lib/iomgr/tcp_server.cc2433 src/core/lib/iomgr/tcp_server.cc3280 src/core/lib/iomgr/tcp_server.cc
1278 src/core/lib/iomgr/tcp_server.cc \1279 src/core/lib/iomgr/tcp_server.h \
1126 src/core/lib/iomgr/tcp_server.h \