0

Amaeyは私が問題を解決するのを手伝ってくれました。

プロジェクトをPVMからMPIに移行する作業をしているので、プロセスを生成するためのMPI_Comm_spawn関数について学習しようとしていました。ここで良いサンプルプログラムを見つけました。そこで、親プロセスが2つの子プロセスにメッセージを送信し、子プロセスがメッセージを出力するように少し変更することにしました。ランク0の子プロセスはメッセージを正しく受信せず、メッセージの一部を受信するだけですが、ランク1の子プロセスはメッセージを受信して​​正常に出力します。誰かがこれが起こっている理由、私が間違っていること、またはこれを修正する方法を説明できますか？助けてくれる人たちに感謝します！

#include "mpi.h"
#include <stdio.h>
#include <stdlib.h>
#include <iostream>

#define NUM_SPAWNS 2
// Based on the example from: http://mpi.deino.net/mpi_functions/MPI_Comm_spawn.html
int main( int argc, char *argv[] )
{
    int my_rank;
    int size;
    int np = NUM_SPAWNS;
    int errcodes[NUM_SPAWNS];
    MPI_Comm parentcomm, intercomm;
    char greeting[100];
    char greeting2[100];
    char greeting3[100];
    MPI_Init( &argc, &argv );
    MPI_Status stat;
    MPI_Comm_get_parent( &parentcomm );
    if (parentcomm == MPI_COMM_NULL)
    {
        /* Create 2 more processes - this example must be called spawn_example.exe for this to work. */
        MPI_Comm_spawn( "spawn_example", MPI_ARGV_NULL, np, MPI_INFO_NULL, 0, MPI_COMM_WORLD, &intercomm, errcodes );
        MPI_Comm_rank(MPI_COMM_WORLD, &my_rank);
        MPI_Comm_size(MPI_COMM_WORLD, &size);
        // Called this Jreeting because process 0 in the new MPI_COMM_WORLD was only receiving a part of this string.
        sprintf(greeting2, "Jreeting from master1 %d of %d\n", my_rank, size);
        sprintf(greeting3, "Greeting from master2 %d of %d\n", my_rank, size);
        for(int i = 0; i<np;i++)
        {
            if(i == 0)
            {
                MPI_Send(greeting2, strlen(greeting)+1, MPI_BYTE, i,1,intercomm);
            }
            if(i == 1)
            {
                MPI_Send(greeting3, strlen(greeting)+1, MPI_BYTE, i,1,intercomm);
            }
            MPI_Recv(greeting, sizeof(greeting), MPI_BYTE, i, 1, intercomm, &stat);
            fputs (greeting, stdout);
        }
    }
    else
    {
        MPI_Comm_rank(MPI_COMM_WORLD, &my_rank);
        MPI_Comm_size(MPI_COMM_WORLD, &size);
        if(my_rank == 0)
        {
            MPI_Recv(greeting2, sizeof(greeting2), MPI_BYTE, 0, 1, parentcomm, &stat);
            std::cout << greeting2 << "\n";
        }
        if(my_rank == 1)
        {
            MPI_Recv(greeting3, sizeof(greeting3), MPI_BYTE, 0, 1, parentcomm, &stat);
            std::cout << greeting3 << "\n";
        }
        sprintf(greeting, "Hello world: processor %d of %d\n", my_rank, size);
        MPI_Send(greeting, strlen(greeting)+1, MPI_BYTE, 0,1,parentcomm);
    }
    fflush(stdout);
    MPI_Finalize();
    return 0;
}

コンパイルすると警告が表示されます...：

hrognkelsi:MPI_TUTORIAL gumundureinarsson$ mpic++ spawn_example.cc -o spawn_example
spawn_example.cc: In function ‘int main(int, char**)’:
spawn_example.cc:24: warning: deprecated conversion from string constant to ‘char*’

私が走るとき：

hrognkelsi:MPI_TUTORIAL gumundureinarsson$ mpirun spawn_example
Jre
Hello world: processor 0 of 2
Greeting from master2 0 of 1
Hello world: processor 1 of 2

ご覧のとおり、子プロセスは、想定どおりmaster1 0 of 1からJreetingではなく、Jreのみを出力します。どうしたの？なぜ他の子プロセスで機能するのですか？

4

1 に答える 1

2

次の行を見てください。 MPI_Send(greeting2, strlen(greeting)+1, MPI_BYTE, i,1,intercomm);

したがって、私が見落としていない限り、何かが「strlen（greeting）」ではなく、単に0です。1つの要素よりも多くのものを送信バッファに入れていることは間違いありません。そこに「strlen（greeting2）」を入れたいと思います。

私が起こっていると思うのは、親プロセスが切り捨てられた文字列を送信し、プロセス0から応答を取得することです。したがって、2番目のMPI_Sendでは'sizeof（greeting）'はゼロ以外であるため、メッセージ全体を送信できます。

于 2012-06-05T15:31:37.540 に答える