| /external/chromium_org/tools/telemetry/telemetry/core/backends/chrome/ |
| inspector_websocket.py | 38 self._socket = None
46 assert not self._socket
47 self._socket = websocket.create_connection(url, timeout=timeout)
52 if self._socket:
53 self._socket.close()
54 self._socket = None
60 self._socket.send(data)
67 while self._socket:
91 while self._socket:
105 self._socket.settimeout(timeout
[all...] |
| inspector_websocket_unittest.py | 73 inspector._socket = FakeSocket(self._mock_timer)
85 inspector._socket = FakeSocket(self._mock_timer)
97 inspector._socket = FakeSocket(self._mock_timer)
|
| inspector_backend.py | 258 self._socket.close()
259 self._socket = None
|
| /external/chromium_org/third_party/webrtc/test/channel_transport/ |
| udp_socket_posix.cc | 50 _socket = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP);
53 _socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
58 if(ioctl(_socket, FIONBIO, &enable_non_blocking) == -1)
65 if(fcntl(_socket, F_SETFD, FD_CLOEXEC) == -1)
74 if(_socket != INVALID_SOCKET)
76 close(_socket);
77 _socket = INVALID_SOCKET;
126 if(0 == setsockopt(_socket, level, optname, optval, optlen ))
148 if (0 == bind(_socket, reinterpret_cast<const sockaddr*>(&name),size))
161 int retVal = sendto(_socket,buf, len, 0
[all...] |
| udp_socket2_win.cc | 70 _socket = INVALID_SOCKET;
127 _socket = WSASocket(FROM_PROTOCOL_INFO, FROM_PROTOCOL_INFO,
132 if (_socket != INVALID_SOCKET)
147 _socket = WSASocket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP, 0 , 0,
151 _socket = WSASocket(AF_INET, SOCK_DGRAM, IPPROTO_UDP, 0 , 0,
154 if (_socket == INVALID_SOCKET)
168 int32_t nRet = setsockopt(_socket, SOL_SOCKET, SO_SNDBUF,
274 if(0 != setsockopt(_socket, level, optname,
341 if (0 != bind(_socket, addr, sizeof(SocketAddress)))
411 retVal = WSASendTo(_socket, &pIoContext->wsabuf, 1, &numOfbytesSent
[all...] |
| udp_socket2_win.h | 64 SOCKET GetFd() { return _socket;}
128 SOCKET _socket; member in class:webrtc::test::UdpSocket2Windows
|
| udp_socket_posix.h | 79 SOCKET _socket; member in class:webrtc::test::UdpSocketPosix
|
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/example/ |
| echo_client.py | 225 ch = _receive_bytes(self._socket, 1)
245 ch = _receive_bytes(self._socket, 1)
262 ch = _receive_bytes(self._socket, 1)
279 ch = _receive_bytes(self._socket, 1)
290 self._socket = socket
305 self._socket.sendall(request_line)
361 self._socket.sendall(field)
363 self._socket.sendall('\r\n')
371 ch = _receive_bytes(self._socket, 1)
392 ch = _receive_bytes(self._socket, 1
[all...] |
| /external/chromium_org/tools/telemetry/third_party/pyserial/serial/urlhandler/ |
| protocol_socket.py | 51 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
52 self._socket.connect(self.fromURL(self.portstr))
54 self._socket = None
57 self._socket.settimeout(POLL_TIMEOUT) # used for write timeout support :/
72 if self._socket is None:
80 if self._socket:
82 self._socket.shutdown(socket.SHUT_RDWR)
83 self._socket.close()
87 self._socket = None
149 block = self._socket.recv(size - len(data)
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| client_for_testing.py | 302 self._socket = socket
306 self._socket.sendall(request_line)
338 self._socket.sendall(field)
339 self._socket.sendall('\r\n')
345 ch = receive_bytes(self._socket, 1)
367 fields = _read_fields(self._socket)
368 ch = receive_bytes(self._socket, 1)
490 self._socket = socket
495 self._socket.sendall(request_line)
529 self._socket.sendall(field
[all...] |
| mux_client_for_testing.py | 296 client_for_testing.read_frame_header(self._mux._socket))
319 self._mux._socket, payload_length)
385 self._socket = None
508 self._socket = socket.socket()
509 self._socket.settimeout(self._options.socket_timeout)
511 self._socket.connect((self._options.server_host,
514 self._socket = _TLSSocket(self._socket)
516 self._handshake.handshake(self._socket)
518 self._socket, self._handshake
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| connection.py | 252 self._socket = socket.socket(getattr(socket, family))
254 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
255 self._socket.setblocking(True)
256 self._socket.bind(address)
257 self._socket.listen(backlog)
258 self._address = self._socket.getsockname()
260 self._socket.close()
273 s, self._last_accepted = self._socket.accept()
281 self._socket.close()
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| connection.py | 252 self._socket = socket.socket(getattr(socket, family))
254 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
255 self._socket.setblocking(True)
256 self._socket.bind(address)
257 self._socket.listen(backlog)
258 self._address = self._socket.getsockname()
260 self._socket.close()
273 s, self._last_accepted = self._socket.accept()
281 self._socket.close()
|
| /external/chromium_org/tools/telemetry/third_party/pyserial/serial/ |
| rfc2217.py | 382 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
383 self._socket.connect(self.fromURL(self.portstr))
384 self._socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
386 self._socket = None
389 self._socket.settimeout(5) # XXX good value?
464 if self._socket is None:
509 if self._socket:
511 self._socket.shutdown(socket.SHUT_RDWR)
512 self._socket.close()
516 self._socket = Non
[all...] |
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/ |
| util.py | 381 self._socket = socket
403 read_data = self._socket.recv(DeflateSocket._RECV_SIZE)
412 self._socket.sendall(self._deflater.compress_and_flush(bytes))
|
| /external/jmdns/src/javax/jmdns/impl/ |
| JmDNSImpl.java | 70 private volatile MulticastSocket _socket; field in class:JmDNSImpl
449 if (_socket != null) {
452 _socket = new MulticastSocket(DNSConstants.MDNS_PORT);
455 _socket.setNetworkInterface(hostInfo.getInterface());
462 _socket.setTimeToLive(255);
463 _socket.joinGroup(_group);
472 if (_socket != null) {
476 _socket.leaveGroup(_group);
480 _socket.close();
506 _socket = null
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/ |
| util.py | 354 self._socket = socket
376 read_data = self._socket.recv(DeflateSocket._RECV_SIZE)
385 self._socket.sendall(self._deflater.compress_and_flush(bytes))
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test___all__.py | 72 # In case _socket fails to build, make this test fail more gracefully
74 import _socket namespace
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test___all__.py | 72 # In case _socket fails to build, make this test fail more gracefully
74 import _socket namespace
|
| /external/chromium_org/third_party/WebKit/Source/devtools/front_end/sdk/ |
| InspectorBackend.js | 636 this._socket = new WebSocket(url);
637 this._socket.onmessage = this._onMessage.bind(this);
638 this._socket.onerror = this._onError.bind(this);
639 this._socket.onopen = onConnectionReady.bind(null, this);
640 this._socket.onclose = this.connectionClosed.bind(this, "websocket_closed");
677 this._socket.send(message);
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/ |
| socket.py | 1 # Wrapper module for _socket, providing some additional facilities
47 import _socket namespace
48 from _socket import *
97 __all__.extend(os._get_exports_list(_socket))
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/ |
| socket.py | 1 # Wrapper module for _socket, providing some additional facilities
47 import _socket namespace
48 from _socket import *
97 __all__.extend(os._get_exports_list(_socket))
|
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/ |
| org.mortbay.jetty.server_6.1.23.v201004211559.jar | |
| /prebuilts/tools/common/google-api-java-client/1.8.0-rc/ |
| google-api-java-client-min-repackaged.jar | |
