Commit 8e5a2279 authored by Eisenhauer, Greg's avatar Eisenhauer, Greg
Browse files

Handle connection failure after init before confirmation

parent 0839f708

source/adios2/toolkit/sst/cp/cp_reader.c

+13 −7
Original line number Diff line number Diff line
@@ -287,7 +287,8 @@ SstStream SstReaderOpen(const char *Name, SstParams Params, MPI_Comm comm) 
            CP_verbose(Stream,

                       "finished wait writer response message in read_open\n");



            assert(response);

            if (response)

            {

                WriterData.WriterCohortSize = response->WriterCohortSize;

                WriterData.WriterConfigParams = response->WriterConfigParams;

                WriterData.StartingStepNumber = response->NextStepNumber;
@@ -296,6 +297,11 @@ SstStream SstReaderOpen(const char *Name, SstParams Params, MPI_Comm comm) 
                rank0_to_rank0_conn = conn;

            }

            else

            {

                WriterData.WriterCohortSize = -1;

            }

        }

        else

        {

            /* there was no contact with the writer at that location, notify the

             * other ranks */