Factor pthread_cond_wait(iolock) to _xcb_wait_io.
This parallels the _xcb_lock_io and _xcb_unlock_io factoring.
This commit is contained in:
parent
4d828c5eba
commit
f6b75d6090
|
@ -288,6 +288,11 @@ void _xcb_unlock_io(xcb_connection_t *c)
|
||||||
pthread_mutex_unlock(&c->iolock);
|
pthread_mutex_unlock(&c->iolock);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void _xcb_wait_io(xcb_connection_t *c, pthread_cond_t *cond)
|
||||||
|
{
|
||||||
|
pthread_cond_wait(cond, &c->iolock);
|
||||||
|
}
|
||||||
|
|
||||||
int _xcb_conn_wait(xcb_connection_t *c, pthread_cond_t *cond, struct iovec **vector, int *count)
|
int _xcb_conn_wait(xcb_connection_t *c, pthread_cond_t *cond, struct iovec **vector, int *count)
|
||||||
{
|
{
|
||||||
int ret;
|
int ret;
|
||||||
|
@ -296,7 +301,7 @@ int _xcb_conn_wait(xcb_connection_t *c, pthread_cond_t *cond, struct iovec **vec
|
||||||
/* If the thing I should be doing is already being done, wait for it. */
|
/* If the thing I should be doing is already being done, wait for it. */
|
||||||
if(count ? c->out.writing : c->in.reading)
|
if(count ? c->out.writing : c->in.reading)
|
||||||
{
|
{
|
||||||
pthread_cond_wait(cond, &c->iolock);
|
_xcb_wait_io(c, cond);
|
||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -190,7 +190,7 @@ unsigned int xcb_send_request(xcb_connection_t *c, int flags, struct iovec *vect
|
||||||
_xcb_lock_io(c);
|
_xcb_lock_io(c);
|
||||||
/* wait for other writing threads to get out of my way. */
|
/* wait for other writing threads to get out of my way. */
|
||||||
while(c->out.writing)
|
while(c->out.writing)
|
||||||
pthread_cond_wait(&c->out.cond, &c->iolock);
|
_xcb_wait_io(c, &c->out.cond);
|
||||||
|
|
||||||
request = ++c->out.request;
|
request = ++c->out.request;
|
||||||
/* send GetInputFocus (sync) when 64k-2 requests have been sent without
|
/* send GetInputFocus (sync) when 64k-2 requests have been sent without
|
||||||
|
@ -297,7 +297,7 @@ int _xcb_out_flush_to(xcb_connection_t *c, unsigned int request)
|
||||||
return _xcb_out_send(c, &vec_ptr, &count);
|
return _xcb_out_send(c, &vec_ptr, &count);
|
||||||
}
|
}
|
||||||
while(c->out.writing)
|
while(c->out.writing)
|
||||||
pthread_cond_wait(&c->out.cond, &c->iolock);
|
_xcb_wait_io(c, &c->out.cond);
|
||||||
assert(XCB_SEQUENCE_COMPARE(c->out.request_written, >=, request));
|
assert(XCB_SEQUENCE_COMPARE(c->out.request_written, >=, request));
|
||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
|
|
|
@ -183,6 +183,7 @@ struct xcb_connection_t {
|
||||||
};
|
};
|
||||||
|
|
||||||
void _xcb_conn_shutdown(xcb_connection_t *c);
|
void _xcb_conn_shutdown(xcb_connection_t *c);
|
||||||
|
void _xcb_wait_io(xcb_connection_t *c, pthread_cond_t *cond);
|
||||||
int _xcb_conn_wait(xcb_connection_t *c, pthread_cond_t *cond, struct iovec **vector, int *count);
|
int _xcb_conn_wait(xcb_connection_t *c, pthread_cond_t *cond, struct iovec **vector, int *count);
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue