src/main.c

   1 #include <sys/types.h>
   2 #include <sys/socket.h>
   3 #include <stdio.h>
   4 #include <string.h>
   5 #include <netinet/in.h>
   6 #include <arpa/inet.h>
   7 #include <unistd.h>
   8 #include <pthread.h>
   9 #include <unistd.h>
  10
  11 /***************SERVER****************/
  12
  13 void *Parser(void*);
  14 void *Receive(void *);
  15 void *Send(void *);
  16 void *Timer_X(void *);
  17 void *Timer_Y(void *);
  18 int CreateSocket(int);
  19
  20 char instr[5], sensors[]="1000000000";
  21
  22 pthread_mutex_t simu_mutex;
  23 pthread_cond_t sensor_trigger;
  24
  25 int main(int argc, char *arcv[])
  26 {
  27   int server_socket, new_socket, rc;
  28
  29   pthread_t parser, send, receive, timer_x, timer_y;
  30   pthread_attr_t attr;
  31
  32   pthread_mutex_init(&simu_mutex, NULL);
  33   pthread_cond_init (&sensor_trigger, NULL);
  34
  35   new_socket = CreateSocket(server_socket);
  36
  37   pthread_attr_init(&attr);
  38   pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
  39
  40   rc = pthread_create(&parser, NULL, Parser, NULL);
  41   if (rc){
  42     printf("ERROR; return code from pthread_create() parser is %d\n", rc);
  43   }
  44
  45   rc = pthread_create(&send, &attr, Send, (void *) new_socket);
  46   if (rc){
  47     printf("ERROR; return code from pthread_create() send is %d\n", rc);
  48   }
  49
  50   rc = pthread_create(&receive, NULL, Receive, (void *) new_socket);
  51   if (rc){
  52     printf("ERROR; return code from pthread_create() receive is %d\n", rc);
  53   }
  54
  55   rc = pthread_create(&timer_x, &attr, Timer_X, NULL);
  56   if (rc){
  57     printf("ERROR; return code from pthread_create() timer_x is %d\n", rc);
  58   }
  59
  60   rc = pthread_create(&timer_y, &attr, Timer_Y, NULL);
  61   if (rc){
  62     printf("ERROR; return code from pthread_create() timer_y is %d\n", rc);
  63   }
  64
  65   pthread_join(send, NULL);
  66   pthread_join(timer_x, NULL);
  67   pthread_join(timer_y, NULL);
  68
  69   while(1)
  70     ;
  71
  72
  73
  74   printf("\n Server: close()...");
  75
  76   close(server_socket);
  77   close(new_socket);
  78
  79   printf("\n Serverprogramm beendet\n\n");
  80
  81
  82   pthread_attr_destroy(&attr);
  83   pthread_mutex_destroy(&simu_mutex);
  84   pthread_cond_destroy(&sensor_trigger);
  85   pthread_exit(NULL);
  86   return(0);
  87 }
  88
  89 int CreateSocket(int server_socket)
  90 {
  91   int new_socket;
  92   int length;
  93   struct sockaddr_in serverinfo, clientinfo;
  94   unsigned short int portnmbr=5000;
  95   char ip_addr[]="127.0.0.1";
  96
  97   printf("\n Server: socket()...");
  98
  99   server_socket = socket(AF_INET, SOCK_STREAM, 0);
 100   serverinfo.sin_family = AF_INET;
 101   serverinfo.sin_addr.s_addr = inet_addr(ip_addr);
 102   serverinfo.sin_port = htons(portnmbr);
 103   length = sizeof(serverinfo);
 104
 105   printf("\n Server: bind()...");
 106   bind(server_socket, (struct sockaddr *)&serverinfo, length);
 107   printf("\n Server: listen()...");
 108   printf("\n Server mit IP %s", ip_addr);
 109   printf(" an Port %d wartet...", portnmbr);
 110
 111   listen(server_socket, 3);
 112   printf("\n Server: accept()...");
 113   new_socket = accept(server_socket,
 114                       (struct sockaddr *)&clientinfo, &length);
 115
 116   printf("Verbindung mit %s", inet_ntoa(clientinfo.sin_addr));
 117
 118   return new_socket;
 119 }
 120
 121 void *Parser(void* arg)
 122 {
 123   char input[10];
 124   printf("\n<Parser> started");
 125   while(1)
 126     {
 127       printf("\n~>");
 128       scanf("%10s", input);
 129       fflush(stdin);
 130       if(strstr(input, "test"))
 131           printf("\nTesteingabe");
 132
 133     }
 134   pthread_exit(NULL);
 135 }
 136
 137 void *Receive(void *new_socket)
 138 {
 139   int socket;
 140   socket=(int) new_socket;
 141
 142   printf("\n<Receive> started");
 143
 144   char rec[2];
 145
 146   read(socket, rec, sizeof(rec));
 147   rec[1]='\0';
 148
 149   printf("\n Empfangen: %s", rec);
 150
 151   pthread_exit(NULL);
 152 }
 153
 154 void *Send(void *new_socket)
 155 {
 156   int socket;
 157   socket=(int) new_socket;
 158
 159   printf("\n<Send> started");
 160
 161   while(1)
 162     {
 163       pthread_mutex_lock(&simu_mutex);
 164       pthread_cond_wait(&sensor_trigger, &simu_mutex);
 165
 166       write(socket, sensors, sizeof(sensors));
 167
 168       printf("\n<Send> received Signal");
 169       fflush(stdout);
 170       pthread_mutex_unlock(&simu_mutex);
 171     }
 172   pthread_exit(NULL);
 173
 174 }
 175
 176 void *Timer_X(void * arg)
 177 {
 178   int i, sensor;
 179
 180   printf("\n<TimerX> started");
 181
 182   for(i=0; i<11; i++)
 183     if(sensors[i]=='1')
 184       sensor=i;
 185
 186   for(i=0; i<10; i++)
 187     {
 188       usleep(1000000);
 189       sensors[sensor++] = '0';
 190       sensors[sensor]   = '1';
 191       pthread_mutex_lock(&simu_mutex);
 192       pthread_cond_signal(&sensor_trigger);
 193       pthread_mutex_unlock(&simu_mutex);
 194     }
 195   pthread_exit(NULL);
 196 }
 197
 198 void *Timer_Y(void *arg)
 199 {
 200   int i;
 201
 202   printf("\n<TimerY> started");
 203
 204   /*  for(i=0; i<10; i++)
 205     {
 206       usleep(1500000);
 207       pthread_mutex_lock(&simu_mutex);
 208       pthread_cond_signal(&sensor_trigger);
 209       pthread_mutex_unlock(&simu_mutex);
 210     }
 211   */
 212   pthread_exit(NULL);
 213 }