diff options
Diffstat (limited to 'Ensure-xcb-owns-socket-and-no-other-threads-are-writ.patch')
-rw-r--r-- | Ensure-xcb-owns-socket-and-no-other-threads-are-writ.patch | 121 |
1 files changed, 0 insertions, 121 deletions
diff --git a/Ensure-xcb-owns-socket-and-no-other-threads-are-writ.patch b/Ensure-xcb-owns-socket-and-no-other-threads-are-writ.patch deleted file mode 100644 index 90a236816174..000000000000 --- a/Ensure-xcb-owns-socket-and-no-other-threads-are-writ.patch +++ /dev/null @@ -1,121 +0,0 @@ -From be0fe56c3bcad5124dcc6c47a2fad01acd16f71a Mon Sep 17 00:00:00 2001 -From: Keith Packard <keithp@keithp.com> -Date: Mon, 23 Dec 2013 21:15:20 -0800 -Subject: [PATCH] Ensure xcb owns socket and no other threads are writing - before send_request - -send_request may only write to out.queue if no other thread is busy -writing to the network (as that thread may be writing from out.queue). - -send_request may only allocate request sequence numbers if XCB owns -the socket. - -Therefore, send_request must make sure that both conditions are true -when it holds iolock, which can only be done by looping until both -conditions are true without having dropped the lock waiting for the -second condition. - -We choose to get the socket back from Xlib first as get_socket_back -has a complicated test and checking for other threads writing is a -simple in-lined check. - -This also changes the sequence number checks (64k requests with no -reply, 4M request wrapping) to ensure that both conditions are true -before queueing the request. - -Signed-off-by: Keith Packard <keithp@keithp.com> -Reviewed-by: Uli Schlachter <psychon@znc.in> ---- - src/xcb_out.c | 57 ++++++++++++++++++++++++++++++++++++++++----------------- - 1 file changed, 40 insertions(+), 17 deletions(-) - -diff --git a/src/xcb_out.c b/src/xcb_out.c -index 18bb5f9..dc42954 100644 ---- a/src/xcb_out.c -+++ b/src/xcb_out.c -@@ -103,6 +103,33 @@ static void get_socket_back(xcb_connection_t *c) - _xcb_in_replies_done(c); - } - -+static void prepare_socket_request(xcb_connection_t *c) -+{ -+ /* We're about to append data to out.queue, so we need to -+ * atomically test for an external socket owner *and* some other -+ * thread currently writing. -+ * -+ * If we have an external socket owner, we have to get the socket back -+ * before we can use it again. -+ * -+ * If some other thread is writing to the socket, we assume it's -+ * writing from out.queue, and so we can't stick data there. -+ * -+ * We satisfy this condition by first calling get_socket_back -+ * (which may drop the lock, but will return when XCB owns the -+ * socket again) and then checking for another writing thread and -+ * escaping the loop if we're ready to go. -+ */ -+ for (;;) { -+ if(c->has_error) -+ return; -+ get_socket_back(c); -+ if (!c->out.writing) -+ break; -+ pthread_cond_wait(&c->out.cond, &c->iolock); -+ } -+} -+ - /* Public interface */ - - void xcb_prefetch_maximum_request_length(xcb_connection_t *c) -@@ -236,24 +263,23 @@ unsigned int xcb_send_request(xcb_connection_t *c, int flags, struct iovec *vect - - /* get a sequence number and arrange for delivery. */ - pthread_mutex_lock(&c->iolock); -- /* wait for other writing threads to get out of my way. */ -- while(c->out.writing) -- pthread_cond_wait(&c->out.cond, &c->iolock); -- get_socket_back(c); -+ -+ prepare_socket_request(c); - - /* send GetInputFocus (sync_req) when 64k-2 requests have been sent without -- * a reply. */ -- if(req->isvoid && c->out.request == c->in.request_expected + (1 << 16) - 2) -- send_sync(c); -- /* Also send sync_req (could use NoOp) at 32-bit wrap to avoid having -+ * a reply. -+ * Also send sync_req (could use NoOp) at 32-bit wrap to avoid having - * applications see sequence 0 as that is used to indicate -- * an error in sending the request */ -- if((unsigned int) (c->out.request + 1) == 0) -+ * an error in sending the request -+ */ -+ -+ while ((req->isvoid && c->out.request == c->in.request_expected + (1 << 16) - 2) || -+ (unsigned int) (c->out.request + 1) == 0) -+ { - send_sync(c); -+ prepare_socket_request(c); -+ } - -- /* The above send_sync calls could drop the I/O lock, but this -- * thread will still exclude any other thread that tries to write, -- * so the sequence number postconditions still hold. */ - send_request(c, req->isvoid, workaround, flags, vector, veclen); - request = c->has_error ? 0 : c->out.request; - pthread_mutex_unlock(&c->iolock); -@@ -373,10 +399,7 @@ int _xcb_out_send(xcb_connection_t *c, struct iovec *vector, int count) - - void _xcb_out_send_sync(xcb_connection_t *c) - { -- /* wait for other writing threads to get out of my way. */ -- while(c->out.writing) -- pthread_cond_wait(&c->out.cond, &c->iolock); -- get_socket_back(c); -+ prepare_socket_request(c); - send_sync(c); - } - --- -1.9.2 - |