diff options
author | Diego Nehab <diego@tecgraf.puc-rio.br> | 2001-03-06 20:16:17 +0000 |
---|---|---|
committer | Diego Nehab <diego@tecgraf.puc-rio.br> | 2001-03-06 20:16:17 +0000 |
commit | bbb4b3e2c19376ee124033b68f699d44f48bee52 (patch) | |
tree | 7047870eec31cee296a6688fc3fa87af84e8cee1 | |
parent | 22a5d3f669c2ad57b422b4cfa8e06cb4713aa12f (diff) | |
download | luasocket-bbb4b3e2c19376ee124033b68f699d44f48bee52.tar.gz luasocket-bbb4b3e2c19376ee124033b68f699d44f48bee52.tar.bz2 luasocket-bbb4b3e2c19376ee124033b68f699d44f48bee52.zip |
Updated to remove use of global methods. Conforming to
LuaSocket release 1.2.1
-rw-r--r-- | test/testclnt.lua | 66 | ||||
-rw-r--r-- | test/testsrvr.lua | 22 |
2 files changed, 44 insertions, 44 deletions
diff --git a/test/testclnt.lua b/test/testclnt.lua index 97e06f2..8ad0f38 100644 --- a/test/testclnt.lua +++ b/test/testclnt.lua | |||
@@ -59,7 +59,7 @@ end | |||
59 | ----------------------------------------------------------------------------- | 59 | ----------------------------------------------------------------------------- |
60 | function reconnect() | 60 | function reconnect() |
61 | if data then | 61 | if data then |
62 | close(data) | 62 | data:close() |
63 | send_command(CLOSE) | 63 | send_command(CLOSE) |
64 | data = nil | 64 | data = nil |
65 | end | 65 | end |
@@ -105,9 +105,9 @@ function test_asciiline(len) | |||
105 | str10 = strrep("aZb.c#dAe?", floor(len/10)) | 105 | str10 = strrep("aZb.c#dAe?", floor(len/10)) |
106 | str = str .. str10 | 106 | str = str .. str10 |
107 | write("testing ", len, " byte(s) line\n") | 107 | write("testing ", len, " byte(s) line\n") |
108 | err = send(data, str, "\n") | 108 | err = data:send(str, "\n") |
109 | if err then fail(err) end | 109 | if err then fail(err) end |
110 | back, err = receive(data) | 110 | back, err = data:receive() |
111 | if err then fail(err) end | 111 | if err then fail(err) end |
112 | if back == str then pass("lines match") | 112 | if back == str then pass("lines match") |
113 | else fail("lines don't match") end | 113 | else fail("lines don't match") end |
@@ -123,10 +123,10 @@ function test_closed() | |||
123 | reconnect() | 123 | reconnect() |
124 | print("testing close while reading line") | 124 | print("testing close while reading line") |
125 | send_command(ECHO_BLOCK, len) | 125 | send_command(ECHO_BLOCK, len) |
126 | send(data, str) | 126 | data:send(str) |
127 | send_command(CLOSE) | 127 | send_command(CLOSE) |
128 | -- try to get a line | 128 | -- try to get a line |
129 | back, err = receive(data) | 129 | back, err = data:receive() |
130 | if not err then fail("shold have gotten 'closed'.") | 130 | if not err then fail("shold have gotten 'closed'.") |
131 | elseif err ~= "closed" then fail("got '"..err.."' instead of 'closed'.") | 131 | elseif err ~= "closed" then fail("got '"..err.."' instead of 'closed'.") |
132 | elseif str ~= back then fail("didn't receive what i should 'closed'.") | 132 | elseif str ~= back then fail("didn't receive what i should 'closed'.") |
@@ -134,10 +134,10 @@ function test_closed() | |||
134 | reconnect() | 134 | reconnect() |
135 | print("testing close while reading block") | 135 | print("testing close while reading block") |
136 | send_command(ECHO_BLOCK, len) | 136 | send_command(ECHO_BLOCK, len) |
137 | send(data, str) | 137 | data:send(str) |
138 | send_command(CLOSE) | 138 | send_command(CLOSE) |
139 | -- try to get a line | 139 | -- try to get a line |
140 | back, err = receive(data, 2*len) | 140 | back, err = data:receive(2*len) |
141 | if not err then fail("shold have gotten 'closed'.") | 141 | if not err then fail("shold have gotten 'closed'.") |
142 | elseif err ~= "closed" then fail("got '"..err.."' instead of 'closed'.") | 142 | elseif err ~= "closed" then fail("got '"..err.."' instead of 'closed'.") |
143 | elseif str ~= back then fail("didn't receive what I should.") | 143 | elseif str ~= back then fail("didn't receive what I should.") |
@@ -157,9 +157,9 @@ function test_rawline(len) | |||
157 | str10 = strrep(strchar(120,21,77,4,5,0,7,36,44,100), floor(len/10)) | 157 | str10 = strrep(strchar(120,21,77,4,5,0,7,36,44,100), floor(len/10)) |
158 | str = str .. str10 | 158 | str = str .. str10 |
159 | write("testing ", len, " byte(s) line\n") | 159 | write("testing ", len, " byte(s) line\n") |
160 | err = send(data, str, "\n") | 160 | err = data:send(str, "\n") |
161 | if err then fail(err) end | 161 | if err then fail(err) end |
162 | back, err = receive(data) | 162 | back, err = data:receive() |
163 | if err then fail(err) end | 163 | if err then fail(err) end |
164 | if back == str then pass("lines match") | 164 | if back == str then pass("lines match") |
165 | else fail("lines don't match") end | 165 | else fail("lines don't match") end |
@@ -177,12 +177,12 @@ function test_block(len) | |||
177 | send_command(ECHO_BLOCK, len) | 177 | send_command(ECHO_BLOCK, len) |
178 | write("testing ", len, " byte(s) block\n") | 178 | write("testing ", len, " byte(s) block\n") |
179 | s1 = strrep("x", half) | 179 | s1 = strrep("x", half) |
180 | err = send(data, s1) | 180 | err = data:send(s1) |
181 | if err then fail(err) end | 181 | if err then fail(err) end |
182 | s2 = strrep("y", len-half) | 182 | s2 = strrep("y", len-half) |
183 | err = send(data, s2) | 183 | err = data:send(s2) |
184 | if err then fail(err) end | 184 | if err then fail(err) end |
185 | back, err = receive(data, len) | 185 | back, err = data:receive(len) |
186 | if err then fail(err) end | 186 | if err then fail(err) end |
187 | if back == s1..s2 then pass("blocks match") | 187 | if back == s1..s2 then pass("blocks match") |
188 | else fail("blocks don't match") end | 188 | else fail("blocks don't match") end |
@@ -229,15 +229,15 @@ function test_blockedtimeout(len, t, s) | |||
229 | send_command(RECEIVE_BLOCK, len) | 229 | send_command(RECEIVE_BLOCK, len) |
230 | write("testing ", len, " bytes, ", t, | 230 | write("testing ", len, " bytes, ", t, |
231 | "s block timeout, ", s, "s sleep\n") | 231 | "s block timeout, ", s, "s sleep\n") |
232 | timeout(data, t) | 232 | data:timeout(t) |
233 | str = strrep("a", 2*len) | 233 | str = strrep("a", 2*len) |
234 | err, total = send(data, str) | 234 | err, total = data:send(str) |
235 | if blockedtimed_out(t, s, err, "send") then return end | 235 | if blockedtimed_out(t, s, err, "send") then return end |
236 | if err then fail(err) end | 236 | if err then fail(err) end |
237 | send_command(SEND_BLOCK) | 237 | send_command(SEND_BLOCK) |
238 | send_command(SLEEP, s) | 238 | send_command(SLEEP, s) |
239 | send_command(SEND_BLOCK) | 239 | send_command(SEND_BLOCK) |
240 | back, err = receive(data, 2*len) | 240 | back, err = data:receive(2*len) |
241 | if blockedtimed_out(t, s, err, "receive") then return end | 241 | if blockedtimed_out(t, s, err, "receive") then return end |
242 | if err then fail(err) end | 242 | if err then fail(err) end |
243 | if back == str then pass("blocks match") | 243 | if back == str then pass("blocks match") |
@@ -278,16 +278,16 @@ function test_returntimeout(len, t, s) | |||
278 | send_command(RECEIVE_BLOCK, len) | 278 | send_command(RECEIVE_BLOCK, len) |
279 | write("testing ", len, " bytes, ", t, | 279 | write("testing ", len, " bytes, ", t, |
280 | "s return timeout, ", s, "s sleep\n") | 280 | "s return timeout, ", s, "s sleep\n") |
281 | timeout(data, t, "return") | 281 | data:timeout(t, "return") |
282 | str = strrep("a", 2*len) | 282 | str = strrep("a", 2*len) |
283 | err, total, delta = send(data, str) | 283 | err, total, delta = data:send(str) |
284 | print("sent in " .. delta .. "s") | 284 | print("sent in " .. delta .. "s") |
285 | if returntimed_out(delta, t, err) then return end | 285 | if returntimed_out(delta, t, err) then return end |
286 | if err then fail("unexpected error: " .. err) end | 286 | if err then fail("unexpected error: " .. err) end |
287 | send_command(SEND_BLOCK) | 287 | send_command(SEND_BLOCK) |
288 | send_command(SLEEP, s) | 288 | send_command(SLEEP, s) |
289 | send_command(SEND_BLOCK) | 289 | send_command(SEND_BLOCK) |
290 | back, err, delta = receive(data, 2*len) | 290 | back, err, delta = data:receive(2*len) |
291 | print("received in " .. delta .. "s") | 291 | print("received in " .. delta .. "s") |
292 | if returntimed_out(delta, t, err) then return end | 292 | if returntimed_out(delta, t, err) then return end |
293 | if err then fail("unexpected error: " .. err) end | 293 | if err then fail("unexpected error: " .. err) end |
@@ -308,37 +308,37 @@ function test_patterns() | |||
308 | block = block .. unix_line1 .. "\n" .. unix_line2 .. "\n" | 308 | block = block .. unix_line1 .. "\n" .. unix_line2 .. "\n" |
309 | block = block .. block | 309 | block = block .. block |
310 | send_command(ECHO_BLOCK, strlen(block)) | 310 | send_command(ECHO_BLOCK, strlen(block)) |
311 | err = send(data, block) | 311 | err = data:send(block) |
312 | if err then fail(err) end | 312 | if err then fail(err) end |
313 | local back = receive(data, "*l") | 313 | local back = data:receive("*l") |
314 | if back ~= dos_line1 then fail("'*l' failed") end | 314 | if back ~= dos_line1 then fail("'*l' failed") end |
315 | back = receive(data, "*l") | 315 | back = data:receive("*l") |
316 | if back ~= dos_line2 then fail("'*l' failed") end | 316 | if back ~= dos_line2 then fail("'*l' failed") end |
317 | back = receive(data, "*lu") | 317 | back = data:receive("*lu") |
318 | if back ~= unix_line1 then fail("'*lu' failed") end | 318 | if back ~= unix_line1 then fail("'*lu' failed") end |
319 | back = receive(data, "*lu") | 319 | back = data:receive("*lu") |
320 | if back ~= unix_line2 then fail("'*lu' failed") end | 320 | if back ~= unix_line2 then fail("'*lu' failed") end |
321 | back = receive(data) | 321 | back = data:receive() |
322 | if back ~= dos_line1 then fail("default failed") end | 322 | if back ~= dos_line1 then fail("default failed") end |
323 | back = receive(data) | 323 | back = data:receive() |
324 | if back ~= dos_line2 then fail("default failed") end | 324 | if back ~= dos_line2 then fail("default failed") end |
325 | back = receive(data, "*lu") | 325 | back = data:receive("*lu") |
326 | if back ~= unix_line1 then fail("'*lu' failed") end | 326 | if back ~= unix_line1 then fail("'*lu' failed") end |
327 | back = receive(data, "*lu") | 327 | back = data:receive("*lu") |
328 | if back ~= unix_line2 then fail("'*lu' failed") end | 328 | if back ~= unix_line2 then fail("'*lu' failed") end |
329 | pass("line patterns are ok") | 329 | pass("line patterns are ok") |
330 | send_command(ECHO_BLOCK, strlen(block)) | 330 | send_command(ECHO_BLOCK, strlen(block)) |
331 | err = send(data, block) | 331 | err = data:send(block) |
332 | if err then fail(err) end | 332 | if err then fail(err) end |
333 | back = receive(data, strlen(block)) | 333 | back = data:receive(strlen(block)) |
334 | if back ~= block then fail("number failed") end | 334 | if back ~= block then fail("number failed") end |
335 | pass("number is ok") | 335 | pass("number is ok") |
336 | send_command(ECHO_BLOCK, strlen(block)) | 336 | send_command(ECHO_BLOCK, strlen(block)) |
337 | send_command(SLEEP, 1) | 337 | send_command(SLEEP, 1) |
338 | send_command(CLOSE) | 338 | send_command(CLOSE) |
339 | err = send(data, block) | 339 | err = data:send(block) |
340 | if err then fail(err) end | 340 | if err then fail(err) end |
341 | back = receive(data, "*a") | 341 | back = data:receive("*a") |
342 | if back ~= block then fail("'*a' failed") end | 342 | if back ~= block then fail("'*a' failed") end |
343 | pass("'*a' is ok") | 343 | pass("'*a' is ok") |
344 | end | 344 | end |
@@ -390,7 +390,7 @@ test_block(800000) | |||
390 | new_test("non-blocking transfer test") | 390 | new_test("non-blocking transfer test") |
391 | -- the value is not important, we only want | 391 | -- the value is not important, we only want |
392 | -- to test non-blockin I/O anyways | 392 | -- to test non-blockin I/O anyways |
393 | timeout(data, 200) | 393 | data:timeout(200) |
394 | test_block(1) | 394 | test_block(1) |
395 | test_block(17) | 395 | test_block(17) |
396 | test_block(200) | 396 | test_block(200) |
@@ -421,7 +421,7 @@ test_returntimeout(800000, 2, 1) | |||
421 | print("client: closing connection with server") | 421 | print("client: closing connection with server") |
422 | send_command(CLOSE) | 422 | send_command(CLOSE) |
423 | send_command(EXIT) | 423 | send_command(EXIT) |
424 | close(control) | 424 | control:close() |
425 | 425 | ||
426 | new_test("the library has passed all tests") | 426 | new_test("the library has passed all tests") |
427 | print(format("time elapsed: %6.2fs", time() - start)) | 427 | print(format("time elapsed: %6.2fs", time() - start)) |
diff --git a/test/testsrvr.lua b/test/testsrvr.lua index d69b5ab..efa5991 100644 --- a/test/testsrvr.lua +++ b/test/testsrvr.lua | |||
@@ -30,7 +30,7 @@ if not server then | |||
30 | exit(1) | 30 | exit(1) |
31 | end | 31 | end |
32 | print("server: waiting for control connection...") | 32 | print("server: waiting for control connection...") |
33 | control = accept(server) | 33 | control = server:accept() |
34 | print("server: control connection stablished!") | 34 | print("server: control connection stablished!") |
35 | 35 | ||
36 | ----------------------------------------------------------------------------- | 36 | ----------------------------------------------------------------------------- |
@@ -42,7 +42,7 @@ print("server: control connection stablished!") | |||
42 | function execute_command(cmd, par) | 42 | function execute_command(cmd, par) |
43 | if cmd == CONNECT then | 43 | if cmd == CONNECT then |
44 | print("server: waiting for data connection...") | 44 | print("server: waiting for data connection...") |
45 | data = accept(server) | 45 | data = server:accept() |
46 | if not data then | 46 | if not data then |
47 | fail("server: unable to start data connection!") | 47 | fail("server: unable to start data connection!") |
48 | else | 48 | else |
@@ -51,31 +51,31 @@ function execute_command(cmd, par) | |||
51 | elseif cmd == CLOSE then | 51 | elseif cmd == CLOSE then |
52 | print("server: closing connection with client...") | 52 | print("server: closing connection with client...") |
53 | if data then | 53 | if data then |
54 | close(data) | 54 | data:close() |
55 | data = nil | 55 | data = nil |
56 | end | 56 | end |
57 | elseif cmd == ECHO_LINE then | 57 | elseif cmd == ECHO_LINE then |
58 | str, err = receive(data) | 58 | str, err = data:receive() |
59 | if err then fail("server: " .. err) end | 59 | if err then fail("server: " .. err) end |
60 | err = send(data, str, "\n") | 60 | err = data:send(str, "\n") |
61 | if err then fail("server: " .. err) end | 61 | if err then fail("server: " .. err) end |
62 | elseif cmd == ECHO_BLOCK then | 62 | elseif cmd == ECHO_BLOCK then |
63 | str, err = receive(data, par) | 63 | str, err = data:receive(par) |
64 | print(format("server: received %d bytes", strlen(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 | print(format("server: sending %d bytes", strlen(str))) | 66 | print(format("server: sending %d bytes", strlen(str))) |
67 | err = send(data, str) | 67 | err = data:send(str) |
68 | if err then fail("server: " .. err) end | 68 | if err then fail("server: " .. err) end |
69 | elseif cmd == RECEIVE_BLOCK then | 69 | elseif cmd == RECEIVE_BLOCK then |
70 | str, err = receive(data, par) | 70 | str, err = data:receive(par) |
71 | print(format("server: received %d bytes", strlen(str))) | 71 | print(format("server: received %d bytes", strlen(str))) |
72 | elseif cmd == SEND_BLOCK then | 72 | elseif cmd == SEND_BLOCK then |
73 | print(format("server: sending %d bytes", strlen(str))) | 73 | print(format("server: sending %d bytes", strlen(str))) |
74 | err = send(data, str) | 74 | err = data:send(str) |
75 | elseif cmd == ECHO_TIMEOUT then | 75 | elseif cmd == ECHO_TIMEOUT then |
76 | str, err = receive(data, par) | 76 | str, err = data:receive(par) |
77 | if err then fail("server: " .. err) end | 77 | if err then fail("server: " .. err) end |
78 | err = send(data, str) | 78 | err = data:send(str) |
79 | if err then fail("server: " .. err) end | 79 | if err then fail("server: " .. err) end |
80 | elseif cmd == COMMAND then | 80 | elseif cmd == COMMAND then |
81 | cmd, par = get_command() | 81 | cmd, par = get_command() |