| /external/webrtc/webrtc/p2p/base/ |
| D | testturnserver.h | 54 : 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 …]
|
| D | testrelayserver.h | 33 : 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 …]
|
| D | stunserver_unittest.cc | 34 server_.reset(new StunServer( in SetUp()
68 rtc::scoped_ptr<StunServer> server_; member in StunServerTest
|
| D | relayserver.h | 190 RelayServer* server() { return server_; } in server()
220 RelayServer* server_;
|
| D | relayserver.cc | 657 : server_(server), in RelayServerBinding()
670 server_->thread()->PostDelayed(lifetime_, this, MSG_LIFETIME_TIMER); in RelayServerBinding()
675 server_->thread()->Clear(this); in ~RelayServerBinding()
684 server_->RemoveBinding(this); in ~RelayServerBinding()
741 server_->thread()->PostDelayed(lifetime_, this, MSG_LIFETIME_TIMER); in OnMessage()
|
| /external/webrtc/webrtc/base/ |
| D | firewallsocketserver.cc | 25 : 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 …]
|
| D | virtualsocketserver.cc | 101 : 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 …]
|
| D | firewallsocketserver.h | 34 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_;
|
| D | httpserver.cc | 121 : 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()
|
| D | natsocketfactory.cc | 338 : 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()
|
| D | ssladapter_unittest.cc | 277 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
|
| D | nat_unittest.cc | 338 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()
|
| D | win32socketserver_unittest.cc | 40 Win32SocketTest() : server_(NULL), scope_(&server_) {} in Win32SocketTest()
41 Win32SocketServer server_; member in rtc::Win32SocketTest
|
| D | physicalsocketserver_unittest.cc | 76 : 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()
|
| D | natsocketfactory.h | 118 NATSocketServer* server_;
127 SocketServer* socketserver() { return server_; } in socketserver()
153 SocketServer* server_;
|
| D | macsocketserver_unittest.cc | 95 : server_(CreateSocketServer()), in MacAsyncSocketTest()
96 scope_(server_.get()) {} in MacAsyncSocketTest()
101 rtc::scoped_ptr<MacBaseSocketServer> server_; member in rtc::MacAsyncSocketTest
|
| D | httpclient.cc | 294 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()
|
| D | virtualsocketserver.h | 39 SocketServer* socketserver() { return server_; } in socketserver()
225 SocketServer* server_; variable
312 VirtualSocketServer* server_; variable
|
| D | httpclient.h | 99 const SocketAddress& server() const { return server_; } in server()
168 SocketAddress server_; variable
|
| /external/google-tv-pairing-protocol/cpp/src/polo/pairing/ |
| D | pairingcontext.cc | 25 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()
|
| D | pairingcontext.h | 58 bool server_; variable
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | xmppclientsettings.h | 79 server_ = server; in set_server()
89 const rtc::SocketAddress& server() const { return server_; } in server()
99 rtc::SocketAddress server_;
|
| D | xmppclient.cc | 57 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/ |
| D | botmanager.js | 74 this.server_ = https.createServer(options, this.app_);
76 this.webSocketServer_ = new WebSocketServer({ server: this.server_ });
79 this.server_.listen(8080);
|
| /external/webrtc/webrtc/examples/peerconnection/client/linux/ |
| D | main_wnd.cc | 130 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()
|