X-Git-Url: http://git.demorecorder.com/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=src%2Fxcb_in.c;h=1f6dcbe3d0ce3c2b8ba98e3783ee6899307af9a6;hb=ff7b6c9124e7caf26381cc7a10fba9eaf1875652;hp=6f084ba9373261b0393d9caac14688690662f45e;hpb=46a754998149c5f4a1670787b3ea36731caf6506;p=free-sw%2Fxcb%2Flibxcb diff --git a/src/xcb_in.c b/src/xcb_in.c index 6f084ba..1f6dcbe 100644 --- a/src/xcb_in.c +++ b/src/xcb_in.c @@ -36,23 +36,18 @@ #include "xcbext.h" #include "xcbint.h" -typedef struct { +typedef struct pending_reply { unsigned int request; enum workarounds workaround; + int flags; + struct pending_reply *next; } pending_reply; typedef struct XCBReplyData { unsigned int request; void *data; - XCBGenericError **error; } XCBReplyData; -static int match_request_error(const void *request, const void *data) -{ - const XCBGenericError *e = data; - return e->response_type == 0 && e->sequence == ((*(unsigned int *) request) & 0xffff); -} - static int match_reply(const void *request, const void *data) { return ((XCBReplyData *) data)->request == *(unsigned int *) request; @@ -74,6 +69,7 @@ static int read_packet(XCBConnection *c) XCBGenericRep genrep; int length = 32; unsigned char *buf; + pending_reply *pend = 0; /* Wait for there to be enough data for us to read a whole packet */ if(c->in.queue_len < length) @@ -87,33 +83,40 @@ static int read_packet(XCBConnection *c) { int lastread = c->in.request_read; c->in.request_read = (lastread & 0xffff0000) | genrep.sequence; - if(c->in.request_read != lastread && !_xcb_queue_is_empty(c->in.current_reply)) + if(c->in.request_read != lastread) { - _xcb_map_put(c->in.replies, lastread, c->in.current_reply); - c->in.current_reply = _xcb_queue_new(); + pending_reply *oldpend = c->in.pending_replies; + if(oldpend && oldpend->request == lastread) + { + c->in.pending_replies = oldpend->next; + if(!oldpend->next) + c->in.pending_replies_tail = &c->in.pending_replies; + free(oldpend); + } + if(!_xcb_queue_is_empty(c->in.current_reply)) + { + _xcb_map_put(c->in.replies, lastread, c->in.current_reply); + c->in.current_reply = _xcb_queue_new(); + } } if(c->in.request_read < lastread) c->in.request_read += 0x10000; } + if(genrep.response_type == 0 || genrep.response_type == 1) + { + pend = c->in.pending_replies; + if(pend && pend->request != c->in.request_read) + pend = 0; + } + /* For reply packets, check that the entire packet is available. */ if(genrep.response_type == 1) { - pending_reply *pend = _xcb_list_peek_head(c->in.pending_replies); - if(pend && pend->request == c->in.request_read) + if(pend && pend->workaround == WORKAROUND_GLX_GET_FB_CONFIGS_BUG) { - switch(pend->workaround) - { - case WORKAROUND_NONE: - break; - case WORKAROUND_GLX_GET_FB_CONFIGS_BUG: - { - CARD32 *p = (CARD32 *) c->in.queue; - genrep.length = p[2] * p[3] * 2; - } - break; - } - free(_xcb_queue_dequeue(c->in.pending_replies)); + CARD32 *p = (CARD32 *) c->in.queue; + genrep.length = p[2] * p[3] * 2; } length += genrep.length * 4; } @@ -127,7 +130,8 @@ static int read_packet(XCBConnection *c) return 0; } - if(buf[0] == 1) /* response is a reply */ + /* reply, or checked error */ + if(genrep.response_type == 1 || (genrep.response_type == 0 && pend && (pend->flags & XCB_REQUEST_CHECKED))) { XCBReplyData *reader = _xcb_list_find(c->in.readers, match_reply, &c->in.request_read); _xcb_queue_enqueue(c->in.current_reply, buf); @@ -136,18 +140,7 @@ static int read_packet(XCBConnection *c) return 1; } - if(buf[0] == 0) /* response is an error */ - { - XCBReplyData *reader = _xcb_list_find(c->in.readers, match_reply, &c->in.request_read); - if(reader && reader->error) - { - *reader->error = (XCBGenericError *) buf; - pthread_cond_signal(reader->data); - return 1; - } - } - - /* event, or error without a waiting reader */ + /* event, or unchecked error */ _xcb_queue_enqueue(c->in.events, buf); pthread_cond_signal(&c->in.event_cond); return 1; /* I have something for you... */ @@ -194,20 +187,12 @@ void *XCBWaitForReply(XCBConnection *c, unsigned int request, XCBGenericError ** if(_xcb_list_find(c->in.readers, match_reply, &request)) goto done; /* error */ - if(e) - { - *e = _xcb_list_remove(c->in.events, match_request_error, &request); - if(*e) - goto done; - } - reader.request = request; reader.data = &cond; - reader.error = e; _xcb_list_append(c->in.readers, &reader); /* If this request has not been read yet, wait for it. */ - while(!(e && *e) && ((signed int) (c->in.request_read - request) < 0 || + while(((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)) @@ -226,6 +211,15 @@ void *XCBWaitForReply(XCBConnection *c, unsigned int request, XCBGenericError ** else ret = _xcb_queue_dequeue(c->in.current_reply); + if(ret && ((XCBGenericRep *) ret)->response_type == 0) /* X error */ + { + if(e) + *e = ret; + else + free(ret); + ret = 0; + } + done: _xcb_list_remove(c->in.readers, match_reply, &request); pthread_cond_destroy(&cond); @@ -301,11 +295,11 @@ int _xcb_in_init(_xcb_in *in) in->replies = _xcb_map_new(); in->events = _xcb_queue_new(); in->readers = _xcb_list_new(); - - in->pending_replies = _xcb_queue_new(); - if(!in->current_reply || !in->replies || !in->events || !in->readers || !in->pending_replies) + if(!in->current_reply || !in->replies || !in->events || !in->readers) return 0; + in->pending_replies_tail = &in->pending_replies; + return 1; } @@ -316,23 +310,27 @@ void _xcb_in_destroy(_xcb_in *in) _xcb_map_delete(in->replies, free); _xcb_queue_delete(in->events, free); _xcb_list_delete(in->readers, 0); - _xcb_queue_delete(in->pending_replies, free); + while(in->pending_replies) + { + pending_reply *pend = in->pending_replies; + in->pending_replies = pend->next; + free(pend); + } } -int _xcb_in_expect_reply(XCBConnection *c, unsigned int request, enum workarounds workaround) +int _xcb_in_expect_reply(XCBConnection *c, unsigned int request, enum workarounds workaround, int flags) { - if(workaround != WORKAROUND_NONE) + if(workaround != WORKAROUND_NONE || flags != 0) { pending_reply *pend = malloc(sizeof(pending_reply)); if(!pend) return 0; pend->request = request; pend->workaround = workaround; - if(!_xcb_queue_enqueue(c->in.pending_replies, pend)) - { - free(pend); - return 0; - } + pend->flags = flags; + pend->next = 0; + *c->in.pending_replies_tail = pend; + c->in.pending_replies_tail = &pend->next; } return 1; }