Updated for LuaSocket 1.2.

author: Diego Nehab <diego@tecgraf.puc-rio.br> 2001-01-25 22:00:18 +0000
committer: Diego Nehab <diego@tecgraf.puc-rio.br> 2001-01-25 22:00:18 +0000
commit: f6b95052256fa9609a8f8a2c8abfe0af1e18706f (patch)
tree: 68e72db02326d4938f12428f8ef8cf0d90c877fc
parent: 2bb209ab9eb746fdfb9b8f5c83eee12b40fc211e (diff)
download: luasocket-f6b95052256fa9609a8f8a2c8abfe0af1e18706f.tar.gz
luasocket-f6b95052256fa9609a8f8a2c8abfe0af1e18706f.tar.bz2
luasocket-f6b95052256fa9609a8f8a2c8abfe0af1e18706f.zip
1 files changed, 104 insertions, 90 deletions
diff --git a/test/testsrvr.lua b/test/testsrvr.lua
index 99ecd2a..d69b5ab 100644
--- a/test/testsrvr.lua
+++ b/test/testsrvr.lua
@@ -1,90 +1,104 @@
-----------------------------------------------------------------------------
+-----------------------------------------------------------------------------
-- LuaSocket automated test module
+-- LuaSocket automated test module
-- server.lua
+-- server.lua
-- This is the server module. It's completely controled by the client module
+-- This is the server module. It's completely controled by the client module
-- by the use of a control connection.
+-- by the use of a control connection.
-----------------------------------------------------------------------------
+-----------------------------------------------------------------------------
-----------------------------------------------------------------------------
+-----------------------------------------------------------------------------
-- Read command definitions
+-- Read command definitions
-----------------------------------------------------------------------------
+-----------------------------------------------------------------------------
-dofile("command.lua")
+assert(dofile("testcmd.lua"))
-test_debug_mode()
+test_debug_mode()
-----------------------------------------------------------------------------
+-----------------------------------------------------------------------------
-- Bind to address and wait for control connection
+-- Get host and port from command line
-----------------------------------------------------------------------------
+-----------------------------------------------------------------------------
-server, err = bind(HOST, PORT)
+HOST = "localhost"
-if not server then
+PORT = 2020
-        print(err)
+if arg then
-        exit(1)
+    HOST = arg[1] or HOST
-end
+    PORT = arg[2] or PORT
-print("server: waiting for control connection...")
+end
-control = server:accept()
-print("server: control connection stablished!")
+-----------------------------------------------------------------------------
+-- Start control connection
-----------------------------------------------------------------------------
+-----------------------------------------------------------------------------
-- Executes a command, detecting any possible failures
+server, err = bind(HOST, PORT)
-- Input
+if not server then
--   cmd: command to be executed
+        fail(err)
--   par: command parameters, if needed
+        exit(1)
-----------------------------------------------------------------------------
+end
-function execute_command(cmd, par)
+print("server: waiting for control connection...")
-        if cmd == CONNECT then
+control = accept(server)
-                print("server: waiting for data connection...")
+print("server: control connection stablished!")
-                data = server:accept()
-                if not data then
+-----------------------------------------------------------------------------
-                        fail("server: unable to start data connection!")
+-- Executes a command, detecting any possible failures
-                else
+-- Input
-                        print("server: data connection stablished!")
+--   cmd: command to be executed
-                end
+--   par: command parameters, if needed
-        elseif cmd == CLOSE then
+-----------------------------------------------------------------------------
-                print("server: closing connection with client...")
+function execute_command(cmd, par)
-                if data then 
+        if cmd == CONNECT then
-                        data:close()
+                print("server: waiting for data connection...")
-                        data = nil
+                data = accept(server)
-                end
+                if not data then
-        elseif cmd == ECHO_LINE then
+                        fail("server: unable to start data connection!")
-                str, err = data:receive()
+                else
-                if err then fail("server: " .. err) end
+                        print("server: data connection stablished!")
-                err = data:send(str, "\n")
+                end
-                if err then fail("server: " .. err) end
+        elseif cmd == CLOSE then
-        elseif cmd == ECHO_BLOCK then
+                print("server: closing connection with client...")
-                str, err = data:receive(par)
+                if data then 
-                if err then fail("server: " .. err) end
+                        close(data)
-                err = data:send(str)
+                        data = nil
-                if err then fail("server: " .. err) end
+                end
-        elseif cmd == RECEIVE_BLOCK then
+        elseif cmd == ECHO_LINE then
-                str, err = data:receive(par)
+                str, err = receive(data)
-        elseif cmd == SEND_BLOCK then
+                if err then fail("server: " .. err) end
-                err = data:send(str)
+                err = send(data, str, "\n")
-        elseif cmd == ECHO_TIMEOUT then
+                if err then fail("server: " .. err) end
-                str, err = data:receive(par)
+        elseif cmd == ECHO_BLOCK then
-                if err then fail("server: " .. err) end
+                str, err = receive(data, par)
-                err = data:send(str)
+                print(format("server: received %d bytes", strlen(str)))
-                if err then fail("server: " .. err) end
+                if err then fail("server: " .. err) end
-        elseif cmd == COMMAND then
+                print(format("server: sending %d bytes", strlen(str)))
-                cmd, par = get_command()
+                err = send(data, str)
-                send_command(cmd, par)
+                if err then fail("server: " .. err) end
-        elseif cmd == EXIT then
+        elseif cmd == RECEIVE_BLOCK then
-                print("server: exiting...")
+                str, err = receive(data, par)
-                exit(0)
+                print(format("server: received %d bytes", strlen(str)))
-        elseif cmd == SYNC then
+        elseif cmd == SEND_BLOCK then
-                print("server: synchronizing...")
+                print(format("server: sending %d bytes", strlen(str)))
-                send_command(SYNC)
+                err = send(data, str)
-        elseif cmd == SLEEP then
+        elseif cmd == ECHO_TIMEOUT then
-                print("server: sleeping for " .. par .. " seconds...")
+                str, err = receive(data, par)
-                sleep(par)
+                if err then fail("server: " .. err) end
-                print("server: woke up!")
+                err = send(data, str)
-        end
+                if err then fail("server: " .. err) end
-end
+        elseif cmd == COMMAND then
+                cmd, par = get_command()
-----------------------------------------------------------------------------
+                send_command(cmd, par)
-- Loop forever, accepting and executing commands
+        elseif cmd == EXIT then
-----------------------------------------------------------------------------
+                print("server: exiting...")
-while 1 do
+                exit(0)
-        cmd, par = get_command()
+        elseif cmd == SYNC then
-        if not cmd then fail("server: " .. par) end
+                print("server: synchronizing...")
-        print_command(cmd, par)
+                send_command(SYNC)
-        execute_command(cmd, par)
+        elseif cmd == SLEEP then
-end
+                print("server: sleeping for " .. par .. " seconds...")
+                sleep(par)
+                print("server: woke up!")
+        end
+end
+-----------------------------------------------------------------------------
+-- Loop forever, accepting and executing commands
+-----------------------------------------------------------------------------
+while 1 do
+        cmd, par = get_command()
+        if not cmd then fail("server: " .. par) end
+        print_command(cmd, par)
+        execute_command(cmd, par)
+end
author	Diego Nehab <diego@tecgraf.puc-rio.br>	2001-01-25 22:00:18 +0000
committer	Diego Nehab <diego@tecgraf.puc-rio.br>	2001-01-25 22:00:18 +0000
commit	f6b95052256fa9609a8f8a2c8abfe0af1e18706f (patch)
tree	68e72db02326d4938f12428f8ef8cf0d90c877fc
parent	2bb209ab9eb746fdfb9b8f5c83eee12b40fc211e (diff)
download	luasocket-f6b95052256fa9609a8f8a2c8abfe0af1e18706f.tar.gz luasocket-f6b95052256fa9609a8f8a2c8abfe0af1e18706f.tar.bz2 luasocket-f6b95052256fa9609a8f8a2c8abfe0af1e18706f.zip

