aboutsummaryrefslogtreecommitdiffstats
path: root/sample/dualstack-httpd.rb
diff options
context:
space:
mode:
authorknu <knu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2001-05-26 03:38:39 +0000
committerknu <knu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2001-05-26 03:38:39 +0000
commita5d64434dd91fa463b7130e11cf1734d0ebd0287 (patch)
treea12fdf6faf528343d284ec5848a6bf779841204e /sample/dualstack-httpd.rb
parent32513e9dcebe6bb04c5eb239f152493c92edae34 (diff)
downloadruby-a5d64434dd91fa463b7130e11cf1734d0ebd0287.tar.gz
Synchronize MANIFEST with reality. Add missing files.
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@1463 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'sample/dualstack-httpd.rb')
-rw-r--r--sample/dualstack-httpd.rb55
1 files changed, 55 insertions, 0 deletions
diff --git a/sample/dualstack-httpd.rb b/sample/dualstack-httpd.rb
new file mode 100644
index 0000000000..893b29feba
--- /dev/null
+++ b/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