Commit 831b87aa authored by Eisenhauer, Greg's avatar Eisenhauer, Greg
Browse files

Protect against repeated calls

parent bbc9a7d7

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

+13 −2
Original line number Diff line number Diff line
@@ -561,6 +561,11 @@ WS_ReaderInfo WriterParticipateInReaderOpen(SstStream Stream) 
     */

    if (MyStartingTimestep != GlobalStartingTimestep)

    {

        CP_verbose(Stream, "In writer participate in reader open, releasing "

                           "timesteps from %ld to %ld\n" MyStartingTimestep,

                   GlobalStartingTimestep - 1);



                   CP_WSR_Stream->LastSentTimestep);

                   SubRefRangeTimestep(Stream, MyStartingTimestep,

                                       GlobalStartingTimestep - 1);

    }
@@ -813,9 +818,15 @@ static void CP_PeerFailCloseWSReader(WS_ReaderInfo CP_WSR_Stream, 
    PTHREAD_MUTEX_LOCK(&ParentStream->DataLock);

    if ((NewState == PeerClosed) || (NewState == Closed))

    {

        CP_verbose(Stream,

                   "In PeerFailCloseWSReader, releasing timesteps from %ld to "

                   "%ld\n" CP_WSR_Stream->OldestUnreleasedTimestep,

                   CP_WSR_Stream->LastSentTimestep);

        SubRefRangeTimestep(CP_WSR_Stream->ParentStream,

                            CP_WSR_Stream->OldestUnreleasedTimestep,

                            CP_WSR_Stream->LastSentTimestep);

        CP_WSR_Stream->OldestUnreleasedTimestep =

            CP_WSR_Stream->LastSentTimestep++;

    }

    if (NewState == PeerFailed)

    {