通过消息队列发送void*对象[linux]

Question

因此，我实现了自己的mpi库（简化版本），我需要在进程之间发送/接收一些数据。MPI_Send看起来像这样（void *buf，整数计数，数据类型数据等）。所以这意味着我需要发送数据类型（char，double或int）的计数元素，指向buf的地址。我需要通过消息队列（mq）发送它们。MPI_Recv采用大致相同的参数。目前，这是我在发送和Recv中所做的：

    //Sender part of code
    ret=mq_send(mq,buf,sizeof(buf),0);
        if(ret < 0)
    return MPI_ERR_IO;
    //Receiver part of code
    ret = mq_receive(mq, buf, MSGSIZE, NULL );
    if(ret < 0)
    return MPI_ERR_IO;

现在我只接收数组的第一个元素。我该如何发送整个邮件？这是我想要的

    //Sender part of pseudocode
    for(i=0,count)
       element=(cast to datatype)buf[i]; 
       mq_send(mq,element,sizeof,0);
    //Receiver part of pseudocode
    //i receive the count number of elements prior to this message
    for(i=0,count)
       mq_receive(mq,local_variable,etc...)
       somehow store them into my void *buf which i receive as an argument ??

如果不够清楚，我会回复

Answer 1

您可以用mq_send的第三个参数指定放入队列的数据量。你的情况是:

ret=mq_send(mq,buf,sizeof(buf),0);

假设buf在某个地方按照如下方式初始化

float f[2];
void *buf = f;

那么表达式sizeof（buf）的意思是：称为“buf”的指针的大小。虽然它可能适用于某些架构，但正确的方法是

ret=mq_send(mq,buf,sizeof(float) * <number of elements>, 0);

也就是说，浮点的大小乘以数组中存储的浮点数。

在这种情况下，您可以将整个数组放入队列中。您还可以避免迭代，只使用恒定数量的消息，而不是线性数字。