qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r..@apache.org
Subject [24/38] qpid-proton git commit: make the timer selectable read from the wakeup pipe
Date Sun, 05 Jul 2015 23:45:25 GMT
make the timer selectable read from the wakeup pipe


Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/76cb49a8
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/76cb49a8
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/76cb49a8

Branch: refs/heads/master
Commit: 76cb49a87935f0659310286c25953efd6b66cfa7
Parents: 5c7f59c
Author: Rafael Schloming <rhs@alum.mit.edu>
Authored: Mon May 11 13:05:00 2015 -0400
Committer: Rafael Schloming <rhs@alum.mit.edu>
Committed: Mon May 11 13:05:00 2015 -0400

----------------------------------------------------------------------
 .../java/org/apache/qpid/proton/reactor/impl/ReactorImpl.java   | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/76cb49a8/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/ReactorImpl.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/ReactorImpl.java b/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/ReactorImpl.java
index a5a39d6..94bae9e 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/ReactorImpl.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/ReactorImpl.java
@@ -344,6 +344,11 @@ public class ReactorImpl implements Reactor {
 
         @Override
         public void run(Selectable selectable) {
+            try {
+                wakeup.source().read(ByteBuffer.allocate(64));
+            } catch (IOException e) {
+                throw new RuntimeException(e);
+            }
             // TODO: this could be more elegant...
             new TimerExpired().run(selectable);
         }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message