From fcbf63e62c627deae76c1b8cb8c0876c536ed811 Mon Sep 17 00:00:00 2001
From: Jari Vetoniemi <jari.vetoniemi@indooratlas.com>
Date: Mon, 16 Mar 2020 18:49:26 +0900
Subject: Fresh start

---
 jni/ruby/sample/dualstack-httpd.rb | 55 ++++++++++++++++++++++++++++++++++++++
 1 file changed, 55 insertions(+)
 create mode 100644 jni/ruby/sample/dualstack-httpd.rb

(limited to 'jni/ruby/sample/dualstack-httpd.rb')

diff --git a/jni/ruby/sample/dualstack-httpd.rb b/jni/ruby/sample/dualstack-httpd.rb
new file mode 100644
index 0000000..a6d4d3a
--- /dev/null
+++ b/jni/ruby/sample/dualstack-httpd.rb
@@ -0,0 +1,55 @@
+# simple httpd
+
+# The code demonstrates how a multi-protocol daemon should be written.
+
+require "socket"
+require "thread"
+
+port = 8888
+res = Socket.getaddrinfo(nil, port, nil, Socket::SOCK_STREAM, nil, Socket::AI_PASSIVE)
+sockpool = []
+names = []
+threads = []
+
+res.each do |i|
+  s = TCPServer.new(i[3], i[1])
+  n = Socket.getnameinfo(s.getsockname, Socket::NI_NUMERICHOST|Socket::NI_NUMERICSERV).join(" port ")
+  sockpool.push s
+  names.push n
+end
+
+(0 .. sockpool.size - 1).each do |i|
+  mysock = sockpool[i]
+  myname = names[i]
+  STDERR.print "socket #{mysock} started, address #{myname}\n"
+  threads[i] = Thread.start do		# Thread.start cannot be used here!
+    ls = mysock	# copy to dynamic variable
+    t = Thread.current
+    STDERR.print "socket #{myname} listener started, pid #{$$} thread #{t}\n"
+    while true
+      as = ls.accept
+      Thread.start do
+        STDERR.print "socket #{myname} accepted, thread ", Thread.current, "\n"
+        s = as	# copy to dynamic variable
+        str = ''
+        while line = s.gets
+          break if line == "\r\n" or line == "\n"
+          str << line
+        end
+        STDERR.print "socket #{myname} got string\n"
+        s.write("HTTP/1.0 200 OK\n")
+        s.write("Content-type: text/plain\n\n")
+        s.write("this is test: my name is #{myname}, you sent:\n")
+        s.write("---start\n")
+        s.write(str)
+        s.write("---end\n")
+        s.close
+        STDERR.print "socket #{myname} processed, thread ", Thread.current, " terminating\n"
+      end
+    end
+  end
+end
+
+for t in threads
+  t.join
+end
-- 
cgit v1.2.3