mq_send, ERRNO 97. Msg too long.

[Zunri]

Hola,

Tengo una aplicación que pide port eclado un entero y lo encola en una cola que previamente se ha abierto. Al hacer el ms_send me obtengo el error de mensaje demasiado largo y no soy capaz de descubrir el problema ya que a simple vista los tamaños parecen correctos.

Código:

#include <stdio.h> 
#include <mqueue.h>
#include <errno.h>

mqd_t queueDescriptor;
#define QUEUE_NAME "/POENK_SENDER_RECEIVER"
#define QUEUE_SIZE 100 /* bytes */

int message;
#define MSG_SIZE   4 


void openQueueForWritting()
{
     struct mq_attr attributes;
     
	 attributes.mq_flags = 0;  /* Only this can be modified at mq_open */
	 attributes.mq_maxmsg = 10;  
	 attributes.mq_msgsize = MSG_SIZE;  
	 attributes.mq_curmsgs = 0; 
        
     queueDescriptor = mq_open(QUEUE_NAME, O_CREAT |O_WRONLY, 0777, &attributes);
     
     if (queueDescriptor < 0)
     {
           printf("\n[ ERROR opening the queue! ]\nError: %d. %s\n", errno, strerror (errno));   
     }
     else
     {
           printf("\n[ Queue opened successfully! ] Descriptor: %d\n", queueDescriptor);
     }
}

void sendMessage()
{   
	 if (0 != mq_send(queueDescriptor,(char *)message, MSG_SIZE, 0)) /* Last value is the priority */
	 {
         printf("\n      [ERROR sending the message]\n      Error: %d. %s\n", errno, strerror (errno));
     }
     else
     {
         printf("\n      [Message sent to the queue]\n");    
     }
}

int main(void)
{
     printf("#########################################\n");
     printf("#                                       #\n");
     printf("#        SENDER process running ...     #\n");
     printf("#                                       #\n");
     printf("#########################################\n");
     
     openQueueForWritting();
      
     while (1)
     {
          printf("\n# Type the integer to transmit: ");
          scanf("%d", &message); 

          sendMessage();
     }
     
     return 0;    
}

[Malenko]

Iniciado por Zunri

y no soy capaz de descubrir el problema ya que a simple vista los tamaños parecen correctos.

Pues yo, a simple vista, no veo donde están correctos los tamaños ni donde verificas la entrada del teclado. Estás enviando como longitud de la cadena la constante MSG_SIZE en lugar de usar un sizeof de lo que has leído por teclado.

[Zunri]

Fijandote un poco puedes ver que el tamaño de un int son 4 bytes, que es el tamaño de la constante MSG_SIZE, a simple vista.

[eferion]

De acuerdo al estándar, el tipo int puede ocupar 2 bytes o 4 bytes, luego asumir que siempre va a ocupar 4 bytes puede ser perjudicial para tus intereses.

Por otro lado también te digo que dudo mucho que en un pc el compilador genere ints de 2 bytes.

Hasta donde llego viendo documentación por internet, la forma de crear la cola en el cliente (el que envia) debería ser algo tal que:

Código C:

queueDescriptor = mq_open(QUEUE_NAME, O_WRONLY);
 

Lo cual difiere ligeramente de tu código:

Código C:

struct mq_attr attributes;
 
attributes.mq_flags = 0;  /* Only this can be modified at mq_open */ 
attributes.mq_maxmsg = 10;
attributes.mq_msgsize = MSG_SIZE;
attributes.mq_curmsgs = 0;
 
queueDescriptor = mq_open(QUEUE_NAME, O_CREAT |O_WRONLY, 0777, &attributes);
 

No se si los tiros irán por ahí, ya que no tengo un linux a mano y en casa tampoco podré probarlo en una temporadita porque mi placa base murió durante el fin de semana con solo 3 añitos de vida :(

Da la impresión de que puedes estar creando la cola dos veces. Piensa que uno de los extremos es el que crea la cola y el otro extremo simplemente se une a dicha cola.

Un saludo.

[Zunri]

Muchas gracias por la respuesta! Lo probaré mañana