/external/testng/src/main/java/org/testng/remote/ |
ConnectionInfo.java | 9 private Socket m_socket; field in class:ConnectionInfo 15 m_ois = new ObjectInputStream(m_socket.getInputStream()); 22 m_oos = new ObjectOutputStream(m_socket.getOutputStream()); 28 m_socket = s; 32 return m_socket;
|
/external/deqp/framework/delibs/decpp/ |
deSocket.cpp | 80 m_socket = deSocket_create(); 81 if (!m_socket) 87 deSocket_destroy(m_socket); 92 if (!deSocket_setFlags(m_socket, flags)) 98 if (!deSocket_listen(m_socket, address)) 104 if (!deSocket_connect(m_socket, address)) 110 if (!deSocket_shutdown(m_socket, DE_SOCKETCHANNEL_BOTH)) 116 if (!deSocket_shutdown(m_socket, DE_SOCKETCHANNEL_SEND)) 122 if (!deSocket_shutdown(m_socket, DE_SOCKETCHANNEL_RECEIVE)) 128 if (!deSocket_close(m_socket)) [all...] |
deSocket.hpp | 80 deSocketState getState (void) const { return deSocket_getState(m_socket); } 93 bool isSendOpen (void) { return (deSocket_getOpenChannels(m_socket) & DE_SOCKETCHANNEL_SEND ) != 0; } 94 bool isReceiveOpen (void) { return (deSocket_getOpenChannels(m_socket) & DE_SOCKETCHANNEL_RECEIVE ) != 0; } 98 deSocketResult send (const void* buf, size_t bufSize, size_t* numSent) { return deSocket_send(m_socket, buf, bufSize, numSent); } 99 deSocketResult receive (void* buf, size_t bufSize, size_t* numRecv) { return deSocket_receive(m_socket, buf, bufSize, numRecv); } 102 Socket (deSocket* socket) : m_socket(socket) {} 108 deSocket* m_socket; member in class:de::Socket
|
/external/deqp/execserver/ |
xsTcpServer.hpp | 52 de::Socket m_socket; member in class:xs::TcpServer 69 ConnectionHandler (TcpServer* server, de::Socket* socket) : m_server(server), m_socket(socket) {} 79 de::Socket* m_socket; member in class:xs::ConnectionHandler
|
xsTcpServer.cpp | 34 : m_socket() 42 m_socket.listen(address); 43 m_socket.setFlags(DE_SOCKET_CLOSE_ON_EXEC); 51 while ((clientSocket = m_socket.accept(clientAddr)) != DE_NULL) 117 m_socket.close(); 143 if (m_socket.getState() != DE_SOCKETSTATE_CLOSED) 144 m_socket.close(); 154 delete m_socket;
|
xsExecutionServer.cpp | 136 m_socket.close(); 151 m_socket->setFlags(DE_SOCKET_NONBLOCKING|DE_SOCKET_KEEPALIVE|DE_SOCKET_CLOSE_ON_EXEC); 194 if (m_socket->isConnected()) 195 m_socket->shutdown(); 349 deSocketResult result = m_socket->receive(&m_sendRecvTmpBuf[0], maxLen, &numRecv); 382 deSocketResult result = m_socket->send(&m_sendRecvTmpBuf[0], maxLen, &numSent);
|
/external/deqp/executor/ |
xeTcpIpLink.cpp | 179 : m_socket (socket) 226 result = m_socket.send(&buf[numSent], numToSend-numSent, &numSent); 264 : m_socket (socket) 320 result = m_socket.receive(&m_curMsgBuf[m_curMsgPos], bytesToRecv, &numRecv); 355 XE_CHECK(!m_socket.isReceiveOpen()); 416 , m_sendThread (m_socket, m_state) 417 , m_recvThread (m_socket, m_state) 440 deSocketState state = m_socket.getState(); 442 m_socket.shutdown(); 454 if (m_socket.getState() != DE_SOCKETSTATE_CLOSED [all...] |
xeTcpIpLink.hpp | 86 de::Socket& m_socket; member in class:xe::TcpIpSendThread 109 de::Socket& m_socket; member in class:xe::TcpIpRecvThread 144 de::Socket m_socket; member in class:xe::TcpIpLink
|
/external/deqp/execserver/tools/ |
xsClient.cpp | 157 de::Socket m_socket; member in class:xs::Client 172 m_socket.connect(m_cmdLine.address); 190 sendMessage(m_socket, msg); 198 ScopedMsgPtr msg(readMessage(m_socket)); 211 sendMessage(m_socket, KeepAliveMessage()); 251 m_socket.shutdown(); 252 m_socket.close();
|
/prebuilts/tools/common/m2/repository/org/testng/testng/6.9.10/ |
testng-6.9.10.jar | |