Page MenuHomePhorge

D6843.1769113429.diff
No OneTemporary

Size
756 B
Referenced Files
None
Subscribers
None

D6843.1769113429.diff

diff --git a/services/tunnelbroker/src/server/mod.rs b/services/tunnelbroker/src/server/mod.rs
--- a/services/tunnelbroker/src/server/mod.rs
+++ b/services/tunnelbroker/src/server/mod.rs
@@ -264,8 +264,14 @@
let tx = tx.clone();
async move {
loop {
+ let device_id = device_id.clone();
let message_to_deliver =
- match waitMessageFromDeliveryBroker(&device_id) {
+ match tokio::task::spawn_blocking(move || {
+ waitMessageFromDeliveryBroker(&device_id)
+ })
+ .await
+ .expect("Error on waiting messages from DeliveryBroker")
+ {
Ok(message_item) => message_item,
Err(err) => {
error!(

File Metadata

Mime Type
text/plain
Expires
Thu, Jan 22, 8:23 PM (18 h, 18 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5980048
Default Alt Text
D6843.1769113429.diff (756 B)

Event Timeline