summaryrefslogtreecommitdiff
path: root/jni/ruby/sample/svr.rb
diff options
context:
space:
mode:
authorJari Vetoniemi <jari.vetoniemi@indooratlas.com>2020-03-16 18:49:26 +0900
committerJari Vetoniemi <jari.vetoniemi@indooratlas.com>2020-03-30 00:39:06 +0900
commitfcbf63e62c627deae76c1b8cb8c0876c536ed811 (patch)
tree64cb17de3f41a2b6fef2368028fbd00349946994 /jni/ruby/sample/svr.rb
Fresh start
Diffstat (limited to 'jni/ruby/sample/svr.rb')
-rw-r--r--jni/ruby/sample/svr.rb34
1 files changed, 34 insertions, 0 deletions
diff --git a/jni/ruby/sample/svr.rb b/jni/ruby/sample/svr.rb
new file mode 100644
index 0000000..eb49ccf
--- /dev/null
+++ b/jni/ruby/sample/svr.rb
@@ -0,0 +1,34 @@
+# socket example - server side
+# usage: ruby svr.rb
+
+# this server might be blocked by an ill-behaved client.
+# see tsvr.rb which is safe from client blocking.
+
+require "socket"
+
+gs = TCPServer.open(0)
+addr = gs.addr
+addr.shift
+printf("server is on %s\n", addr.join(":"))
+socks = [gs]
+
+loop do
+ nsock = select(socks);
+ next if nsock == nil
+ for s in nsock[0]
+ if s == gs
+ ns = s.accept
+ socks.push(ns)
+ print(s, " is accepted\n")
+ else
+ if s.eof?
+ print(s, " is gone\n")
+ s.close
+ socks.delete(s)
+ # single thread gets may block whole service
+ elsif str = s.gets
+ s.write(str)
+ end
+ end
+ end
+end