DPL: improve reporting of why the loop was triggered

ktf · ktf · commit c9f54d8b3ea6 · 2023-02-16T06:04:10.000+01:00
diff --git a/Framework/Core/src/DPLWebSocket.cxx b/Framework/Core/src/DPLWebSocket.cxx
@@ -509,7 +509,7 @@ void ws_client_write_callback(uv_write_t* h, int status)
     free(h);
     return;
   }
-  context->state->loopReason |= DeviceState::WS_COMMUNICATION;
+  context->state->loopReason |= (DeviceState::WS_COMMUNICATION | DeviceState::WS_READING);
   if (context->buf.base) {
     free(context->buf.base);
   }
@@ -520,7 +520,7 @@ void ws_client_write_callback(uv_write_t* h, int status)
 void ws_client_bulk_write_callback(uv_write_t* h, int status)
 {
   BulkWriteRequestContext* context = (BulkWriteRequestContext*)h->data;
-  context->state->loopReason |= DeviceState::WS_COMMUNICATION;
+  context->state->loopReason |= (DeviceState::WS_COMMUNICATION | DeviceState::WS_WRITING);
   if (status < 0) {
     LOG(error) << "uv_write error: " << uv_err_name(status);
     free(h);

Original file line number	Diff line number	Diff line change
`@@ -509,7 +509,7 @@ void ws_client_write_callback(uv_write_t* h, int status)`
`509`	`509`	`free(h);`
`510`	`510`	`return;`
`511`	`511`	`}`
`512`		`- context->state->loopReason \|= DeviceState::WS_COMMUNICATION;`
	`512`	`+ context->state->loopReason \|= (DeviceState::WS_COMMUNICATION \| DeviceState::WS_READING);`
`513`	`513`	`if (context->buf.base) {`
`514`	`514`	`free(context->buf.base);`
`515`	`515`	`}`
`@@ -520,7 +520,7 @@ void ws_client_write_callback(uv_write_t* h, int status)`
`520`	`520`	`void ws_client_bulk_write_callback(uv_write_t* h, int status)`
`521`	`521`	`{`
`522`	`522`	`BulkWriteRequestContext* context = (BulkWriteRequestContext*)h->data;`
`523`		`- context->state->loopReason \|= DeviceState::WS_COMMUNICATION;`
	`523`	`+ context->state->loopReason \|= (DeviceState::WS_COMMUNICATION \| DeviceState::WS_WRITING);`
`524`	`524`	`if (status < 0) {`
`525`	`525`	`LOG(error) << "uv_write error: " << uv_err_name(status);`
`526`	`526`	`free(h);`