---

communication.cpp File Reference

#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"

Go to the source code of this file.

Functions
void*	IncomingThread (void* argz)
	The Incoming Thread. More...
void*	OutgoingThread (void* argz)
	The Outgoing Thread. More...

---

Function Documentation

void * IncomingThread ( void * args)

The Incoming Thread.

Parameters:

args	The arguments passed from the clientThread

Definition at line 43 of file communication.cpp.

{
    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);
    }

void * OutgoingThread ( void * args)

The Outgoing Thread.

Parameters:

args	The arguments passed from the clientThread

Definition at line 127 of file communication.cpp.

{
    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;
            }
        }
    }

---