src/test/scala/net/lag/smile/kestrel/KestrelSpec.scala @@ -444,26 +444,33 @@ class KestrelTest extends StressTest { // // Unit-like tests // + log.debug("unit-like tests") suite(1, 3, 10, 0, 250, 250) // // Test client actor compatability. // + log.debug("pester tests") testPester(512) // // Single-Queue tests // + log.debug("single-queue tests") suite(1, 20000, 256, 8000, 250, 5) // // 3-Queue tests // + log.debug("3-queue 1 tests") suite(3, 10000, 256, 8000, 250, 10) + log.debug("3-queue 2 tests") suite(3, 10000, 2, 4, 250, 5) // 12-Queue tests + log.debug("12-queue 1 tests") suite(12, 5000, 2, 4, 1000, 10) + log.debug("12-queue list tests") List(2, 15, 25, 50, 75).foreach(pause => suite(12, 1000, 2, 4, pause * 10, pause)) log.info("TESTS PASS") @@ -472,12 +479,13 @@ class KestrelTest extends StressTest { object Kestrel { def main(args: Array[String]): Unit = { - if (args.size != 1) { - println("Must specify 1 host") + val hostPort = System.getProperty("hostport") + if (hostPort == null) { + println("hostport property unset. -Dhostport=\"localhost:22133\"") } else { Configgy.configure("test.conf") val k = new KestrelTest() - k.setHosts(args) + k.setHosts(Array(hostPort)) k.go() } } src/test/scala/net/lag/smile/stress/Kestrel.scala src/test/scala/net/lag/smile/kestrel/KestrelClientSpec.scala a3a701c320ed38c0a8addb5f0e9fa25499e2cfa7 a536e9b2c496dd56097e8805f31a9c81848c2046 Robey Pointer robey@twitter.com http://github.com/robey/smile/commit/4b323c75f7a9b720c41b67cc7cd4f4dce436feb0 4b323c75f7a9b720c41b67cc7cd4f4dce436feb0 2009-11-02T17:16:31-08:00 2009-11-02T17:16:31-08:00 Merge remote branch 'jkalucki/master' 49b8d25bb3389f470f830787ba79ac2c791f4e17 Robey Pointer robey@twitter.com