---

communication.cpp

Go to the documentation of this file.

/********************************************************************
Description:
part of the 3Dsia project
created: StonedBones, 1.2.2000

History:
    date,   name,       changes,                    in funtion
    240400  xandi       merge, code clean, bugfixes
    180400  StonedBones added dynamic packet length
    010200  StonedBones created source

********************************************************************/

#include <sys/time.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <stdlib.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <string>
#include <pthread.h>

#include "protocol.h"
#include "options.h"

#include "communication.h"

/*...................................................................
Description: Thread that manages the incoming buffer
Args: ComArgs* args: various arguments (see header-file)
Returns: <none>
Created: StonedBones, 1.2.2000
[ToDo:]
[Comments:]
Changes:
    fixed all (i hope) bugs                             230400, xandi
    merged server/communication & client-commthreads
    into common/communication                           240400, xandi
    code cleanup                                        240400, xandi
-------------------------------------------------------------------*/

void* IncomingThread (void* argz)
    {
    ComArgs* args = (ComArgs*) argz;
    fd_set  checkIt;

    Buffer* myBuffer = args->buffer;
    int mySocket     = args->socket;

    if (myBuffer == 0)
        {
        fprintf(stderr,"[comT.incoming] PANIK!! my buffer is not existing!\n");
        exit(1);
        }

    fprintf(stderr,"[comT.incoming] Incoming Thread started for socket %d\n",args->socket);

    FD_ZERO (&checkIt);
    FD_SET (mySocket, &checkIt);

    if (select (70, &checkIt, 0, 0, NULL) < 0)
        {
        fprintf (stderr,"[comT.incoming] error: select (not critical)");
        }

    while (1)
        {
        packet* pak = new packet;

#ifdef DEBUG
        fprintf(stderr,"[comT.incoming] I am waiting on socket %d....\n",mySocket);
#endif
        if (FD_ISSET (mySocket, &checkIt))
            {
            packet_header tmpH;

            unsigned int temp  = read (mySocket, &tmpH, sizeof (packet_header) );
            char* tmpCh = new char[tmpH.length];

            temp += read (mySocket, tmpCh, tmpH.length );

            #ifdef DEBUG
            fprintf ( stderr,"[comT.incoming] received %d bytes\n",temp);
            #endif

            if ( temp == ( tmpH.length + sizeof (packet_header ) ) )
                {
                pak->h = tmpH;
                pak->data.assign (tmpCh, tmpH.length);
                myBuffer->write (pak);

                #ifdef DEBUG
                fprintf(stderr,"[comT.incoming] packet (type %d, size = %d) written into buffer...\n",pak->h.header[0],tmpH.length);
                #endif
               }
            else
                {
                fprintf(stderr,"[comT.incoming] seems read was not successful..\n");
                break;
                }
            }
        else
            {
            fprintf(stderr,"[comT.incoming] FD_ISSET gave false...\n");
            break;
            }
        }

    fprintf(stderr,"[comT.incoming] Thread terminated\n");
    packet* pak = new packet;
    pak->h.header[0] = PROT_KILL_CLIENT;
    myBuffer->write (pak);
    pthread_exit (NULL);
    }

/*...................................................................
Description: Thread that manages the outgoing buffer
Args: ComArgs* args: various arguments (see header-files)
Returns: <none>
Created: StonedBones, 1.2.2000
[ToDo:]
[Comments:]
Changes:
-------------------------------------------------------------------*/

void* OutgoingThread (void* argz)
    {
    ComArgs* args = (ComArgs*) argz;
    Buffer* myBuffer = args->buffer;
    int mySocket     = args->socket;

    if ( !myBuffer )
        {
        fprintf(stderr,"[comT.outgoing] PANIK!! my buffer is not existing!\n");
        exit(1);
        }

    fprintf(stderr,"[comT.outgoing] OutgoingThread started for socket %d\n",mySocket);

    while (1)
        {
        if (!myBuffer->isEmpty ())
            {
            packet* pak = myBuffer->read ();

//            if ( !pak->data.length() ) //TEMP!!!!!!!!!!!
//                pak->data = "x";  //TEMP!!!!!!!!!!!

            if (pak->h.header[0] == PROT_KILL_CLIENT)
                pthread_exit (NULL);

            #ifdef DEBUG
            fprintf(stderr,"[comT.outgoing] sending a package..\n");
            #endif

            packet_header tmpH  = pak->h;
            tmpH.length = pak->data.length ();
            const char*   tmpCh = pak->data.data ();

            unsigned int temp;
            temp  = write ( mySocket, &tmpH, sizeof (packet_header) );
            temp += write ( mySocket, tmpCh, tmpH.length );

            if ( temp != ( sizeof (packet_header) + tmpH.length ) )
                {
                fprintf (stderr,"[comT.outgoing] Error: write\n");
                pthread_exit (NULL);
                }

            #ifdef DEBUG
            fprintf(stderr,"[comT.outoing] %d bytes sent\n", tmpH.length);
            #endif
            delete pak;
            pak = 0;
            }
        }
    }

---