From b83f18a4cc2303dfda59807d56e16bbc5c18b09d Mon Sep 17 00:00:00 2001 From: Jamey Sharp Date: Sun, 12 Mar 2006 13:20:29 -0800 Subject: [PATCH] Only _xcb_conn_wait calls _xcb_out_write now, so move it to xcb_conn.c and make it static. --- src/xcb_conn.c | 31 ++++++++++++++++++++++++++++++- src/xcb_out.c | 29 ----------------------------- src/xcbint.h | 1 - 3 files changed, 30 insertions(+), 31 deletions(-) diff --git a/src/xcb_conn.c b/src/xcb_conn.c index 1b3e1a2..2da3150 100644 --- a/src/xcb_conn.c +++ b/src/xcb_conn.c @@ -33,6 +33,7 @@ #include #include #include +#include #include "xcb.h" #include "xcbint.h" @@ -138,6 +139,34 @@ static int read_setup(XCBConnection *c) return 1; } +/* precondition: there must be something for us to write. */ +static int write_vec(XCBConnection *c, struct iovec **vector, int *count) +{ + int n; + assert(!c->out.queue_len); + n = writev(c->fd, *vector, *count); + if(n < 0 && errno == EAGAIN) + return 1; + if(n <= 0) + return 0; + + for(; *count; --*count, ++*vector) + { + int cur = (*vector)->iov_len; + if(cur > n) + cur = n; + (*vector)->iov_len -= cur; + (*vector)->iov_base = (char *) (*vector)->iov_base + cur; + n -= cur; + if((*vector)->iov_len) + break; + } + if(!*count) + *vector = 0; + assert(n == 0); + return 1; +} + /* Public interface */ XCBConnSetupSuccessRep *XCBGetSetup(XCBConnection *c) @@ -233,7 +262,7 @@ int _xcb_conn_wait(XCBConnection *c, pthread_cond_t *cond, struct iovec **vector ret = ret && _xcb_in_read(c); if(FD_ISSET(c->fd, &wfds)) - ret = ret && _xcb_out_write(c, vector, count); + ret = ret && write_vec(c, vector, count); } if(count) diff --git a/src/xcb_out.c b/src/xcb_out.c index b0130e7..2b1a434 100644 --- a/src/xcb_out.c +++ b/src/xcb_out.c @@ -29,7 +29,6 @@ #include #include #include -#include #include "xcb.h" #include "xcbext.h" @@ -224,34 +223,6 @@ void _xcb_out_destroy(_xcb_out *out) pthread_mutex_destroy(&out->reqlenlock); } -/* precondition: there must be something for us to write. */ -int _xcb_out_write(XCBConnection *c, struct iovec **vector, int *count) -{ - int n; - assert(!c->out.queue_len); - n = writev(c->fd, *vector, *count); - if(n < 0 && errno == EAGAIN) - return 1; - if(n <= 0) - return 0; - - for(; *count; --*count, ++*vector) - { - int cur = (*vector)->iov_len; - if(cur > n) - cur = n; - (*vector)->iov_len -= cur; - (*vector)->iov_base = (char *) (*vector)->iov_base + cur; - n -= cur; - if((*vector)->iov_len) - break; - } - if(!*count) - *vector = 0; - assert(n == 0); - return 1; -} - int _xcb_out_send(XCBConnection *c, struct iovec **vector, int *count) { int ret = 1; diff --git a/src/xcbint.h b/src/xcbint.h index e90ede2..7b32248 100644 --- a/src/xcbint.h +++ b/src/xcbint.h @@ -74,7 +74,6 @@ typedef struct _xcb_out { int _xcb_out_init(_xcb_out *out); void _xcb_out_destroy(_xcb_out *out); -int _xcb_out_write(XCBConnection *c, struct iovec **vector, int *count); int _xcb_out_send(XCBConnection *c, struct iovec **vector, int *count); int _xcb_out_flush_to(XCBConnection *c, unsigned int request); -- 2.34.1