code di messaggi IPC

[pasqualino10]

Ho voluto provare a scrivere un programma banale, anzi due, per leggere e scrivere rispettivamente da una coda di messaggi ripetutamente.
IL problema è che non riesce a leggere dalla coda di messagi ma solo ad inviare e scrivere messaggi su di essa.
Posto qui i due programmi:
il primo legge dallo standard input e scrive e salva i valori sulla coda di messaggi, il secondo programma in pratica dovrebbe soltanto leggere i valori dalla coda di messaggi e stamparli su stdout.
Provate ad eseguirli e vedete se riuscite a capire il problema.

/*devo realizzare una coda di messaggi IPC
attraverso la quale due programmi si scambiano
ripetutamente messaggi*/
/*Questo è quello che scrive sulla coda di 
messaggi i valori letti da tastiera(stdin)*/
#include<stdio.h>
#include<stdlib.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<errno.h>
struct msgbuf{
  long mtype;
  int value;
};
void send_on_queue(long v, int mq_id)
{
  /*invia la riga letta da linea di comando
   direttamente sulla coda di messaggi in
   modo che possa subito essere letta da qualcun altro*/
  struct msgbuf msg;
  msg.mtype = 1;
  msg.value = v;
  if(msgsnd(mq_id,&msg,sizeof(long),0) == -1){
    perror("in msgsnd");
    exit(EXIT_FAILURE);
  }
}
long read_value()
{
  errno = 0;
  long num;
  char buf[32];
  /*legge un'intera riga da terminale fino al 
   carattere newline tramite la fgets*/
    if(fgets(buf,32,stdin) == NULL){
      perror("in fgets");
      exit(EXIT_FAILURE);
    }
    char *end_ptr;
    num = strtol(buf,&end_ptr,10);
    /*if(errno != 0 || *end_ptr != '\0'){
      perror("in strtol");
      exit(EXIT_FAILURE);
    }
    */
    /*una volta che ho letto il valore posso
     inviarlo sulla coda di messaggi*/
    return num;
}
int open_queue_messages(void)
{
  key_t key;
  int qid;
  /*prima creiamo la chiave*/
  key = ftok(".",'a');
  if(key == -1){
    perror("in ftok");
    exit(EXIT_FAILURE);
  }
  /*ora devo aprire la coda di messaggi e ottenere
   l'identificatore per essa(un intero)*/
  qid = msgget(key,IPC_CREAT | 0666);
  if(qid == -1){
    perror("in msgget");
    exit(EXIT_FAILURE);
  }
  return qid;
}
int main(int argc, char *argv[])
{
  if(argc != 1){
    fprintf(stderr,"Usage only the argument : %s ",argv[0]);
    return EXIT_FAILURE;
  }
  /*ovviamente la coda di messaggi dovrà avere
   la stessa chiave anche nell'altro programma*/
  int q_id;/*identificatore coda di messaggi*/
  q_id = open_queue_messages();
  /*legge continuamente da standard input
   e continuamente scrive i valori sulla
   coda di messaggi(li invia con msgsnd)*/
  long val;
  for(;;){
    val = read_value();
    send_on_queue(val,q_id);
  }
  
return EXIT_SUCCESS;
}

/*quest'altro programma ha il compito di
ricevere messaggi dalla coda di messaggi, i 
quali sono inviati dall'altro programma.*/
#include<stdio.h>
#include<stdlib.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<unistd.h>
struct msgbuf{
  long mtype;
  long value;
};
long read_from_queue(int id)
{
  struct msgbuf msg;
  if(msgrcv(id,&msg,sizeof(long),0,0) != sizeof(long)){
    perror("in msgrcv");
    exit(EXIT_FAILURE);
  }
  
return msg.value; /* ho ricevuto un messaggio */
}
int open_queue_messages(void)
{
  key_t key;
  int qid;
  /*prima creiamo la chiave*/
  key = ftok(".",'a');
  if(key == -1){
    perror("in ftok");
    exit(EXIT_FAILURE);
  }
  /*ora devo aprire la coda di messaggi e ottenere
   l'identificatore per essa(un intero)*/
  qid = msgget(key,IPC_CREAT | 0666);
  if(qid == -1){
    perror("in msgget");
    exit(EXIT_FAILURE);
  }
  return qid;
}
int main(int argc, char *argv[])
{
  if(argc != 1){
    fprintf(stderr,"Usage only argument : %s ",argv[0]);
    return EXIT_FAILURE;
  }
  int q_id;/*identificatore coda di messaggi*/
  q_id = open_queue_messages();
  long value;
  for(;;){
    value = read_from_queue(q_id);
    printf("Ho letto il numero %ld \n",value);

  }
return EXIT_SUCCESS;  
}