/* If this request has not been written yet, write it. */
if((signed int) (c->out.request_written - request) < 0)
- if(_xcb_out_flush(c) <= 0)
+ if(!_xcb_out_flush(c))
goto done; /* error */
if(_xcb_list_find(c->in.readers, match_reply, &request))
while(!(e && *e) && ((signed int) (c->in.request_read - request) < 0 ||
(c->in.request_read == request &&
_xcb_queue_is_empty(c->in.current_reply))))
- if(_xcb_conn_wait(c, /*should_write*/ 0, &cond) <= 0)
+ if(!_xcb_conn_wait(c, /*should_write*/ 0, &cond))
goto done;
if(c->in.request_read != request)
pthread_mutex_lock(&c->iolock);
/* _xcb_list_remove_head returns 0 on empty list. */
while(!(ret = _xcb_queue_dequeue(c->in.events)))
- if(_xcb_conn_wait(c, /*should_write*/ 0, &c->in.event_cond) <= 0)
+ if(!_xcb_conn_wait(c, /*should_write*/ 0, &c->in.event_cond))
break;
wake_up_next_reader(c);