| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| D | test_timeout.py | 17 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
20 self.sock.close()
24 self.assertEqual(self.sock.gettimeout(), None,
29 self.sock.settimeout(7.345)
30 self.assertEqual(self.sock.gettimeout(), 7.345)
32 self.sock.settimeout(3)
33 self.assertEqual(self.sock.gettimeout(), 3)
35 self.sock.settimeout(None)
36 self.assertEqual(self.sock.gettimeout(), None)
40 self.sock.settimeout(1)
[all …]
|
| D | test_httplib.py | 83 conn.sock = FakeSocket('blahblahblah')
95 conn.sock = FakeSocket(None)
106 sock = FakeSocket('')
107 conn.sock = sock
109 self.assertTrue(sock.data.startswith(expected))
114 sock = FakeSocket('')
115 conn.sock = sock
117 self.assertTrue(sock.data.startswith(expected))
125 sock = FakeSocket(body)
126 resp = httplib.HTTPResponse(sock)
[all …]
|
| D | test_ftplib.py | 107 sock = socket.socket()
108 sock.bind((self.socket.getsockname()[0], 0))
109 sock.listen(5)
110 sock.settimeout(10)
111 ip, port = sock.getsockname()[:2]
115 conn, addr = sock.accept()
126 sock = socket.socket(socket.AF_INET6)
127 sock.bind((self.socket.getsockname()[0], 0))
128 sock.listen(5)
129 sock.settimeout(10)
[all …]
|
| D | test_telnetlib.py | 49 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
50 self.sock.settimeout(3)
51 self.port = test_support.bind_port(self.sock)
52 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
65 telnet.sock.close()
74 self.assertEqual(telnet.sock.gettimeout(), 30)
75 telnet.sock.close()
85 self.assertTrue(telnet.sock.gettimeout() is None)
86 telnet.sock.close()
90 self.assertEqual(telnet.sock.gettimeout(), 30)
[all …]
|
| D | test_poplib.py | 283 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
284 self.sock.settimeout(3)
285 self.port = test_support.bind_port(self.sock)
286 threading.Thread(target=self.server, args=(self.evt,self.sock)).start()
312 self.assertEqual(pop.sock.gettimeout(), 30)
313 pop.sock.close()
322 self.assertTrue(pop.sock.gettimeout() is None)
323 pop.sock.close()
327 self.assertEqual(pop.sock.gettimeout(), 30)
328 pop.sock.close()
|
| /device/google/cuttlefish/host/frontend/adb_connector/ |
| D | adb_connection_maintainer.cpp | 56 bool SendAll(cvd::SharedFD sock, const std::string& msg) { in SendAll() argument
59 if (!sock->IsOpen()) { in SendAll()
62 auto just_written = sock->Send(msg.c_str() + total_written, in SendAll()
72 std::string RecvAll(cvd::SharedFD sock, const size_t count) { in RecvAll() argument
76 auto just_read = sock->Read(data.get() + total_read, count - total_read); in RecvAll()
96 bool AdbSendMessage(cvd::SharedFD sock, const std::string& message) { in AdbSendMessage() argument
97 if (!sock->IsOpen()) { in AdbSendMessage()
100 if (!SendAll(sock, message)) { in AdbSendMessage()
104 return RecvAll(sock, kAdbStatusResponseLength) == kAdbOkayStatusResponse; in AdbSendMessage()
108 auto sock = cvd::SharedFD::SocketLocalClient(kAdbDaemonPort, SOCK_STREAM); in AdbSendMessage() local
[all …]
|
| /device/google/cuttlefish/host/frontend/gcastv2/https/ |
| D | RunLoop.cpp | 153 void RunLoop::postSocketRecv(int sock, AsyncFunction fn) { in postSocketRecv() argument
154 CHECK_GE(sock, 0); in postSocketRecv()
158 mAddInfos.push_back({ sock, InfoType::RECV, fn }); in postSocketRecv()
162 void RunLoop::postSocketSend(int sock, AsyncFunction fn) { in postSocketSend() argument
163 CHECK_GE(sock, 0); in postSocketSend()
167 mAddInfos.push_back({ sock, InfoType::SEND, fn }); in postSocketSend()
171 void RunLoop::cancelSocket(int sock) { in cancelSocket() argument
172 CHECK_GE(sock, 0); in cancelSocket()
175 mAddInfos.push_back({ sock, InfoType::CANCEL, nullptr }); in cancelSocket()
229 const int sock = addInfo.mSock; in run() local
[all …]
|
| D | BufferedSocket.cpp | 22 BufferedSocket::BufferedSocket(std::shared_ptr<RunLoop> rl, int sock) in BufferedSocket() argument
24 mSock(sock) { in BufferedSocket()
|
| D | HTTPClientConnection.cpp | 50 int sock; in HTTPClientConnection() local
52 sock = socket(PF_INET, SOCK_STREAM, 0); in HTTPClientConnection()
53 if (sock < 0) { in HTTPClientConnection()
58 makeFdNonblocking(sock); in HTTPClientConnection()
64 mRunLoop, sock, 0 /* flags */, *trusted_pem_path); in HTTPClientConnection()
66 mImpl = std::make_shared<PlainSocket>(mRunLoop, sock); in HTTPClientConnection()
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/ |
| D | poplib.py | 83 self.sock = socket.create_connection((host, port), timeout)
84 self.file = self.sock.makefile('rb')
91 self.sock.sendall('%s%s' % (line, CRLF))
255 self.sock.close()
256 del self.file, self.sock
337 self.sock = None
341 self.sock = socket.socket(af, socktype, proto)
342 self.sock.connect(sa)
344 if self.sock:
345 self.sock.close()
[all …]
|
| D | ftplib.py | 104 sock = None variable in FTP
132 self.sock = socket.create_connection((self.host, self.port), self.timeout)
133 self.af = self.sock.family
134 self.file = self.sock.makefile('rb')
173 self.sock.sendall(line)
236 self.sock.sendall(line, MSG_OOB)
277 sock = None
281 sock = socket.socket(af, socktype, proto)
282 sock.bind(sa)
284 if sock:
[all …]
|
| D | socket.py | 58 def ssl(sock, keyfile=None, certfile=None): argument
64 return _realssl.sslwrap_simple(sock, keyfile, certfile)
202 sock, addr = self._sock.accept()
203 return _socketobject(_sock=sock), addr
246 def __init__(self, sock, mode='rb', bufsize=-1, close=False): argument
247 self._sock = sock
555 sock = None
557 sock = socket(af, socktype, proto)
559 sock.settimeout(timeout)
561 sock.bind(source_address)
[all …]
|
| D | telnetlib.py | 199 self.sock = None
225 self.sock = socket.create_connection((host, port), timeout)
255 if self.sock:
256 self.sock.close()
257 self.sock = 0
264 return self.sock
268 return self.sock.fileno()
280 self.sock.sendall(buffer)
455 self.option_callback(self.sock, c, NOOPT)
469 self.option_callback(self.sock, cmd, opt)
[all …]
|
| D | ssl.py | 100 def __init__(self, sock, keyfile=None, certfile=None, argument
105 socket.__init__(self, _sock=sock._sock)
361 def wrap_socket(sock, keyfile=None, certfile=None, argument
367 return SSLSocket(sock, keyfile=keyfile, certfile=certfile,
444 def sslwrap_simple(sock, keyfile=None, certfile=None): argument
450 if hasattr(sock, "_sock"):
451 sock = sock._sock
453 ssl_sock = _ssl.sslwrap(sock, 0, keyfile, certfile, CERT_NONE,
456 sock.getpeername()
|
| D | smtplib.py | 302 self.sock = self._get_socket(host, port, self.timeout)
312 if hasattr(self, 'sock') and self.sock:
314 self.sock.sendall(str)
344 self.file = self.sock.makefile('rb')
631 self.sock = ssl.wrap_socket(self.sock, keyfile, certfile)
632 self.file = SSLFakeFile(self.sock)
738 if self.sock:
739 self.sock.close()
740 self.sock = None
810 self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
[all …]
|
| D | asyncore.py | 230 def __init__(self, sock=None, map=None): argument
238 if sock:
241 sock.setblocking(0)
242 self.set_socket(sock, map)
247 self.addr = sock.getpeername()
294 sock = socket.socket(family, type)
295 sock.setblocking(0)
296 self.set_socket(sock)
298 def set_socket(self, sock, map=None): argument
299 self.socket = sock
[all …]
|
| D | httplib.py | 335 def __init__(self, sock, debuglevel=0, strict=0, method=None, buffering=False): argument
339 self.fp = sock.makefile('rb')
346 self.fp = sock.makefile('rb', 0)
684 self.sock = None
736 response = self.response_class(self.sock, strict = self.strict,
753 self.sock = socket.create_connection((self.host,self.port),
761 if self.sock:
762 self.sock.close() # close it manually... there may be other refs
763 self.sock = None
771 if self.sock is None:
[all …]
|
| /device/google/cuttlefish/host/frontend/gcastv2/webrtc/ |
| D | AdbWebSocketHandler.cpp | 34 int sock);
51 int sock) in AdbConnection() argument
52 : BaseConnection(runLoop, sock), in AdbConnection()
181 int sock = socket(PF_INET, SOCK_STREAM, 0); in setupSocket() local
183 if (sock < 0) { in setupSocket()
188 makeFdNonblocking(sock); in setupSocket()
196 if (connect(sock, in setupSocket()
204 mSocket = sock; in setupSocket()
209 close(sock); in setupSocket()
210 sock = -1; in setupSocket()
|
| D | STUNClient.cpp | 37 int sock = socket(PF_INET, SOCK_DGRAM, 0); in STUNClient() local
38 makeFdNonblocking(sock); in STUNClient()
47 sock, in STUNClient()
56 res = getsockname(sock, reinterpret_cast<sockaddr *>(&tmp), &tmpLen); in STUNClient()
61 mSocket = std::make_shared<PlainSocket>(mRunLoop, sock); in STUNClient()
|
| /device/google/cuttlefish/host/frontend/vnc_server/ |
| D | vnc_server.cpp | 45 void VncServer::StartClient(ClientSocket sock) { in StartClient() argument
46 std::thread t(&VncServer::StartClientThread, this, std::move(sock)); in StartClient()
50 void VncServer::StartClientThread(ClientSocket sock) { in StartClientThread() argument
56 VncClientConnection client(std::move(sock), virtual_inputs_, &bb_, in StartClientThread()
|
| D | vnc_server.h | 45 void StartClient(ClientSocket sock);
47 void StartClientThread(ClientSocket sock);
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Tools/ccbench/ |
| D | ccbench.py | 273 def _sendto(sock, s, addr): argument
274 sock.sendto(s.encode('ascii'), addr)
276 def _recv(sock, n): argument
277 return sock.recv(n).decode('ascii')
280 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
284 _sendto(sock, "%r\n" % _time(), addr)
292 _sendto(sock, LAT_END + "\n", addr)
303 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
304 sock.bind(("127.0.0.1", 0))
305 addr = sock.getsockname()
[all …]
|
| /device/google/cuttlefish/host/frontend/gcastv2/https/include/https/ |
| D | RunLoop.h | 67 void postSocketRecv(int sock, AsyncFunction fn);
68 void postSocketSend(int sock, AsyncFunction fn);
69 void cancelSocket(int sock);
120 void addPollFd_l(int sock);
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.10/Lib/ |
| D | socket.py | 58 def ssl(sock, keyfile=None, certfile=None): argument
64 return _realssl.sslwrap_simple(sock, keyfile, certfile)
206 sock, addr = self._sock.accept()
207 return _socketobject(_sock=sock), addr
250 def __init__(self, sock, mode='rb', bufsize=-1, close=False): argument
251 self._sock = sock
559 sock = None
561 sock = socket(af, socktype, proto)
563 sock.settimeout(timeout)
565 sock.bind(source_address)
[all …]
|
| /device/generic/goldfish-opengl/shared/OpenglCodecCommon/ |
| D | TcpStream.cpp | 68 TcpStream::TcpStream(int sock, size_t bufSize) : in TcpStream() argument
69 SocketStream(sock, bufSize) in TcpStream()
79 setsockopt( sock, IPPROTO_TCP, TCP_NODELAY, (const char*)&flag, sizeof(flag) ); in TcpStream()
|