Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__UDP_SocketServer_CPP__
#define __J2K__UDP_SocketServer_CPP__

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

// Port 2000 by default
UDP_SocketServer::UDP_SocketServer( short TFTP_Port ) : UDP_Socket()
{
   memset( &server, 0, sizeof( struct sockaddr_in ) );
   memset( &client, 0, sizeof( struct sockaddr_in ) );

   server.sin_family      = PF_INET;
   server.sin_addr.s_addr = htonl( INADDR_ANY );
   server.sin_port        = htons( TFTP_Port );

   memset( buffer, 0, UDP_BUFFER_SIZE );
   gethostname( buffer, 80 );

   mySocket = socket(PF_INET, SOCK_DGRAM, 0);

   if ( mySocket < 0 )
   {
      printf( "Error: listen socket creation failed\n" );
   }
  
   if( bind( mySocket, (struct sockaddr*)&server, sizeof(server) ) != 0 )
   {
      printf("Error: bind on listen socket failed\n");
      closesocket( mySocket );
      exit( 3 );
   }

   getHostData( buffer );
   memset( buffer, 0, UDP_BUFFER_SIZE );

   // Start thread

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

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

   int clientAddrLength = sizeof( me->client );
  
   while( 1 )  // Infinite loop
   {  
      memset( me->buffer, 0, UDP_BUFFER_SIZE );
      int result = recvfrom( me->mySocket,
                             me->buffer,
                             UDP_BUFFER_SIZE, 0,
                             (struct sockaddr *) &me->client, 
                             (socklen_t       *) &clientAddrLength 
                           );

      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 %d\n",
                   inet_ntoa( me->client.sin_addr ),
                   ntohs(     me->client.sin_port )
          );

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

         // Call TFTP_PacketParser
         UDP_CALLBACK();
         fflush( stdout );      

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

// Reply to the message
inline BOOL UDP_SocketServer::send( void* msg, size_t msgLength  )
{
#ifdef DEBUG
    option.showChar( "SendPDU=", (char*)msg, msgLength );
#endif
    
  return  UDP_Socket::send( msg, msgLength, &client );
}

inline UDP_SocketServer::~UDP_SocketServer() { }

#endif

---