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

Fix fuzzing build, make a more interesting example of pubsub

Browse Source
This commit is contained in:
Alex Hultman
2021-09-12 17:23:46 +02:00
parent c35d6c1bb8
commit 0bf9483894
2 changed files with 52 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fuzzing/EpollEchoServerPubSub.cpp
+2 -2
View File
@@ -43,7 +43,7 @@ void test() {
PerSocketData *perSocketData = (PerSocketData *) ws->getUserData();
for (int i = 0; i < 100; i++) {
std::string topic = std::to_string(ws);
std::string topic = std::to_string((uintptr_t)ws) + "-" + std::to_string(i);
perSocketData->topics.push_back(topic);
ws->subscribe(topic);
}
@@ -51,7 +51,7 @@ void test() {
.message = [&app](auto *ws, std::string_view message, uWS::OpCode opCode) {
PerSocketData *perSocketData = (PerSocketData *) ws->getUserData();
app->publish(perSocketData->topics[++nr % 100], message, opCode);
app->publish(perSocketData->topics[++perSocketData->nr % 100], message, opCode);
},
.drain = [](auto */*ws*/) {
/* Check ws->getBufferedAmount() here */