bmsd/websocket.c

changeset 676
b0718965dcb1
parent 675
a27af02ab16a
child 677
6e82fece1f8f
equal deleted inserted replaced
675:a27af02ab16a 676:b0718965dcb1
182 if (ringbuffer_head == (MAX_MESSAGE_QUEUE - 1)) 182 if (ringbuffer_head == (MAX_MESSAGE_QUEUE - 1))
183 ringbuffer_head = 0; 183 ringbuffer_head = 0;
184 else 184 else
185 ringbuffer_head++; 185 ringbuffer_head++;
186 186
187 // syslog(LOG_NOTICE, "ws: %d %s", ringbuffer_head, msg); 187 // syslog(LOG_NOTICE, "ws: broadcast buffer=%d len=%d", ringbuffer_head, len);
188 syslog(LOG_NOTICE, "ws: broadcast buffer=%d len=%d", ringbuffer_head, len);
189 188
190 lws_callback_on_writable_all_protocol(context, &protocols[0]); 189 lws_callback_on_writable_all_protocol(context, &protocols[0]);
191 err = pthread_mutex_unlock(&ws_mutex); 190 err = pthread_mutex_unlock(&ws_mutex);
192 if (err) { 191 if (err) {
193 syslog(LOG_NOTICE, "ws_broadcast pthread_mutex_unlock error %d", err); 192 syslog(LOG_NOTICE, "ws_broadcast pthread_mutex_unlock error %d", err);

mercurial