summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/server/PreProcessor.cpp12
1 files changed, 4 insertions, 8 deletions
diff --git a/src/server/PreProcessor.cpp b/src/server/PreProcessor.cpp
index a053e024..1223aad4 100644
--- a/src/server/PreProcessor.cpp
+++ b/src/server/PreProcessor.cpp
@@ -77,14 +77,10 @@ PreProcessor::event(Event* const ev)
unsigned
PreProcessor::process(ProcessContext& context, PostProcessor& dest, size_t limit)
{
- Event* const head = _head.load();
- if (!head) {
- return 0;
- }
-
- size_t n_processed = 0;
- Event* ev = head;
- Event* last = ev;
+ Event* const head = _head.load();
+ size_t n_processed = 0;
+ Event* ev = head;
+ Event* last = ev;
while (ev && ev->is_prepared() && ev->time() < context.end()) {
if (ev->time() < context.start()) {
// Didn't get around to executing in time, oh well...