diff --git a/test/testsrvr.lua b/test/testsrvr.lua index 99ecd2a..d69b5ab 100644 --- a/test/testsrvr.lua +++ b/test/testsrvr.lua
@@ -1,90 +1,104 @@
1	-----------------------------------------------------------------------------	1	-----------------------------------------------------------------------------
2	-- LuaSocket automated test module	2	-- LuaSocket automated test module
3	-- server.lua	3	-- server.lua
4	-- This is the server module. It's completely controled by the client module	4	-- This is the server module. It's completely controled by the client module
5	-- by the use of a control connection.	5	-- by the use of a control connection.
6	-----------------------------------------------------------------------------	6	-----------------------------------------------------------------------------
7		7
8	-----------------------------------------------------------------------------	8	-----------------------------------------------------------------------------
9	-- Read command definitions	9	-- Read command definitions
10	-----------------------------------------------------------------------------	10	-----------------------------------------------------------------------------
11	dofile("command.lua")	11	assert(dofile("testcmd.lua"))
12	test_debug_mode()	12	test_debug_mode()
13		13
14	-----------------------------------------------------------------------------	14	-----------------------------------------------------------------------------
15	-- Bind to address and wait for control connection	15	-- Get host and port from command line
16	-----------------------------------------------------------------------------	16	-----------------------------------------------------------------------------
17	server, err = bind(HOST, PORT)	17	HOST = "localhost"
18	if not server then	18	PORT = 2020
19	print(err)	19	if arg then
20	exit(1)	20	HOST = arg[1] or HOST
21	end	21	PORT = arg[2] or PORT
22	print("server: waiting for control connection...")	22	end
23	control = server:accept()	23
24	print("server: control connection stablished!")	24	-----------------------------------------------------------------------------
25		25	-- Start control connection
26	-----------------------------------------------------------------------------	26	-----------------------------------------------------------------------------
27	-- Executes a command, detecting any possible failures	27	server, err = bind(HOST, PORT)
28	-- Input	28	if not server then
29	-- cmd: command to be executed	29	fail(err)
30	-- par: command parameters, if needed	30	exit(1)
31	-----------------------------------------------------------------------------	31	end
32	function execute_command(cmd, par)	32	print("server: waiting for control connection...")
33	if cmd == CONNECT then	33	control = accept(server)
34	print("server: waiting for data connection...")	34	print("server: control connection stablished!")
35	data = server:accept()	35
36	if not data then	36	-----------------------------------------------------------------------------
37	fail("server: unable to start data connection!")	37	-- Executes a command, detecting any possible failures
38	else	38	-- Input
39	print("server: data connection stablished!")	39	-- cmd: command to be executed
40	end	40	-- par: command parameters, if needed
41	elseif cmd == CLOSE then	41	-----------------------------------------------------------------------------
42	print("server: closing connection with client...")	42	function execute_command(cmd, par)
43	if data then	43	if cmd == CONNECT then
44	data:close()	44	print("server: waiting for data connection...")
45	data = nil	45	data = accept(server)
46	end	46	if not data then
47	elseif cmd == ECHO_LINE then	47	fail("server: unable to start data connection!")
48	str, err = data:receive()	48	else
49	if err then fail("server: " .. err) end	49	print("server: data connection stablished!")
50	err = data:send(str, "\n")	50	end
51	if err then fail("server: " .. err) end	51	elseif cmd == CLOSE then
52	elseif cmd == ECHO_BLOCK then	52	print("server: closing connection with client...")
53	str, err = data:receive(par)	53	if data then
54	if err then fail("server: " .. err) end	54	close(data)
55	err = data:send(str)	55	data = nil
56	if err then fail("server: " .. err) end	56	end
57	elseif cmd == RECEIVE_BLOCK then	57	elseif cmd == ECHO_LINE then
58	str, err = data:receive(par)	58	str, err = receive(data)
59	elseif cmd == SEND_BLOCK then	59	if err then fail("server: " .. err) end
60	err = data:send(str)	60	err = send(data, str, "\n")
61	elseif cmd == ECHO_TIMEOUT then	61	if err then fail("server: " .. err) end
62	str, err = data:receive(par)	62	elseif cmd == ECHO_BLOCK then
63	if err then fail("server: " .. err) end	63	str, err = receive(data, par)
64	err = data:send(str)	64	print(format("server: received %d bytes", strlen(str)))
65	if err then fail("server: " .. err) end	65	if err then fail("server: " .. err) end
66	elseif cmd == COMMAND then	66	print(format("server: sending %d bytes", strlen(str)))
67	cmd, par = get_command()	67	err = send(data, str)
68	send_command(cmd, par)	68	if err then fail("server: " .. err) end
69	elseif cmd == EXIT then	69	elseif cmd == RECEIVE_BLOCK then
70	print("server: exiting...")	70	str, err = receive(data, par)
71	exit(0)	71	print(format("server: received %d bytes", strlen(str)))
72	elseif cmd == SYNC then	72	elseif cmd == SEND_BLOCK then
73	print("server: synchronizing...")	73	print(format("server: sending %d bytes", strlen(str)))
74	send_command(SYNC)	74	err = send(data, str)
75	elseif cmd == SLEEP then	75	elseif cmd == ECHO_TIMEOUT then
76	print("server: sleeping for " .. par .. " seconds...")	76	str, err = receive(data, par)
77	sleep(par)	77	if err then fail("server: " .. err) end
78	print("server: woke up!")	78	err = send(data, str)
79	end	79	if err then fail("server: " .. err) end
80	end	80	elseif cmd == COMMAND then
81		81	cmd, par = get_command()
82	-----------------------------------------------------------------------------	82	send_command(cmd, par)
83	-- Loop forever, accepting and executing commands	83	elseif cmd == EXIT then
84	-----------------------------------------------------------------------------	84	print("server: exiting...")
85	while 1 do	85	exit(0)
86	cmd, par = get_command()	86	elseif cmd == SYNC then
87	if not cmd then fail("server: " .. par) end	87	print("server: synchronizing...")
88	print_command(cmd, par)	88	send_command(SYNC)
89	execute_command(cmd, par)	89	elseif cmd == SLEEP then
90	end	90	print("server: sleeping for " .. par .. " seconds...")
		91	sleep(par)
		92	print("server: woke up!")
		93	end
		94	end
		95
		96	-----------------------------------------------------------------------------
		97	-- Loop forever, accepting and executing commands
		98	-----------------------------------------------------------------------------
		99	while 1 do
		100	cmd, par = get_command()
		101	if not cmd then fail("server: " .. par) end
		102	print_command(cmd, par)
		103	execute_command(cmd, par)
		104	end