| /third_party/node/deps/npm/node_modules/socks/build/client/ |
| D | socksclient.js | 213 this._socket = existing_socket;
216 this._socket = new net.Socket();
219 this._socket.once('close', this._onClose);
220 this._socket.once('error', this._onError);
221 this._socket.once('connect', this._onConnect);
222 this._socket.on('data', this._onDataReceived);
226 this._socket.emit('connect');
229 this._socket.connect(this.getSocketOptions());
232 this._socket.setNoDelay(!!this._options.set_tcp_nodelay);
348 this._socket.pause();
[all …]
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/android/ |
| D | android_console.dart | 29 AndroidConsole(this._socket);
31 Socket _socket;
35 assert(_socket != null);
38 _queue = StreamQueue<String>(_socket.asyncMap(ascii.decode));
50 if (_socket != null) {
51 _socket.destroy();
52 _socket = null;
74 _socket.add(ascii.encode(text));
|
| /third_party/python/Lib/ |
| D | socket.py | 51 import _socket
52 from _socket import *
67 __all__.extend(os._get_exports_list(_socket))
214 class socket(_socket.socket):
232 _socket.socket.__init__(self, family, type, proto, fileno)
380 raise _socket.timeout('timed out')
493 def _real_close(self, _ss=_socket.socket):
547 if hasattr(_socket.socket, "sendmsg"):
555 return sock.sendmsg(buffers, [(_socket.SOL_SOCKET,
556 _socket.SCM_RIGHTS, array.array("i", fds))])
[all …]
|
| D | ssl.py | 257 import socket as _socket namespace
333 addr = _socket.inet_aton(ipname)
338 if _socket.inet_ntoa(addr) == ipname:
348 return _socket.inet_pton(_socket.AF_INET6, ipname)
|
| /third_party/node/lib/internal/debugger/ |
| D | inspect_client.js | 233 if (this._socket) {
234 this._socket.destroy();
238 this._socket = null;
245 if (!this._socket) {
256 this._socket.write(encodeFrameHybi17(Buffer.from(json)));
343 this._socket = socket;
|
| /third_party/boost/libs/phoenix/example/ |
| D | adapted_echo_server.cpp | 85 phx::expression::argument<1>::type _socket; in main() local
90 write(_socket, buffer(_buf, _length), phx::ref(write_handler)) in main()
94 … read(_socket, buffer(_buf, max_length), boost::asio::transfer_at_least(1), phx::ref(read_handler)) in main()
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | channel_ready_test.py | 35 address, self._port, self._socket = get_socket(
38 self._socket.close()
|
| D | wait_for_ready_test.py | 98 address, self._port, self._socket = get_socket(listen=False)
101 self._socket.close()
|
| /third_party/python/Lib/multiprocessing/ |
| D | connection.py | 584 self._socket = socket.socket(getattr(socket, family))
588 self._socket.setsockopt(socket.SOL_SOCKET,
590 self._socket.setblocking(True)
591 self._socket.bind(address)
592 self._socket.listen(backlog)
593 self._address = self._socket.getsockname()
595 self._socket.close()
609 s, self._last_accepted = self._socket.accept()
615 self._socket.close()
|
| /third_party/node/deps/npm/node_modules/socks/typings/client/ |
| D | socksclient.d.ts | 21 private _socket; property in SocksClient
|
| /third_party/node/test/common/ |
| D | inspector-helper.js | 127 this._socket = socket;
161 this._socket.destroy();
214 (resolve) => this._socket.write(formatWSFrame(msg), resolve))
|
| /third_party/python/Tools/freeze/ |
| D | extensions_win32.ini | 28 [_socket] section
29 dsp=%PYTHONPREFIX%\PCbuild\_socket.dsp argument
|
| /third_party/python/Lib/test/ |
| D | test___all__.py | 80 import _socket
|
| D | test_socket.py | 46 import _socket
48 _socket = None variable
833 import _socket
834 self.assertTrue(socket.SocketType is _socket.socket)
853 @unittest.skipUnless(_socket is not None, 'need _socket module')
855 s = _socket.socket(_socket.AF_INET, _socket.SOCK_STREAM)
6468 @unittest.skipIf(not hasattr(_socket, 'IPPROTO_IPV6') or
6469 not hasattr(_socket, 'IPV6_V6ONLY'),
|
| /third_party/python/PCbuild/ |
| D | readme.txt | 142 _socket
|
| D | pcbuild.sln | 32 Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "_socket", "_socket.vcxproj", "{86937F53-C189-4…
|
| /third_party/python/Modules/ |
| D | Setup | 210 #_socket socketmodule.c
|
| /third_party/glib/gio/ |
| D | gsocket.c | 335 #define win32_unset_event_mask(_socket, _mask) _win32_unset_event_mask (_socket, _mask) argument
345 #define win32_unset_event_mask(_socket, _mask) argument
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_base_events.py | 1083 def _socket(*args, **kw): function
1088 m_socket.socket = _socket
|
| /third_party/python/Doc/howto/ |
| D | sockets.rst | 1 .. _socket-howto:
|
| /third_party/python/Doc/library/ |
| D | socket.rst | 1142 .. _socket-objects:
1786 .. _socket-timeouts:
1840 .. _socket-example:
|
| D | logging.handlers.rst | 444 .. _socket-handler:
|
| /third_party/flutter/engine/flutter/lib/snapshot/ |
| D | fuchsia_compilation_trace.txt | 1490 dart:io,_RawSocket,get:_socket
1585 dart:io,_HttpClientConnection,get:_socket
|
| /third_party/flutter/engine/flutter/shell/platform/fuchsia/flutter/ |
| D | compilation_trace.txt | 89 dart:_http,_HttpClientConnection,get:_socket
2223 dart:io,_RawSecureSocket,get:_socket
2267 dart:io,_RawSocket,get:_socket
|
| /third_party/python/Doc/whatsnew/ |
| D | 2.3.rst | 1113 <type '_socket.socket'>
|