talksik/uWebSockets
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix publish with ded. compr. compress = false

Browse Source
This commit is contained in:
Alex Hultman
2021-01-08 21:08:19 +01:00
parent 3fe995912a
commit a86a500f3b
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/WebSocketContextData.h
+4 -2
View File
@@ -169,7 +169,8 @@ public:
/* Leave second field empty as nobody will ever read it */ /* Leave second field empty as nobody will ever read it */
topicTree.publish(topic, {std::string_view(dst, dst_length), {}}); topicTree.publish(topic, {std::string_view(dst, dst_length), {}});
} else { } else {
if (compress) { /* DEDICATED_COMPRESSOR always takes the same path as must always have MessageMetadata as head */
if (compress || compression != SHARED_COMPRESSOR) {
/* Shared compression mode publishes compressed, framed data */ /* Shared compression mode publishes compressed, framed data */
if (compression == SHARED_COMPRESSOR) { if (compression == SHARED_COMPRESSOR) {
/* Loop data holds shared compressor */ /* Loop data holds shared compressor */
@@ -209,7 +210,8 @@ public:
::free(dst_compressed); ::free(dst_compressed);
} }
} else { } else {
/* If not compressing, put same message on both tracks */ /* If not compressing, put same message on both tracks (only valid for SHARED_COMPRESSOR).
* DEDICATED_COMPRESSOR_xKB must never end up here as we don't put a proper head here. */
topicTree.publish(topic, {std::string_view(dst, dst_length), std::string_view(dst, dst_length)}); topicTree.publish(topic, {std::string_view(dst, dst_length), std::string_view(dst, dst_length)});
} }
} }