/external/webrtc/webrtc/test/channel_transport/ |
udp_socket_posix.cc | 49 _socket = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP); 52 _socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); 57 if(ioctl(_socket, FIONBIO, &enable_non_blocking) == -1) 64 if(fcntl(_socket, F_SETFD, FD_CLOEXEC) == -1) 73 if(_socket != INVALID_SOCKET) 75 close(_socket); 76 _socket = INVALID_SOCKET; 119 if(0 == setsockopt(_socket, level, optname, optval, optlen )) 141 if (0 == bind(_socket, reinterpret_cast<const sockaddr*>(&name),size)) 154 int retVal = sendto(_socket,buf, len, 0 [all...] |
udp_socket2_win.cc | 71 _socket = INVALID_SOCKET; 128 _socket = WSASocket(FROM_PROTOCOL_INFO, FROM_PROTOCOL_INFO, 133 if (_socket != INVALID_SOCKET) 148 _socket = WSASocket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP, 0 , 0, 152 _socket = WSASocket(AF_INET, SOCK_DGRAM, IPPROTO_UDP, 0 , 0, 155 if (_socket == INVALID_SOCKET) 169 int32_t nRet = setsockopt(_socket, SOL_SOCKET, SO_SNDBUF, 265 if(0 != setsockopt(_socket, level, optname, 332 if (0 != bind(_socket, addr, sizeof(SocketAddress))) 395 retVal = WSASendTo(_socket, &pIoContext->wsabuf, 1, &numOfbytesSent [all...] |
udp_socket2_win.h | 65 SOCKET GetFd() { return _socket;} 132 SOCKET _socket; member in class:webrtc::test::UdpSocket2Windows
|
udp_socket_posix.h | 79 SOCKET _socket; member in class:webrtc::test::UdpSocketPosix
|
/external/parameter-framework/upstream/remote-processor/ |
RemoteProcessorServer.cpp | 43 : _uiPort(uiPort), _io_service(), _acceptor(_io_service), _socket(_io_service) 91 _socket.set_option(asio::ip::tcp::no_delay(true)); 94 _socket.close(); 99 _acceptor.async_accept(_socket, peerHandler); 130 res = requestMessage.serialize(Socket(_socket), false, strError); 155 res = answerMessage.serialize(_socket, true, strError);
|
RemoteProcessorServer.h | 62 asio::ip::tcp::socket _socket; member in class:CRemoteProcessorServer
|
/external/autotest/client/cros/ |
dhcp_test_server.py | 76 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/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/autotest/client/cros/netprotos/ |
interface_host.py | 25 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/autotest/client/bin/net/ |
net_utils.py | 124 self._socket = socket.socket(socket.PF_PACKET, socket.SOCK_RAW) 125 self._socket.settimeout(TIMEOUT) 126 self._socket.bind((name, raw_socket.ETH_P_ALL)) 375 self._socket.send(buf) 379 return self._socket.recv(len) 383 self._socket.close() 384 self._socket = socket.socket(socket.PF_PACKET, socket.SOCK_RAW) 385 self._socket.settimeout(TIMEOUT) 386 self._socket.bind((self._name, raw_socket.ETH_P_ALL)) 473 self._socket = Non [all...] |
/external/autotest/site_utils/lxc/container_pool/ |
async_listener.py | 32 self._socket = connection.Listener(address, family='AF_UNIX') 113 self._socket.close() 145 self._queue.put(self._socket.accept())
|
/device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Demo/pdist/ |
server.py | 23 self._socket = None
24 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
25 self._socket.bind(address)
26 self._socket.listen(1)
37 if self._socket:
38 self._socket.close()
39 self._socket = None
47 conn, address = self._socket.accept()
|
client.py | 28 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
29 self._socket.connect(address)
34 self._rf = self._socket.makefile('r')
35 self._wf = self._socket.makefile('w')
48 if self._socket: self._socket.close()
49 self._socket = None
|
/external/python/cpython2/Demo/pdist/ |
server.py | 23 self._socket = None 24 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 25 self._socket.bind(address) 26 self._socket.listen(1) 37 if self._socket: 38 self._socket.close() 39 self._socket = None 47 conn, address = self._socket.accept()
|
client.py | 28 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 29 self._socket.connect(address) 34 self._rf = self._socket.makefile('r') 35 self._wf = self._socket.makefile('w') 48 if self._socket: self._socket.close() 49 self._socket = None
|
/external/webrtc/webrtc/examples/objc/AppRTCDemo/ |
ARDWebSocketChannel.m | 29 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/python/cpython2/Lib/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() 275 s, self._last_accepted = self._socket.accept() 289 self._socket.close()
|
/prebuilts/gdb/darwin-x86/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/gdb/linux-x86/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/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/python/cpython3/Lib/ |
socket.py | 1 # Wrapper module for _socket, providing some additional facilities 49 import _socket 50 from _socket import * 65 __all__.extend(os._get_exports_list(_socket)) 69 # Note that _socket only knows about the integer values. The public interface 133 class socket(_socket.socket): 135 """A subclass of _socket.socket adding the makefile() method.""" 141 # for the underlying _socket.socket they're just integers. The 142 # constructor of _socket.socket converts the given argument to an 144 _socket.socket.__init__(self, family, type, proto, fileno [all...] |
/system/bt/vendor_libs/test_vendor_lib/scripts/ |
test_channel.py | 67 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 68 self._socket.connect(('localhost', port)) 71 self._socket.close() 74 self._socket.sendall(data)
|
/device/linaro/bootloader/edk2/BaseTools/Source/ |
BinaryFiles.txt | 77 _socket.pyd
|
/external/chromium-trace/catapult/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...] |