diff options
author | Bram Moolenaar <Bram@vim.org> | 2016-02-03 21:32:46 +0100 |
---|---|---|
committer | Bram Moolenaar <Bram@vim.org> | 2016-02-03 21:32:46 +0100 |
commit | fcb1e3d16832ce06da0dc38ecb7ab9aaa3ee4383 (patch) | |
tree | 59135ca051bf4f7f2fb68792651e6421cafd5e5f /src/testdir | |
parent | f92591f7f9fc78d2aced99befe444cb423b26df8 (diff) |
patch 7.4.1249v7.4.1249
Problem: Crash when the process a channel is connected to exits.
Solution: Use the file descriptor properly. Add a test. (Damien)
Also add a test for eval().
Diffstat (limited to 'src/testdir')
-rw-r--r-- | src/testdir/test_channel.py | 23 | ||||
-rw-r--r-- | src/testdir/test_channel.vim | 58 |
2 files changed, 65 insertions, 16 deletions
diff --git a/src/testdir/test_channel.py b/src/testdir/test_channel.py index 2364494831..64546c0205 100644 --- a/src/testdir/test_channel.py +++ b/src/testdir/test_channel.py @@ -52,7 +52,6 @@ class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler): decoded = [-1, ''] # Send a response if the sequence number is positive. - # Negative numbers are used for "eval" responses. if decoded[0] >= 0: if decoded[1] == 'hello!': # simply send back a string @@ -65,9 +64,27 @@ class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler): print("sending: {}".format(cmd)) thesocket.sendall(cmd.encode('utf-8')) response = "ok" + elif decoded[1] == 'eval-works': + # Send an eval request. We ignore the response. + cmd = '["eval","\\"foo\\" . 123", -1]' + print("sending: {}".format(cmd)) + thesocket.sendall(cmd.encode('utf-8')) + response = "ok" + elif decoded[1] == 'eval-fails': + # Send an eval request that will fail. + cmd = '["eval","xxx", -2]' + print("sending: {}".format(cmd)) + thesocket.sendall(cmd.encode('utf-8')) + response = "ok" + elif decoded[1] == 'eval-result': + # Send back the last received eval result. + response = last_eval elif decoded[1] == '!quit!': # we're done sys.exit(0) + elif decoded[1] == '!crash!': + # Crash! + 42 / 0 else: response = "what?" @@ -75,6 +92,10 @@ class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler): print("sending: {}".format(encoded)) thesocket.sendall(encoded.encode('utf-8')) + # Negative numbers are used for "eval" responses. + elif decoded[0] < 0: + last_eval = decoded + thesocket = None class ThreadedTCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer): diff --git a/src/testdir/test_channel.vim b/src/testdir/test_channel.vim index 9d4c778372..d1289903e7 100644 --- a/src/testdir/test_channel.vim +++ b/src/testdir/test_channel.vim @@ -18,25 +18,14 @@ else endif func s:start_server() + " The Python program writes the port number in Xportnr. + call delete("Xportnr") + if has('win32') silent !start cmd /c start "test_channel" py test_channel.py else silent !python test_channel.py& endif -endfunc - -func s:kill_server() - if has('win32') - call system('taskkill /IM py.exe /T /F /FI "WINDOWTITLE eq test_channel"') - else - call system("pkill --full test_channel.py") - endif -endfunc - -func Test_communicate() - call delete("Xportnr") - " The Python program writes the port number in Xportnr. - call s:start_server() " Wait for up to 2 seconds for the port number to be there. let cnt = 20 @@ -57,10 +46,28 @@ func Test_communicate() if len(l) == 0 " Can't make the connection, give up. call s:kill_server() - return + call assert_false(1, "Can't start test_channel.py") + return -1 endif let port = l[0] + let handle = ch_open('localhost:' . port, 'json') + return handle +endfunc + +func s:kill_server() + if has('win32') + call system('taskkill /IM py.exe /T /F /FI "WINDOWTITLE eq test_channel"') + else + call system("pkill --full test_channel.py") + endif +endfunc + +func Test_communicate() + let handle = s:start_server() + if handle < 0 + return + endif " Simple string request and reply. call assert_equal('got it', ch_sendexpr(handle, 'hello!')) @@ -73,8 +80,29 @@ func Test_communicate() call assert_equal('added1', getline(line('$') - 1)) call assert_equal('added2', getline('$')) + " Send an eval request that works. + call assert_equal('ok', ch_sendexpr(handle, 'eval-works')) + call assert_equal([-1, 'foo123'], ch_sendexpr(handle, 'eval-result')) + + " Send an eval request that fails. + call assert_equal('ok', ch_sendexpr(handle, 'eval-fails')) + call assert_equal([-2, 'ERROR'], ch_sendexpr(handle, 'eval-result')) + " make the server quit, can't check if this works, should not hang. call ch_sendexpr(handle, '!quit!', 0) call s:kill_server() endfunc + +" Test that a server crash is handled gracefully. +func Test_server_crash() + let handle = s:start_server() + if handle < 0 + return + endif + call ch_sendexpr(handle, '!crash!') + + " kill the server in case if failed to crash + sleep 10m + call s:kill_server() +endfunc |