| /external/google-tv-pairing-protocol/cpp/src/polo/pairing/ |
| pairingcontext.cc | 25 server_(server) {
37 return server_ ? peer_certificate_ : local_certificate_;
41 return server_ ? local_certificate_ : peer_certificate_;
45 return server_;
49 return !server_;
|
| pairingcontext.h | 58 bool server_; member in class:polo::pairing::PairingContext
|
| /system/connectivity/shill/vpn/ |
| openvpn_management_server_unittest.cc | 54 : server_(&driver_) {}
61 void SetSockets() { server_.sockets_ = &sockets_; }
62 void SetDispatcher() { server_.dispatcher_ = &dispatcher_; }
63 void ExpectNotStarted() { EXPECT_FALSE(server_.IsStarted()); }
66 server_.connected_socket_ = kConnectedSocket;
125 server_.SendSignal(signal);
129 server_.OnInput(data);
133 server_.ProcessMessage(message);
137 return server_.ProcessSuccessMessage(message);
141 return server_.ProcessStateMessage(message)
170 OpenVPNManagementServer server_; \/\/ Destroy before anything it references. member in class:shill::OpenVPNManagementServerTest
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| testturnserver.h | 54 : server_(thread) {
56 server_.SetExternalSocketFactory(new rtc::BasicPacketSocketFactory(),
58 server_.set_realm(kTestRealm);
59 server_.set_software(kTestSoftware);
60 server_.set_auth_hook(this);
64 server_.set_enable_otu_nonce(enable);
67 TurnServer* server() { return &server_; }
70 server_.set_redirect_hook(redirect_hook);
77 server_.AddInternalSocket(rtc::AsyncUDPSocket::Create(
86 server_.AddInternalServerSocket(socket, proto)
111 TurnServer server_; member in class:cricket::TestTurnServer
[all...] |
| testrelayserver.h | 33 : server_(thread) {
34 server_.AddInternalSocket(rtc::AsyncUDPSocket::Create(
36 server_.AddExternalSocket(rtc::AsyncUDPSocket::Create(
45 return server_.GetConnectionCount();
48 return server_.GetConnection(connection);
51 return server_.HasConnection(address);
77 server_.AddInternalSocket(packet_socket);
81 server_.AddExternalSocket(packet_socket);
86 server_.RemoveInternalSocket(socket);
89 server_.RemoveExternalSocket(socket)
92 cricket::RelayServer server_; member in class:cricket::TestRelayServer
[all...] |
| stunserver_unittest.cc | 34 server_.reset(new StunServer(
68 rtc::scoped_ptr<StunServer> server_; member in class:StunServerTest
|
| /external/webrtc/webrtc/base/ |
| firewallsocketserver.cc | 25 : AsyncSocketAdapter(socket), server_(server), type_(type) {
30 if (!server_->Check(FP_TCP, GetLocalAddress(), addr)) {
46 if (!server_->Check(FP_UDP, GetLocalAddress(), addr)) {
65 if (server_->Check(FP_UDP, *paddr, GetLocalAddress()))
76 if (!server_->tcp_listen_enabled()) {
86 if (server_->Check(FP_TCP, addr, GetLocalAddress())) {
101 FirewallSocketServer* server_; member in class:rtc::FirewallSocket
108 : server_(server), manager_(manager),
120 if (server_ && should_delete_server_) {
121 delete server_;
[all...] |
| firewallsocketserver.h | 34 SocketServer* socketserver() const { return server_; }
36 if (server_ && should_delete_server_) {
37 delete server_;
38 server_ = NULL;
41 server_ = server;
75 SocketServer * server_; member in class:rtc::FirewallSocketServer
|
| httpserver.cc | 121 : connection_id_(connection_id), server_(server),
166 server_->Remove(connection_id_);
183 server_->SignalHttpRequestHeader(server_, current_, &custom_document);
195 server_->SignalHttpRequestComplete(server_, current_, err);
203 server_->Remove(connection_id_);
212 server_->SignalHttpRequest(server_, transaction);
226 server_->Remove(connection_id_)
[all...] |
| virtualsocketserver.cc | 101 : server_(server),
149 int result = server_->Bind(this, &local_addr_);
158 server_->msg_queue_->Post(this, MSG_ID_ADDRESS_BOUND);
170 server_->Unbind(local_addr_, this);
181 server_->Disconnect(server_->LookupBinding(addr));
191 server_->LookupConnection(local_addr_, remote_addr_);
197 socket = server_->LookupBinding(remote_addr_);
199 server_->Disconnect(socket);
202 server_->RemoveConnection(remote_addr_, local_addr_)
[all...] |
| win32socketserver_unittest.cc | 40 Win32SocketTest() : server_(NULL), scope_(&server_) {}
41 Win32SocketServer server_; member in class:rtc::Win32SocketTest
|
| ssladapter_unittest.cc | 277 server_(new SSLAdapterTestDummyServer(ssl_mode_, key_params)),
291 rv = client_->Connect(server_->GetHostname(), server_->GetAddress());
299 server_->AcceptConnection(client_->GetAddress());
326 EXPECT_EQ_WAIT(message, server_->GetReceivedData(), kTimeout);
328 rv = server_->Send(message);
342 rtc::scoped_ptr<SSLAdapterTestDummyServer> server_; member in class:SSLAdapterTestBase
|
| macsocketserver_unittest.cc | 95 : server_(CreateSocketServer()),
96 scope_(server_.get()) {}
101 rtc::scoped_ptr<MacBaseSocketServer> server_; member in class:rtc::MacAsyncSocketTest
|
| natsocketfactory.h | 118 NATSocketServer* server_; member in class:rtc::NATSocketServer::Translator
127 SocketServer* socketserver() { return server_; }
153 SocketServer* server_; member in class:rtc::NATSocketServer
|
| nat_unittest.cc | 338 accepted_.reset(server_->Accept(NULL));
345 server_->SignalReadEvent.connect(this, &NatTcpTest::OnAcceptEvent);
361 rtc::scoped_ptr<AsyncSocket> server_; member in class:NatTcpTest
366 server_.reset(ext_vss_->CreateAsyncSocket(SOCK_STREAM));
367 server_->Bind(ext_addr_);
368 server_->Listen(5);
372 EXPECT_GE(0, client_->Connect(server_->GetLocalAddress()));
377 EXPECT_EQ(client_->GetRemoteAddress(), server_->GetLocalAddress());
|
| natsocketfactory.cc | 338 : server_(server), msg_queue_(NULL) {
352 return nats_.Add(ext_ip, new Translator(this, type, int_ip, server_, ext_ip));
378 server_->SetMessageQueue(queue);
382 return server_->Wait(cms, process_io);
386 server_->WakeUp();
398 socket = server_->CreateAsyncSocket(family, type);
407 : server_(server) {
411 VirtualSocketServer* internal_server = new VirtualSocketServer(server_);
412 internal_server->SetMessageQueue(server_->queue());
433 new Translator(server_, type, int_ip, server_, ext_ip))
[all...] |
| physicalsocketserver_unittest.cc | 76 : server_(new FakePhysicalSocketServer(this)),
77 scope_(server_.get()),
83 rtc::scoped_ptr<FakePhysicalSocketServer> server_; member in class:rtc::PhysicalSocketTest
131 scoped_ptr<AsyncSocket> client1(server_->CreateAsyncSocket(loopback.family(),
137 scoped_ptr<AsyncSocket> client2(server_->CreateAsyncSocket(loopback.family(),
145 server_->CreateAsyncSocket(loopback.family(), SOCK_STREAM));
|
| httpclient.h | 99 const SocketAddress& server() const { return server_; }
168 SocketAddress server_; member in class:rtc::HttpClient
|
| httpserver.h | 97 HttpServer* server_; member in class:rtc::HttpServer::Connection
|
| /system/webservd/webservd/ |
| dbus_request_handler.h | 42 Server* server_{nullptr};
|
| main.cc | 65 server_.reset(new webservd::Server{
68 server_->RegisterAsync(
73 server_.reset();
78 std::unique_ptr<webservd::Server> server_; member in class:__anon73696::final
|
| dbus_protocol_handler.cc | 40 server_{server} {
51 server_->GetBus()->UnlistenForServiceOwnerChange(
81 new RequestHandlerProxy{server_->GetBus(), in_service_name});
86 server_->GetBus()->ListenForServiceOwnerChange(
92 new DBusRequestHandler{server_, p->second.handler_proxy.get()}
122 server_->GetBus()->UnlistenForServiceOwnerChange(
149 server_->GetBus()->UnlistenForServiceOwnerChange(
|
| protocol_handler.cc | 156 if (server_) {
265 server_ = MHD_start_daemon(flags, config->port, nullptr, nullptr,
268 if (!server_) {
279 if (server_) {
281 MHD_stop_daemon(server_);
282 server_ = nullptr;
370 MHD_run(server_);
381 CHECK_EQ(MHD_YES, MHD_get_fdset(server_, &rs, &ws, &es, &max_fd));
412 if (MHD_get_timeout(server_, &mhd_timeout) == MHD_YES) {
|
| dbus_request_handler.cc | 47 : server_{server},
73 server_->GetConfig().use_debug);
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| xmppclientsettings.h | 79 server_ = server;
89 const rtc::SocketAddress& server() const { return server_; }
99 rtc::SocketAddress server_; member in class:buzz::XmppClientSettings
|
