31 		if (ws_ctx->socketList[i]  in send_to_all_websockets()
32 		    && (ws_ctx->socketList[i]->webSockState == 2)) {  in send_to_all_websockets()
33 			mg_websocket_write(ws_ctx->socketList[i]->conn,  in send_to_all_websockets()
53 	wsock->webSockState = 0;  in websocket_ready_handler()
58 		if (0 == ws_ctx->socketList[i]) {  in websocket_ready_handler()
59 			ws_ctx->socketList[i] = wsock;  in websocket_ready_handler()
60 			wsock->conn = conn;  in websocket_ready_handler()
61 			wsock->webSockState = 1;  in websocket_ready_handler()
66 	       rq->remote_addr,  in websocket_ready_handler()
67 	       rq->remote_port);  in websocket_ready_handler()
79 		wsock->webSockState = 99;  in websocket_done()
81 			if (wsock == ws_ctx->socketList[i]) {  in websocket_done()
82 				ws_ctx->socketList[i] = 0;  in websocket_done()
87 		       mg_get_request_info(wsock->conn)->remote_addr,  in websocket_done()
88 		       mg_get_request_info(wsock->conn)->remote_port);  in websocket_done()
103 	tWebSockInfo *wsock = (tWebSockInfo *)rq->conn_data;  in websocket_data_handler()
116 	if (((data_len >= 5) && (data_len < 100) && (flags == 129))  in websocket_data_handler()
120 		if ((wsock->webSockState == 1) && (!memcmp(data, "init ", 5))) {  in websocket_data_handler()
123 			memcpy(msg, data + 5, data_len - 5);  in websocket_data_handler()
124 			msg[data_len - 5] = 0;  in websocket_data_handler()
126 			wsock->initId = gid;  in websocket_data_handler()
128 				wsock->webSockState = 2;  in websocket_data_handler()
135 		if ((wsock->webSockState == 2) && (!memcmp(data, "msg ", 4))) {  in websocket_data_handler()
158 	tWebSockInfo *wsock = (tWebSockInfo *)rq->conn_data;  in connection_close_handler()
177 	ws_ctx->runLoop = 1;  in eventMain()
178 	while (ws_ctx->runLoop) {  in eventMain()
222 	ws_ctx->runLoop = 0;  in websock_exit_lib()