Merge branch 'reactor' of https://github.com/prestona/qpid-proton into proton-j-reactor
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/a65760ab Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/a65760ab Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/a65760ab Branch: refs/heads/master Commit: a65760abe2642579ed6dea0aa89af40d56d4c310 Parents: bfb5dcd 46b9d84 Author: Rafael Schloming <r...@alum.mit.edu> Authored: Thu May 7 02:32:20 2015 -0400 Committer: Rafael Schloming <r...@alum.mit.edu> Committed: Thu May 7 02:32:20 2015 -0400 ---------------------------------------------------------------------- config.sh.in | 2 +- examples/java/reactor/.gitignore | 1 + .../apache/qpid/proton/example/reactor/Cat.java | 95 +++++ .../proton/example/reactor/CountRandomly.java | 104 +++++ .../qpid/proton/example/reactor/Counter.java | 81 ++++ .../qpid/proton/example/reactor/Delegates.java | 68 +++ .../qpid/proton/example/reactor/Echo.java | 90 ++++ .../example/reactor/EchoInputStreamWrapper.java | 76 ++++ .../proton/example/reactor/GlobalLogger.java | 114 +++++ .../proton/example/reactor/GoodbyeWorld.java | 62 +++ .../qpid/proton/example/reactor/HelloWorld.java | 60 +++ .../proton/example/reactor/ReactorLogger.java | 103 +++++ .../qpid/proton/example/reactor/Recv.java | 79 ++++ .../qpid/proton/example/reactor/Scheduling.java | 60 +++ .../qpid/proton/example/reactor/Send.java | 142 +++++++ .../qpid/proton/example/reactor/Unhandled.java | 46 +++ .../java/org/apache/qpid/proton/Proton.java | 20 +- .../apache/qpid/proton/engine/BaseHandler.java | 28 ++ .../apache/qpid/proton/engine/Collector.java | 1 + .../apache/qpid/proton/engine/Connection.java | 9 +- .../org/apache/qpid/proton/engine/Event.java | 10 + .../org/apache/qpid/proton/engine/Handler.java | 18 + .../qpid/proton/engine/HandlerEndpoint.java | 28 ++ .../org/apache/qpid/proton/engine/Link.java | 4 +- .../org/apache/qpid/proton/engine/Session.java | 2 +- .../qpid/proton/engine/impl/CollectorImpl.java | 10 +- .../qpid/proton/engine/impl/ConnectionImpl.java | 36 +- .../qpid/proton/engine/impl/EventImpl.java | 99 ++++- .../proton/engine/impl/HandlerEndpointImpl.java | 44 ++ .../qpid/proton/engine/impl/LinkImpl.java | 28 +- .../qpid/proton/engine/impl/SessionImpl.java | 14 +- .../qpid/proton/engine/impl/TransportImpl.java | 33 +- .../apache/qpid/proton/reactor/Acceptor.java | 30 ++ .../qpid/proton/reactor/FlowController.java | 72 ++++ .../apache/qpid/proton/reactor/Handshaker.java | 72 ++++ .../org/apache/qpid/proton/reactor/Reactor.java | 101 +++++ .../qpid/proton/reactor/ReactorChild.java | 28 ++ .../apache/qpid/proton/reactor/Selectable.java | 102 +++++ .../apache/qpid/proton/reactor/Selector.java | 43 ++ .../org/apache/qpid/proton/reactor/Task.java | 35 ++ .../qpid/proton/reactor/impl/AcceptorImpl.java | 138 +++++++ .../qpid/proton/reactor/impl/IOHandler.java | 341 +++++++++++++++ .../qpid/proton/reactor/impl/ReactorImpl.java | 413 +++++++++++++++++++ .../reactor/impl/ReactorInternalException.java | 44 ++ .../proton/reactor/impl/SelectableImpl.java | 271 ++++++++++++ .../qpid/proton/reactor/impl/SelectorImpl.java | 161 ++++++++ .../qpid/proton/reactor/impl/TaskImpl.java | 83 ++++ .../apache/qpid/proton/reactor/impl/Timer.java | 70 ++++ .../apache/qpid/proton/reactor/ReactorTest.java | 341 +++++++++++++++ .../proton/reactor/impl/AcceptorImplTest.java | 95 +++++ .../org/apache/qpid/proton/ProtonJInterop.java | 203 +++++++++ tests/java/pythonTests.ignore | 1 + tests/python/proton_tests/__init__.py | 1 + tests/python/proton_tests/reactor_interop.py | 163 ++++++++ 54 files changed, 4349 insertions(+), 26 deletions(-) ---------------------------------------------------------------------- --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
