connections.c File Reference

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/wait.h>
#include <signal.h>
#include <pthread.h>
#include "connections.h"
#include <mysql.h>

Include dependency graph for connections.c:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
void	setup ()
void	DB_udp ()
void *	DB_udphandler (void *udp_BUF)
void	DB_process_UDP (unsigned char *udp_BUF)
Variables
pthread_mutex_t	mutex_on_buffer

---

Function Documentation

void DB_process_UDP

(

unsigned char *

udp_BUF

)

Definition at line 245 of file connections.c.

References cfgparser(), and dataparser().

Referenced by DB_udphandler().

                                           {

        int stat_status,i;
        unsigned char c = udp_BUF[1];
        c <<= 1;
        c >>= 5;
        if(c == 0x00){                                  /* If data frame */

                printf("\nData frame\n");
                stat_status = dataparser(udp_BUF);
                printf("Return from DParser\n");

        } else if(c == 0x03) {                  /* If configuration frame */

                for(i=0;i<400;i++)printf("%x\t",udp_BUF[i]);
                printf("\nConfiguration frame\n");
                cfgparser(udp_BUF);
                printf("Return from CFG\n");
                

        } else {        
                
                printf("Erroneous frame\n");

        }       
        fflush(stdout);
} 

Here is the call graph for this function:

Here is the caller graph for this function:

void DB_udp

(

)

Definition at line 160 of file connections.c.

References buffer, copy_cbyc(), DB_addr_len, DB_sockfd, DB_udphandler(), MAXBUFLEN, mutex_on_buffer, numbytes, and their_addr.

Referenced by setup().

             {

        // UDP threads are created for each received UDP message in 'detached' mode. Thus allowing any number of threads to be created. 
        int err;
        pthread_attr_t attr;
        pthread_attr_init(&attr);

        if((err = pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED))) { // In  the detached state, the thread resources are
                                                                                // immediately freed when it terminates, but 
                perror(strerror(err));                                          // pthread_join(3) cannot be used to synchronize
                exit(1);                                                        //  on the thread termination.         
                                                                                
        }                                                               
                                                                                                                                                                                                                                                                                          
        if((err = pthread_attr_setschedpolicy(&attr,SCHED_FIFO))) { // Shed policy = SCHED_FIFO (realtime, first-in first-out)

                perror(strerror(err));
                exit(1);
        }  


        /* UDP data Received */
        while(1) {

               if ((numbytes = recvfrom(DB_sockfd,buffer, MAXBUFLEN-1, 0,(struct sockaddr *)&their_addr, (socklen_t *)&DB_addr_len)) == -1) { 
                                                                                                        // Main if
                         perror("recvfrom");
                         exit(1);

                } else { /* New datagram has been received */
        
                        pthread_t t;
                        int tt;
                        unsigned char *udp_BUF;
                        udp_BUF = malloc(MAXBUFLEN*sizeof(unsigned char));
        
                        if(!udp_BUF) {
        
                                printf("No space for udp_BUF\n");
                                exit(1);
                        }
                        printf("\nUDP Server got packet from %s\n",inet_ntoa(their_addr.sin_addr));
                        printf("packet is %d bytes long\n",numbytes);
                        buffer[numbytes] = '\0';
        
                        /* Copy the udp_buf data to a local variable */
                        pthread_mutex_lock(&mutex_on_buffer);
                        copy_cbyc(udp_BUF,buffer,MAXBUFLEN);
                        memset(buffer, '\0', MAXBUFLEN);
                        pthread_mutex_unlock(&mutex_on_buffer);
        
                        /* Creates a new thread for each received UDP message */
                        if((tt = pthread_create(&t,&attr,DB_udphandler,(void *)udp_BUF))) {
                
                                perror(strerror(tt));   
                                exit(1);
                        }               
        
                } // Main if ends

         } // while ends
        
         pthread_attr_destroy(&attr);           
} 

Here is the call graph for this function:

Here is the caller graph for this function:

void* DB_udphandler

(

void *

udp_BUF

)

Definition at line 230 of file connections.c.

References DB_process_UDP().

Referenced by DB_udp().

                                    {

        DB_process_UDP((unsigned char*)udp_BUF);

        free((unsigned char*)udp_BUF);

        pthread_exit(NULL); /* Exit the thread once the task is done. */
                
}

Here is the call graph for this function:

Here is the caller graph for this function:

void setup

(

)

Definition at line 68 of file connections.c.

References conn_cfg, conn_data, database, DB_addr_len, DB_sockfd, DB_udp(), DBPORT, password, server, and user.

Referenced by main().

            {

        printf("Entering setup()\n");

/* MySQL data base parameters */

        server = "localhost";
        user = "root";
        password = "root";
        database = "openPDC";

/* MySQL data base connection */
        
        conn_data = mysql_init(NULL);
        conn_cfg = mysql_init(NULL);

        if(conn_data == NULL) {

                printf("No sufficient memory\n");
                exit(1);
        }

        if(conn_cfg == NULL) {

                printf("No sufficient memory\n");
                exit(1);
        }

/* Connect to database */
        if (!mysql_real_connect(conn_data, server,
                      user, password, database, 0, NULL, 0)) {

                fprintf(stderr, "%s\n", mysql_error(conn_data));
                exit(1);
        }

        if (!mysql_real_connect(conn_cfg, server,
                      user, password, database, 0, NULL, 0)) {

                fprintf(stderr, "%s\n", mysql_error(conn_cfg));
                exit(1);
        }

/* Create UDP socket and bind to port */
        int yes;
        if ((DB_sockfd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) {

                 perror("socket");
                 exit(1);
        
        } else {

                printf("DB Socket:Sucessfully created\n");

        }       

        if (setsockopt(DB_sockfd,SOL_SOCKET,SO_REUSEADDR,&yes,sizeof(int)) == -1) {
                perror("setsockopt");
                exit(1);
        }

        DB_server_addr.sin_family = AF_INET;            // host byte order
        DB_server_addr.sin_port = htons(DBPORT);        // short, network byte order
        DB_server_addr.sin_addr.s_addr = INADDR_ANY;    // automatically fill with my IP
        memset(&(DB_server_addr.sin_zero),'\0', 8);     // zero the rest of the struct

        if (bind(DB_sockfd, (struct sockaddr *)&DB_server_addr,
                                     sizeof(DB_server_addr)) == -1) {
                 perror("bind");
                 exit(1);
        
        } else {

                printf("DB Socket Bind :Sucessfull\n");
        } 

        printf("\nDB Server Listening on port %d\n",DBPORT);

        DB_addr_len = sizeof(struct sockaddr);

        DB_udp();
        mysql_close(conn_cfg);
        mysql_close(conn_data);

}

Here is the call graph for this function:

Here is the caller graph for this function:

---

Variable Documentation

pthread_mutex_t mutex_on_buffer

Definition at line 62 of file connections.c.

Referenced by DB_udp().