|
|
@ -657,7 +657,7 @@ static void *__sntll_thread(void *b)
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
while(1) {
|
|
|
|
while(1) {
|
|
|
|
__again:
|
|
|
|
__again:
|
|
|
|
//if(co->flags & SNSX_CLOSED) goto __finish; /* go away if required asap */
|
|
|
|
if(co->flags & SNSX_CLOSED) goto __finish; /* go away if required asap */
|
|
|
|
/* works with pending messages */
|
|
|
|
/* works with pending messages */
|
|
|
|
if(co->pending_messages && !(co->flags & SNSX_CLOSED)) {
|
|
|
|
if(co->pending_messages && !(co->flags & SNSX_CLOSED)) {
|
|
|
|
pthread_mutex_lock(&co->write_pending_lock);
|
|
|
|
pthread_mutex_lock(&co->write_pending_lock);
|
|
|
|