Searched refs:m_socket (Results 1 – 8 of 8) sorted by relevance
| /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 … (const void* buf, int bufSize, int* numSent) { return deSocket_send(m_socket, buf, bufSize, nu… in send()
99 …e (void* buf, int bufSize, int* 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/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/deqp/execserver/tools/ |
| D | xsClient.cpp | 157 de::Socket m_socket; member in xs::Client
172 m_socket.connect(m_cmdLine.address); in run()
190 sendMessage(m_socket, msg); in run()
198 ScopedMsgPtr msg(readMessage(m_socket)); in run()
211 sendMessage(m_socket, KeepAliveMessage()); in run()
251 m_socket.shutdown(); in run()
252 m_socket.close(); in run()
|