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