diff --git a/examples/websocket/WebSockCallbacks.c b/examples/websocket/WebSockCallbacks.c index d90f712a..36cf68f4 100644 --- a/examples/websocket/WebSockCallbacks.c +++ b/examples/websocket/WebSockCallbacks.c @@ -73,6 +73,7 @@ void websocket_ready_handler(struct mg_connection *conn) { break; } } + printf("\nNew websocket attached: %08x:%u\n", rq->remote_ip, rq->remote_port); pthread_mutex_unlock(&sMutex); } @@ -87,6 +88,7 @@ static void websocket_done(tWebSockInfo * wsock) { break; } } + printf("\nClose websocket attached: %08x:%u\n", mg_get_request_info(wsock->conn)->remote_ip, mg_get_request_info(wsock->conn)->remote_port); free(wsock); } } @@ -185,8 +187,8 @@ void websock_send_broadcast(const char * data, int data_len) { if (data_len<=256) { strcpy(buffer, "msg "); memcpy(buffer+4, data, data_len); - - pthread_mutex_lock(&sMutex); + + pthread_mutex_lock(&sMutex); send_to_all_websockets(buffer, data_len+4); pthread_mutex_unlock(&sMutex); } diff --git a/examples/websocket/websocket.c b/examples/websocket/websocket.c index 06349569..5e5d2c79 100644 --- a/examples/websocket/websocket.c +++ b/examples/websocket/websocket.c @@ -16,7 +16,7 @@ int main(void) "document_root", "../../examples/websocket", /* port: use http standard to match websocket url in websock.htm: ws://127.0.0.1/MyWebSock */ - /* if the port is changed here, it needs to be changed in websock.htm as wenn */ + /* if the port is changed here, it needs to be changed in websock.htm as well */ "listening_ports", "80", NULL