HomeSort by relevance Sort by last modified time
    Searched refs:_socket (Results 1 - 25 of 57) sorted by null

1 2 3

  /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...]

Completed in 1403 milliseconds

1 2 3