| /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 | |
