| /external/webrtc/webrtc/test/channel_transport/ |
| D | udp_socket_posix.cc | 49 _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 …]
|
| D | udp_socket2_win.cc | 71 _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 …]
|
| D | udp_socket2_win.h | 65 SOCKET GetFd() { return _socket;} in GetFd()
132 SOCKET _socket; variable
|
| D | udp_socket_posix.h | 79 SOCKET _socket; variable
|
| /external/autotest/client/cros/ |
| D | 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 …]
|
| D | httpd.py | 248 _socket = socket.socket(self.address_family, self.socket_type)
249 self.socket = ssl.wrap_socket(_socket,
|
| /external/autotest/client/bin/net/ |
| D | 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 = None
[all …]
|
| /external/python/cpython2/PC/VC6/ |
| D | _socket.dsp | 1 # Microsoft Developer Studio Project File - Name="_socket" - Package Owner=<4>
7 CFG=_socket - Win32 Debug
11 !MESSAGE NMAKE /f "_socket.mak".
16 !MESSAGE NMAKE /f "_socket.mak" CFG="_socket - Win32 Debug"
20 !MESSAGE "_socket - Win32 Release" (based on "Win32 (x86) Dynamic-Link Library")
21 !MESSAGE "_socket - Win32 Debug" (based on "Win32 (x86) Dynamic-Link Library")
26 # PROP Scc_ProjName "_socket"
32 !IF "$(CFG)" == "_socket - Win32 Release"
42 # PROP Intermediate_Dir "x86-temp-release\_socket"
57 …32.lib /nologo /base:"0x1e1D0000" /subsystem:windows /dll /debug /machine:I386 /out:"./_socket.pyd"
[all …]
|
| D | pcbuild.dsw | 90 Project: "_socket"=".\_socket.dsp" - Package Owner=<4>
|
| /external/chromium-trace/catapult/third_party/pyserial/serial/urlhandler/ |
| D | 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/site_tests/platform_PrinterPpds/ |
| D | fake_printer.py | 45 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
48 self._socket.bind( ('localhost', port) )
54 self._socket.close()
120 (connection, client_address) = self._socket.accept()
161 self._socket.listen(1)
164 self._socket.settimeout(0.5)
180 self._socket.close()
|
| /external/python/cpython2/Demo/pdist/ |
| D | 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()
|
| D | 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/autotest/client/cros/netprotos/ |
| D | 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/parameter-framework/upstream/remote-processor/ |
| D | RemoteProcessorServer.cpp | 45 : _bindAddress(bindAddress), _io_service(), _acceptor(_io_service), _socket(_io_service) in CRemoteProcessorServer()
146 const auto &endpoint = _socket.local_endpoint(); in acceptRegister()
148 _socket.set_option(asio::ip::tcp::no_delay(true)); in acceptRegister()
152 _socket.close(); in acceptRegister()
157 _acceptor.async_accept(_socket, peerHandler); in acceptRegister()
188 res = requestMessage.serialize(Socket(_socket), false, strError); in handleNewConnection()
213 res = answerMessage.serialize(_socket, true, strError); in handleNewConnection()
|
| D | RemoteProcessorServer.h | 62 asio::generic::stream_protocol::socket _socket; variable
|
| /external/python/cpython3/Lib/ |
| D | socket.py | 49 import _socket
50 from _socket import *
65 __all__.extend(os._get_exports_list(_socket))
133 class socket(_socket.socket):
151 _socket.socket.__init__(self, family, type, proto, fileno)
299 raise _socket.timeout('timed out')
412 def _real_close(self, _ss=_socket.socket):
466 if hasattr(_socket.socket, "share"):
476 if hasattr(_socket, "socketpair"):
491 a, b = _socket.socketpair(family, type, proto)
[all …]
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | 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()
|
| /external/python/oauth2client/tests/contrib/ |
| D | test_devshell.py | 127 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
128 self._socket.bind(('localhost', 0))
129 port = self._socket.getsockname()[1]
131 self._socket.listen(0)
141 self._socket.close()
149 self._socket.settimeout(None)
151 s, unused_addr = self._socket.accept()
|
| /external/webrtc/webrtc/examples/objc/AppRTCDemo/ |
| D | 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/chromium-trace/catapult/third_party/pyserial/serial/ |
| D | 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 = None
[all …]
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | connection.py | 574 self._socket = socket.socket(getattr(socket, family))
578 self._socket.setsockopt(socket.SOL_SOCKET,
580 self._socket.setblocking(True)
581 self._socket.bind(address)
582 self._socket.listen(backlog)
583 self._address = self._socket.getsockname()
585 self._socket.close()
598 s, self._last_accepted = self._socket.accept()
604 self._socket.close()
|
| /external/python/cpython2/Lib/ |
| D | socket.py | 47 import _socket
48 from _socket import *
101 __all__.extend(os._get_exports_list(_socket))
|
| /external/python/cpython3/Tools/freeze/ |
| D | extensions_win32.ini | 28 [_socket] section
29 dsp=%PYTHONPREFIX%\PCbuild\_socket.dsp argument
|
| /external/python/cpython2/Tools/freeze/ |
| D | extensions_win32.ini | 28 [_socket] section
29 dsp=%PYTHONPREFIX%\PCBuild\_socket.dsp argument
|