| /external/webrtc/webrtc/base/ |
| D | signalthread_unittest.cc | 54 Thread::Current()->socketserver()->Wait(250, false); in DoWork()
115 Thread::Current()->socketserver()->Wait(100, false); in Run()
142 Thread::Current()->socketserver()->Wait(10, false); in TEST_F()
149 Thread::Current()->socketserver()->Wait(500, false); in TEST_F()
|
| D | testclient_unittest.cc | 22 AsyncSocket* socket = main->socketserver() in TestUdpInternal()
38 AsyncSocket* socket = main->socketserver() in TestTcpInternal()
|
| D | thread.cc | 363 current_thread->socketserver()->Wait(kForever, false); in Send()
381 current_thread->socketserver()->WakeUp(); in Send()
405 smsg.thread->socketserver()->WakeUp(); in ReceiveSendsFromThread()
450 smsg.thread->socketserver()->WakeUp(); in Clear()
|
| D | socket_unittest.h | 27 virtual void SetUp() { ss_ = Thread::Current()->socketserver(); } in SetUp()
|
| D | testechoserver.h | 27 : server_socket_(thread->socketserver()->CreateAsyncSocket(addr.family(), in TestEchoServer()
|
| D | firewallsocketserver.h | 34 SocketServer* socketserver() const { return server_; } in socketserver() function
|
| D | physicalsocketserver_unittest.cc | 92 static_cast<FakePhysicalSocketServer*>(socketserver()); in DoAccept()
490 thread->socketserver()->Wait(1000, false); in Run()
|
| D | natsocketfactory.h | 127 SocketServer* socketserver() { return server_; } in socketserver() function
|
| D | thread.h | 314 old_ss_ = Thread::Current()->socketserver(); in SocketServerScope()
|
| D | physicalsocketserver.h | 156 SocketServer* socketserver() { return ss_; } in socketserver() function
|
| D | messagequeue.h | 173 SocketServer* socketserver() { return ss_; } in socketserver() function
|
| D | testutils.h | 327 socket = Thread::Current()->socketserver() in Init()
386 : socket_(Thread::Current()->socketserver() in SocketTestServer()
|
| D | thread_unittest.cc | 195 Socket* socket = th1.socketserver()->CreateAsyncSocket(addr.family(), in TEST()
202 th2.socketserver()->CreateAsyncSocket(addr.family(), SOCK_DGRAM); in TEST()
|
| D | autodetectproxy.cc | 192 Thread::Current()->socketserver()->CreateAsyncSocket( in DoConnect()
|
| D | httpserver.cc | 242 Thread::Current()->socketserver()->CreateAsyncSocket(address.family(), in Listen()
|
| /external/webrtc/webrtc/p2p/base/ |
| D | testrelayserver.h | 35 thread->socketserver(), udp_int_addr)); in TestRelayServer()
37 thread->socketserver(), udp_ext_addr)); in TestRelayServer()
58 thread->socketserver()->CreateAsyncSocket(addr.family(), SOCK_STREAM); in CreateListenSocket()
|
| D | testturnserver.h | 78 thread->socketserver(), int_addr), proto); in AddInternalSocket()
83 thread->socketserver()->CreateAsyncSocket(SOCK_STREAM); in AddInternalSocket()
|
| D | teststunserver.h | 26 thread->socketserver()->CreateAsyncSocket(addr.family(), SOCK_DGRAM); in Create()
|
| D | basicpacketsocketfactory.cc | 203 return thread_->socketserver(); in socket_factory()
|
| /external/webrtc/webrtc/examples/relayserver/ |
| D | relayserver_main.cc | 39 rtc::AsyncUDPSocket::Create(pthMain->socketserver(), int_addr)); in main()
47 rtc::AsyncUDPSocket::Create(pthMain->socketserver(), ext_addr)); in main()
|
| /external/curl/tests/ |
| D | http_pipe.py | 21 import socketserver
23 import SocketServer as socketserver namespace
338 class PipelineRequestHandler(socketserver.BaseRequestHandler):
412 class PipelineServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
|
| /external/webrtc/webrtc/examples/stunserver/ |
| D | stunserver_main.cc | 37 rtc::AsyncUDPSocket::Create(pthMain->socketserver(), server_addr); in main()
|
| /external/chromium-trace/catapult/third_party/typ/typ/fakes/ |
| D | test_result_server_fake.py | 31 from socketserver import TCPServer # pylint: disable=F0401
|
| /external/webrtc/webrtc/examples/turnserver/ |
| D | turnserver_main.cc | 65 rtc::AsyncUDPSocket::Create(main->socketserver(), int_addr); in main()
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | xmppsocket.cc | 44 pth->socketserver()->CreateAsyncSocket(family, SOCK_STREAM); in CreateCricketSocket()
|