Home
last modified time | relevance | path

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

12

/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 …]
Dstunserver_unittest.cc34 server_.reset(new StunServer( in SetUp()
68 rtc::scoped_ptr<StunServer> server_; member in StunServerTest
Drelayserver.h190 RelayServer* server() { return server_; } in server()
220 RelayServer* server_;
/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()
Dwin32socketserver_unittest.cc40 Win32SocketTest() : server_(NULL), scope_(&server_) {} in Win32SocketTest()
41 Win32SocketServer server_; member in rtc::Win32SocketTest
Dphysicalsocketserver_unittest.cc76 : server_(new FakePhysicalSocketServer(this)), in PhysicalSocketTest()
77 scope_(server_.get()), in PhysicalSocketTest()
83 rtc::scoped_ptr<FakePhysicalSocketServer> server_; member in rtc::PhysicalSocketTest
131 scoped_ptr<AsyncSocket> client1(server_->CreateAsyncSocket(loopback.family(), in ConnectInternalAcceptError()
137 scoped_ptr<AsyncSocket> client2(server_->CreateAsyncSocket(loopback.family(), in ConnectInternalAcceptError()
145 server_->CreateAsyncSocket(loopback.family(), SOCK_STREAM)); in ConnectInternalAcceptError()
Dnatsocketfactory.h118 NATSocketServer* server_;
127 SocketServer* socketserver() { return server_; } in socketserver()
153 SocketServer* server_;
Dmacsocketserver_unittest.cc95 : server_(CreateSocketServer()), in MacAsyncSocketTest()
96 scope_(server_.get()) {} in MacAsyncSocketTest()
101 rtc::scoped_ptr<MacBaseSocketServer> server_; member in rtc::MacAsyncSocketTest
Dhttpclient.cc294 server_.Clear(); in reset()
307 server_ = resolver_->address(); in OnResolveResult()
312 << server_; in OnResolveResult()
322 resolver_->Start(server_); in StartDNSLookup()
326 server_ = address; in set_server()
329 request().setHeader(HH_HOST, HttpAddress(server_, false), true); in set_server()
399 if (server_.IsUnresolvedIP()) { in connect()
403 StreamInterface* stream = pool_->RequestConnectedStream(server_, &stream_err); in connect()
Dvirtualsocketserver.h39 SocketServer* socketserver() { return server_; } in socketserver()
225 SocketServer* server_; variable
312 VirtualSocketServer* server_; variable
Dhttpclient.h99 const SocketAddress& server() const { return server_; } in server()
168 SocketAddress server_; variable
/external/google-tv-pairing-protocol/cpp/src/polo/pairing/
Dpairingcontext.cc25 server_(server) { in PairingContext()
37 return server_ ? peer_certificate_ : local_certificate_; in client_certificate()
41 return server_ ? local_certificate_ : peer_certificate_; in server_certificate()
45 return server_; in is_server()
49 return !server_; in is_client()
/external/adhd/cras/src/tests/
Ddbus_test.cc390 server_(NULL), in DBusTest()
484 server_ = dbus_server_listen(kServerAddress, NULL); in SetUp()
485 ASSERT_TRUE(server_ != NULL); in SetUp()
487 dbus_server_set_new_connection_function(server_, NewConnectionThunk, in SetUp()
491 success = dbus_server_set_watch_functions(server_, in SetUp()
498 success = dbus_server_set_timeout_functions(server_, in SetUp()
551 dbus_server_disconnect(server_); in TearDown()
552 dbus_server_unref(server_); in TearDown()
553 server_ = NULL; in TearDown()
/external/webrtc/webrtc/libjingle/xmpp/
Dxmppclientsettings.h79 server_ = server; in set_server()
89 const rtc::SocketAddress& server() const { return server_; } in server()
99 rtc::SocketAddress server_;
Dxmppclient.cc57 rtc::SocketAddress server_; member in buzz::XmppClient::Private
145 d_->server_ = settings.server(); in Connect()
210 d_->engine_->GetUser(), d_->server_, d_->pass_, in ProcessStart()
279 if (!d_->socket_->Connect(d_->server_)) { in ProcessStartXmppLogin()
/external/webrtc/webrtc/tools/rtcbot/
Dbotmanager.js74 this.server_ = https.createServer(options, this.app_);
76 this.webSocketServer_ = new WebSocketServer({ server: this.server_ });
79 this.server_.listen(8080);
/external/boringssl/src/ssl/
Dssl_test.cc1610 return ConnectClientAndServer(&client_, &server_, client_ctx_.get(), in Connect()
1620 bssl::UniquePtr<SSL> client_, server_; member in bssl::__anonb772228d0111::SSLVersionTest
1639 ASSERT_LE(SSL_read(server_.get(), &byte, 1), 0); in TEST_P()
1643 uint64_t server_read_seq = SSL_get_read_sequence(server_.get()); in TEST_P()
1644 uint64_t server_write_seq = SSL_get_write_sequence(server_.get()); in TEST_P()
1664 EXPECT_EQ(SSL_read(server_.get(), &byte, 1), 1); in TEST_P()
1669 EXPECT_EQ(server_read_seq + 1, SSL_get_read_sequence(server_.get())); in TEST_P()
1685 ASSERT_EQ(SSL_read(server_.get(), &byte, 1), 0); in TEST_P()
1686 ASSERT_EQ(SSL_get_error(server_.get(), 0), SSL_ERROR_ZERO_RETURN); in TEST_P()
1691 ASSERT_EQ(SSL_write(server_.get(), &byte, 1), 1); in TEST_P()
[all …]
/external/webrtc/webrtc/examples/peerconnection/client/linux/
Dmain_wnd.cc130 server_(server), autoconnect_(autoconnect), autocall_(autocall) { in GtkMainWnd()
245 gtk_entry_set_text(GTK_ENTRY(server_edit_), server_.c_str()); in SwitchToConnectUI()
338 server_ = gtk_entry_get_text(GTK_ENTRY(server_edit_)); in OnClicked()
341 callback_->StartLogin(server_, port); in OnClicked()

12