benchmarks/messaging.rb in dcell-0.10.0 vs benchmarks/messaging.rb in dcell-0.12.0.pre
- old
+ new
@@ -8,11 +8,11 @@
require 'dcell'
DCell.setup
DCell.run!
-RECEIVER_PORT = 12345
+RECEIVER_PORT = 2043
$receiver_pid = Process.spawn Gem.ruby, File.expand_path("../receiver.rb", __FILE__)
STDERR.print "Waiting for test node to start up..."
socket = nil
@@ -49,9 +49,15 @@
def complete
signal :complete
end
end
+
+DCell.start :id => "messaging_node", :addr => "tcp://127.0.0.1:2042",
+ :directory => {
+ :id => "benchmark_receiver",
+ :addr => "tcp://127.0.0.1:#{RECEIVER_PORT}"
+ }
receiver = DCell::Node['benchmark_receiver']
progenator = receiver[:progenator]
test = AsyncPerformanceTest.new progenator