Client.cpp

Go to the documentation of this file.

#include "Client.h"
Client::Client()
{       
    host = gethostbyname("127.0.0.1");
    server_addr.sin_family = AF_INET;     
    server_addr.sin_port = htons(5000);   
    server_addr.sin_addr = *((struct in_addr *)host->h_addr);
    bzero(&(server_addr.sin_zero),8);
    initiate = false;
    char *message1 = "Thread 1";
    char *message2 = "Thread 2";
    //int iret1 = pthread_create( &thread1, NULL, print_message_function,(void*) message1);
    //int iret2 = pthread_create( &thread2, NULL, print_message_function,(void*) message2); 
    //boost::thread t1 = boost::thread::thread(explore);
    create_thread();
}

Client::~Client()
{
  close(sock);
}

void* proxy_function(void* foo_ptr){
    static_cast<Client*>(foo_ptr)->thread_function();
}

void Client::create_thread(){
    pthread_t thread;
    thread=pthread_create(&thread, NULL, proxy_function, this);
}  

void Client::thread_function()
{
while(1)
{
bytes_recieved=recv(sock,recv_data,1024,0);
recv_data[bytes_recieved] = '\0';
//printf("\n RECIEVED DATA from Server:\n delim = %i , command = %i , length = %i , Channels = %i " ,recv_data[0], recv_data[1], recv_data[2] , recv_data[4]);
}
}

void Client::explore()
{
printf("Thread");
}
void* Client::print_message_function( void *ptr )
{
             char *message;
             message = (char *) ptr;
             printf("%s \n", message);
}

void Client::start_stopBroadcasting(int frqy)
{
          unsigned char frq = (unsigned char) frqy;
          delim = 2;
          printf("function");
          command = 1;
          length = 1;
          memcpy(nbuffer,&delim, sizeof(delim));
          memcpy(&nbuffer[sizeof(delim)],&command, sizeof(command));
          memcpy(&nbuffer[sizeof(delim)+sizeof(command)], &length, sizeof(length)); 
          memcpy(&nbuffer[sizeof(delim)+sizeof(command)+sizeof(length)], &frq, sizeof(frq));           
          send(sock,(void*)&nbuffer,sizeof(nbuffer), 0); 
          printf("\nCOMMAND SENT: delim = %i , command = %i , length = %d, Broadcastfrequency = %d" ,*nbuffer, *(&nbuffer[sizeof(delim)]), *(&nbuffer[sizeof(delim)+sizeof(command)]),frq);
}

void Client::on_offChannel(char channel, char status)
{
          delim = 2;
          command = 4;
          length = 2;
          memcpy(nbuffer,&delim, sizeof(delim));
          memcpy(&nbuffer[sizeof(delim)],&command, sizeof(command));
          memcpy(&nbuffer[sizeof(delim)+sizeof(command)], &length, sizeof(length));
          memcpy(&nbuffer[sizeof(delim)+sizeof(command)+sizeof(length)], &channel, sizeof(channel));
          memcpy(&nbuffer[sizeof(delim)+sizeof(command)+sizeof(length)+sizeof(channel)], &status, sizeof(status));            
          send(sock,(void*)&nbuffer,sizeof(nbuffer), 0); 
          printf("\nCOMMAND SENT: delim = %i , command = %i , length = %d  , channel#= %c, ON/OFF= %c" ,*nbuffer, *(&nbuffer[sizeof(delim)]), *(&nbuffer[sizeof(delim)+sizeof(command)]),*(&nbuffer[sizeof(delim)+sizeof(command)+sizeof(length)]),*(&nbuffer[sizeof(delim)+sizeof(command)+sizeof(length)+sizeof(channel)]));
}


void Client::re_initClient()
{
 close(sock);
 Client();
 initClient();
}

void Client::initClient()
{ 
  if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
         perror("Socket");
         exit(1);
    }
  if (connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1) {
            perror("Connection error!");
            exit(1);
    }
  initiate = true;
}

void Client::receiveFromServer()
{

        
          bytes_recieved=recv(sock,recv_data,1024,0);
          recv_data[bytes_recieved] = '\0';
 
          //printf("\n RECIEVED DATA from Server:\n delim = %c , command = %c , length = %d , Channels = %d " ,recv_data[0], recv_data[1], recv_data[2] , recv_data[4]);
           char command = recv_data[1];
           ushort length = *(&recv_data[2]);
           int channels = *(&recv_data[4]);
           //printf("\nCommand = %i, Bytes=%i,Channels=%d", command, length,channels);
          if(command == 0)
          {
             int offset = 5;
             for(int channel=0;channel<channels;channel++)
             {
                //printf("\n Channel# : %d, Max_Vol= %f, Max_Cur= %f", channel,*((float *)(recv_data+offset)), *((float *)(recv_data+offset+4)));
                offset = offset + 8;
              }
           }else
                {
                  int offset = 5;
                  for(int channel=0;channel<channels;channel++)
                  {
                    //printf("\n Channel# : %d, Switch ON/OFF = %c Flowing_Vol= %d, Flowing_Cur= %d", channel,*(&recv_data[offset]),*(&recv_data[offset+1]), *(&recv_data[offset+5]));
                    offset = offset + 9;
                  }//for
              }//else
                           
}
 

void Client::requestMeasurments()
{
          delim = 2;
          command = 3;
          length = 0;
          memcpy(nbuffer,&delim, sizeof(delim));
          memcpy(&nbuffer[sizeof(delim)],&command, sizeof(command));
          memcpy(&nbuffer[sizeof(delim)+sizeof(command)], &length, sizeof(length));            
          send(sock,(void*)&nbuffer,sizeof(nbuffer), 0); 
          printf("\nCOMMAND SENT: delim = %i , command = %i , length = %i  " ,nbuffer[0], nbuffer[sizeof(delim)], nbuffer[sizeof(delim)+sizeof(command)]);
}