413 if (ringbuffer_head == (MAX_MESSAGE_QUEUE - 1)) |
413 if (ringbuffer_head == (MAX_MESSAGE_QUEUE - 1)) |
414 ringbuffer_head = 0; |
414 ringbuffer_head = 0; |
415 else |
415 else |
416 ringbuffer_head++; |
416 ringbuffer_head++; |
417 |
417 |
418 // syslog(LOG_NOTICE, "ws: broadcast buffer=%d len=%d", ringbuffer_head, len); |
418 syslog(LOG_NOTICE, "ws: broadcast buffer=%d len=%d", ringbuffer_head, len); |
419 |
419 |
420 lws_callback_on_writable_all_protocol(context, &protocols[0]); |
420 lws_callback_on_writable_all_protocol(context, &protocols[0]); |
421 err = pthread_mutex_unlock(&ws_mutex); |
421 err = pthread_mutex_unlock(&ws_mutex); |
422 if (err) { |
422 if (err) { |
423 syslog(LOG_NOTICE, "ws_broadcast pthread_mutex_unlock error %d", err); |
423 syslog(LOG_NOTICE, "ws_broadcast pthread_mutex_unlock error %d", err); |