You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by kn...@apache.org on 2015/11/23 22:08:15 UTC
[36/37] storm git commit: Merge branch 'STORM-855' of
https://github.com/knusbaum/incubator-storm
Merge branch 'STORM-855' of https://github.com/knusbaum/incubator-storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8d4d72ca
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8d4d72ca
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8d4d72ca
Branch: refs/heads/master
Commit: 8d4d72cac5e0e5080d6907a378e54381e0ed5db4
Parents: a8d253a e7a8c94
Author: Kyle Nusbaum <Ky...@gmail.com>
Authored: Mon Nov 23 15:06:16 2015 -0600
Committer: Kyle Nusbaum <Ky...@gmail.com>
Committed: Mon Nov 23 15:06:16 2015 -0600
----------------------------------------------------------------------
bin/storm.py | 38 +-
conf/defaults.yaml | 10 +
docs/documentation/Pacemaker.md | 108 +++
pom.xml | 1 +
storm-core/pom.xml | 7 +-
storm-core/src/clj/backtype/storm/cluster.clj | 279 +++-----
.../cluster_state/zookeeper_state_factory.clj | 157 +++++
.../clj/backtype/storm/command/heartbeats.clj | 52 ++
storm-core/src/clj/backtype/storm/config.clj | 6 +
.../src/clj/backtype/storm/daemon/worker.clj | 5 -
storm-core/src/clj/backtype/storm/util.clj | 16 +
.../org/apache/storm/pacemaker/pacemaker.clj | 237 +++++++
.../storm/pacemaker/pacemaker_state_factory.clj | 124 ++++
storm-core/src/jvm/backtype/storm/Config.java | 55 ++
.../backtype/storm/cluster/ClusterState.java | 208 ++++++
.../storm/cluster/ClusterStateContext.java | 41 ++
.../storm/cluster/ClusterStateFactory.java | 28 +
.../storm/cluster/ClusterStateListener.java | 22 +
.../backtype/storm/cluster/ConnectionState.java | 24 +
.../jvm/backtype/storm/cluster/DaemonType.java | 27 +
.../generated/HBAuthorizationException.java | 406 ++++++++++++
.../storm/generated/HBExecutionException.java | 406 ++++++++++++
.../jvm/backtype/storm/generated/HBMessage.java | 636 ++++++++++++++++++
.../backtype/storm/generated/HBMessageData.java | 640 ++++++++++++++++++
.../jvm/backtype/storm/generated/HBNodes.java | 461 +++++++++++++
.../jvm/backtype/storm/generated/HBPulse.java | 522 +++++++++++++++
.../jvm/backtype/storm/generated/HBRecords.java | 466 +++++++++++++
.../storm/generated/HBServerMessageType.java | 113 ++++
.../jvm/backtype/storm/generated/Nimbus.java | 36 +-
.../storm/messaging/netty/ControlMessage.java | 17 +-
.../messaging/netty/INettySerializable.java | 26 +
.../netty/KerberosSaslClientHandler.java | 152 +++++
.../netty/KerberosSaslNettyClient.java | 203 ++++++
.../netty/KerberosSaslNettyClientState.java | 31 +
.../netty/KerberosSaslNettyServer.java | 210 ++++++
.../netty/KerberosSaslNettyServerState.java | 30 +
.../netty/KerberosSaslServerHandler.java | 133 ++++
.../storm/messaging/netty/MessageDecoder.java | 4 +-
.../netty/NettyRenameThreadFactory.java | 10 +-
.../netty/NettyUncaughtExceptionHandler.java | 35 +
.../storm/messaging/netty/SaslMessageToken.java | 37 +-
.../storm/messaging/netty/SaslNettyClient.java | 22 +-
.../storm/messaging/netty/SaslNettyServer.java | 244 ++++---
.../messaging/netty/SaslNettyServerState.java | 13 +-
.../messaging/netty/SaslStormServerHandler.java | 21 +-
.../storm/messaging/netty/SaslUtils.java | 1 +
.../backtype/storm/messaging/netty/Server.java | 50 +-
.../messaging/netty/StormServerHandler.java | 24 +-
.../backtype/storm/security/auth/AuthUtils.java | 69 ++
.../src/jvm/backtype/storm/utils/Utils.java | 51 ++
.../storm/validation/ConfigValidation.java | 20 +-
.../storm/pacemaker/IServerMessageHandler.java | 25 +
.../apache/storm/pacemaker/PacemakerClient.java | 255 +++++++
.../storm/pacemaker/PacemakerClientHandler.java | 75 +++
.../apache/storm/pacemaker/PacemakerServer.java | 163 +++++
.../storm/pacemaker/codec/ThriftDecoder.java | 76 +++
.../storm/pacemaker/codec/ThriftEncoder.java | 110 ++++
.../pacemaker/codec/ThriftNettyClientCodec.java | 94 +++
.../pacemaker/codec/ThriftNettyServerCodec.java | 99 +++
.../jvm/storm/trident/util/TridentUtils.java | 33 +-
storm-core/src/py/storm/Nimbus.py | 14 +-
storm-core/src/py/storm/ttypes.py | 658 +++++++++++++++++++
storm-core/src/storm.thrift | 59 ++
.../test/clj/backtype/storm/cluster_test.clj | 7 +-
.../storm/pacemaker_state_factory_test.clj | 150 +++++
.../clj/org/apache/storm/pacemaker_test.clj | 242 +++++++
.../jvm/backtype/storm/TestConfigValidate.java | 18 +
67 files changed, 8135 insertions(+), 477 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8d4d72ca/bin/storm.py
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8d4d72ca/conf/defaults.yaml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8d4d72ca/storm-core/src/jvm/backtype/storm/Config.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8d4d72ca/storm-core/src/jvm/backtype/storm/utils/Utils.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8d4d72ca/storm-core/src/py/storm/ttypes.py
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8d4d72ca/storm-core/src/storm.thrift
----------------------------------------------------------------------