| /third_party/vk-gl-cts/framework/delibs/decpp/ |
| H A 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...] |
| H A 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_SEND ) != 0; } in isSendOpen()
94 bool isReceiveOpen (void) { return (deSocket_getOpenChannels(m_socket) & DE_SOCKETCHANNEL_RECEIVE ) != 0; } in isReceiveOpen()
98 deSocketResult send (const void* buf, size_t bufSize, size_t* numSent) { return deSocket_send(m_socket, buf, bufSize, numSent); } in send()
99 deSocketResult receive (void* buf, size_t bufSize, size_t* numRecv) { return deSocket_receive(m_socket, buf, bufSize, numRecv); } in receive()
102 Socket (deSocket* socket) : m_socket(socket) {} in Socket()
108 deSocket* m_socket; member in de::Socket
|
| /third_party/vk-gl-cts/execserver/ |
| H A 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()
|
| H A 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
|
| H A 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()
|
| /third_party/python/Lib/test/test_asyncio/ |
| H A 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()
44 return m_socket
141 def test_ipaddr_info_no_inet_pton(self, m_socket):
142 del m_socket.inet_pton
1082 def test_create_connection_multiple_errors(self, m_socket):
1102 m_socket
[all...] |
| H A D | test_unix_events.py | 392 def test_create_unix_server_bind_error(self, m_socket):
395 m_socket.socket.return_value = sock
|
| /third_party/vk-gl-cts/executor/ |
| H A 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 in closeConnection()
[all...] |
| H A 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
|
| /third_party/vk-gl-cts/execserver/tools/ |
| H A 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()
251 m_socket.shutdown(); in run()
252 m_socket.close(); in run()
|