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); |