redgpu/bullet: Bullet Physics SDK: real-time collision detection and multi-physics simulation for VR, games, visual effects, robotics, machine learning etc.

test/clsocket/EchoServer.cpp

66 строк2 KB

Erwin Coumans

use TCP in main thread, accumulate bytes until size matches.

21 фев 2017, 05:54

21 фев 2017, 05:54942015d


#include "PassiveSocket.h"       // Include header for active socket object definition

#define MAX_PACKET 4096 

int main(int argc, char **argv)
{
    CPassiveSocket socket;
    CActiveSocket *pClient = NULL;

    //--------------------------------------------------------------------------
    // Initialize our socket object 
    //--------------------------------------------------------------------------
    socket.Initialize();

    socket.Listen("localhost", 6667);

    while (true)
    {
        if ((pClient = socket.Accept()) != NULL)
        {
			int clientPort = socket.GetClientPort();
			printf("connected from %s:%d\n", socket.GetClientAddr(),clientPort);
            //----------------------------------------------------------------------
            // Receive request from the client.
            //----------------------------------------------------------------------
            while (1)
			{
				//printf("try receive\n");
				bool receivedData = false;
				int recBytes = 0;
				recBytes = pClient->Receive(MAX_PACKET);
				if (recBytes)
				{
					char* msg = (char*) pClient->GetData();
					msg[recBytes]=0;
					printf("received message [%s]\n",msg);
					//------------------------------------------------------------------
					// Send response to client and close connection to the client.
					//------------------------------------------------------------------
					pClient->Send( pClient->GetData(), pClient->GetBytesReceived() );
					receivedData = true;
					if (strncmp(msg,"stop",4)==0)
					{
						printf("Stop request received\n");
						break;
					}
				}
				if (!receivedData)
				{
					printf("Didn't receive data.\n");
					break;
				} 
			}
			printf("Disconnecting client.\n");
			pClient->Close();
            delete pClient;
        }
    }

    //-----------------------------------------------------------------------------
    // Receive request from the client.
    //-----------------------------------------------------------------------------
    socket.Close();

    return 1;
}