Skip to content

Commit

Permalink
guard stats tracing against no iFileIO in output
Browse files Browse the repository at this point in the history
  • Loading branch information
jakesmith committed Jun 13, 2024
1 parent 2f0827d commit 56f2688
Showing 1 changed file with 8 additions and 5 deletions.
13 changes: 8 additions & 5 deletions thorlcr/thorutil/thbuf.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1822,12 +1822,15 @@ class CSharedFullSpillingWriteAhead : public CInterfaceOf<ISharedRowStreamReader
freeRows();
ds.setStream(nullptr);

StringBuffer tracing;
getFileIOStats(tracing, iFileIO);
owner.activity.ActPrintLog("CSharedFullSpillingWriteAhead::COutputRowStream: input stream finished: output=%u%s", whichOutput, tracing.str());
if (inputStream)
{
StringBuffer tracing;
getFileIOStats(tracing, iFileIO);
owner.activity.ActPrintLog("CSharedFullSpillingWriteAhead::COutputRowStream: input stream finished: output=%u%s", whichOutput, tracing.str());

iFileIO.clear();
inputStream.clear();
iFileIO.clear();
inputStream.clear();
}

// NB: this will set lastKnownAvailable to max[(rowcount_t)-1] (within owner.readAheadCS) to prevent it being considered as lowest any longer
owner.outputStopped(whichOutput);
Expand Down

0 comments on commit 56f2688

Please sign in to comment.