@@ -326,7 +326,7 @@ bool DataProcessingDevice::tryDispatchComputation()
326326 // PROCESSING:{START,END} is done so that we can trigger on begin / end of processing
327327 // in the GUI.
328328 auto dispatchProcessing = [&processingCount, &allocator, &statefulProcess, &statelessProcess, &monitoringService,
329- &context, &rootContext, &stringContext, &rdfContext, &rawContext, &serviceRegistry, &device](int i , InputRecord& record) {
329+ &context, &rootContext, &stringContext, &rdfContext, &rawContext, &serviceRegistry, &device](TimesliceSlot slot , InputRecord& record) {
330330 if (statefulProcess) {
331331 LOG (DEBUG) << " PROCESSING:START:" << slot.index ;
332332 monitoringService.send ({ processingCount++, " dpl/stateful_process_count" });
@@ -369,14 +369,10 @@ bool DataProcessingDevice::tryDispatchComputation()
369369 // propagates it to the various contextes (i.e. the actual entities which
370370 // create messages) because the messages need to have the timeslice id into
371371 // it.
372- auto prepareAllocatorForCurrentTimeSlice = [&timingInfo, &rootContext, &stringContext, &context, &relayer, ×liceIndex](TimesliceSlot i) {
372+ auto prepareAllocatorForCurrentTimeSlice = [&timingInfo, &rootContext, &stringContext, &rawContext, & context, &relayer, ×liceIndex](TimesliceSlot i) {
373373 auto timeslice = timesliceIndex.getTimesliceForSlot (i);
374374 LOG (DEBUG) << " Timeslice for cacheline is " << timeslice.value ;
375375 timingInfo.timeslice = timeslice.value ;
376- auto prepareAllocatorForCurrentTimeSlice = [&timingInfo, &rootContext, &stringContext, &rawContext, &context, &relayer](int i) {
377- size_t timeslice = relayer.getTimesliceForCacheline (i);
378- LOG (DEBUG) << " Timeslice for cacheline is " << timeslice;
379- timingInfo.timeslice = timeslice;
380376 rootContext.clear ();
381377 context.clear ();
382378 stringContext.clear ();
0 commit comments