Home
last modified time | relevance | path

Searched refs:_socket (Results 1 – 25 of 39) sorted by relevance

12

/external/jetty/src/java/org/eclipse/jetty/io/bio/
DSocketEndPoint.java36 final Socket _socket; field in SocketEndPoint
48 _socket=socket; in SocketEndPoint()
49 _local=(InetSocketAddress)_socket.getLocalSocketAddress(); in SocketEndPoint()
50 _remote=(InetSocketAddress)_socket.getRemoteSocketAddress(); in SocketEndPoint()
51 super.setMaxIdleTime(_socket.getSoTimeout()); in SocketEndPoint()
62 _socket=socket; in SocketEndPoint()
63 _local=(InetSocketAddress)_socket.getLocalSocketAddress(); in SocketEndPoint()
64 _remote=(InetSocketAddress)_socket.getRemoteSocketAddress(); in SocketEndPoint()
65 _socket.setSoTimeout(maxIdleTime>0?maxIdleTime:0); in SocketEndPoint()
76 return super.isOpen() && _socket!=null && !_socket.isClosed(); in isOpen()
[all …]
/external/jetty/src/java/org/eclipse/jetty/io/nio/
DChannelEndPoint.java48 protected final Socket _socket; field in ChannelEndPoint
59 _socket=(channel instanceof SocketChannel)?((SocketChannel)channel).socket():null; in ChannelEndPoint()
60 if (_socket!=null) in ChannelEndPoint()
62 _local=(InetSocketAddress)_socket.getLocalSocketAddress(); in ChannelEndPoint()
63 _remote=(InetSocketAddress)_socket.getRemoteSocketAddress(); in ChannelEndPoint()
64 _maxIdleTime=_socket.getSoTimeout(); in ChannelEndPoint()
76 _socket=(channel instanceof SocketChannel)?((SocketChannel)channel).socket():null; in ChannelEndPoint()
77 if (_socket!=null) in ChannelEndPoint()
79 _local=(InetSocketAddress)_socket.getLocalSocketAddress(); in ChannelEndPoint()
80 _remote=(InetSocketAddress)_socket.getRemoteSocketAddress(); in ChannelEndPoint()
[all …]
DNetworkTrafficSelectChannelEndPoint.java81 listener.opened(_socket); in notifyOpened()
100 listener.incoming(_socket, view); in notifyIncoming()
121 listener.outgoing(_socket, view); in notifyOutgoing()
139 listener.closed(_socket); in notifyClosed()
DSelectChannelEndPoint.java589 ((!_socket.isInputShutdown() && read_interest ) ? SelectionKey.OP_READ : 0) in updateKey()
590 | ((!_socket.isOutputShutdown()&& write_interest) ? SelectionKey.OP_WRITE : 0); in updateKey()
837 _socket.getRemoteSocketAddress(), in toString()
838 _socket.getLocalSocketAddress(), in toString()
/external/webrtc/webrtc/test/channel_transport/
Dudp_socket_posix.cc49 _socket = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP); in UdpSocketPosix()
52 _socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); in UdpSocketPosix()
57 if(ioctl(_socket, FIONBIO, &enable_non_blocking) == -1) in UdpSocketPosix()
64 if(fcntl(_socket, F_SETFD, FD_CLOEXEC) == -1) in UdpSocketPosix()
73 if(_socket != INVALID_SOCKET) in ~UdpSocketPosix()
75 close(_socket); in ~UdpSocketPosix()
76 _socket = INVALID_SOCKET; in ~UdpSocketPosix()
119 if(0 == setsockopt(_socket, level, optname, optval, optlen )) in SetSockopt()
141 if (0 == bind(_socket, reinterpret_cast<const sockaddr*>(&name),size)) in Bind()
154 int retVal = sendto(_socket,buf, len, 0, in SendTo()
[all …]
Dudp_socket2_win.cc71 _socket = INVALID_SOCKET; in UdpSocket2Windows()
128 _socket = WSASocket(FROM_PROTOCOL_INFO, FROM_PROTOCOL_INFO, in UdpSocket2Windows()
133 if (_socket != INVALID_SOCKET) in UdpSocket2Windows()
148 _socket = WSASocket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP, 0 , 0, in UdpSocket2Windows()
152 _socket = WSASocket(AF_INET, SOCK_DGRAM, IPPROTO_UDP, 0 , 0, in UdpSocket2Windows()
155 if (_socket == INVALID_SOCKET) in UdpSocket2Windows()
169 int32_t nRet = setsockopt(_socket, SOL_SOCKET, SO_SNDBUF, in UdpSocket2Windows()
265 if(0 != setsockopt(_socket, level, optname, in SetSockopt()
332 if (0 != bind(_socket, addr, sizeof(SocketAddress))) in Bind()
395 retVal = WSASendTo(_socket, &pIoContext->wsabuf, 1, &numOfbytesSent, in SendTo()
[all …]
Dudp_socket2_win.h65 SOCKET GetFd() { return _socket;} in GetFd()
132 SOCKET _socket; variable
Dudp_socket_posix.h79 SOCKET _socket; variable
/external/autotest/client/cros/
Ddhcp_test_server.py76 self._socket = None
95 return self._socket is not None
123 self._socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
126 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
127 self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
130 self._socket.setsockopt(socket.SOL_SOCKET,
133 self._socket.bind((self._ingress_address, self._ingress_port))
136 self._socket.settimeout(0.1)
140 if not self._socket is None:
141 self._socket.close()
[all …]
/external/chromium-trace/catapult/telemetry/telemetry/internal/backends/chrome_inspector/
Dinspector_websocket.py26 self._socket = None
63 assert not self._socket
64 self._socket = websocket.create_connection(url, timeout=timeout)
75 if self._socket:
76 self._socket.close()
77 self._socket = None
90 if not self._socket:
95 self._socket.send(data)
138 self._socket.settimeout(timeout)
142 if not self._socket:
[all …]
Dinspector_websocket_unittest.py67 inspector._socket = fake_socket
84 inspector._socket = fake_socket
102 inspector._socket = fake_socket
132 inspector._socket = fake_socket
167 inspector._socket = fake_socket
180 inspector._socket = fake_socket
/external/autotest/client/bin/net/
Dnet_utils.py123 self._socket = socket.socket(socket.PF_PACKET, socket.SOCK_RAW)
124 self._socket.settimeout(TIMEOUT)
125 self._socket.bind((name, raw_socket.ETH_P_ALL))
373 self._socket.send(buf)
377 return self._socket.recv(len)
381 self._socket.close()
382 self._socket = socket.socket(socket.PF_PACKET, socket.SOCK_RAW)
383 self._socket.settimeout(TIMEOUT)
384 self._socket.bind((self._name, raw_socket.ETH_P_ALL))
471 self._socket = None
[all …]
/external/chromium-trace/catapult/telemetry/third_party/pyserial/serial/urlhandler/
Dprotocol_socket.py51 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/autotest/client/cros/netprotos/
Dinterface_host.py25 self._socket = None
30 if self._socket:
31 self._socket.close()
45 if self._socket is not None:
49 self._socket = InterfaceDatagramSocket(self.ip_addr)
50 return self._socket
69 self._socket.run_once()
/external/parameter-framework/upstream/remote-processor/
DRemoteProcessorServer.cpp43 : _uiPort(uiPort), _io_service(), _acceptor(_io_service), _socket(_io_service) in CRemoteProcessorServer()
91 _socket.set_option(asio::ip::tcp::no_delay(true)); in acceptRegister()
94 _socket.close(); in acceptRegister()
99 _acceptor.async_accept(_socket, peerHandler); in acceptRegister()
130 res = requestMessage.serialize(Socket(_socket), false, strError); in handleNewConnection()
155 res = answerMessage.serialize(_socket, true, strError); in handleNewConnection()
DRemoteProcessorServer.h62 asio::ip::tcp::socket _socket; variable
/external/chromium-trace/catapult/third_party/gsutil/third_party/oauth2client/tests/
Dtest_devshell.py42 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
43 self._socket.bind(('localhost', 0))
44 port = self._socket.getsockname()[1]
46 self._socket.listen(0)
55 self._socket.close()
60 self._socket.settimeout(15)
61 s, unused_addr = self._socket.accept()
/external/jetty/src/java/org/eclipse/jetty/server/bio/
DSocketConnector.java194 protected final Socket _socket; field in SocketConnector.ConnectorEndPoint
200 _socket=socket; in ConnectorEndPoint()
302 if (!_socket.isClosed()) in run()
307 _socket.setSoTimeout(getMaxIdleTime()); in run()
311 c = _socket.getInputStream().read(); in run()
314 if (!_socket.isClosed()) in run()
315 _socket.close(); in run()
/external/jetty/src/java/org/eclipse/jetty/server/nio/
DBlockingChannelConnector.java328 if (!_socket.isClosed()) in run()
333 _socket.setSoTimeout(getMaxIdleTime()); in run()
337 c = _socket.getInputStream().read(); in run()
340 if (!_socket.isClosed()) in run()
341 _socket.close(); in run()
357 _socket.getRemoteSocketAddress(), in toString()
358 _socket.getLocalSocketAddress(), in toString()
/external/webrtc/webrtc/examples/objc/AppRTCDemo/
DARDWebSocketChannel.m29 SRWebSocket *_socket;
44 _socket = [[SRWebSocket alloc] initWithURL:url];
45 _socket.delegate = self;
47 [_socket open];
94 [_socket send:messageString];
114 [_socket close];
196 [_socket send:messageString];
/external/autotest/client/virt/
Drss_client.py94 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
95 self._socket.settimeout(timeout)
97 self._socket.connect((address, port))
122 self._socket.close()
129 self._socket.settimeout(timeout)
130 self._socket.sendall(str)
146 self._socket.settimeout(timeout)
147 data = self._socket.recv(size)
Dkvm_monitor.py74 self._socket = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
77 self._socket.connect(filename)
107 self._socket.shutdown(socket.SHUT_RDWR)
110 self._socket.close()
124 return bool(select.select([self._socket], [], [], timeout)[0])
133 data = self._socket.recv(1024)
227 self._socket.sendall(cmd + "\n")
522 self._socket.sendall(data)
/external/chromium-trace/catapult/telemetry/third_party/pyserial/serial/
Drfc2217.py382 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 = None
[all …]
/external/jetty/src/java/org/eclipse/jetty/server/ssl/
DSslSocketConnector.java643 int oldTimeout = _socket.getSoTimeout(); in run()
645 _socket.setSoTimeout(handshakeTimeout); in run()
647 final SSLSocket ssl=(SSLSocket)_socket; in run()
668 _socket.setSoTimeout(oldTimeout); in run()
/external/jmdns/src/javax/jmdns/impl/
DJmDNSImpl.java70 private volatile MulticastSocket _socket; field in JmDNSImpl
449 if (_socket != null) { in openMulticastSocket()
452 _socket = new MulticastSocket(DNSConstants.MDNS_PORT); in openMulticastSocket()
455 _socket.setNetworkInterface(hostInfo.getInterface()); in openMulticastSocket()
462 _socket.setTimeToLive(255); in openMulticastSocket()
463 _socket.joinGroup(_group); in openMulticastSocket()
472 if (_socket != null) { in closeMulticastSocket()
476 _socket.leaveGroup(_group); in closeMulticastSocket()
480 _socket.close(); in closeMulticastSocket()
506 _socket = null; in closeMulticastSocket()
[all …]

12