Searched refs:tcp_server_ (Results 1 – 3 of 3) sorted by relevance
/third_party/grpc/test/cpp/interop/ |
D | reconnect_interop_server.cc | 69 reconnect_server_init(&tcp_server_); in ReconnectServiceImpl() 74 reconnect_server_destroy(&tcp_server_); in ~ReconnectServiceImpl() 78 void Poll(int seconds) { reconnect_server_poll(&tcp_server_, seconds); } in Poll() 94 tcp_server_.max_reconnect_backoff_ms = in Start() 101 reconnect_server_start(&tcp_server_, retry_port_); in Start() 103 reconnect_server_clear_timestamps(&tcp_server_); in Start() 112 reconnect_server_clear_timestamps(&tcp_server_); in Stop() 124 const int kMaxBackoffMs = tcp_server_.max_reconnect_backoff_ms in Verify() 125 ? tcp_server_.max_reconnect_backoff_ms in Verify() 128 for (timestamp_list* cur = tcp_server_.head; cur && cur->next; in Verify() [all …]
|
/third_party/grpc/src/core/ext/transport/chttp2/server/ |
D | chttp2_server.cc | 112 listener_->tcp_server_, &listener_->resolved_address_, &port_temp); in UpdateConfig() 170 grpc_tcp_server* tcp_server_; member in grpc_core::__anonb188a9f60111::Chttp2ServerListener 331 grpc_tcp_server_unref(self->listener_->tcp_server_); in OnHandshakeDone() 351 args, &listener->tcp_server_); in Create() 358 error = grpc_tcp_server_add_port(listener->tcp_server_, addr, port_num); in Create() 376 if (listener->tcp_server_ != nullptr) { in Create() 378 grpc_tcp_server_unref(listener->tcp_server_); in Create() 395 &listener->tcp_server_shutdown_complete_, args, &listener->tcp_server_); in CreateWithAcceptor() 403 *arg_val = grpc_tcp_server_create_fd_handler(listener->tcp_server_); in CreateWithAcceptor() 440 grpc_tcp_server_start(tcp_server_, &server_->pollsets(), OnAccept, this); in StartListening() [all …]
|
/third_party/grpc/test/cpp/end2end/ |
D | port_sharing_end2end_test.cc | 99 test_tcp_server_init(&tcp_server_, &TestTcpServer::OnConnect, this); in TestTcpServer() 106 test_tcp_server_destroy(&tcp_server_); in ~TestTcpServer() 114 test_tcp_server_start(&tcp_server_, port_); in Start() 134 test_tcp_server_poll(&tcp_server_, 1); in Run() 201 test_tcp_server tcp_server_; member in grpc::testing::__anon7907f4340111::TestTcpServer
|