Skip to content

Commit c41d388

Browse files
committed
DPL: adapt to FairMQ new API
Rebuild() of a message will call free() on the supplied buffer after copying it, if a custom free function was not given as an argument. Since oldestPossingTimeslice is not a heap object, calling free() on it is not allowed, which seems to be enforced by some compilers.
1 parent 25f4dfe commit c41d388

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

Framework/Core/src/CommonDataProcessors.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,7 @@ void retryMetricCallback(uv_async_t* async)
167167
return;
168168
}
169169
fair::mq::MessagePtr payload(device->NewMessage());
170-
payload->Rebuild(&oldestPossingTimeslice, sizeof(int64_t), nullptr, nullptr);
170+
payload->Rebuild(&oldestPossingTimeslice, sizeof(int64_t), [](void*, void*) -> void {}, nullptr);
171171
auto consumed = oldestPossingTimeslice;
172172

173173
size_t start = uv_hrtime();

0 commit comments

Comments
 (0)