MPI消息的接收计数是否始终与发送计数匹配？
MPI消息的接收计数是否始终与发送计数匹配取决于具体的MPI通信函数和通信模式。在大多数情况下，接收计数与发送计数应该是匹配的，即接收到的消息数量应该与发送的消息数量一致。
然而，MPI提供了不同的通信模式，其中一些允许非精确匹配。具体而言，MPI的非阻塞通信函数（如MPI_Isend和MPI_Irecv）可以在消息未完成之前返回，并允许程序继续执行其他任务。因此，在使用这些函数时，接收计数和发送计数可能不匹配。为了确保匹配，需要使用MPI_Wait或MPI_Test等函数来等待或测试非阻塞通信的完成状态。
另外，MPI还提供了一些特殊的通信操作，如广播（MPI_Bcast）和归约（MPI_Reduce），这些操作不需要显式的发送和接收计数。在这种情况下，发送计数和接收计数并不显式存在。
总之，MPI消息的接收计数是否与发送计数匹配取决于具体的通信函数和通信模式，以及在编程时是否正确地管理消息的发送和接收。
相关·内容
假设我有一个服务器，它处理由不同类型的MPI标记标识的几种请求。
while(!stop)
{
MPI_Iprobe(MPI_ANY_SOURCE,MPI_ANY_TAG,MPI_COMM_WORLD,&ready,&status);
if(ready)
{
src = status.MPI_SOURCE;
switch(status.MPI_TAG)
{
case MPI_REQ_A:
MPI_Irecv(...);
浏览 1提问于2014-08-02得票数 2
回答已采纳
一个看似愚蠢的问题，但我似乎找不到一个明确的答案。
基本的问题是，对于一个MPI::Isend，我是否需要有一个对应的MPI::Irecv？
也就是说，即使消息发送是非阻塞的，只要我在重用发送缓冲区之前等待发送完成，我是否需要使用非阻塞接收和等待来接收发送缓冲区？
我的观点是，我希望在发送消息时使用非阻塞发送来“做其他事情”，但接收方进程将立即使用缓冲区，因此我希望它们阻塞，直到真正接收到缓冲区。
看起来我应该能够用MPI::Recv接收消息，即使它们是用MPI::Isend发送的，但是我想知道我是不是遗漏了什么？
一段简单的伪代码
if( rank == 0 ){
int r;
浏览 2提问于2012-05-19得票数 8
回答已采纳
1回答
可以将源代码列表传递给MPI_Recv (或等效的)调用吗？目前，我的代码看起来像这样：
do i=nod1,nod2
call mpi_recv(tmp,n,MPI_REAL,MPI_ANY_SOURCE,tag,MPI_COMM_WORLD,status,ierr)
... do stuff with tmp here
call mpi_send(tmp,n,MPI_REAL,status(MPI_SOURCE),tag,MPI_COMM_WORLD,ierr)
enddo
当然，这并不能保证它能做我想要的事情。(如果在nod2可以发送一条消息之前，nod1在这里发
浏览 0提问于2012-04-17得票数 1
回答已采纳
根据文档，MPI_Ssend和MPI_Issend是一个阻塞和非阻塞的发送操作，两者都是同步的。MPI规范指出，当接收方开始接收消息时，同步发送完成，然后更新发送缓冲区是安全的：
函数MPI_WAIT和MPI_TEST用于完成非阻塞通信。发送操作的完成表明，发送方现在可以自由地更新发送缓冲区中的位置(发送操作本身保持发送缓冲区的内容不变)。它并不表示消息已被接收，而是可能已被通信子系统缓冲。但是，如果使用同步模式send，则send操作的完成表明已启动匹配的接收，并且消息最终将通过此匹配的接收来接收。
考虑到同步发送在刚开始接收时被认为已经完成，我不确定以下几点：
当MPI_Ssend或MP
浏览 3提问于2020-08-02得票数 1
回答已采纳
1回答
我必须编写一个MPI库，其中每个进程都在执行一些独立的任务，但是应该对一些消息做出反应，这些消息可以从其他进程不可预知地发送出去。这些消息的发送和接收都是库的一部分，我不能假设库函数将经常被调用，以跟踪立即发送的进度或检查接收队列。如果接收进程正在进行某种计算，则发送进程可能会被阻塞一些不可预测的时间。
我目前感兴趣的解决方案是让每个MPI进程在自己的CPU上固定一个线程线程，使用循环中的阻塞接收来接收这些消息。正如我担心的那样，我的实验表明，这个线程占用CPU时间的一半(我希望阻塞接收将以某种方式与内核一起工作以避免这种情况)。
我测量这种行为的方法是在进程的一个线程中有一个假的计算函数，在
浏览 0提问于2018-03-09得票数 4
我试图确定发送操作和接收操作的哪些参数必须与要传递的消息匹配。
我理解接收操作必须匹配(或包含)消息的来源、标签和通信器。但是，数据类型是否需要匹配呢？
我能和0级的人匹配吗？
MPI_Send (send_buffer, 1, MPI_INT, 1, 0, MPI_COMM_WORLD);
第1级的接收操作：
MPI_Recv (recv_buffer, 4, MPI_BYTE, 0, 0, MPI_COMM_WORLD, status);
特别是当发送‘计数’小于接收计数时，我知道这对于MPI是有效的。
谢谢。
浏览 2提问于2013-08-25得票数 3
回答已采纳
1回答
我在一个与MPI开发有关的项目中遇到了问题。我正在使用MPI实现一个RNA解析算法，在该算法中，我使用一个主节点，根据一些解析规则和解析表(包含不同的状态和相关操作)开始对输入字符串进行解析。在解析表中，每个状态有多个操作，可以并行执行。所以，我必须在不同的过程中分配这些动作。为此，我将当前状态和解析信息(当前的解析堆栈)发送到使用单独线程从其他节点接收操作的节点，而主线程则忙于基于接收到的操作进行解析。以下是发送方和接收方的代码片段：
发件人代码：
StackFlush(&snd_stack);
StackPush(&snd_stack, state_index);
Stac
浏览 1提问于2011-12-19得票数 3
据我所知，MPI_Bsend将在MPI库管理的本地缓冲区中保存发送方的缓冲区，因此将发送方的缓冲区用于其他目的是安全的。我不明白的是MPI_Ssend如何保证这一点？
以同步方式发送。
无论是否发布了匹配的接收，都可以启动使用同步模式的发送。但是，只有在发送匹配的接收，并且接收操作已开始接收同步发送发送的消息时，发送才能成功完成。因此，同步发送的完成不仅意味着发送缓冲区可以重用，而且还表示接收方在执行过程中已经到达了某个点，即它已经开始执行匹配的接收。
如上所述，如果匹配的接收已经发布，并且已经开始接收同步发送发送的消息，MPI_Ssend将返回(即允许进一步的程序执行)。考虑以下情况：
我
浏览 0提问于2020-03-27得票数 0
这个问题是关于用于接收操作的输入参数count的解释。
在MPI手册的中，它说(see here矿藏)：
int MPI_Recv(void *buf, int count, MPI_Datatype datatype, int source, int tag,
MPI_Comm comm, MPI_Status *status)
Output Parameters
count
maximum number of elements in receive buffer (integer) <-------- see here
在中，它说
int MP
浏览 2提问于2021-11-09得票数 0
2回答
我正在进行一个使用MPI例程和多线程来发送和接收消息的项目。我希望每个接收线程都集中在不同的传入消息上，而不是让两个或两个以上的线程尝试接收相同的消息。有办法做到这一点吗？
我不知道这是否有帮助，但我目前正在使用I探针()检查传入消息，使用Irecv()和Test()检查线程是否收到了整个消息。
浏览 3提问于2015-08-21得票数 0
回答已采纳
2回答
是否可以为MPI_Recv函数指定一组标记？
我的场景：
我正在使用一个具有多个线程同时执行MPI_Recv函数的应用程序。我打算使用mpi标记来控制哪个线程将接收消息。但是我也需要控制消息是data_message还是stop_message。
那么，是否可以为MPI_Recv定义一组标记呢？在语义上，应该是“接收带有标记0或1的消息”，或者“接收带有标记10或11的消息”等。
使用这种方法可以使用标记thread_id*2作为data_message，使用thread_id*2+1作为stop_message。
浏览 1提问于2016-05-06得票数 2
回答已采纳
我正在对多个进程进行大量的MPI_Isend调用，以分发一些数据。在每次调用时，我都将结果MPI_Request存储在一个数组中。在所有MPI_Isend调用完成后，我对请求执行MPI_Waitall。
消息的顺序很重要，即我希望每个进程接收消息的顺序与发送消息的顺序相同。这是因为对于我发送的每一段数据，我还使用单独的MPI_Isend调用分发了一些元数据。我认为这是一个坏主意，但我不知道有什么替代方案。显然，元数据必须在数据之前到达，所以我需要FIFO保证。这就是我正在做的事情吗？
我不关心不同的进程以不同的顺序接收数据，我只关心各个进程以正确的顺序获取数据。这有记录在案吗？我使用的是MPI
浏览 4提问于2014-01-04得票数 0
2回答
MPI超过缓冲器
、、、、
假设我有两个处理器：
第一个P0
调用MPI_Send将消息A发送给p1；
呼叫MPI_Recv从p1接收B；
第二个P1
调用MPI_Send将消息B发送给p0；
呼叫MPI_Recv从p0接收A；
如果消息A和B的大小都超过了系统缓冲区，会发生什么情况？
浏览 5提问于2017-05-26得票数 0
1回答
MPI反向探针
、、、
有没有办法检查一些进程是否在等待MPI_Recv？
我有一个根进程和一些从进程。
从伪码：
while (1) {
do_some_stuff; // calls MPI_Test and clear unused buffers
MPI_Recv(buf, ...);
do_something_with_buf;
MPI_Isend(buf2, ...); // possibly many sends depending on what was in buf
}
如果所有从进程都挂起在MPI_Recv上，那么作业就完成了，我需要停止这个循环。现在，我需要一些方
浏览 4提问于2015-06-14得票数 1
我有一个嵌套的循环，从循环中调用MPI发送，我希望它向接收方发送一个特定的值，然后在接收端接收数据，然后再将MPI消息发送到另一组CPU.我用过这样的东西，但看上去有个问题.我看不出我哪里出了问题.“机器在某个地方有无限的循环.
我试图让它像这样工作:主CPU >>发送到其他CPU，>>发送给从CPU。
.
.
.
int currentCombinationsCount;
int mp;
if (rank == 0)
{
for (int pr = 0; pr < combinationsSegmentSize; pr+
浏览 4提问于2013-01-23得票数 1
2回答
是否有允许使用MPI发送/接收可变大小消息的库调用？
一种变通办法是在第一条消息中发送数据大小，并在其后面加上实际有效负载，但我想知道是否有将这两个单独的消息组合在一起的约定。
浏览 1提问于2010-11-25得票数 3
回答已采纳
我想确定MPI中非阻塞点对点通信的开销。有一些基准测试可用(如或)，但出于某些原因，它们不区分MPI提供的发送模式(标准、就绪、缓冲、同步)和仅使用标准模式。MPI报告指出：
在这种模式下，要由MPI来决定是否要缓冲传出消息。MPI可以缓冲传出消息。在这种情况下，发送呼叫可以在调用匹配的接收之前完成。另一方面，由于性能原因，缓冲区空间可能不可用，或者MPI可能选择不缓冲传出消息。在这种情况下，发送呼叫将无法完成，直到一个匹配的接收已经张贴，并且数据已经移动到接收器。
我假设将消息写入缓冲区可能与直接将消息发送到接收方(可能在物理上很远，通过低带宽连接等)具有不同的性能。因此，我的问题是
浏览 0提问于2017-05-21得票数 0
回答已采纳
1回答
我知道如果双方都是非阻塞发送和接收，那么MPI_Wait或MPI_Test是必需的。但是我想知道如果我们混合了非阻塞发送和阻塞接收，考虑到阻塞接收可以确保通信的完成，我还需要调用MPI_Wait吗？
浏览 0提问于2018-05-26得票数 4
回答已采纳
1回答
我有许多进程(大约在100到1000之间)，每个进程都必须将一些数据发送给其他进程中的一些进程(例如大约10个)。(通常情况下，但并非总是必要的，如果A发送到B，B也发送给A)每个进程都知道要从哪个进程接收多少数据。
因此，我只需使用MPI_Alltoallv，其中许多或大部分消息长度为零。但是，我听说，由于MPI_send性能的原因，使用多个和通信而不是使用<code>E 216</code>全局MPI_Alltoallv.是更好的。我不明白的是:如果一系列的发送和接收呼叫比一个Alltoallv调用更有效，那么为什么是Alltoallv而不是--只将实现为--发送和
浏览 4提问于2012-11-22得票数 5
回答已采纳
1回答
我想知道是否有可能从一个发送者并发接收消息，反过来，将消息并发发送到一个接收者。如果是，它将如何表现？
为了使问题更清晰，假设我们有4个线程，每个线程都在监听来自相同来源的消息
MPI_Recv(buf, count, type, THE_SAME_SOURCE, tag, status)
所有这些线程都在相同的MPI进程中，因此它们都具有相同的MPI等级。而来自其他MPI进程或相同但来自不同线程的人，则称为MPI_Send。是每个接收者都收到相同的消息，还是只有一个接收者，或者抛出了一些异常(发生了错误)？
反过来，如果4个线程(在相同的MPI进程内或不在同一MPI进程内)将消息发送到也可能
浏览 0提问于2011-09-08得票数 2
回答已采纳
如果我使用MPI_Send或MPI_Isend发送，并且接收过程要么没有接收死亡，要么太忙而无法回复，该怎么办？
我怎么知道我应该停止发送到进程，因为它没有接收/死亡或繁忙。
我试过1：
MPI_Send (&destNode, strlen(destNode)+1, MPI_CHAR, nameServer, TAG_NAME_RESOLUTION, MPI_COMM_WORLD, &req);
但是，当nameServer没有接收模式时，发送是阻塞的。
我使用MPI_Isend尝试了2，并测试了是否发送了msg：
//Ask nameServer (process
浏览 2提问于2018-10-30得票数 0
回答已采纳
我有一段MPI代码，它看起来如下所示：
for(i=0;i<NTask;i++)
{
got_initial_bit_of_data[i]=0;
if(need_to_communicate with i)
MPI_ISend(&bit_of_pre_data_for_i,1,MPI_INT,partner,0,MPI_COMM_WORLD,&pre_requests[i]);
}
while(1)
{
MPI_Testsome(NTask,pre_requests,&ndone,idxs,MPI_STATUSES_IGNORE)
if(
浏览 1提问于2013-09-25得票数 1
回答已采纳
1回答
我有关于MPI发送和接收操作的问题。
假设我们有两个MPI线程，它们试图相互发送消息。下面是三个代码片段：
第一(阻塞‘发送’和‘接收’)：
...
int data = ...;
...
MPI_Send( &data, sizeof( int ), MPI_INT,
(my_id == 0)?1:0, 0, MPI_COMM_WORLD );
MPI_Status status;
MPI_Recv( &data, sizeof( int ), MPI_INT,
(my_id == 0)?1:0, 0, MPI_COMM_WORLD, &
浏览 1提问于2012-02-23得票数 4
我使用以下命令从一个等级为0的进程发送一条消息：
MPI_Send(sendmsg, strlen(sendmsg) + 1, MPI_CHAR, 1, 99, MPI_COMM_WORLD);
这是一条针对等级为1的进程的消息。
现在，在我的代码中，如果排名是1，程序什么也不做。它只是调用MPI_Finalize()并返回。因此，如果rank为1，则不会进行MPI_Recv()调用。
我读到过MPI_Send是一个阻塞发送，我认为这意味着在使用MPI_Recv的其他进程接收到缓冲区的内容之前，控制不会返回给程序。
然而，程序并没有像我预期的那样被卡住(永远等待)，而是以下面的错误消息终止：
浏览 25提问于2021-02-02得票数 0
MPI中描述发送和接收的许多例程-- MPI_Sendrecv、MPI_Scatter等--都有用于发送和接收的计数和类型的参数。例如，在Fortran中，MPI_Scatter的签名是：
MPI_SCATTER(SENDBUF, SENDCOUNT, SENDTYPE,
RECVBUF, RECVCOUNT, RECVTYPE, ROOT, COMM, IERROR)
如果发送的数据量必须与接收的数据量相同，为什么两者都需要？这不是只是带来了不一致的可能性吗？
需要不同计数/类型的用例是什么？
浏览 6提问于2015-05-11得票数 5
回答已采纳
1回答
基于标准的MPI非阻塞细节问题
、、、、
所以最近，我在我的研究中开发了一些异步算法。我做了一些并行的性能研究，我一直怀疑我没有正确地理解有关各种非阻塞MPI功能的一些细节。
我在这里看到了一些有洞察力的文章，即：
有几件事我不确定，或者只是想澄清一下与非阻塞功能有关的工作，我认为这些功能可能会帮助我提高我当前软件的性能。
来自MPI 3.0标准的非阻塞通信部分：
非阻塞发送开始调用启动发送操作，但未完成该操作。发送开始调用可以在消息从发送缓冲区复制之前返回。需要单独的发送完全调用来完成通信，即验证数据已从发送缓冲区复制。通过适当的硬件，数据从发送者内存中的传输可以与发送启动后在发送完成之前在发送方进行的计算同时
浏览 0提问于2019-06-30得票数 2
回答已采纳
是否可能MPI_Recv接收到标签不匹配的消息？
我的逻辑是: MPI_Isend / MPI_Recv通信。
节点1发送一条标记为0的消息，然后发送另一条标记为1的消息。因为节点1中有两个线程，所以发送操作可能会同时发生。
Node 2将探测是否有来自Node 1的报文，如果有，则接收报文。
在我的设计中，我希望Node 2先接收标记为0的消息，然后再接收标记为1的消息。但是，当Node 2探测到消息来自Node 1的信号时，它收到的消息长度与tag 1消息的长度相同。则不再有来自节点1的消息。看起来标签0消息丢失了。
我很困惑，期待一些答案。
浏览 0提问于2012-11-08得票数 0
在启动MPI_Send之前，是否有一种方法可以检查非阻塞接收是否已发布(对于给定的源和标记)？我有一种情况，发送者和接收者都不知道他们想从谁那里发送/接收。我的想法是首先在所有选择的接收器上发布一个开放的Irecv。然后发送者将检查某一等级是否已发出一个接收，并且只有在正确的情况下才发送(否则继续)。在发送成功之后，接收方将取消未发送的Irecv。
这目前适用于集体(在MPI_COMM_WORLD上)数组广播；我想知道是否有不同的方式
我想我可以用MPI_Isend和MPI_Probe进行反向操作。不过，在这种情况下，我担心未接收的发送缓冲区会发生什么(并且听说MPI_Cancel对发
浏览 1提问于2016-08-23得票数 1
回答已采纳
3回答
我想要向接收具有特定标签的消息的其中一个队列发送消息。如果接收到任何等级，则该消息和该消息被消费。在MPI_Recv()中，我们可以使用MPI_SOURCE/MPI_TAG接收消息，但是MPI_Send()不能这样做。如何发送目标未知的消息？MPI_Bcast()不能这样做，因为在接收之后，我必须回复源进程。谢谢。
浏览 2提问于2012-03-15得票数 6
回答已采纳
当通过MPI接口发送/接收数据时，我遇到了使用std：：sent的.size()方法的麻烦。我创建了一个名为point的自定义类型
template<typename T>
struct point{
T data[ndim];
point() = default;
point(const T& a, const T& b): data{a,b} {} // not correct
point(const T&& a, const T&&b): data{std::mov
浏览 2提问于2022-02-14得票数 0
回答已采纳
2回答
当我在MPI中阅读有关阻止发送和接收的文章时，我感到很困惑。如MPI标准2.2所述，第3.4节通信模式：
...最后一节中描述的接收操作是阻塞的:只有在接收缓冲区包含新接收的消息后才返回。接收可以在匹配发送完成之前完成(当然，只有在匹配发送启动后才能完成)。
有人能向我解释一下如何在相应的发送完成之前完成阻塞接收吗？我的理解是，当数据准备好在接收缓冲区中使用时(即数据已经完全接收)，阻塞接收(MPI_recv)返回。不是这样的吗？
浏览 6提问于2012-02-03得票数 2
回答已采纳
对于大于0的procs，我在NT上执行此循环(数百万次迭代)。对于每次迭代，120字节的消息被发送到proc 0，proc 0接收它们(对于proc 0，我在NT上有相同的循环)。
我希望proc 0接收它们的顺序，这样我就可以将它们存储在数组nhdr1中。
问题是proc 0不能正确接收消息，并且我在数组nhdr中的值通常为0。
如何修改代码，使消息的接收顺序与发送顺序相同？
[...]
if (rank == 0) {
nhdr = malloc((unsigned long)15*sizeof(*nhdr));
nhdr1 = malloc((
浏览 1提问于2014-01-29得票数 0
在空间分解的2D域中，我需要将粒子发送到8个邻居。我知道我发送了多少，但不知道我会从这些邻居那里收到多少。我用MPI_Send()、MPI_Probe()和MPI_Recv()实现了一段代码，但我意识到当消息太大时会导致死锁。
我决定使用非阻塞通信，但是我不知道应该以什么顺序调用MPI_Isend、MPI_Irecv和MPI_Iprobe？在实际调用MPI_Irecv之前，我肯定需要知道应该为接收缓冲区分配的大小，所以我被MPI_Isend()、MPI_Iprobe()和MPI_Irecv()的顺序所吸引，但问题是MPI_Iprove()总是返回一个等于false的标志，并且我陷入了while
浏览 2提问于2014-02-11得票数 0
2回答
我的MPI_Isend和MPI_Irecv代码块遇到了问题。我需要向下一个进程发送一个数字Cin，然后当前进程就可以继续它的事务了。
接收进程需要接收，然后才能进一步计算，但当我没有MPI_Wait时，它永远不会获得数据，而当我这样做时，它就会永远挂起。我做错了什么？
注意:我只是将Cin设置为3，以便查看消息何时无法通过。目前它只是挂起了。
void ComputeS5C()
{
MPI_Request send_request, recv_request;
MPI_Status status;
int Cin[1] = {3};
if(my_rank ==
浏览 33提问于2017-02-24得票数 1
回答已采纳
2回答
我有一个网络，其中进程向其邻居发送随机消息，同时从其邻居接收消息。我可以使用套接字和线程来做这件事。一个线程接收消息，另一个线程向随机选择的邻居发送消息。是否可以使用MPI_SEND和MPI_RECV来实现这一点？
浏览 0提问于2013-02-13得票数 1
我知道对MPI_Irecv的调用需要与MPI_Wait (或MPI_Test等)配对。完成。然而，在MPI_Ssend下面的代码似乎正在迫使Irecv完成。
#include <iostream>
#include "mpi.h"
int main(int argc, char **argv) {
MPI_Init(&argc, &argv);
int rank = 0;
int size = 0;
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_CO
浏览 3提问于2022-08-16得票数 0
1回答
MPI标准是否实现了请求-应答通信模式？
读到MPI，我发现有一些点对点的例程，如：
同步发送
阻塞发送/阻塞接收
非阻塞发送/非阻塞接收
缓冲发送
联合发送/接收
“准备”发送
也许开发人员可以使用这些例程实现请求应答通信模式，但是MPI似乎没有直接实现它。
编辑：为了澄清目的，requestor ( response )是一种消息交换模式，在这种模式中，请求者向接收和处理请求的应答系统发送请求消息，最终返回响应消息。这是一种简单但功能强大的消息传递模式，它允许两个应用程序通过一个通道进行双向对话。这种模式在客户机-服务器体系结构中特别常见。它可以是同步的，也
浏览 6提问于2017-11-30得票数 0
回答已采纳
我发现MPI_Probe用于查找消息大小，MPI_Get_count用于查找消息长度。消息长度和消息大小有什么区别？它们不都是一样的吗？此外，MPI_Send或MPI_Recv中的count参数表示什么？这是否意味着从进程x向进程y发送/接收相同消息的次数？
浏览 1提问于2012-08-24得票数 0
回答已采纳
1回答
开放中的同步通信
、、、
在阻塞和非阻塞操作(在OpenMPI中)的上下文中，我稍微混淆了同步-异步的概念：
：MPI_Isend是，不一定是异步的(所以它可以同步吗?)
：MPI_Isend()和MPI_Irecv()是MPI的异步通信原语。
我已经看过了以前关于堆栈溢出()的同步异步阻塞-非阻塞问题，但是对我没有任何帮助。据我所知：
立即 (MPI_Isend)：方法返回并执行下一行->非阻塞
Standard/non-immediate (MPI_Send)：对于大型消息，它阻塞直到传输完成
同步操作块()
asynchronous操作是非阻塞的()。
那么，为什么M
浏览 6提问于2014-11-12得票数 8
如果发送数据的大小大于MPI缓冲区大小，MPI_Send()如何将数据通信到接收进程？例如，假设我希望在单个发送消息中发送10个字节的数据(即我的应用程序缓冲区的大小为10B)，但是MPI缓冲区的固定大小为6B。在这种情况下，MPI_Send()如何发送数据？它是否先转移6B，然后再转移剩余的4B？还是只转6B？
浏览 3提问于2015-04-21得票数 2
回答已采纳
1回答
我正在尝试写MPI发送/接收代码，但我有一个问题。我想检查一下接收消息。如果我有来自任何来源的信息，请阅读此文。否则，继续编写代码。
MPI_Comm_size(MPI_COMM_WORLD,&p);
MPI_Comm_rank(MPI_COMM_WORLD,&id);
MPI_Status status;
int source,ask,request,answer,tag=10;
for(i=first; i<last; i++){
if(there is a message for my id){
MPI_Recv(&request,1
浏览 0提问于2015-04-03得票数 4
消息传递接口API总是使用int作为count变量的类型。例如，MPI_Send的原型是：
int MPI_Send(const void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm);
如果要发送或接收的元素数量接近甚至超过 INT_MAX，这可能是一个问题。
当然，可以通过以下两种方法来解决降低count值的问题：
将单个调用拆分为多个调用
定义(不必要的)聚合MPI_Datatype
无论如何，这两种方法都是一种黑客，而不是真正的解决方案，特别是如果用简单的启发式方法实现
浏览 14提问于2014-05-12得票数 4
回答已采纳
1回答
我想知道是否有人可以为我解释一下MPI_Waitall函数。我有一个使用MPI_Isend和MPI_Irecv传递信息的程序。在所有发送和接收完成后，程序中的一个进程(在本例中为进程0)将打印一条消息。我的Isend/Irecv正在工作，但是消息在程序中的某个随机位置打印出来；所以我尝试使用MPI_Waitall在打印消息之前等待所有请求完成。我收到以下错误消息：
Fatal error in PMPI_Waitall: Invalid MPI_Request, error stack:
PMPI_Waitall(311): MPI_Waitall(count=16, req_array=0x
浏览 1提问于2013-03-16得票数 6
回答已采纳
我的问题是发送有关计算状态和程序状态的消息。每一位主持人都有一份工作。如果主机完成了工作，它应该将结果发送给接收者。计算运行时，接收者可能会改变。为了调试目的，每个主机上的状态也应该转移到等级为0的主机上。
从那时起我收到了很多信息。但我不清楚我是如何在主机之间发送信息的。
一种可能是像圆圈一样的消息传输，每个邻居都将消息发送给下一个邻居。
非阻塞通信方式如MPI_Isend和MPI_Irecv可以作为解决方案。但是每个主机都应该是发送者和接收者。
最简单的方法是每个主持人都在哪里广播消息，但这是一个很大的流量。
我需要一个像广播一样的功能，每个主机都可以接收和发送。只有在
浏览 0提问于2013-04-29得票数 0
回答已采纳
1回答
我使用的是MPI_Raccumulate函数，它是通过预定义的聚合函数从源到目的地的单向通信。
我想检查程序结束时是否所有的MPI_Raccumulate呼叫都已经完成(发送者发送数据，接收方成功地接收到数据)。然而，MPI_Wait似乎不是这个问题的解决方案；它只等待检查源缓冲区是否可更新(用户可用)。
是否有任何方法(1)检查特定的MPI单边通信呼叫是否已经完全完成(在发送方和接收方)？(2)确认每个处理器中没有发送/接收MPI请求？
我的应用程序应该使用单向通信，但需要确认在特定任务结束时没有更多的通信。
谢谢
浏览 6提问于2016-01-12得票数 1
回答已采纳
2回答
我有邻接矩阵和以下代码：
if (is_broadcast_message) {
MPI_Send(&broadcast_message,1,MPI_INT,j,3,MPI_COMM_WORLD);
MPI_Send(&message,20,MPI_CHAR,j,3,MPI_COMM_WORLD);
}
Where broadcast_message=128(随机数，用于知道我何时收到，这是一条广播消息)
消息被定义为char20。
else if (i have to send only to a node) {
MPI_Send(&desti
浏览 5提问于2014-01-10得票数 5
1回答
我有这个简单的MPI程序在两个处理器上运行。在我的示例中(或者可能只在我的计算机上)，我的控制台在发送消息之前输出接收消息。
我知道有一种使用MPI对接收进行排序的方法，但我认为我的示例将等待处理器0发送数据，因此接收输出必须以秒为单位。
如何在发送消息后打印接收消息？
这是我的代码：
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mpi.h>
int main(int argc, char *argv[]){
int np, myId;
浏览 0提问于2012-10-16得票数 0
回答已采纳
我不确定在MPI发送、接收呼叫时，标记字段需要使用不同的数字。我读过，但我不明白。
有时，A可能需要向B发送许多不同类型的消息，而不是B必须通过额外的措施来区分所有这些消息，MPI允许发送者和接收者也用消息指定消息ID(称为标记)。当进程B只请求具有特定标记号的消息时，网络将缓冲具有不同标记的消息，直到B为它们做好准备。
例如，当我有来自进程A的多个调用"isend“(带有不同的标记)，而在进程B中只有一个调用"ireceive”时，我必须使用标记吗？
浏览 6提问于2015-07-13得票数 30
回答已采纳
我试图让每个进程都以这种方式向所有其他进程广播
#include "mpi.h"
#include <stdio.h>
int main(argc,argv)
int argc;
char **argv;
{
int MyProc, size,tag=1;
int msg_recpt;
MPI_Status status;
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &MyProc);
MPI_Comm_size(MPI_COMM_WORLD, &a
浏览 0提问于2018-11-18得票数 0
回答已采纳
我试图从一个进程向所有MPI进程发送消息，同时也从进程中的所有进程接收消息。它基本上是所有通信的全部，其中每个进程向每个其他进程发送消息(除自身外)，并接收来自每个其他进程的消息。
下面的示例代码片段显示了我正在尝试实现的目标。现在，MPI_Send的问题在于它的行为，对于小消息大小，它是非阻塞的，但是对于更大的消息(在我的机器BUFFER_SIZE 16400中)，它会阻塞。我知道这就是MPI_Send的行为方式。作为解决办法，我将下面的代码替换为阻塞(send+recv)，即MPI_Sendrecv。示例代码类似于这个MPI_Sendrecv(intSendPack, BUFFER_SIZ
浏览 0提问于2019-05-24得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
