CharCount finito

Reti/Laboratorio/Assigment5/CharCount/client.c

@@ -4,6 +4,7 @@
 #include <stdlib.h>
 #include <string.h>
 #include <sys/socket.h>
+#include <sys/time.h>
 #include <sys/types.h>
 #include <unistd.h>
 
@@ -13,8 +14,15 @@ int main(int argc, char *argv[]) {
   char iterationsServer[256] = {'\0'};
 
   int iterations;
+
+  struct timeval startTime, endTime;
+  double timeServ;
+
   printf("Inserire il numero di iterazioni: ");
   scanf("%d", &iterations);
+  if (!iterations) {
+    exit(1);
+  }
   snprintf(iterationsServer, sizeof(iterationsServer), "%d", iterations);
 
   int simpleSocket = 0;
@@ -55,7 +63,7 @@ int main(int argc, char *argv[]) {
                          sizeof(simpleServer));
 
   if (returnStatus == 0) {
-    fprintf(stderr, "Connect successful!\n");
+    printf("Connect successful!\n");
   } else {
     fprintf(stderr, "Could not connect to address!\n");
     close(simpleSocket);
@@ -63,21 +71,59 @@ int main(int argc, char *argv[]) {
   }
 
   // Inviando il numero di iterazioni al server
-  write(simpleSocket, iterationsServer, strlen(valueToSend));
+  write(simpleSocket, iterationsServer, strlen(iterationsServer));
 
-  for (int i = 0; i < iterations; ++i) {
+  // Avvio il timer
+  gettimeofday(&startTime, NULL);
 
-    /* get the message from the server   */
-    // returnStatus = read(simpleSocket, buffer, sizeof(buffer));
+  // Aspettando l'ACK
+  read(simpleSocket, valueToReceive, sizeof(valueToReceive));
+  if (strcmp(valueToReceive, "ACK") != 0) {
+    fprintf(stderr, "Invalid ACK");
+    exit(0);
+  }
+  printf("%s\n", valueToReceive);
+
+  int i = 0;
+  while (i < iterations) {
+    // Pulisco i buffer
+    memset(&valueToReceive, '\0', sizeof(valueToReceive));
+    memset(&valueToSend, '\0', sizeof(valueToSend));
 
     printf("Inserire il valore da voler inviare al server: ");
     scanf("%s", valueToSend);
-    write(simpleSocket, valueToSend, strlen(valueToSend));
-    read(simpleSocket, valueToReceive, sizeof(valueToReceive));
-    printf("\n\nEcho: %s\n", valueToReceive);
-    close(simpleSocket);
+    if (valueToSend[0] == '\0') {
+      fprintf(stderr, "Impossibile inviare una riga vuota!");
+    } else {
+      write(simpleSocket, valueToSend, strlen(valueToSend));
+      read(simpleSocket, valueToReceive, sizeof(valueToReceive));
+      printf("\n\nEcho: %s\n", valueToReceive);
+      ++i;
+    }
   }
 
+  // Invio il BYE
+  memset(&valueToSend, '\0', sizeof(valueToSend));
+  snprintf(valueToSend, sizeof(valueToSend), "BYE");
+  write(simpleSocket, valueToSend, sizeof(valueToSend));
+
+  // Aspettando l'ACK
+  read(simpleSocket, valueToReceive, sizeof(valueToReceive));
+  if (strcmp(valueToReceive, "ACK") != 0) {
+    fprintf(stderr, "Invalid ACK");
+    exit(0);
+  }
+  printf("%s\n", valueToReceive);
+
   close(simpleSocket);
+
+  // Spengo il timer
+  gettimeofday(&endTime, NULL);
+
+  timeServ = (endTime.tv_sec + (endTime.tv_usec / 1000000.0)) -
+             (startTime.tv_sec + (startTime.tv_usec / 1000000.0));
+
+  printf("Service Time: %.2f", timeServ);
+
   return 0;
 }

Reti/Laboratorio/Assigment5/CharCount/server.c

@@ -74,25 +74,53 @@ int main(int argc, char *argv[]) {
   int clientNameLength = sizeof(clientName);
 
   /* wait here */
+  while (1) {
+    char valueToSend[256] = {'\0'};
+    char valueToRead[256] = {'\0'};
 
-  simpleChildSocket =
-      accept(simpleSocket, (struct sockaddr *)&clientName, &clientNameLength);
+    simpleChildSocket =
+        accept(simpleSocket, (struct sockaddr *)&clientName, &clientNameLength);
 
-  if (simpleChildSocket == -1) {
-    fprintf(stderr, "Cannot accept connections!\n");
-    close(simpleSocket);
-    exit(1);
-  }
+    if (simpleChildSocket == -1) {
+      fprintf(stderr, "Cannot accept connections!\n");
+      close(simpleSocket);
+      exit(1);
+    }
 
-  char bufferRead[256] = {'\0'};
-  read(simpleChildSocket, bufferRead, sizeof(bufferRead));
+    // Leggendo il numero di richieste da svolgere
+    read(simpleChildSocket, valueToRead, sizeof(valueToRead));
+    int iterations = atoi(valueToRead);
+    printf("Numero iterazioni: %d\n", iterations);
 
-  while (1) {
-    // Read message from client
-    read(simpleChildSocket, bufferRead, sizeof(bufferRead));
-    printf("Received: %s\n", bufferRead);
-    char valueToSend[256] = {'\0'};
-    snprintf(valueToSend, sizeof(valueToSend), "%s", bufferRead);
+    // Mando ACK al Client
+    snprintf(valueToSend, sizeof(valueToSend), "ACK");
+    write(simpleChildSocket, valueToSend, sizeof(valueToSend));
+
+    for (int i = 0; i < iterations; ++i) {
+      // Pulisco i buffer
+      memset(valueToRead, '\0', sizeof(valueToRead));
+      memset(valueToSend, '\0', sizeof(valueToSend));
+
+      // Leggo il valore ricevuto dal client e gli restituisco la lunghezza
+      read(simpleChildSocket, valueToRead, sizeof(valueToRead));
+      snprintf(valueToSend, sizeof(valueToSend), "%zu", strlen(valueToRead));
+      write(simpleChildSocket, valueToSend, sizeof(valueToSend));
+    }
+
+    memset(valueToRead, '\0', sizeof(valueToRead));
+    memset(valueToSend, '\0', sizeof(valueToSend));
+
+    // Aspetto il BYE dal client
+    read(simpleChildSocket, valueToRead, sizeof(valueToRead));
+
+    if (strcmp(valueToRead, "BYE") != 0) {
+      fprintf(stderr, "Invalid BYE\n");
+      exit(1);
+    }
+    printf("\tBYE RECEIVED\n");
+
+    // Invio ACK al Server
+    snprintf(valueToSend, sizeof(valueToSend), "ACK");
     write(simpleChildSocket, valueToSend, sizeof(valueToSend));
 
     close(simpleChildSocket);