Loading source/adios2/toolkit/sst/cp/cp_writer.c +5 −6 Original line number Diff line number Diff line Loading @@ -562,10 +562,9 @@ 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); "timesteps from %ld to %ld\n", MyStartingTimestep, GlobalStartingTimestep - 1); CP_WSR_Stream->LastSentTimestep); SubRefRangeTimestep(Stream, MyStartingTimestep, GlobalStartingTimestep - 1); } Loading Loading @@ -818,7 +817,7 @@ static void CP_PeerFailCloseWSReader(WS_ReaderInfo CP_WSR_Stream, PTHREAD_MUTEX_LOCK(&ParentStream->DataLock); if ((NewState == PeerClosed) || (NewState == Closed)) { CP_verbose(Stream, CP_verbose(ParentStream, "In PeerFailCloseWSReader, releasing timesteps from %ld to " "%ld\n" CP_WSR_Stream->OldestUnreleasedTimestep, CP_WSR_Stream->LastSentTimestep); Loading Loading
source/adios2/toolkit/sst/cp/cp_writer.c +5 −6 Original line number Diff line number Diff line Loading @@ -562,10 +562,9 @@ 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); "timesteps from %ld to %ld\n", MyStartingTimestep, GlobalStartingTimestep - 1); CP_WSR_Stream->LastSentTimestep); SubRefRangeTimestep(Stream, MyStartingTimestep, GlobalStartingTimestep - 1); } Loading Loading @@ -818,7 +817,7 @@ static void CP_PeerFailCloseWSReader(WS_ReaderInfo CP_WSR_Stream, PTHREAD_MUTEX_LOCK(&ParentStream->DataLock); if ((NewState == PeerClosed) || (NewState == Closed)) { CP_verbose(Stream, CP_verbose(ParentStream, "In PeerFailCloseWSReader, releasing timesteps from %ld to " "%ld\n" CP_WSR_Stream->OldestUnreleasedTimestep, CP_WSR_Stream->LastSentTimestep); Loading