From 4ce8dd5d091d63fcafddb447475ae36f769fd8c5 Mon Sep 17 00:00:00 2001 From: Patrick Simianer Date: Fri, 6 Mar 2015 18:25:04 +0100 Subject: first implementation of dtrain_net and downpour --- training/dtrain/feed.rb | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) create mode 100755 training/dtrain/feed.rb (limited to 'training/dtrain/feed.rb') diff --git a/training/dtrain/feed.rb b/training/dtrain/feed.rb new file mode 100755 index 00000000..fe8dd509 --- /dev/null +++ b/training/dtrain/feed.rb @@ -0,0 +1,22 @@ +#!/usr/bin/env ruby + +require 'nanomsg' + +port = ARGV[0] +sock = NanoMsg::PairSocket.new +addr = "tcp://127.0.0.1:#{port}" +sock.bind addr + +puts sock.recv +while true + line = STDIN.gets + if !line + sock.send 'shutdown' + break + end + sock.send line.strip + sleep 1 + sock.recv + sock.send "a=1 b=2" +end + -- cgit v1.2.3