| /external/python/cpython3/Lib/test/ |
| D | test_socketserver.py | 14 import socketserver
48 class ForkingUnixStreamServer(socketserver.ForkingMixIn,
49 socketserver.UnixStreamServer):
52 class ForkingUnixDatagramServer(socketserver.ForkingMixIn,
53 socketserver.UnixDatagramServer):
152 if HAVE_FORKING and isinstance(server, socketserver.ForkingMixIn):
180 self.run_server(socketserver.TCPServer,
181 socketserver.StreamRequestHandler,
185 self.run_server(socketserver.ThreadingTCPServer,
186 socketserver.StreamRequestHandler,
[all …]
|
| D | test_imaplib.py | 7 import socketserver
93 class SecureTCPServer(socketserver.TCPServer):
112 class SimpleIMAPHandler(socketserver.StreamRequestHandler):
261 class EOFHandler(socketserver.StreamRequestHandler):
542 server_class = socketserver.TCPServer
583 server_class = socketserver.TCPServer
702 class EOFHandler(socketserver.StreamRequestHandler):
|
| /external/curl/tests/ |
| D | dictserver.py | 34 import SocketServer as socketserver namespace
36 import socketserver
64 socketserver.TCPServer.allow_reuse_address = True
65 server = socketserver.TCPServer(local_bind, DictHandler)
71 class DictHandler(socketserver.BaseRequestHandler):
|
| D | negtelnetserver.py | 31 import socketserver
33 import SocketServer as socketserver namespace
62 socketserver.TCPServer.allow_reuse_address = True
63 server = socketserver.TCPServer(local_bind, NegotiatingTelnetHandler)
69 class NegotiatingTelnetHandler(socketserver.BaseRequestHandler):
|
| /external/autotest/site_utils/ |
| D | log_socket_server.py | 23 import six.moves.socketserver
30 class LogRecordStreamHandler(six.moves.socketserver.StreamRequestHandler):
84 class LogRecordSocketReceiver(six.moves.socketserver.ThreadingTCPServer):
94 six.moves.socketserver.ThreadingTCPServer.__init__(self, (host, port), handler)
|
| /external/python/cpython3/Doc/library/ |
| D | socketserver.rst | 1 :mod:`socketserver` --- A framework for network servers
4 .. module:: socketserver
7 **Source code:** :source:`Lib/socketserver.py`
11 The :mod:`socketserver` module simplifies the task of writing network servers.
118 :meth:`socketserver.ForkingMixIn.server_close` waits until all child
120 :attr:`socketserver.ForkingMixIn.block_on_close` attribute is false.
122 :meth:`socketserver.ThreadingMixIn.server_close` waits until all non-daemon
124 :attr:`socketserver.ThreadingMixIn.block_on_close` attribute is false. Use
131 :meth:`socketserver.ForkingMixIn.server_close` and
132 :meth:`socketserver.ThreadingMixIn.server_close` now waits until all
[all …]
|
| D | internet.rst | 41 socketserver.rst
|
| /external/webrtc/rtc_base/deprecated/ |
| D | signal_thread_unittest.cc | 65 Thread::Current()->socketserver()->Wait(250, false); in DoWork()
146 Thread::Current()->socketserver()->Wait(100, false); in Run()
183 Thread::Current()->socketserver()->Wait(10, false); in TEST_F()
190 Thread::Current()->socketserver()->Wait(500, false); in TEST_F()
|
| /external/llvm-project/clang/tools/scan-view/bin/ |
| D | scan-view | 88 import socketserver
90 import SocketServer as socketserver namespace
92 t = socketserver.TCPServer((kDefaultHost, port), None)
|
| /external/llvm-project/llvm/tools/sancov/ |
| D | coverage-report-server.py | 29 import socketserver
196 socketserver.TCPServer.allow_reuse_address = True
197 httpd = socketserver.TCPServer((args.host, args.port), ServerHandler)
|
| /external/webrtc/rtc_base/ |
| D | test_client_unittest.cc | 44 main->socketserver()->CreateAsyncSocket(loopback.family(), SOCK_DGRAM); in TestUdpInternal()
60 main->socketserver()->CreateAsyncSocket(loopback.family(), SOCK_STREAM); in TestTcpInternal()
|
| D | test_echo_server.cc | 18 : server_socket_(thread->socketserver()->CreateAsyncSocket(addr.family(), in TestEchoServer()
|
| D | physical_socket_server_unittest.cc | 136 static_cast<FakePhysicalSocketServer*>(socketserver()); in DoAccept()
149 static_cast<FakePhysicalSocketServer*>(socketserver()); in DoSend()
164 static_cast<FakePhysicalSocketServer*>(socketserver()); in DoSendTo()
|
| /external/webrtc/examples/androidvoip/jni/ |
| D | android_voip_client.cc | 50 RTC_DCHECK(thread->socketserver() != nullptr); in QueryDefaultLocalAddress()
54 thread->socketserver()->CreateAsyncSocket(family, SOCK_DGRAM)); in QueryDefaultLocalAddress()
252 rtp_socket_.reset(rtc::AsyncUDPSocket::Create(voip_thread_->socketserver(), in StartSession()
261 rtcp_socket_.reset(rtc::AsyncUDPSocket::Create(voip_thread_->socketserver(), in StartSession()
|
| /external/perfetto/tools/ |
| D | record_android_trace | 9 import socketserver
235 socketserver.TCPServer.allow_reuse_address = True
236 with socketserver.TCPServer(('127.0.0.1', PORT), HttpHandler) as httpd:
|
| /external/webrtc/p2p/base/ |
| D | test_turn_server.h | 97 rtc::AsyncUDPSocket::Create(thread_->socketserver(), int_addr),
103 thread_->socketserver()->CreateAsyncSocket(AF_INET, SOCK_STREAM);
|
| D | test_stun_server.cc | 21 thread->socketserver()->CreateAsyncSocket(addr.family(), SOCK_DGRAM); in Create()
|
| /external/python/cpython3/Lib/idlelib/ |
| D | rpc.py | 38 import socketserver
73 class RPCServer(socketserver.TCPServer):
78 socketserver.TCPServer.__init__(self, addr, handlerclass)
506 class RPCHandler(socketserver.BaseRequestHandler, SocketIO):
514 socketserver.BaseRequestHandler.__init__(self, sock, addr, svr)
|
| /external/webrtc/examples/stunserver/ |
| D | stunserver_main.cc | 35 rtc::AsyncUDPSocket::Create(pthMain->socketserver(), server_addr); in main()
|
| /external/webrtc/test/network/ |
| D | network_emulation_unittest.cc | 211 auto* s1 = t1->socketserver()->CreateAsyncSocket(AF_INET, SOCK_DGRAM); in TEST()
212 auto* s2 = t2->socketserver()->CreateAsyncSocket(AF_INET, SOCK_DGRAM); in TEST()
335 auto* s1 = t1->socketserver()->CreateAsyncSocket(AF_INET, SOCK_DGRAM); in TEST()
336 auto* s2 = t2->socketserver()->CreateAsyncSocket(AF_INET, SOCK_DGRAM); in TEST()
|
| /external/webrtc/sdk/android/src/jni/ |
| D | android_network_monitor.cc | 218 worker_thread()->socketserver()->set_network_binder(this); in Start()
235 if (worker_thread()->socketserver()->network_binder() == this) { in Stop()
236 worker_thread()->socketserver()->set_network_binder(nullptr); in Stop()
|
| /external/python/cpython2/Doc/library/ |
| D | internet.rst | 39 socketserver.rst
|
| /external/python/cpython3/Lib/http/ |
| D | server.py | 102 import socketserver
132 class HTTPServer(socketserver.TCPServer):
138 socketserver.TCPServer.server_bind(self)
144 class ThreadingHTTPServer(socketserver.ThreadingMixIn, HTTPServer):
148 class BaseHTTPRequestHandler(socketserver.StreamRequestHandler):
|
| /external/webrtc/examples/turnserver/ |
| D | turnserver_main.cc | 74 rtc::AsyncUDPSocket::Create(main->socketserver(), int_addr); in main()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | utils.py | 12 import socketserver
213 class UnixHTTPServer(socketserver.UnixStreamServer, HTTPServer):
216 socketserver.UnixStreamServer.server_bind(self)
|