You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/11/12 20:19:39 UTC
[2/3] storm git commit: Merge branch 'server-callback' of
https://github.com/revans2/incubator-storm into STORM-1145
Merge branch 'server-callback' of https://github.com/revans2/incubator-storm into STORM-1145
STORM-1145: Have IConnection push tuples instead of pull them
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/cdb8a850
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/cdb8a850
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/cdb8a850
Branch: refs/heads/master
Commit: cdb8a850a7fb063208333697e79c73045bdc9d06
Parents: f4bd90a 1bdfd7e
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Thu Nov 12 13:11:12 2015 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Thu Nov 12 13:11:12 2015 -0600
----------------------------------------------------------------------
.../src/clj/backtype/storm/daemon/executor.clj | 60 +++----
.../src/clj/backtype/storm/daemon/worker.clj | 59 ++++---
.../src/clj/backtype/storm/messaging/loader.clj | 76 ++-------
.../src/clj/backtype/storm/messaging/local.clj | 72 +-------
storm-core/src/jvm/backtype/storm/Config.java | 7 -
.../storm/messaging/AddressedTuple.java | 46 ++++++
.../DeserializingConnectionCallback.java | 60 +++++++
.../backtype/storm/messaging/IConnection.java | 10 +-
.../storm/messaging/IConnectionCallback.java | 31 ++++
.../backtype/storm/messaging/local/Context.java | 164 +++++++++++++++++++
.../backtype/storm/messaging/netty/Client.java | 3 +-
.../backtype/storm/messaging/netty/Server.java | 121 ++------------
.../backtype/storm/tuple/AddressedTuple.java | 48 ++++++
.../storm/messaging/netty_unit_test.clj | 122 ++++++++------
.../test/clj/backtype/storm/messaging_test.clj | 25 ---
15 files changed, 506 insertions(+), 398 deletions(-)
----------------------------------------------------------------------