| /external/deqp/framework/delibs/decpp/ |
| D | deSocket.cpp | 80 m_socket = deSocket_create(); in Socket()
81 if (!m_socket) in Socket()
87 deSocket_destroy(m_socket); in ~Socket()
92 if (!deSocket_setFlags(m_socket, flags)) in setFlags()
98 if (!deSocket_listen(m_socket, address)) in listen()
104 if (!deSocket_connect(m_socket, address)) in connect()
110 if (!deSocket_shutdown(m_socket, DE_SOCKETCHANNEL_BOTH)) in shutdown()
116 if (!deSocket_shutdown(m_socket, DE_SOCKETCHANNEL_SEND)) in shutdownSend()
122 if (!deSocket_shutdown(m_socket, DE_SOCKETCHANNEL_RECEIVE)) in shutdownReceive()
128 if (!deSocket_close(m_socket)) in close()
[all …]
|
| D | deSocket.hpp | 80 deSocketState getState (void) const { return deSocket_getState(m_socket); } in getState()
93 …bool isSendOpen (void) { return (deSocket_getOpenChannels(m_socket) & DE_SOCKETCHANNEL_… in isSendOpen()
94 …bool isReceiveOpen (void) { return (deSocket_getOpenChannels(m_socket) & DE_SOCKETCHANNE… in isReceiveOpen()
98 …onst void* buf, size_t bufSize, size_t* numSent) { return deSocket_send(m_socket, buf, bufSize, nu… in send()
99 …(void* buf, size_t bufSize, size_t* numRecv) { return deSocket_receive(m_socket, buf, bufSize, nu… in receive()
102 Socket (deSocket* socket) : m_socket(socket) {} in Socket()
108 deSocket* m_socket; member in de::Socket
|
| /external/deqp/execserver/ |
| D | xsTcpServer.cpp | 34 : m_socket() in TcpServer()
42 m_socket.listen(address); in TcpServer()
43 m_socket.setFlags(DE_SOCKET_CLOSE_ON_EXEC); in TcpServer()
51 while ((clientSocket = m_socket.accept(clientAddr)) != DE_NULL) in runServer()
117 m_socket.close(); in stopServer()
143 if (m_socket.getState() != DE_SOCKETSTATE_CLOSED) in ~TcpServer()
144 m_socket.close(); in ~TcpServer()
154 delete m_socket; in ~ConnectionHandler()
|
| D | xsTcpServer.hpp | 52 de::Socket m_socket; member in xs::TcpServer
69 … ConnectionHandler (TcpServer* server, de::Socket* socket) : m_server(server), m_socket(socket) {} in ConnectionHandler()
79 de::Socket* m_socket; member in xs::ConnectionHandler
|
| D | xsExecutionServer.cpp | 136 m_socket.close(); in connectionDone()
151 m_socket->setFlags(DE_SOCKET_NONBLOCKING|DE_SOCKET_KEEPALIVE|DE_SOCKET_CLOSE_ON_EXEC); in ExecutionRequestHandler()
194 if (m_socket->isConnected()) in handle()
195 m_socket->shutdown(); in handle()
349 deSocketResult result = m_socket->receive(&m_sendRecvTmpBuf[0], maxLen, &numRecv); in receive()
382 deSocketResult result = m_socket->send(&m_sendRecvTmpBuf[0], maxLen, &numSent); in send()
|
| /external/llvm-project/lldb/source/Host/common/ |
| D | TCPSocket.cpp | 66 m_socket = socket; in TCPSocket()
72 m_socket = socket; in TCPSocket()
78 return m_socket != kInvalidSocketValue || m_listen_sockets.size() != 0; in IsValid()
83 if (m_socket != kInvalidSocketValue) { in GetLocalPortNumber()
86 if (::getsockname(m_socket, sock_addr, &sock_addr_len) == 0) in GetLocalPortNumber()
101 if (m_socket != kInvalidSocketValue) { in GetLocalIPAddress()
104 if (::getsockname(m_socket, sock_addr, &sock_addr_len) == 0) in GetLocalIPAddress()
111 if (m_socket != kInvalidSocketValue) { in GetRemotePortNumber()
114 if (::getpeername(m_socket, sock_addr, &sock_addr_len) == 0) in GetRemotePortNumber()
123 if (m_socket != kInvalidSocketValue) { in GetRemoteIPAddress()
[all …]
|
| D | Socket.cpp | 78 m_socket(kInvalidSocketValue), in Socket()
320 return m_socket; in GetWaitableHandle()
327 bytes_received = ::recv(m_socket, static_cast<char *>(buf), num_bytes, 0); in Read()
342 static_cast<void *>(this), static_cast<uint64_t>(m_socket), buf, in Read()
370 static_cast<void *>(this), static_cast<uint64_t>(m_socket), buf, in Write()
390 static_cast<void *>(this), static_cast<uint64_t>(m_socket)); in Close()
393 bool success = !!closesocket(m_socket); in Close()
395 bool success = !!::close(m_socket); in Close()
398 m_socket = kInvalidSocketValue; in Close()
410 return ::getsockopt(m_socket, level, option_name, option_value_p, in GetOption()
[all …]
|
| D | UDPSocket.cpp | 33 m_socket = socket; in UDPSocket()
40 return ::sendto(m_socket, static_cast<const char *>(buf), num_bytes, 0, in Send()
137 if (m_socket != kInvalidSocketValue) { in GetRemoteConnectionURI()
|
| /external/testng/src/main/java/org/testng/remote/ |
| D | ConnectionInfo.java | 9 private Socket m_socket; field in ConnectionInfo
15 m_ois = new ObjectInputStream(m_socket.getInputStream()); in getOis()
22 m_oos = new ObjectOutputStream(m_socket.getOutputStream()); in getOos()
28 m_socket = s; in setSocket()
32 return m_socket; in getSocket()
|
| /external/llvm-project/lldb/tools/lldb-vscode/ |
| D | IOStream.cpp | 37 ::closesocket(m_socket); in ~StreamDescriptor()
39 ::close(m_socket); in ~StreamDescriptor()
50 m_socket = other.m_socket; in operator =()
59 sd.m_socket = s; in from_socket()
76 bytes_written = ::send(descriptor.m_socket, str.data(), str.size(), 0); in write_full()
100 bytes_read = ::recv(descriptor.m_socket, ptr, length, 0); in read_full()
|
| D | IOStream.h | 48 SOCKET m_socket; member
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_base_events.py | 31 m_socket = mock.MagicMock(spec=socket)
37 setattr(m_socket, name, getattr(socket, name))
39 delattr(m_socket, name)
41 m_socket.socket = mock.MagicMock()
42 m_socket.socket.return_value = test_utils.mock_nonblocking_socket()
43 m_socket.getaddrinfo._is_coroutine = False
45 return m_socket
142 def test_ipaddr_info_no_inet_pton(self, m_socket): argument
143 del m_socket.inet_pton
1068 def test_create_connection_multiple_errors(self, m_socket): argument
[all …]
|
| D | test_unix_events.py | 383 def test_create_unix_server_bind_error(self, m_socket): argument
386 m_socket.socket.return_value = sock
|
| /external/deqp/executor/ |
| D | xeTcpIpLink.cpp | 179 : m_socket (socket) in TcpIpSendThread()
226 result = m_socket.send(&buf[numSent], numToSend-numSent, &numSent); in run()
264 : m_socket (socket) in TcpIpRecvThread()
320 result = m_socket.receive(&m_curMsgBuf[m_curMsgPos], bytesToRecv, &numRecv); in run()
355 XE_CHECK(!m_socket.isReceiveOpen()); in stop()
416 , m_sendThread (m_socket, m_state) in TcpIpLink()
417 , m_recvThread (m_socket, m_state) in TcpIpLink()
440 deSocketState state = m_socket.getState(); in closeConnection()
442 m_socket.shutdown(); in closeConnection()
454 if (m_socket.getState() != DE_SOCKETSTATE_CLOSED) in closeConnection()
[all …]
|
| D | xeTcpIpLink.hpp | 86 de::Socket& m_socket; member in xe::TcpIpSendThread
109 de::Socket& m_socket; member in xe::TcpIpRecvThread
144 de::Socket m_socket; member in xe::TcpIpLink
|
| /external/llvm-project/lldb/source/Host/posix/ |
| D | DomainSocket.cpp | 72 m_socket = socket; in DomainSocket()
82 m_socket = CreateSocket(kDomain, kType, 0, m_child_processes_inherit, error); in Connect()
101 m_socket = CreateSocket(kDomain, kType, 0, m_child_processes_inherit, error); in Listen()
130 if (m_socket != kInvalidSocketValue) { in GetSocketName()
134 if (::getpeername(m_socket, (struct sockaddr *)&saddr_un, &sock_addr_len) == in GetSocketName()
148 if (m_socket != kInvalidSocketValue) { in GetRemoteConnectionURI()
|
| /external/deqp/execserver/tools/ |
| D | xsClient.cpp | 158 de::Socket m_socket; member in xs::Client
173 m_socket.connect(m_cmdLine.address); in run()
191 sendMessage(m_socket, msg); in run()
199 ScopedMsgPtr msg(readMessage(m_socket)); in run()
212 sendMessage(m_socket, KeepAliveMessage()); in run()
252 m_socket.shutdown(); in run()
253 m_socket.close(); in run()
|
| /external/llvm-project/lldb/include/lldb/Host/ |
| D | Socket.h | 94 NativeSocket GetNativeSocket() const { return m_socket; } in GetNativeSocket()
103 bool IsValid() const override { return m_socket != kInvalidSocketValue; } in IsValid()
128 NativeSocket m_socket; variable
|
| /external/antlr/runtime/Cpp/include/ |
| D | antlr3debugeventlistener.hpp | 74 SOCKET m_socket; member in DebugEventListener
|
| /external/mdnsresponder/mDNSWindows/DLL.NET/ |
| D | dnssd_NET.cpp | 333 m_socket = (SOCKET) DNSServiceRefSockFD(m_ref); in SetupEvents()
334 check(m_socket != INVALID_SOCKET); in SetupEvents()
343 int err = WSAEventSelect(m_socket, m_socketEvent, FD_READ|FD_CLOSE); in SetupEvents()
|
| D | dnssd_NET.h | 397 SOCKET m_socket; variable
|