Loading source/adios2/toolkit/sst/cp/cp_writer.c +4 −0 Original line number Diff line number Diff line Loading @@ -1063,6 +1063,10 @@ static void DoWriterSideGlobalOp(SstStream Stream, int *DiscardIncomingTimestep) { SendBlock[1] = 1; /* this rank is over stream limit */ } else { SendBlock[1] = 0; /* No problems here */ } for (int i = 0; i < Stream->ReaderCount; i++) { SendBlock[i + 2] = Stream->Readers[i]->ReaderStatus; Loading testing/adios2/engine/sst/run_multi_test.in +1 −1 Original line number Diff line number Diff line Loading @@ -31,7 +31,7 @@ GetOptions ('verbose!' => \$verbose, 'nr=i' => \$num_readers, 'duration=i' => \$duration, 'interval=i' => \$interval, 'max_readers=i' => \$num_readers, 'max_readers=i' => \$max_readers, 'test_protocol=s' => \$test_protocol) or die("Error in command line arguments\n"); Loading Loading
source/adios2/toolkit/sst/cp/cp_writer.c +4 −0 Original line number Diff line number Diff line Loading @@ -1063,6 +1063,10 @@ static void DoWriterSideGlobalOp(SstStream Stream, int *DiscardIncomingTimestep) { SendBlock[1] = 1; /* this rank is over stream limit */ } else { SendBlock[1] = 0; /* No problems here */ } for (int i = 0; i < Stream->ReaderCount; i++) { SendBlock[i + 2] = Stream->Readers[i]->ReaderStatus; Loading
testing/adios2/engine/sst/run_multi_test.in +1 −1 Original line number Diff line number Diff line Loading @@ -31,7 +31,7 @@ GetOptions ('verbose!' => \$verbose, 'nr=i' => \$num_readers, 'duration=i' => \$duration, 'interval=i' => \$interval, 'max_readers=i' => \$num_readers, 'max_readers=i' => \$max_readers, 'test_protocol=s' => \$test_protocol) or die("Error in command line arguments\n"); Loading