You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/02/23 22:11:33 UTC
[6/6] storm git commit: fix merge mistake by removing
test-server-delayed from netty_unit_test.clj
fix merge mistake by removing test-server-delayed from netty_unit_test.clj
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d7334849
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d7334849
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d7334849
Branch: refs/heads/master
Commit: d7334849b8d1262c7e82dc6f6e5d59d904c9ae4e
Parents: c291631
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Mon Feb 23 16:08:29 2015 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Mon Feb 23 16:08:29 2015 -0500
----------------------------------------------------------------------
.../storm/messaging/netty_unit_test.clj | 30 --------------------
1 file changed, 30 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/d7334849/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 51d03b1..7188d7a 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
@@ -93,36 +93,6 @@
(.close server)
(.term context)))
-(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
- STORM-MESSAGING-NETTY-MAX-SLEEP-MS 5000
- STORM-MESSAGING-NETTY-SERVER-WORKER-THREADS 1
- STORM-MESSAGING-NETTY-CLIENT-WORKER-THREADS 1
- }
- context (TransportFactory/makeContext storm-conf)
- client (.connect context nil "localhost" port)
-
- server (Thread.
- (fn []
- (Thread/sleep 1000)
- (let [server (.bind context nil port)
- iter (.recv server 0 0)
- resp (.next iter)]
- (is (= task (.task resp)))
- (is (= req_msg (String. (.message resp))))
- (.close server)
- )))
- _ (.start server)
- _ (.send client task (.getBytes req_msg))
- ]
- (.close client)
- (.join server)
- (.term context)))
(deftest test-batch
(let [num-messages 100000