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() |
