/third_party/vk-gl-cts/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
|
/third_party/vk-gl-cts/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()
|
/third_party/python/Lib/test/test_asyncio/ |
D | test_base_events.py | 32 m_socket = mock.MagicMock(spec=socket) 38 setattr(m_socket, name, getattr(socket, name)) 40 delattr(m_socket, name) 42 m_socket.socket = mock.MagicMock() 43 m_socket.socket.return_value = test_utils.mock_nonblocking_socket() 44 m_socket.getaddrinfo._is_coroutine = False 46 return m_socket 143 def test_ipaddr_info_no_inet_pton(self, m_socket): argument 144 del m_socket.inet_pton 1077 def test_create_connection_multiple_errors(self, m_socket): argument [all …]
|
D | test_unix_events.py | 392 def test_create_unix_server_bind_error(self, m_socket): argument 395 m_socket.socket.return_value = sock
|
/third_party/vk-gl-cts/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
|
/third_party/vk-gl-cts/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() 251 m_socket.shutdown(); in run() 252 m_socket.close(); in run()
|