Repository: qpid-proton Updated Branches: refs/heads/proton-j-reactor 5c7f59cf6 -> 76cb49a87
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/proton-j-reactor Commit: 76cb49a87935f0659310286c25953efd6b66cfa7 Parents: 5c7f59c Author: Rafael Schloming <[email protected]> Authored: Mon May 11 13:05:00 2015 -0400 Committer: Rafael Schloming <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
