From e76d0b1194c912f7329908d6f799eeccf9ab5456 Mon Sep 17 00:00:00 2001 From: Patrick Simianer Date: Wed, 13 May 2015 20:32:08 +0200 Subject: nanomsg --- nanomsg/slave.rb | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 nanomsg/slave.rb (limited to 'nanomsg/slave.rb') diff --git a/nanomsg/slave.rb b/nanomsg/slave.rb new file mode 100644 index 0000000..3183df8 --- /dev/null +++ b/nanomsg/slave.rb @@ -0,0 +1,25 @@ +require 'nanomsg' + +sock = NanoMsg::PairSocket.new +sock.connect "tcp://127.0.0.1:#{ARGV[0]}" + +sock.recv +sleep 1 +sock.send "hello there" + +i = 0 +while true + msg = sock.recv + if msg == "shutdown" + sock.send "shutting down" + break + end + me, id, input = msg.split + sleep 1 + sock.send "#{me} answers #{id}" + sleep 1 + sock.send "----2#{i}----" if i%2==0 + sleep 1 + i += 1 +end + -- cgit v1.2.3