thermferm/websocket.c

changeset 676
09b5efe0c633
parent 675
825210ba2707
child 678
cc49115e769e
equal deleted inserted replaced
675:825210ba2707 676:09b5efe0c633
73 73
74 case LWS_CALLBACK_ESTABLISHED: { 74 case LWS_CALLBACK_ESTABLISHED: {
75 ws_clients++; 75 ws_clients++;
76 pss->ringbuffer_tail = ringbuffer_head; 76 pss->ringbuffer_tail = ringbuffer_head;
77 pss->wsi = wsi; 77 pss->wsi = wsi;
78 syslog(LOG_NOTICE, "Websocket: new client, now %d", ws_clients);
78 break; 79 break;
79 } 80 }
80 81
81 case LWS_CALLBACK_PROTOCOL_DESTROY: 82 case LWS_CALLBACK_PROTOCOL_DESTROY:
82 syslog(LOG_NOTICE, "Websocket: protocol cleaning up"); 83 syslog(LOG_NOTICE, "Websocket: protocol cleaning up");
113 114
114 case LWS_CALLBACK_RECEIVE: 115 case LWS_CALLBACK_RECEIVE:
115 116
116 memcpy(buf, in, len); 117 memcpy(buf, in, len);
117 buf[len] = '\0'; 118 buf[len] = '\0';
118 // syslog(LOG_NOTICE, "ws: reveived %ld bytes %s", len, buf); 119 syslog(LOG_NOTICE, "ws: reveived %ld bytes %s", len, buf);
119 /* 120 /*
120 * These are send by bmsapp to bmsd. Then bmsd resends these via MQTT. 121 * These are send by bmsapp to bmsd. Then bmsd resends these via MQTT.
121 * Do we want to change that? Or use it for the new web pages. 122 * Do we want to change that? Or use it for the new web pages.
122 * {"node":"rpi01","group_id":"fermenters","control":"reboot"} 123 * {"node":"rpi01","group_id":"fermenters","control":"reboot"}
123 * {"node":"rpi01","group_id":"fermenters","control":"rebirth"} 124 * {"node":"rpi01","group_id":"fermenters","control":"rebirth"}
134 135
135 break; 136 break;
136 137
137 case LWS_CALLBACK_CLOSED: 138 case LWS_CALLBACK_CLOSED:
138 ws_clients--; 139 ws_clients--;
140 syslog(LOG_NOTICE, "Websocket: del client, now %d", ws_clients);
139 break; 141 break;
140 142
141 default: 143 default:
142 break; 144 break;
143 } 145 }

mercurial