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 2014/06/11 18:10:10 UTC
[38/50] [abbrv] git commit: Merge branch
'storm_async_netty_and_batch_api' of
https://github.com/clockfly/incubator-storm into STORM-297
Merge branch 'storm_async_netty_and_batch_api' of https://github.com/clockfly/incubator-storm into STORM-297
STORM-297: Storm performance scaling with CPU
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/701ac94d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/701ac94d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/701ac94d
Branch: refs/heads/security
Commit: 701ac94d9ad29192368ad63e7d6975794dc3c2f7
Parents: dd1d213 f6915d4
Author: Robert (Bobby) Evans <bo...@apache.org>
Authored: Sat Jun 7 10:30:33 2014 -0500
Committer: Robert (Bobby) Evans <bo...@apache.org>
Committed: Sat Jun 7 10:30:33 2014 -0500
----------------------------------------------------------------------
conf/defaults.yaml | 9 +
.../src/clj/backtype/storm/daemon/executor.clj | 1 +
.../src/clj/backtype/storm/daemon/worker.clj | 67 ++--
storm-core/src/clj/backtype/storm/disruptor.clj | 10 +-
.../src/clj/backtype/storm/messaging/loader.clj | 81 ++--
.../src/clj/backtype/storm/messaging/local.clj | 20 +-
storm-core/src/clj/backtype/storm/timer.clj | 5 +-
storm-core/src/jvm/backtype/storm/Config.java | 19 +
.../backtype/storm/messaging/IConnection.java | 15 +-
.../backtype/storm/messaging/netty/Client.java | 388 +++++++++++--------
.../backtype/storm/messaging/netty/Context.java | 41 +-
.../storm/messaging/netty/ControlMessage.java | 6 +-
.../storm/messaging/netty/MessageBatch.java | 5 +
.../storm/messaging/netty/MessageDecoder.java | 108 ++++--
.../netty/NettyRenameThreadFactory.java | 35 ++
.../backtype/storm/messaging/netty/Server.java | 145 ++++++-
.../netty/StormClientErrorHandler.java | 41 ++
.../messaging/netty/StormClientHandler.java | 87 -----
.../netty/StormClientPipelineFactory.java | 2 +-
.../messaging/netty/StormServerHandler.java | 40 +-
.../storm/testing/TestEventLogSpout.java | 105 +++++
.../storm/testing/TestEventOrderCheckBolt.java | 76 ++++
.../backtype/storm/utils/DisruptorQueue.java | 9 +-
.../backtype/storm/utils/TransferDrainer.java | 113 ++++++
.../src/jvm/backtype/storm/utils/Utils.java | 46 ++-
.../storm/messaging/netty_unit_test.clj | 46 ++-
.../test/clj/backtype/storm/messaging_test.clj | 35 +-
27 files changed, 1110 insertions(+), 445 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/701ac94d/conf/defaults.yaml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/701ac94d/storm-core/src/clj/backtype/storm/daemon/executor.clj
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/701ac94d/storm-core/src/clj/backtype/storm/daemon/worker.clj
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/701ac94d/storm-core/src/jvm/backtype/storm/Config.java
----------------------------------------------------------------------