Search  

---

C:/temp/src/j2k/Deprecated/UDP.Unix/UnixSocketReceiver.cpp

Go to the documentation of this file.

#include "UnixSocketReceiver.hpp"

UnixSocketReceiver::UnixSocketReceiver( short Listen_Port )
{
   ListenSocket = INVALID_SOCKET;

   memset( &srv,    0, sizeof( struct sockaddr_in ) );
   memset( &client, 0, sizeof( struct sockaddr_in ) );

   srv.sin_family      = PF_INET;
   srv.sin_addr.s_addr = htonl( INADDR_ANY );
   srv.sin_port        = htons( Listen_Port );
}

// ::SendMsg
// hostdata -> dest
// dest
// sento( ListenSocket, ... )

// ::Listen()
// ListenSocket = socket( ... )
// srv

// ::ListenThread()
// socketData
// client

UnixSocketReceiver::~UnixSocketReceiver()
{
   if ( ListenSocket != INVALID_SOCKET ) 
   {
      closesocket(ListenSocket);
   }
}

inline SOCKET UnixSocketReceiver::getSocket()
{
   return ListenSocket;
}

void* UnixSocketReceiver::ListenThread(void* data)
{
   char buf[ BUFFER_SIZE ];
   UnixSocketReceiver* socketData = (UnixSocketReceiver*)data;

   int msglen = sizeof( socketData->client);
  
   while(1)  // Infinite loop
   {  
      int result = recvfrom( socketData->ListenSocket,
                             buf,
                             sizeof(buf) - 1, 0,
                             (struct sockaddr*)&socketData->client, 
                             (socklen_t *)&msglen 
                           );

      if ( result > 0 )
      {

         buf[ result ] = 0;

         printf("Message received from host %s port %i\n",
                inet_ntoa( socketData->client.sin_addr ),
                ntohs(     socketData->client.sin_port )
               );
      
         printf("%s",buf);
         fflush(0);
      }  
   }  
}

bool UnixSocketReceiver::Listen()
{
   ListenSocket = socket(PF_INET, SOCK_DGRAM, 0);

   if ( ListenSocket == INVALID_SOCKET ) 
   {
      printf( "Error: listen socket creation failed\n" );
      return false;
   }
  
   if( bind(ListenSocket, (struct sockaddr*)&srv, sizeof(srv) ) != 0 )
   {
      printf("Error: bind on listen socket failed\n");
      closesocket(ListenSocket);
      return false;
   }
 
   int ThreadID;

   pthread_t thread;
   ThreadID = pthread_create( &thread, 0,
                              UnixSocketReceiver::ListenThread,
                              (void*)this
                            );
   if ( ThreadID )
   {
      printf("Error creating listen thread\n");
      return false;
   } else {
      return true;
   }
}

---