Lines Matching defs:socket
70 void sendMessage (de::Socket& socket, const Message& message)
76 // Write to socket.
82 deSocketResult result = socket.send(&buf[pos], numLeft, &numSent);
91 void readBytes (de::Socket& socket, vector<deUint8>& dst, size_t numBytes)
99 deSocketResult result = socket.receive(&dst[numRead], numLeft, &curNumRead);
108 Message* readMessage (de::Socket& socket)
112 readBytes(socket, header, MESSAGE_HEADER_SIZE);
128 readBytes(socket, messageBuf, messageSize-MESSAGE_HEADER_SIZE);
192 virtual void runClient (de::Socket& socket) = DE_NULL;
299 de::Socket socket;
300 socket.connect(m_testCtx.address);
303 socket.setFlags(DE_SOCKET_CLOSE_ON_EXEC);
306 testCase->runClient(socket);
309 if (socket.isConnected())
310 socket.shutdown();
344 void runClient (de::Socket& socket)
346 DE_UNREF(socket);
360 void runClient (de::Socket& socket)
363 sendMessage(socket, (const xs::Message&)msg);
377 void runClient (de::Socket& socket)
385 sendMessage(socket, execMsg);
395 ScopedMsgPtr msg(readMessage(socket));
417 void runClient (de::Socket& socket)
425 sendMessage(socket, execMsg);
438 ScopedMsgPtr msg(readMessage(socket));
476 void runClient (de::Socket& socket)
484 sendMessage(socket, execMsg);
498 ScopedMsgPtr msg(readMessage(socket));
538 void runClient (de::Socket& socket)
546 sendMessage(socket, execMsg);
560 ScopedMsgPtr msg(readMessage(socket));
630 void runClient (de::Socket& socket)
638 sendMessage(socket, execMsg);
652 ScopedMsgPtr msg(readMessage(socket));
668 sendMessage(socket, KeepAliveMessage());
722 void runClient (de::Socket& socket)
746 sendMessage(socket, KeepAliveMessage());
756 ScopedMsgPtr msg(readMessage(socket));
775 sendMessage(socket, KeepAliveMessage());
788 ScopedMsgPtr msg(readMessage(socket));