msgrcv

src/F4Client.c

@@ -4,30 +4,83 @@
 #include <sys/ipc.h>
 #include <sys/stat.h>
 #include <sys/msg.h>
+#include <signal.h>
+#include <sys/sem.h>
 
 #include <custom_sem.h>
 #include <structures.h>
 #include <custom_shm.h>
+#include <errExit.h>
+
+
+void sigHandlerClient(int sig) {
+    if (sig == SIGINT) {
+        //TODO:
+    }
+
+    if (sig == SIGTERM) {
+        //TODO:
+    }
+
+    exit(0);
+}
+
+int semid;
+
 
 //TODO: mettere main ma non l'ho fatto per makefile
 int client(){
 
+    input_server_t input;
+
+    // SIGNAL
+    sigset_t mySet;
+    sigfillset(&mySet);
+    sigdelset(&mySet, SIGINT);
+    sigdelset(&mySet, SIGTERM);
+    sigprocmask(SIG_SETMASK, &mySet, NULL);
+
+    if (signal(SIGINT, sigHandlerClient) == SIG_ERR) {
+        errExit("signal SIGINT", "F4Client");
+    }
+    if (signal(SIGTERM, sigHandlerClient) == SIG_ERR) {
+        errExit("signal SIGTERM", "F4Client");
+    }
+    //
+
     // MSGQ
     key_t msgKey = ftok(KEYFILE, 'M');
-    int msqid = msgget(msgKey, IPC_CREAT | S_IRUSR | S_IWUSR);
-    if (msqid == -1) {
-        errExit("msgq", "F4Client");
+    int msgid = msgget(msgKey, IPC_CREAT | S_IRUSR | S_IWUSR);
+    if (msgid == -1) {
+        errExit("msgget", "F4Client");
     }
 
-    if (msgrcv(msqid, ) == -1){
-        errExit("msgrcv", )
+        // msg
+        msg_t msg;
+
+        // msgsnd
+        if (msgrcv(msgid, &msg, sizeof(msg_t) - sizeof(long), 1, 0) == -1) {
+            errExit("msgrcv", "F4Client");
+        }
+
+        input = msg.server_in;
+    //
+
+
+    // SHM
+    int shmBoardid = getShmid(input.rows, input.collums);
+    tile_t *board = shmServerAt(shmBoardid);
+    //
+
+    // SEM
+    key_t semKey = ftok(KEYFILE, 'S');
+    if ((semid = semget(semKey, 2, S_IRUSR | S_IWUSR | IPC_CREAT)) == -1) {
+        errExit("getsem", "F4Client");
     }
     //
 
 
 
-    int semid;
-
     semOp(semid, 0, -1);    // aspetta che il server gli dia il permesso di connettersi
 
     printf("\033[94m<Client>\033[39m Connecting to server...\n");

src/F4Server.c

@@ -13,35 +13,24 @@
 #include <custom_shm.h>
 #include <errExit.h>
 
-void sigHandler(int sig) {
-    if (sig = SIGINT) {
+void sigHandlerServer(int sig) {
+    if (sig == SIGINT) {
         //TODO:
     }
 
-    if (sig = SIGTERM) {
+    if (sig == SIGTERM) {
         //TODO:
     }
 
     exit(0);
 }
 
+int semid;
+
 
 int main(int argc, char *argv[]){
     input_server_t input = check_input(argc, argv);
 
-
-    // SHM
-    int shmBoardid = getShmid(input.rows, input.collums);
-    tile_t *board = shmServerAt(shmBoardid);
-    //
-
-    // SEM
-    key_t semKey = ftok(KEYFILE, 'S');
-    int semid = getSemid(semKey, 2);
-    
-    resetServerSem(semid);
-    //
-
     // SIGNAL
     sigset_t mySet;
     sigfillset(&mySet);
@@ -49,21 +38,22 @@ int main(int argc, char *argv[]){
     sigdelset(&mySet, SIGTERM);
     sigprocmask(SIG_SETMASK, &mySet, NULL);
 
-    if (signal(SIGINT, sigHandler) == SIG_ERR) {
+    if (signal(SIGINT, sigHandlerServer) == SIG_ERR) {
         errExit("signal SIGINT", "f4Server");
     }
-    if (signal(SIGTERM, sigHandler) == SIG_ERR) {
+    if (signal(SIGTERM, sigHandlerServer) == SIG_ERR) {
         errExit("signal SIGTERM", "f4Server");
     }
     //
 
+
     // MSGQ
     key_t msgKey = ftok(KEYFILE, 'M');
     int msgid = msgget(msgKey, IPC_CREAT | S_IRUSR | S_IWUSR);
     if (msgid == -1) {
-        errExit("msgq", "F4Server");
+        errExit("msgget", "F4Server");
     }
-        // msg_t
+        // msg
         msg_t msg = {
             .mtype = 1,
             .server_in = input
@@ -76,6 +66,20 @@ int main(int argc, char *argv[]){
 
     //
 
+    // SHM
+    int shmBoardid = getShmid(input.rows, input.collums);
+    tile_t *board = shmServerAt(shmBoardid);
+    //
+
+    // SEM
+    key_t semKey = ftok(KEYFILE, 'S');
+    if ((semid = semget(semKey, 2, S_IRUSR | S_IWUSR | IPC_CREAT)) == -1) {
+        errExit("getsem", "F4Server");
+    }
+    
+    resetServerSem(semid);
+    //
+
 
 
     semOp(semid, 0, 2); // aperurta semaforo per connessione dei due client