Search  

---

C:/temp/src/j2k/Net/UDP/UDP_SocketClient.cpp

Go to the documentation of this file.

#ifndef __J2K__UDP_SocketClient_CPP__
#define __J2K__UDP_SocketClient_CPP__

#include <j2k/Net/UDP/UDP_SocketClient.hpp>

UDP_SocketClient::UDP_SocketClient( char* srvNameAddress, short TFTP_Port )
 : UDP_Socket()
{
   memset( &dest,  0, sizeof( struct sockaddr_in ) );

   getHostData( srvNameAddress );

   dest.sin_family = PF_INET;
   dest.sin_addr   = *(in_addr*)( hostdata->h_addr_list[0] );
   dest.sin_port   = htons( TFTP_Port );

   // Server part:

   memset( &server, 0, sizeof( struct sockaddr_in ) );
    
   server.sin_family      = PF_INET;
   server.sin_addr.s_addr = htonl( INADDR_ANY );
   server.sin_port        = htons( TFTP_Port );

   mySocket = socket( PF_INET, SOCK_DGRAM, 0 );
      
   if ( mySocket < 0 )
   {
      printf( "Error: listen socket creation failed\n" );
   }

   // Start thread
   PrintInfo();    
   int ThreadID;
   pthread_t thread;
   ThreadID = pthread_create( &thread, 0,
                              UDP_SocketClient::ListenThread,
                              (void*)this
                            );
   if ( ThreadID )
   {
      printf("Error creating listen thread\n");
      exit( 3 );
   }
}

void* UDP_SocketClient::ListenThread( void* data )
{
   UDP_SocketClient* me = (UDP_SocketClient*)data;

   int serverAddrLength = sizeof( me->server );

   while( 1 )  // Infinite loop
   {
      // Clear buffer
      memset( me->buffer, 0, UDP_BUFFER_SIZE );

      int result = recvfrom( me->mySocket,
                             me->buffer,   
                             UDP_BUFFER_SIZE, 0,
                             (struct sockaddr *) &me->server,
                             (socklen_t       *) &serverAddrLength
                           );

      size_t pduLength = result;
      if ( pduLength > 60 ) pduLength = 60;

      // We retrieve the client name from recvfrom()
    
      if ( result >= 0 ) 
      {
          printf( "Received %d bytes\n", result);
          printf( "Message received from host %s port %i\n",
                   inet_ntoa( me->server.sin_addr ),
                   ntohs(     me->server.sin_port )
                );

      option.showChar( "Received:", (char*)me->buffer, pduLength );

         fflush( stdout );

         // Call TFTP_PacketParser
         UDP_CALLBACK();

         fflush( 0 );
 
      } else if ( result < -1 ) {
         printf( "[%d]", result );
         printf( "Error while receiving message: recvfrom() < 0 " );
         fflush( stdout );
      }

      if ( me->dest.sin_addr.s_addr != me->server.sin_addr.s_addr ) 
      {
          
        printf( "Error, received message from else where!\n" );
        exit( 4 );
      }
   }
}

// Send a message
inline BOOL UDP_SocketClient::send( void* msg, size_t msgLength )
{
   return UDP_Socket::send( msg, msgLength, &dest );
}

inline UDP_SocketClient::~UDP_SocketClient() { }

#endif

---