|
@@ -32,12 +32,9 @@ int clients_websocket_data_handler(
|
|
|
struct synchronization_tool *sync = (struct synchronization_tool *) user_data;
|
|
|
|
|
|
unique_lock<mutex> lck(sync->mtx);
|
|
|
- stringstream buffer;
|
|
|
- buffer << data;
|
|
|
- BinarySizeT numClients;
|
|
|
- buffer >> numClients;
|
|
|
- std::cout << "raw data from websocket on number clients: " << numClients.val() << std::endl;
|
|
|
- sync->val = numClients.val();
|
|
|
+
|
|
|
+ if (data_len == sizeof(sync->val))
|
|
|
+ sync->val = *((size_t *) data);
|
|
|
|
|
|
return false;
|
|
|
}
|