11 received(rhs.received),
12 evtNumber(rhs.evtNumber),
13 fileNumber(rhs.fileNumber) {
20 :
ptr(reinterpret_cast<void*>((std::
uint64_t(body[0]) << 32) +
29 if (received && (
ptr !=
nullptr)) {
39 received = rhs.received;
40 evtNumber = rhs.evtNumber;
41 fileNumber = rhs.fileNumber;
56 "Incorrect ClusterMessage constructor used for message type {}",
65 "Incorrect ClusterMessage constructor used for message type {}",
74 "Incorrect ClusterMessage constructor used for message type {}",
88 "Incorrect ClusterMessage constructor used for message type {}",
99 if (body.has_value()) {
100 const auto& body_2 = *body;
106 status.createdEvents = body_2[1];
107 status.finishedEvents = body_2[2];
108 status.skippedEvents = body_2[3];
119 constexpr
int max_tag = 16383;
122 static thread_local
int next_msg =
128 next_msg = (next_msg % max_tag) + 1;
131 const auto& payload_local = std::get<DataDescr>(
payload);
146 next_msg = (next_msg % max_tag) + 1;
149 const auto& payload_local = std::get<WorkerStatus>(
payload);
150 body[0] =
static_cast<int>(payload_local.status.getCode());
151 body[1] = payload_local.createdEvents;
152 body[2] = payload_local.finishedEvents;
153 body[3] = payload_local.skippedEvents;
154 body[4] = body[5] = body[6] = body[7] = body[8] = body[9] = 0;