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/07/30 18:16:43 UTC
[7/9] git commit: STORM-348: Netty SASL Authentication
STORM-348: Netty SASL Authentication
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/90cf0e6c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/90cf0e6c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/90cf0e6c
Branch: refs/heads/security
Commit: 90cf0e6c21df978462d29fe906ad0f2a6adcdb1f
Parents: 02e7949
Author: Raghavendra Nandagopal <sp...@gmail.com>
Authored: Tue Jul 29 17:32:38 2014 -0700
Committer: Raghavendra Nandagopal <sp...@gmail.com>
Committed: Tue Jul 29 17:32:38 2014 -0700
----------------------------------------------------------------------
.../test/clj/backtype/storm/messaging/netty_integration_test.clj | 1 +
storm-core/test/clj/backtype/storm/messaging/netty_unit_test.clj | 4 ++++
2 files changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/90cf0e6c/storm-core/test/clj/backtype/storm/messaging/netty_integration_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/messaging/netty_integration_test.clj b/storm-core/test/clj/backtype/storm/messaging/netty_integration_test.clj
index 8534c82..dea4abe 100644
--- a/storm-core/test/clj/backtype/storm/messaging/netty_integration_test.clj
+++ b/storm-core/test/clj/backtype/storm/messaging/netty_integration_test.clj
@@ -25,6 +25,7 @@
(with-simulated-time-local-cluster [cluster :supervisors 4 :supervisor-slot-port-min 6710
:daemon-conf {STORM-LOCAL-MODE-ZMQ true
STORM-MESSAGING-TRANSPORT "backtype.storm.messaging.netty.Context"
+ STORM_MESSAGING_NETTY_AUTHENTICATION false
STORM-MESSAGING-NETTY-BUFFER-SIZE 1024000
STORM-MESSAGING-NETTY-MAX-RETRIES 10
STORM-MESSAGING-NETTY-MIN-SLEEP-MS 1000
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/90cf0e6c/storm-core/test/clj/backtype/storm/messaging/netty_unit_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/messaging/netty_unit_test.clj b/storm-core/test/clj/backtype/storm/messaging/netty_unit_test.clj
index ea7b8dc..04d25ec 100644
--- a/storm-core/test/clj/backtype/storm/messaging/netty_unit_test.clj
+++ b/storm-core/test/clj/backtype/storm/messaging/netty_unit_test.clj
@@ -26,6 +26,7 @@
(deftest test-basic
(let [req_msg (String. "0123456789abcdefghijklmnopqrstuvwxyz")
storm-conf {STORM-MESSAGING-TRANSPORT "backtype.storm.messaging.netty.Context"
+ STORM_MESSAGING_NETTY_AUTHENTICATION false
STORM-MESSAGING-NETTY-BUFFER-SIZE 1024
STORM-MESSAGING-NETTY-MAX-RETRIES 10
STORM-MESSAGING-NETTY-MIN-SLEEP-MS 1000
@@ -48,6 +49,7 @@
(deftest test-large-msg
(let [req_msg (apply str (repeat 2048000 'c'))
storm-conf {STORM-MESSAGING-TRANSPORT "backtype.storm.messaging.netty.Context"
+ STORM_MESSAGING_NETTY_AUTHENTICATION false
STORM-MESSAGING-NETTY-BUFFER-SIZE 102400
STORM-MESSAGING-NETTY-MAX-RETRIES 10
STORM-MESSAGING-NETTY-MIN-SLEEP-MS 1000
@@ -70,6 +72,7 @@
(deftest test-server-delayed
(let [req_msg (String. "0123456789abcdefghijklmnopqrstuvwxyz")
storm-conf {STORM-MESSAGING-TRANSPORT "backtype.storm.messaging.netty.Context"
+ STORM_MESSAGING_NETTY_AUTHENTICATION false
STORM-MESSAGING-NETTY-BUFFER-SIZE 1024
STORM-MESSAGING-NETTY-MAX-RETRIES 10
STORM-MESSAGING-NETTY-MIN-SLEEP-MS 1000
@@ -99,6 +102,7 @@
(deftest test-batch
(let [storm-conf {STORM-MESSAGING-TRANSPORT "backtype.storm.messaging.netty.Context"
+ STORM_MESSAGING_NETTY_AUTHENTICATION false
STORM-MESSAGING-NETTY-BUFFER-SIZE 1024000
STORM-MESSAGING-NETTY-MAX-RETRIES 10
STORM-MESSAGING-NETTY-MIN-SLEEP-MS 1000