Home
last modified time | relevance | path

Searched refs:server_ (Results 1 – 25 of 86) sorted by relevance

1234

/external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/
DGetServersResponse.java19 server_ = java.util.Collections.emptyList(); in GetServersResponse()
56 server_ = new java.util.ArrayList<io.grpc.channelz.v1.Server>(); in GetServersResponse()
59 server_.add( in GetServersResponse()
77 server_ = java.util.Collections.unmodifiableList(server_); in GetServersResponse()
97 private java.util.List<io.grpc.channelz.v1.Server> server_; field in GetServersResponse
107 return server_; in getServerList()
119 return server_; in getServerOrBuilderList()
130 return server_.size(); in getServerCount()
141 return server_.get(index); in getServer()
153 return server_.get(index); in getServerOrBuilder()
[all …]
/external/webrtc/webrtc/p2p/base/
Dtestturnserver.h54 : server_(thread) { in TestTurnServer()
56 server_.SetExternalSocketFactory(new rtc::BasicPacketSocketFactory(), in TestTurnServer()
58 server_.set_realm(kTestRealm); in TestTurnServer()
59 server_.set_software(kTestSoftware); in TestTurnServer()
60 server_.set_auth_hook(this); in TestTurnServer()
64 server_.set_enable_otu_nonce(enable); in set_enable_otu_nonce()
67 TurnServer* server() { return &server_; } in server()
70 server_.set_redirect_hook(redirect_hook); in set_redirect_hook()
77 server_.AddInternalSocket(rtc::AsyncUDPSocket::Create( in AddInternalSocket()
86 server_.AddInternalServerSocket(socket, proto); in AddInternalSocket()
[all …]
Dtestrelayserver.h33 : server_(thread) { in TestRelayServer()
34 server_.AddInternalSocket(rtc::AsyncUDPSocket::Create( in TestRelayServer()
36 server_.AddExternalSocket(rtc::AsyncUDPSocket::Create( in TestRelayServer()
45 return server_.GetConnectionCount(); in GetConnectionCount()
48 return server_.GetConnection(connection); in GetConnection()
51 return server_.HasConnection(address); in HasConnection()
77 server_.AddInternalSocket(packet_socket); in OnAccept()
81 server_.AddExternalSocket(packet_socket); in OnAccept()
86 server_.RemoveInternalSocket(socket); in OnInternalClose()
89 server_.RemoveExternalSocket(socket); in OnExternalClose()
[all …]
/external/webrtc/webrtc/base/
Dfirewallsocketserver.cc25 : AsyncSocketAdapter(socket), server_(server), type_(type) { in FirewallSocket()
30 if (!server_->Check(FP_TCP, GetLocalAddress(), addr)) { in Connect()
46 if (!server_->Check(FP_UDP, GetLocalAddress(), addr)) { in SendTo()
65 if (server_->Check(FP_UDP, *paddr, GetLocalAddress())) in RecvFrom()
76 if (!server_->tcp_listen_enabled()) { in Listen()
86 if (server_->Check(FP_TCP, addr, GetLocalAddress())) { in Accept()
101 FirewallSocketServer* server_; member in rtc::FirewallSocket
108 : server_(server), manager_(manager), in FirewallSocketServer()
120 if (server_ && should_delete_server_) { in ~FirewallSocketServer()
121 delete server_; in ~FirewallSocketServer()
[all …]
Dvirtualsocketserver.cc101 : server_(server), in VirtualSocket()
149 int result = server_->Bind(this, &local_addr_); in Bind()
158 server_->msg_queue_->Post(this, MSG_ID_ADDRESS_BOUND); in Bind()
170 server_->Unbind(local_addr_, this); in Close()
181 server_->Disconnect(server_->LookupBinding(addr)); in Close()
191 server_->LookupConnection(local_addr_, remote_addr_); in Close()
197 socket = server_->LookupBinding(remote_addr_); in Close()
199 server_->Disconnect(socket); in Close()
202 server_->RemoveConnection(remote_addr_, local_addr_); in Close()
203 server_->RemoveConnection(local_addr_, remote_addr_); in Close()
[all …]
Dhttpserver.cc121 : connection_id_(connection_id), server_(server), in Connection()
166 server_->Remove(connection_id_); in InitiateClose()
183 server_->SignalHttpRequestHeader(server_, current_, &custom_document); in onHttpHeaderComplete()
195 server_->SignalHttpRequestComplete(server_, current_, err); in onHttpComplete()
203 server_->Remove(connection_id_); in onHttpComplete()
212 server_->SignalHttpRequest(server_, transaction); in onHttpComplete()
226 server_->Remove(connection_id_); in onHttpClosed()
Dfirewallsocketserver.h34 SocketServer* socketserver() const { return server_; } in socketserver()
36 if (server_ && should_delete_server_) { in set_socketserver()
37 delete server_; in set_socketserver() local
38 server_ = NULL; in set_socketserver()
41 server_ = server; in set_socketserver()
75 SocketServer * server_;
Dnatsocketfactory.cc338 : server_(server), msg_queue_(NULL) { in NATSocketServer()
352 return nats_.Add(ext_ip, new Translator(this, type, int_ip, server_, ext_ip)); in AddTranslator()
378 server_->SetMessageQueue(queue); in SetMessageQueue()
382 return server_->Wait(cms, process_io); in Wait()
386 server_->WakeUp(); in WakeUp()
398 socket = server_->CreateAsyncSocket(family, type); in CreateInternalSocket()
407 : server_(server) { in Translator()
411 VirtualSocketServer* internal_server = new VirtualSocketServer(server_); in Translator()
412 internal_server->SetMessageQueue(server_->queue()); in Translator()
433 new Translator(server_, type, int_ip, server_, ext_ip)); in AddTranslator()
Dssladapter_unittest.cc277 server_(new SSLAdapterTestDummyServer(ssl_mode_, key_params)), in SSLAdapterTestBase()
291 rv = client_->Connect(server_->GetHostname(), server_->GetAddress()); in TestHandshake()
299 server_->AcceptConnection(client_->GetAddress()); in TestHandshake()
326 EXPECT_EQ_WAIT(message, server_->GetReceivedData(), kTimeout); in TestTransfer()
328 rv = server_->Send(message); in TestTransfer()
342 rtc::scoped_ptr<SSLAdapterTestDummyServer> server_; member in SSLAdapterTestBase
Dnat_unittest.cc338 accepted_.reset(server_->Accept(NULL)); in OnAcceptEvent()
345 server_->SignalReadEvent.connect(this, &NatTcpTest::OnAcceptEvent); in ConnectEvents()
361 rtc::scoped_ptr<AsyncSocket> server_; member in NatTcpTest
366 server_.reset(ext_vss_->CreateAsyncSocket(SOCK_STREAM)); in TEST_F()
367 server_->Bind(ext_addr_); in TEST_F()
368 server_->Listen(5); in TEST_F()
372 EXPECT_GE(0, client_->Connect(server_->GetLocalAddress())); in TEST_F()
377 EXPECT_EQ(client_->GetRemoteAddress(), server_->GetLocalAddress()); in TEST_F()
/external/grpc-grpc/src/cpp/server/
Dserver_cc.cc107 server_(server), in UnimplementedAsyncRequest()
116 Server* const server_; member in grpc::Server::UnimplementedAsyncRequest
217 server_(server) { in CallData()
236 : server_->resource_exhausted_handler_.get(); in Run()
259 Server* server_; member in grpc::Server::SyncRequest::CallData
285 server_(server), in SyncRequestThreadManager()
322 SyncRequest::CallData cd(server_, sync_req); in DoWork()
326 sync_req->Request(server_->c_server(), server_cq_->cq()); in DoWork()
370 (*m)->Request(server_->c_server(), server_cq_->cq()); in Start()
378 Server* server_; member in grpc::Server::SyncRequestThreadManager
[all …]
/external/grpc-grpc/src/core/lib/iomgr/
Dudp_server.cc118 grpc_udp_server* server_; member in GrpcUdpListener
147 server_(server), in GrpcUdpListener()
299 GRPC_CLOSURE_INIT(&destroyed_closure_, destroyed_port, server_, in OrphanFd()
332 GRPC_CLOSURE_INIT(&destroyed_closure_, destroyed_port, server_, in OnFdAboutToOrphan()
340 udp_handler_->OnFdAboutToOrphan(&orphan_fd_closure_, server_->user_data); in OnFdAboutToOrphan()
469 gpr_mu_lock(&server_->mu); in OnRead()
470 if (0 == --server_->active_ports && server_->shutdown) { in OnRead()
471 gpr_mu_unlock(&server_->mu); in OnRead()
472 deactivated_all_ports(server_); in OnRead()
474 gpr_mu_unlock(&server_->mu); in OnRead()
[all …]
/external/grpc-grpc/include/grpcpp/impl/
Dserver_initializer.h34 ServerInitializer(Server* server) : server_(server) {} in ServerInitializer()
37 if (!server_->RegisterService(nullptr, service.get())) { in RegisterService()
45 return &server_->services_; in GetServiceList()
49 Server* server_;
/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_fixtures.h85 server_ = b.BuildAndStart(); in FullstackFixture()
92 channel_ = server_->InProcessChannel(args); in FullstackFixture()
100 grpc_server_shutdown_and_notify(server_->c_server(), cq_->cq(), in ~FullstackFixture()
120 std::unique_ptr<Server> server_;
182 server_ = b.BuildAndStart(); in EndpointPairFixture()
190 grpc_server_get_channel_args(server_->c_server()); in EndpointPairFixture()
196 grpc_server_get_pollsets(server_->c_server(), &pollsets, &num_pollsets); in EndpointPairFixture()
202 grpc_server_setup_transport(server_->c_server(), server_transport_, in EndpointPairFixture()
229 grpc_server_shutdown_and_notify(server_->c_server(), cq_->cq(), in ~EndpointPairFixture()
254 std::unique_ptr<Server> server_;
Dbm_opencensus_plugin.cc59 server_ = builder.BuildAndStart(); in EchoServerThread()
60 if (server_ == nullptr || port == 0) { in EchoServerThread()
68 server_->Shutdown(); in ~EchoServerThread()
75 void RunServerLoop() { server_->Wait(); } in RunServerLoop()
79 std::unique_ptr<grpc::Server> server_; member in EchoServerThread
/external/grpc-grpc/test/cpp/end2end/
Dhealth_service_end2end_test.cc149 server_ = builder.BuildAndStart(); in SetUpServer()
153 if (server_) { in TearDown()
154 server_->Shutdown(); in TearDown()
193 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in VerifyHealthCheckService()
225 std::unique_ptr<Server> server_; member in grpc::testing::__anon697682d60111::HealthServiceEnd2endTest
235 server_->GetHealthCheckService(); in TEST_F()
263 server_->GetHealthCheckService(); in TEST_F()
277 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in TEST_F()
293 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in TEST_F()
Dexception_test.cc69 server_ = builder.BuildAndStart(); in SetUp()
72 void TearDown() override { server_->Shutdown(); } in TearDown()
75 channel_ = server_->InProcessChannel(ChannelArguments()); in ResetStub()
81 std::unique_ptr<Server> server_; member in grpc::testing::ExceptionTest
Dclient_crash_test.cc57 server_.reset(new SubProcess({ in CreateServerAndStub()
61 GPR_ASSERT(server_); in CreateServerAndStub()
66 void KillServer() { server_.reset(); } in KillServer()
69 std::unique_ptr<SubProcess> server_; member in grpc::testing::__anon3f8d3e200111::CrashTest
Dserver_load_reporting_end2end_test.cc74 server_ = in SetUp()
86 void RunServerLoop() { server_->Wait(); } in RunServerLoop()
89 server_->Shutdown(); in TearDown()
118 std::unique_ptr<Server> server_; member in grpc::testing::__anonecb9b27f0111::ServerLoadReportingEnd2endTest
/external/grpc-grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc57 server_ = grpc_server_create(&args, nullptr); in Start()
58 ASSERT_TRUE(grpc_server_add_insecure_http2_port(server_, address_)); in Start()
60 grpc_server_register_completion_queue(server_, cq_, nullptr); in Start()
61 grpc_server_start(server_); in Start()
68 grpc_server_shutdown_and_notify(server_, shutdown_cq, nullptr); in Shutdown()
74 grpc_server_destroy(server_); in Shutdown()
88 grpc_server* server_ = nullptr; member in grpc_core::test::__anon707ef09f0111::ServerThread
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dservice_type.h60 Service() : server_(nullptr) {} in Service()
100 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncUnary()
108 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncClientStreaming()
117 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncServerStreaming()
125 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncBidiStreaming()
185 ServerInterface* server_; variable
/external/grpc-grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc83 server_ = b.BuildAndStart(); in EndpointPairFixture()
90 grpc_server_get_channel_args(server_->c_server()); in EndpointPairFixture()
96 grpc_server_get_pollsets(server_->c_server(), &pollsets, &num_pollsets); in EndpointPairFixture()
102 grpc_server_setup_transport(server_->c_server(), transport, nullptr, in EndpointPairFixture()
126 server_->Shutdown(); in ~EndpointPairFixture()
138 std::unique_ptr<Server> server_; member in grpc::testing::EndpointPairFixture
/external/boringssl/src/ssl/
Dssl_test.cc1635 return ConnectClientAndServer(&client_, &server_, client_ctx_.get(), in Connect()
1647 bssl::UniquePtr<SSL> client_, server_; member in __anond8fd7f190111::SSLVersionTest
1666 ASSERT_LE(SSL_read(server_.get(), &byte, 1), 0); in TEST_P()
1670 uint64_t server_read_seq = SSL_get_read_sequence(server_.get()); in TEST_P()
1671 uint64_t server_write_seq = SSL_get_write_sequence(server_.get()); in TEST_P()
1691 EXPECT_EQ(SSL_read(server_.get(), &byte, 1), 1); in TEST_P()
1696 EXPECT_EQ(server_read_seq + 1, SSL_get_read_sequence(server_.get())); in TEST_P()
1712 ASSERT_EQ(SSL_read(server_.get(), &byte, 1), 0); in TEST_P()
1713 ASSERT_EQ(SSL_get_error(server_.get(), 0), SSL_ERROR_ZERO_RETURN); in TEST_P()
1718 ASSERT_EQ(SSL_write(server_.get(), &byte, 1), 1); in TEST_P()
[all …]
/external/libchrome/mojo/core/
Dchannel_posix.cc106 server_ = connection_params.TakeServerEndpoint(); in ChannelPosix()
110 CHECK(server_.is_valid() || socket_.is_valid()); in ChannelPosix()
298 if (server_.is_valid()) { in StartOnIOThread()
300 server_.platform_handle().GetFD().get(), false /* persistent */, in StartOnIOThread()
342 server_.TakePlatformHandle().release(); in ShutDownOnIOThread()
345 ignore_result(server_.TakePlatformHandle()); in ShutDownOnIOThread()
424 if (server_.is_valid()) { in OnFileCanReadWithoutBlocking()
425 CHECK_EQ(fd, server_.platform_handle().GetFD().get()); in OnFileCanReadWithoutBlocking()
430 AcceptSocketConnection(server_.platform_handle().GetFD().get(), &socket_); in OnFileCanReadWithoutBlocking()
431 ignore_result(server_.TakePlatformHandle()); in OnFileCanReadWithoutBlocking()
[all …]
/external/grpc-grpc/examples/cpp/helloworld/
Dgreeter_async_server.cc42 server_->Shutdown(); in ~ServerImpl()
61 server_ = builder.BuildAndStart(); in Run()
159 std::unique_ptr<Server> server_; member in ServerImpl

1234