{
int lastread = c->in.request_read;
c->in.request_read = (lastread & 0xffff0000) | genrep.sequence;
+ if(c->in.request_read < lastread)
+ c->in.request_read += 0x10000;
+
if(c->in.request_read != lastread)
{
- 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(c->in.current_reply)
{
_xcb_map_put(c->in.replies, lastread, c->in.current_reply);
c->in.current_reply = 0;
c->in.current_reply_tail = &c->in.current_reply;
}
+ c->in.request_completed = c->in.request_read - 1;
+ }
+ if(genrep.response_type != 1) /* not reply: error or event */
+ c->in.request_completed = c->in.request_read; /* XXX: does event/error imply no more replies? */
+
+ while(c->in.pending_replies && c->in.pending_replies->request <= c->in.request_completed)
+ {
+ pending_reply *oldpend = c->in.pending_replies;
+ c->in.pending_replies = oldpend->next;
+ if(!oldpend->next)
+ c->in.pending_replies_tail = &c->in.pending_replies;
+ free(oldpend);
}
- if(c->in.request_read < lastread)
- c->in.request_read += 0x10000;
}
if(genrep.response_type == 0 || genrep.response_type == 1)
reader.next = *prev_reader;
*prev_reader = &reader;
- /* If this request has not been read yet, wait for it. */
- while(((signed int) (c->in.request_read - request) < 0 ||
- (c->in.request_read == request && !c->in.current_reply)))
+ /* If this request has not completed yet and has no reply waiting,
+ * wait for one. */
+ while(c->in.request_completed < request &&
+ !(c->in.request_read == request && c->in.current_reply))
if(!_xcb_conn_wait(c, /*should_write*/ 0, &cond))
goto done;
in->queue_len = 0;
in->request_read = 0;
+ in->request_completed = 0;
in->replies = _xcb_map_new();
if(!in->replies)