summaryrefslogtreecommitdiffstats
path: root/common/queryrunner.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/queryrunner.cpp')
-rw-r--r--common/queryrunner.cpp8
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