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 <[email protected]> Authored: Mon Feb 23 16:08:29 2015 -0500 Committer: P. Taylor Goetz <[email protected]> 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
