diff options
Diffstat (limited to 'common/queryrunner.cpp')
-rw-r--r-- | common/queryrunner.cpp | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp index a86d8a8..4af9866 100644 --- a/common/queryrunner.cpp +++ b/common/queryrunner.cpp | |||
@@ -215,7 +215,9 @@ ReplayResult QueryWorker<DomainType>::executeIncrementalQuery(const Sink::Query | |||
215 | resultProviderCallback(query, resultProvider, result); | 215 | resultProviderCallback(query, resultProvider, result); |
216 | }); | 216 | }); |
217 | 217 | ||
218 | SinkTraceCtx(mLogCtx) << "Incremental query took: " << Log::TraceTime(time.elapsed()); | 218 | SinkTraceCtx(mLogCtx) << "Replayed " << replayResult.replayedEntities << " results.\n" |
219 | << (replayResult.replayedAll ? "Replayed all available results.\n" : "") | ||
220 | << "Incremental query took: " << Log::TraceTime(time.elapsed()); | ||
219 | return {entityStore.maxRevision(), replayResult.replayedEntities, replayResult.replayedAll}; | 221 | return {entityStore.maxRevision(), replayResult.replayedEntities, replayResult.replayedAll}; |
220 | } | 222 | } |
221 | 223 | ||
@@ -246,7 +248,9 @@ ReplayResult QueryWorker<DomainType>::executeInitialQuery( | |||
246 | resultProviderCallback(query, resultProvider, result); | 248 | resultProviderCallback(query, resultProvider, result); |
247 | }); | 249 | }); |
248 | 250 | ||
249 | SinkTraceCtx(mLogCtx) << "Initial query took: " << Log::TraceTime(time.elapsed()); | 251 | SinkTraceCtx(mLogCtx) << "Replayed " << replayResult.replayedEntities << " results.\n" |
252 | << (replayResult.replayedAll ? "Replayed all available results.\n" : "") | ||
253 | << "Initial query took: " << Log::TraceTime(time.elapsed()); | ||
250 | return {entityStore.maxRevision(), replayResult.replayedEntities, replayResult.replayedAll}; | 254 | return {entityStore.maxRevision(), replayResult.replayedEntities, replayResult.replayedAll}; |
251 | } | 255 | } |
252 | 256 | ||