时间戳

首页 > 解决方案 > MPi 多播 BIGNUM

c - MPi 多播 BIGNUM

问题描述

我有以下代码：

int MPIbcastBigNum(BIGNUM *num, int rank, char* purpoce){
    int size = BN_num_bytes(num);
    unsigned char *message = OPENSSL_malloc(size);

    if(!BN_bn2bin(num, message)) {
     fprintf(stderr, "RANK %d: Fail to allocate an array for key bytes \"%s\" \n", rank, purpoce);
     fflush(stderr);
     OPENSSL_free(message);
     return -1;    
    }

    //Do the actual Broadcast && Debug
    printf("RANK %d: Broaccasting bignum for purpoce \"%s\" \n", rank, purpoce);
    fflush(stdout);
    int value = MPI_Bcast(message, size, MPI_BYTE, rank, MPI_COMM_WORLD);
    switch(value) {
        case MPI_ERR_COMM:
         fprintf(stderr, "RANK %d: COMMUNICATIPN ERROR on BIGNUM sending for purpoce \"%s\" \n", rank, purpoce);
         fflush(stderr);
         OPENSSL_free(message);
         return -1;

        case MPI_ERR_COUNT:
         fprintf(stderr, "RANK %d: Invalid Size Count on BIGNUM sending for purpoce \"%s\" \n", rank, purpoce);
         fflush(stderr);
         OPENSSL_free(message);
         return -1;

        case MPI_ERR_TYPE:
         fprintf(stderr, "RANK %d: Invalid Data Type on BIGNUM sending for purpoce \"%s\" \n", rank, purpoce);
         fflush(stderr);
         OPENSSL_free(message);
         return -1;

        case MPI_ERR_BUFFER:
         fprintf(stderr, "RANK %d: Invalid Buffer on BIGNUM sending for purpoce \"%s\" \n", rank, purpoce);
         fflush(stderr);
         OPENSSL_free(message);
         return -1;

        default:
          printf("RANK %d: ALL OK on BIGNUM sending on purpoce \"%s\" \n", rank, purpoce);
          fflush(stdout);
    }

    //Cleanups
    OPENSSL_free(message);
    return 0;
}

我尝试做的是通过 MPI 发送一个 OpenSSL BIGNUM。但我的问题是每个 BIGNUM 的大小可能不同。所以我需要知道通知接收进程我的数据长度。

到目前为止，我的想法是先广播大小MPI_INT，然后将实际数据广播为 n 大小的MPI_BYTE数组。但是，当我尝试同时接收 size 和 BigNum 时，这些如何不会出现故障？

标签： copensslmpibroadcast

解决方案

首先广播大小，然后广播数据是正确的做法。在这种情况下，排序不是问题。集体沟通不能相互超越。即使是点对点消息也能保证消息不会被一对发送者和接收者超越。

推荐阅读