RanchiMall/Flo-Whatsapp
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Directly unicast/broadcast the incoming websocket messages

Browse Source 
Directly send the incoming websocket messages through unicast or broadcast
Incoming messages for unicast and broadcast are not processed inside the server
Server response speed is increased as duplicating the message is eliminated
Websocket message limit of 5000 is eliminated since the message is directly sent
This commit is contained in:
sairajzero 2019-09-16 17:08:59 +05:30
parent eaa3470cf4
commit dc8efe511a
2 changed files with 3 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
app/websocket_chat
View File

Binary file not shown.

14
util/websocket_chat.c
View File

@ -22,23 +22,15 @@ static int is_websocket(const struct mg_connection *nc) {
static void broadcast(struct mg_connection *nc, const struct mg_str msg) {
struct mg_connection *c;
char buf[500];
snprintf(buf, sizeof(buf), "%.*s", (int) msg.len, msg.p);
printf("%s\n", buf); /* Local echo. */
for (c = mg_next(nc->mgr, NULL); c != NULL; c = mg_next(nc->mgr, c)) {
if (c == nc) continue; /* Don't send to the sender. */
mg_send_websocket_frame(c, WEBSOCKET_OP_TEXT, buf, strlen(buf));
mg_send_websocket_frame(c, WEBSOCKET_OP_TEXT, msg.p, msg.len);
}
}
static void unicast(struct mg_connection *nc,const struct mg_str msg) {
char buf[5000];
snprintf(buf, sizeof(buf), "%.*s", (int) msg.len, msg.p);
printf("%s\n", buf); /* Local echo. */
if(nc != NULL)
mg_send_websocket_frame(nc, WEBSOCKET_OP_TEXT, buf, strlen(buf));
mg_send_websocket_frame(nc, WEBSOCKET_OP_TEXT, msg.p, msg.len);
else
printf("No selfClient is connected!\n");
@ -115,7 +107,7 @@ int main(int argc, char** argv) {
nc = mg_bind(&mgr, s_http_port, ev_handler);
mg_set_protocol_http_websocket(nc);
s_http_server_opts.document_root = "app"; // Serve current directory
s_http_server_opts.document_root = "."; // Serve current directory
s_http_server_opts.enable_directory_listing = "no";
printf("Started on port %s\n", s_http_port);