| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| testturnserver.h | 49 : server_(thread) {
50 server_.AddInternalSocket(talk_base::AsyncUDPSocket::Create(
52 server_.SetExternalSocketFactory(new talk_base::BasicPacketSocketFactory(),
54 server_.set_realm(kTestRealm);
55 server_.set_software(kTestSoftware);
56 server_.set_auth_hook(this);
60 server_.set_enable_otu_nonce(enable);
63 TurnServer* server() { return &server_; }
73 TurnServer server_; member in class:cricket::TestTurnServer
|
| testrelayserver.h | 50 : server_(thread) {
51 server_.AddInternalSocket(talk_base::AsyncUDPSocket::Create(
53 server_.AddExternalSocket(talk_base::AsyncUDPSocket::Create(
62 return server_.GetConnectionCount();
65 return server_.GetConnection(connection);
68 return server_.HasConnection(address);
94 server_.AddInternalSocket(packet_socket);
98 server_.AddExternalSocket(packet_socket);
103 server_.RemoveInternalSocket(socket);
106 server_.RemoveExternalSocket(socket)
109 cricket::RelayServer server_; member in class:cricket::TestRelayServer
[all...] |
| teststunserver.h | 45 server_(udp_socket_) {
50 cricket::StunServer server_; member in class:cricket::TestStunServer
|
| /external/chromium/third_party/libjingle/source/talk/base/ |
| firewallsocketserver.h | 51 SocketServer* socketserver() const { return server_; }
53 if (server_ && should_delete_server_) {
54 delete server_;
55 server_ = NULL;
58 server_ = server;
81 server_->SetMessageQueue(queue);
84 return server_->Wait(cms, process_io);
87 return server_->WakeUp();
94 SocketServer * server_; member in class:talk_base::FirewallSocketServer
|
| firewallsocketserver.cc | 41 : AsyncSocketAdapter(socket), server_(server), type_(type) {
46 if (!server_->Check(FP_TCP, GetLocalAddress(), addr)) {
62 if (!server_->Check(FP_UDP, GetLocalAddress(), addr)) {
81 if (server_->Check(FP_UDP, *paddr, GetLocalAddress()))
92 if (!server_->tcp_listen_enabled()) {
102 if (server_->Check(FP_TCP, addr, GetLocalAddress())) {
117 FirewallSocketServer* server_; member in class:talk_base::FirewallSocket
124 : server_(server), manager_(manager),
136 if (server_ && should_delete_server_) {
137 delete server_;
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| firewallsocketserver.h | 51 SocketServer* socketserver() const { return server_; }
53 if (server_ && should_delete_server_) {
54 delete server_;
55 server_ = NULL;
58 server_ = server;
85 server_->SetMessageQueue(queue);
88 return server_->Wait(cms, process_io);
91 return server_->WakeUp();
98 SocketServer * server_; member in class:talk_base::FirewallSocketServer
|
| firewallsocketserver.cc | 41 : AsyncSocketAdapter(socket), server_(server), type_(type) {
46 if (!server_->Check(FP_TCP, GetLocalAddress(), addr)) {
62 if (!server_->Check(FP_UDP, GetLocalAddress(), addr)) {
81 if (server_->Check(FP_UDP, *paddr, GetLocalAddress()))
92 if (!server_->tcp_listen_enabled()) {
102 if (server_->Check(FP_TCP, addr, GetLocalAddress())) {
117 FirewallSocketServer* server_; member in class:talk_base::FirewallSocket
124 : server_(server), manager_(manager),
136 if (server_ && should_delete_server_) {
137 delete server_;
[all...] |
| httpserver.cc | 138 : connection_id_(connection_id), server_(server),
183 server_->Remove(connection_id_);
200 server_->SignalHttpRequestHeader(server_, current_, &custom_document);
212 server_->SignalHttpRequestComplete(server_, current_, err);
220 server_->Remove(connection_id_);
229 server_->SignalHttpRequest(server_, transaction);
243 server_->Remove(connection_id_)
[all...] |
| virtualsocketserver.cc | 116 : server_(server), family_(family), type_(type), async_(async),
152 int result = server_->Bind(this, &local_addr_);
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_);
203 server_->RemoveConnection(local_addr_, remote_addr_)
512 VirtualSocketServer* server_; member in class:talk_base::VirtualSocket
[all...] |
| natsocketfactory.h | 130 NATSocketServer* server_; member in class:talk_base::NATSocketServer::Translator
139 SocketServer* socketserver() { return server_; }
156 server_->SetMessageQueue(queue);
159 return server_->Wait(cms, process_io);
162 server_->WakeUp();
170 SocketServer* server_; member in class:talk_base::NATSocketServer
|
| /external/chromium_org/v8/test/cctest/ |
| test-sockets.cc | 42 server_(NULL),
50 delete server_;
63 Socket* server_; // Server socket used for bind/accept. member in class:SocketListenerThread
73 server_ = OS::CreateSocket();
74 server_->SetReuseAddress(true);
75 CHECK(server_ != NULL);
76 ok = server_->Bind(port_);
80 ok = server_->Listen(1);
85 client_ = server_->Accept();
|
| /external/v8/test/cctest/ |
| test-sockets.cc | 17 server_(NULL),
25 delete server_;
38 Socket* server_; // Server socket used for bind/accept. member in class:SocketListenerThread
48 server_ = OS::CreateSocket();
49 server_->SetReuseAddress(true);
50 CHECK(server_ != NULL);
51 ok = server_->Bind(port_);
55 ok = server_->Listen(1);
60 client_ = server_->Accept();
|
| /external/chromium_org/net/test/embedded_test_server/ |
| embedded_test_server_unittest.cc | 60 server_.reset(new EmbeddedTestServer(io_thread_.message_loop_proxy()));
61 ASSERT_TRUE(server_->InitializeAndWaitUntilReady());
65 ASSERT_TRUE(server_->ShutdownAndWaitUntilComplete());
92 GURL absolute_url = server_->GetURL(request.relative_url);
110 scoped_ptr<EmbeddedTestServer> server_; member in class:net::test_server::EmbeddedTestServerTest
114 EXPECT_EQ(base::StringPrintf("http://127.0.0.1:%d/", server_->port()),
115 server_->base_url().spec());
120 server_->port()),
121 server_->GetURL("/path?query=foo").spec());
125 server_->RegisterRequestHandler
[all...] |
| /external/chromium_org/chrome/test/chromedriver/net/ |
| test_http_server.cc | 89 server_->AcceptWebSocket(connection_id, info);
92 server_->Send404(connection_id);
98 base::Bind(&net::HttpServer::Close, server_, connection_id));
112 server_->SendOverWebSocket(connection_id, data);
118 base::Bind(&net::HttpServer::Close, server_, connection_id));
132 server_ = new net::HttpServer(factory, this);
135 int error = server_->GetLocalAddress(&address);
142 server_ = NULL;
144 *success = server_.get();
149 if (server_.get()
[all...] |
| sync_websocket_impl_unittest.cc | 35 ASSERT_TRUE(server_.Start());
39 server_.Stop();
43 TestHttpServer server_; member in class:__anon9453::SyncWebSocketImplTest
56 ASSERT_TRUE(sock.Connect(server_.web_socket_url()));
66 ASSERT_TRUE(sock.Connect(server_.web_socket_url()));
77 ASSERT_TRUE(sock.Connect(server_.web_socket_url()));
88 ASSERT_TRUE(sock.Connect(server_.web_socket_url()));
101 ASSERT_TRUE(sock.Connect(server_.web_socket_url()));
121 server_.SetMessageAction(TestHttpServer::kCloseOnMessage);
123 ASSERT_TRUE(sock.Connect(server_.web_socket_url()))
[all...] |
| net_util_unittest.cc | 58 server_ = new net::HttpServer(factory, this);
60 CHECK_EQ(net::OK, server_->GetLocalAddress(&address));
66 server_ = NULL;
75 server_->Send200(connection_id, "hello", "text/plain");
78 server_->Send404(connection_id);
84 base::Bind(&net::HttpServer::Close, server_, connection_id));
107 scoped_refptr<net::HttpServer> server_; member in class:__anon9451::FetchUrlTest
|
| websocket_unittest.cc | 91 ASSERT_TRUE(server_.Start());
95 server_.Stop();
115 return CreateWebSocket(server_.web_socket_url(), listener);
133 TestHttpServer server_; member in class:__anon9455::WebSocketTest
145 ASSERT_TRUE(CreateWebSocket(server_.web_socket_url(), &listener));
147 ASSERT_TRUE(server_.WaitForConnectionsToClose());
156 server_.SetRequestAction(TestHttpServer::kNotFound);
158 ASSERT_FALSE(CreateWebSocket(server_.web_socket_url(), NULL));
160 ASSERT_TRUE(server_.WaitForConnectionsToClose());
164 server_.SetRequestAction(TestHttpServer::kClose)
[all...] |
| /external/chromium_org/chrome/test/perf/ |
| mach_ports_test.cc | 27 : server_(net::SpawnedTestServer::TYPE_HTTP,
35 ASSERT_TRUE(server_.Start());
59 GURL url = server_.GetURL("files/" + domain + "/").Resolve("?skip");
64 net::SpawnedTestServer server_; member in class:__anon9483::MachPortsTest
|
| /external/chromium_org/net/server/ |
| http_connection.cc | 33 : server_(server),
40 server_->delegate_->OnClose(id_);
|
| http_connection.h | 43 HttpServer* server_; member in class:net::HttpConnection
|
| /external/chromium_org/chrome/browser/ui/ |
| crypto_module_password_dialog.cc | 30 server_(server),
66 slot_name, retry, reason_, server_,
83 std::string server_; member in class:chrome::__anon8481::CryptoModuleBlockingDialogDelegate
|
| /external/chromium_org/v8/src/ |
| debug-agent.h | 50 server_(OS::CreateSocket()), terminate_(false),
59 delete server_;
77 Socket* server_; // Server socket for listen/accept. member in class:v8::internal::DebuggerAgent
|
| /external/v8/src/ |
| debug-agent.h | 50 server_(OS::CreateSocket()), terminate_(false),
59 delete server_;
77 Socket* server_; // Server socket for listen/accept. member in class:v8::internal::DebuggerAgent
|
| /external/chromium/chrome/browser/debugger/ |
| devtools_protocol_handler.cc | 37 server_(NULL) {
43 DCHECK(server_.get() == NULL);
54 server_ = DevToolsRemoteListenSocket::Listen(
68 server_ = NULL;
|
| /external/chromium_org/sync/test/accounts_client/ |
| test_accounts_client.h | 58 const string server_; member in class:TestAccountsClient
|
