Programming

#define _REENTRANT
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <string.h>
#include <sys/uio.h>
#include <unistd.h>
#include <pthread.h>
#define MAXBUFSIZE 500
#define num 5


/* function prototypes and global variables */
    void * process(void *);
      
    int    service_count;
    int sock, status;
    socklen_t socklen;
     unsigned char buffer[MAXBUFSIZE]={0};
    struct sockaddr_in saddr;
    pthread_t thread[num];
    void *thread_result;
      int broadcast=1;
    int res1,res;
//using namespace std;
int main ( int argc, char *argv[] )
{
   
     FILE * fp1;
      char ch={0};
    int ccount=0;
// SET CONTENT OF STRUCT SADDR AND BUFFER TO ZERO
    memset ( &saddr, 0, sizeof ( struct sockaddr_in ) );

    // OPEN A UDP socket
    sock = socket ( AF_INET, SOCK_DGRAM, 0);
    if ( sock < 0 )
        perror ( "Error creating socket" );
   
    saddr.sin_family = AF_INET;
    saddr.sin_port = htons(5880); //(8904);
    //saddr.sin_addr.s_addr =inet_addr("192.9.200.159");
    saddr.sin_addr.s_addr =INADDR_ANY;
    socklen = sizeof ( struct sockaddr_in );
    //BINDING PROCESS TO PORT
    status = bind ( sock, ( struct sockaddr * ) &saddr,socklen );
    if(status<0)
    perror("bind error:");
   
    //SET SOCKET OPTIONS
    status = setsockopt ( sock,SOL_SOCKET,SO_BROADCAST,
            (char*) &broadcast,sizeof(broadcast));
    perror ( "setsockopt::" );
        int i;
        for(i=1;i<=5;i++)
{
        /* create a new thread to process the incomming request */
         res=pthread_create(&thread[i], NULL, process, (void *) sock);
       
        if(res!=0)
{       
        printf("\nthread[%d] creation failed",thread[i]);
}
        sleep(10);

}        /* the server is now free to accept another socket request */
              res1=pthread_join(thread[i],&thread_result);
        if(res!=0)
{       
        perror("\nfailed to join");
}
   
 return 0;       
   
}


//handling of request by thread

    void * process(void *arg)
{
    //pthread_mutex_t lock;   
    int     mysocfd = (int) arg;
    unsigned char buf[MAXBUFSIZE]={0};

    //printf("Child thread [%d]: Socket number = %d\n", pthread_self(), mysocfd);

    /* receive from the given socket */
    //read(mysocfd, data, 40);

    //memset ( &buf, 0, sizeof ( buf ) );
    int len=recvfrom( mysocfd, buf, MAXBUFSIZE, 0,( struct sockaddr * )(&saddr),&socklen );
    //printf("buffer is %s",buf);
    printf("Child thread [%d]: My data = %s\n", pthread_self(), buf);

    service_count++;
    printf("Child thread [%d]: The tota0l sockets served = %d\n",pthread_self(), service_count);

    /* close the socket and exit this thread */
    close(mysocfd);
    pthread_exit("thread returned");
    //pthread_exit((void *)0);
}

#define _REENTRANT
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <string.h>
#include <sys/uio.h>
#include <unistd.h>
#include <pthread.h>
#define MAXBUFSIZE 500

/* function prototypes and global variables */
    void * senddata(void *);
      
    int    service_count;
    int sock, status;
    socklen_t socklen;
     unsigned char buffer[MAXBUFSIZE]={0};
    struct sockaddr_in saddr;
    pthread_t thread1;
      int broadcast=1;
//using namespace std;
int main ( int argc, char *argv[] )
{
   
     FILE * fp1;
      char ch={0};
    int ccount=0;
    // SET CONTENT OF STRUCT SADDR AND BUFFER TO NULL VALUES
    memset ( &saddr, 0, sizeof ( struct sockaddr_in ) );
    memset ( &buffer,0,MAXBUFSIZE );
   
    // OPEN A UDP SOCKET
    sock = socket ( AF_INET, SOCK_DGRAM, 0 );
    if ( sock < 0 )
    perror ( "Error creating socket" );
   
    //SETTING THE ADDRESS STRUCTURE PARAMETERS
    saddr.sin_family = AF_INET;
    saddr.sin_port = htons ( 5880);
   
    // this ip may be specific or any ......
    saddr.sin_addr.s_addr =INADDR_ANY;
    //saddr.sin_addr.s_addr =inet_addr("192.9.200.199");
    socklen = sizeof ( struct sockaddr_in );
   
    //SETTING THE SOCKET OPTIONS
    status = setsockopt ( sock,SOL_SOCKET,SO_BROADCAST,
                          (char*)&broadcast,sizeof (broadcast) );
    perror ( "setsockopt::" );
    status = setsockopt ( sock,SOL_SOCKET,SO_REUSEADDR,
                          (char*) &broadcast,sizeof(broadcast) );
    if ( status < 0 )
        perror ( "Error bind:");

   
    //send data to the server
    char cc[MAXBUFSIZE]="HELLO this is from client machine ";

    int count=sendto( sock,cc,400,0,( struct sockaddr * ) (&saddr),socklen );
    if ( count<0 )
        perror ( "error in sending data:" );
     else printf("send");

    /* create a new thread to process the incomming request */
    /*    pthread_create(&thread1, NULL,senddata, (void *) sock);
       
        /* the server is now free to accept another socket request */
    //pthread_join(&thread1,NULL);*/
    close(sock);
     return 0;       
   
}