vim: src/testdir/test_channel.vim comparison

comparison src/testdir/test_channel.vim @ 17559:0ba896d48a56 v8.1.1777

patch 8.1.1777: useless checks for job feature in channel test commit https://github.com/vim/vim/commit/f386f08ccbd88e28479a4131a1b919bd3c0913ea Author: Bram Moolenaar <Bram@vim.org> Date: Mon Jul 29 23:03:03 2019 +0200 patch 8.1.1777: useless checks for job feature in channel test Problem: Useless checks for job feature in channel test. Solution: Remove the checks. Remove ch_log() calls.

author	Bram Moolenaar <Bram@vim.org>
date	Mon, 29 Jul 2019 23:15:06 +0200
parents	4a22102fda8f
children	0da9bc55c31a

comparison

equal deleted inserted replaced

-:2f85a7639b50
+:0ba896d48a56
-" Test for channel functions.
+" Test for channel and job functions.
+" When +channel is supported then +job is too, so we don't check for that.
 source check.vim
 CheckFeature channel
 source shared.vim
 source screendump.vim
 throw 'Skipped: Python command missing'
 endif
 " Uncomment the next line to see what happens. Output is in
 " src/testdir/channellog.
+" Add ch_log() calls where you want to see what happens.
 " call ch_logfile('channellog', 'w')
 let s:chopt = {}
 " Run "testfunc" after sarting the server and stop the server afterwards.
 unlet s:chopt.noblock
 if ch_status(handle) == "fail"
 call assert_report("Can't open channel")
 return
 endif
-if has('job')
 " check that getjob without a job is handled correctly
 call assert_equal('no process', string(ch_getjob(handle)))
-endif
 let dict = ch_info(handle)
 call assert_true(dict.id != 0)
 call assert_equal('open', dict.status)
 call assert_equal(a:port, string(dict.port))
 call assert_equal('open', dict.sock_status)
 endfunc
 """""""""
 func Test_raw_pipe()
-if !has('job')
-return
-endif
-call ch_log('Test_raw_pipe()')
 " Add a dummy close callback to avoid that messages are dropped when calling
 " ch_canread().
 " Also test the non-blocking option.
 let job = job_start(s:python . " test_channel_pipe.py",
 	\ {'mode': 'raw', 'drop': 'never', 'noblock': 1})
 endfor
 call assert_equal(1, found)
 endfunc
 func Test_raw_pipe_blob()
-if !has('job')
-return
-endif
-call ch_log('Test_raw_pipe_blob()')
 " Add a dummy close callback to avoid that messages are dropped when calling
 " ch_canread().
 " Also test the non-blocking option.
 let job = job_start(s:python . " test_channel_pipe.py",
 	\ {'mode': 'raw', 'drop': 'never', 'noblock': 1})
 let info = job_info(job)
 call assert_equal("dead", info.status)
 endfunc
 func Test_nl_pipe()
-if !has('job')
-return
-endif
-call ch_log('Test_nl_pipe()')
 let job = job_start([s:python, "test_channel_pipe.py"])
 call assert_equal("run", job_status(job))
 try
 let handle = job_getchannel(job)
 call ch_sendraw(handle, "echo something\n")
 finally
 call job_stop(job)
 endtry
 endfunc
-func Test_nl_err_to_out_pipe()
+func Stop_g_job()
-if !has('job')
+call job_stop(g:job)
+if has('win32')
+" On MS-Windows the server must close the file handle before we are able
+" to delete the file.
+call WaitForAssert({-> assert_equal('dead', job_status(g:job))})
+sleep 10m
+endif
+endfunc
+func Test_nl_read_file()
+call writefile(['echo something', 'echoerr wrong', 'double this'], 'Xinput')
+let g:job = job_start(s:python . " test_channel_pipe.py",
+	\ {'in_io': 'file', 'in_name': 'Xinput'})
+call assert_equal("run", job_status(g:job))
+try
+let handle = job_getchannel(g:job)
+call assert_equal("something", ch_readraw(handle))
+call assert_equal("wrong", ch_readraw(handle, {'part': 'err'}))
+call assert_equal("this", ch_readraw(handle))
+call assert_equal("AND this", ch_readraw(handle))
+finally
+call Stop_g_job()
+call delete('Xinput')
+endtry
+endfunc
+func Test_nl_write_out_file()
+let g:job = job_start(s:python . " test_channel_pipe.py",
+	\ {'out_io': 'file', 'out_name': 'Xoutput'})
+call assert_equal("run", job_status(g:job))
+try
+let handle = job_getchannel(g:job)
+call ch_sendraw(handle, "echo line one\n")
+call ch_sendraw(handle, "echo line two\n")
+call ch_sendraw(handle, "double this\n")
+call WaitForAssert({-> assert_equal(['line one', 'line two', 'this', 'AND this'], readfile('Xoutput'))})
+finally
+call Stop_g_job()
+call assert_equal(-1, match(s:get_resources(), '\(^\|/\)Xoutput$'))
+call delete('Xoutput')
+endtry
+endfunc
+func Test_nl_write_err_file()
+let g:job = job_start(s:python . " test_channel_pipe.py",
+	\ {'err_io': 'file', 'err_name': 'Xoutput'})
+call assert_equal("run", job_status(g:job))
+try
+let handle = job_getchannel(g:job)
+call ch_sendraw(handle, "echoerr line one\n")
+call ch_sendraw(handle, "echoerr line two\n")
+call ch_sendraw(handle, "doubleerr this\n")
+call WaitForAssert({-> assert_equal(['line one', 'line two', 'this', 'AND this'], readfile('Xoutput'))})
+finally
+call Stop_g_job()
+call delete('Xoutput')
+endtry
+endfunc
+func Test_nl_write_both_file()
+let g:job = job_start(s:python . " test_channel_pipe.py",
+	\ {'out_io': 'file', 'out_name': 'Xoutput', 'err_io': 'out'})
+call assert_equal("run", job_status(g:job))
+try
+let handle = job_getchannel(g:job)
+call ch_sendraw(handle, "echoerr line one\n")
+call ch_sendraw(handle, "echo line two\n")
+call ch_sendraw(handle, "double this\n")
+call ch_sendraw(handle, "doubleerr that\n")
+call WaitForAssert({-> assert_equal(['line one', 'line two', 'this', 'AND this', 'that', 'AND that'], readfile('Xoutput'))})
+finally
+call Stop_g_job()
+call assert_equal(-1, match(s:get_resources(), '\(^\|/\)Xoutput$'))
+call delete('Xoutput')
+endtry
+endfunc
+func BufCloseCb(ch)
+let g:Ch_bufClosed = 'yes'
+endfunc
+func Run_test_pipe_to_buffer(use_name, nomod, do_msg)
+let g:Ch_bufClosed = 'no'
+let options = {'out_io': 'buffer', 'close_cb': 'BufCloseCb'}
+let expected = ['', 'line one', 'line two', 'this', 'AND this', 'Goodbye!']
+if a:use_name
+let options['out_name'] = 'pipe-output'
+if a:do_msg
+let expected[0] = 'Reading from channel output...'
+else
+let options['out_msg'] = 0
+call remove(expected, 0)
+endif
+else
+sp pipe-output
+let options['out_buf'] = bufnr('%')
+quit
+call remove(expected, 0)
+endif
+if a:nomod
+let options['out_modifiable'] = 0
+endif
+let job = job_start(s:python . " test_channel_pipe.py", options)
+call assert_equal("run", job_status(job))
+try
+let handle = job_getchannel(job)
+call ch_sendraw(handle, "echo line one\n")
+call ch_sendraw(handle, "echo line two\n")
+call ch_sendraw(handle, "double this\n")
+call ch_sendraw(handle, "quit\n")
+sp pipe-output
+call WaitFor('line("$") == ' . len(expected) . ' && g:Ch_bufClosed == "yes"')
+call assert_equal(expected, getline(1, '$'))
+if a:nomod
+call assert_equal(0, &modifiable)
+else
+call assert_equal(1, &modifiable)
+endif
+call assert_equal('yes', g:Ch_bufClosed)
+bwipe!
+finally
+call job_stop(job)
+endtry
+endfunc
+func Test_pipe_to_buffer_name()
+call Run_test_pipe_to_buffer(1, 0, 1)
+endfunc
+func Test_pipe_to_buffer_nr()
+call Run_test_pipe_to_buffer(0, 0, 1)
+endfunc
+func Test_pipe_to_buffer_name_nomod()
+call Run_test_pipe_to_buffer(1, 1, 1)
+endfunc
+func Test_pipe_to_buffer_name_nomsg()
+call Run_test_pipe_to_buffer(1, 0, 1)
+endfunc
+func Test_close_output_buffer()
+enew!
+let test_lines = ['one', 'two']
+call setline(1, test_lines)
+call ch_log('Test_close_output_buffer()')
+let options = {'out_io': 'buffer'}
+let options['out_name'] = 'buffer-output'
+let options['out_msg'] = 0
+split buffer-output
+let job = job_start(s:python . " test_channel_write.py", options)
+call assert_equal("run", job_status(job))
+try
+call WaitForAssert({-> assert_equal(3, line('$'))})
+quit!
+sleep 100m
+" Make sure the write didn't happen to the wrong buffer.
+call assert_equal(test_lines, getline(1, line('$')))
+call assert_equal(-1, bufwinnr('buffer-output'))
+sbuf buffer-output
+call assert_notequal(-1, bufwinnr('buffer-output'))
+sleep 100m
+close  " no more writes
+bwipe!
+finally
+call job_stop(job)
+endtry
+endfunc
+func Run_test_pipe_err_to_buffer(use_name, nomod, do_msg)
+let options = {'err_io': 'buffer'}
+let expected = ['', 'line one', 'line two', 'this', 'AND this']
+if a:use_name
+let options['err_name'] = 'pipe-err'
+if a:do_msg
+let expected[0] = 'Reading from channel error...'
+else
+let options['err_msg'] = 0
+call remove(expected, 0)
+endif
+else
+sp pipe-err
+let options['err_buf'] = bufnr('%')
+quit
+call remove(expected, 0)
+endif
+if a:nomod
+let options['err_modifiable'] = 0
+endif
+let job = job_start(s:python . " test_channel_pipe.py", options)
+call assert_equal("run", job_status(job))
+try
+let handle = job_getchannel(job)
+call ch_sendraw(handle, "echoerr line one\n")
+call ch_sendraw(handle, "echoerr line two\n")
+call ch_sendraw(handle, "doubleerr this\n")
+call ch_sendraw(handle, "quit\n")
+sp pipe-err
+call WaitForAssert({-> assert_equal(expected, getline(1, '$'))})
+if a:nomod
+call assert_equal(0, &modifiable)
+else
+call assert_equal(1, &modifiable)
+endif
+bwipe!
+finally
+call job_stop(job)
+endtry
+endfunc
+func Test_pipe_err_to_buffer_name()
+call Run_test_pipe_err_to_buffer(1, 0, 1)
+endfunc
+func Test_pipe_err_to_buffer_nr()
+call Run_test_pipe_err_to_buffer(0, 0, 1)
+endfunc
+func Test_pipe_err_to_buffer_name_nomod()
+call Run_test_pipe_err_to_buffer(1, 1, 1)
+endfunc
+func Test_pipe_err_to_buffer_name_nomsg()
+call Run_test_pipe_err_to_buffer(1, 0, 0)
+endfunc
+func Test_pipe_both_to_buffer()
+let job = job_start(s:python . " test_channel_pipe.py",
+	\ {'out_io': 'buffer', 'out_name': 'pipe-err', 'err_io': 'out'})
+call assert_equal("run", job_status(job))
+try
+let handle = job_getchannel(job)
+call ch_sendraw(handle, "echo line one\n")
+call ch_sendraw(handle, "echoerr line two\n")
+call ch_sendraw(handle, "double this\n")
+call ch_sendraw(handle, "doubleerr that\n")
+call ch_sendraw(handle, "quit\n")
+sp pipe-err
+call WaitForAssert({-> assert_equal(['Reading from channel output...', 'line one', 'line two', 'this', 'AND this', 'that', 'AND that', 'Goodbye!'], getline(1, '$'))})
+bwipe!
+finally
+call job_stop(job)
+endtry
+endfunc
+func Run_test_pipe_from_buffer(use_name)
+sp pipe-input
+call setline(1, ['echo one', 'echo two', 'echo three'])
+let options = {'in_io': 'buffer', 'block_write': 1}
+if a:use_name
+let options['in_name'] = 'pipe-input'
+else
+let options['in_buf'] = bufnr('%')
+endif
+let job = job_start(s:python . " test_channel_pipe.py", options)
+call assert_equal("run", job_status(job))
+try
+let handle = job_getchannel(job)
+call assert_equal('one', ch_read(handle))
+call assert_equal('two', ch_read(handle))
+call assert_equal('three', ch_read(handle))
+bwipe!
+finally
+call job_stop(job)
+endtry
+endfunc
+func Test_pipe_from_buffer_name()
+call Run_test_pipe_from_buffer(1)
+endfunc
+func Test_pipe_from_buffer_nr()
+call Run_test_pipe_from_buffer(0)
+endfunc
+func Run_pipe_through_sort(all, use_buffer)
+if !executable('sort')
+throw 'Skipped: sort program not found'
+endif
+let options = {'out_io': 'buffer', 'out_name': 'sortout'}
+if a:use_buffer
+split sortin
+call setline(1, ['ccc', 'aaa', 'ddd', 'bbb', 'eee'])
+let options.in_io = 'buffer'
+let options.in_name = 'sortin'
+endif
+if !a:all
+let options.in_top = 2
+let options.in_bot = 4
+endif
+let job = job_start('sort', options)
+if !a:use_buffer
+call assert_equal("run", job_status(job))
+call ch_sendraw(job, "ccc\naaa\nddd\nbbb\neee\n")
+call ch_close_in(job)
+endif
+call WaitForAssert({-> assert_equal("dead", job_status(job))})
+sp sortout
+call WaitFor('line("$") > 3')
+call assert_equal('Reading from channel output...', getline(1))
+if a:all
+call assert_equal(['aaa', 'bbb', 'ccc', 'ddd', 'eee'], getline(2, 6))
+else
+call assert_equal(['aaa', 'bbb', 'ddd'], getline(2, 4))
+endif
+call job_stop(job)
+if a:use_buffer
+bwipe! sortin
+endif
+bwipe! sortout
+endfunc
+func Test_pipe_through_sort_all()
+call ch_log('Test_pipe_through_sort_all()')
+call Run_pipe_through_sort(1, 1)
+endfunc
+func Test_pipe_through_sort_some()
+call ch_log('Test_pipe_through_sort_some()')
+call Run_pipe_through_sort(0, 1)
+endfunc
+func Test_pipe_through_sort_feed()
+call ch_log('Test_pipe_through_sort_feed()')
+call Run_pipe_through_sort(1, 0)
+endfunc
+func Test_pipe_to_nameless_buffer()
+let job = job_start(s:python . " test_channel_pipe.py",
+	\ {'out_io': 'buffer'})
+call assert_equal("run", job_status(job))
+try
+let handle = job_getchannel(job)
+call ch_sendraw(handle, "echo line one\n")
+call ch_sendraw(handle, "echo line two\n")
+exe ch_getbufnr(handle, "out") . 'sbuf'
+call WaitFor('line("$") >= 3')
+call assert_equal(['Reading from channel output...', 'line one', 'line two'], getline(1, '$'))
+bwipe!
+finally
+call job_stop(job)
+endtry
+endfunc
+func Test_pipe_to_buffer_json()
+let job = job_start(s:python . " test_channel_pipe.py",
+	\ {'out_io': 'buffer', 'out_mode': 'json'})
+call assert_equal("run", job_status(job))
+try
+let handle = job_getchannel(job)
+call ch_sendraw(handle, "echo [0, \"hello\"]\n")
+call ch_sendraw(handle, "echo [-2, 12.34]\n")
+exe ch_getbufnr(handle, "out") . 'sbuf'
+call WaitFor('line("$") >= 3')
+call assert_equal(['Reading from channel output...', '[0,"hello"]', '[-2,12.34]'], getline(1, '$'))
+bwipe!
+finally
+call job_stop(job)
+endtry
+endfunc
+" Wait a little while for the last line, minus "offset", to equal "line".
+func s:wait_for_last_line(line, offset)
+for i in range(100)
+if getline(line('$') - a:offset) == a:line
+break
+endif
+sleep 10m
+endfor
+endfunc
+func Test_pipe_io_two_buffers()
+" Create two buffers, one to read from and one to write to.
+split pipe-output
+set buftype=nofile
+split pipe-input
+set buftype=nofile
+let job = job_start(s:python . " test_channel_pipe.py",
+	\ {'in_io': 'buffer', 'in_name': 'pipe-input', 'in_top': 0,
+	\  'out_io': 'buffer', 'out_name': 'pipe-output',
+	\  'block_write': 1})
+call assert_equal("run", job_status(job))
+try
+exe "normal Gaecho hello\<CR>"
+exe bufwinnr('pipe-output') . "wincmd w"
+call s:wait_for_last_line('hello', 0)
+call assert_equal('hello', getline('$'))
+exe bufwinnr('pipe-input') . "wincmd w"
+exe "normal Gadouble this\<CR>"
+exe bufwinnr('pipe-output') . "wincmd w"
+call s:wait_for_last_line('AND this', 0)
+call assert_equal('this', getline(line('$') - 1))
+call assert_equal('AND this', getline('$'))
+bwipe!
+exe bufwinnr('pipe-input') . "wincmd w"
+bwipe!
+finally
+call job_stop(job)
+endtry
+endfunc
+func Test_pipe_io_one_buffer()
+" Create one buffer to read from and to write to.
+split pipe-io
+set buftype=nofile
+let job = job_start(s:python . " test_channel_pipe.py",
+	\ {'in_io': 'buffer', 'in_name': 'pipe-io', 'in_top': 0,
+	\  'out_io': 'buffer', 'out_name': 'pipe-io',
+	\  'block_write': 1})
+call assert_equal("run", job_status(job))
+try
+exe "normal Goecho hello\<CR>"
+call s:wait_for_last_line('hello', 1)
+call assert_equal('hello', getline(line('$') - 1))
+exe "normal Gadouble this\<CR>"
+call s:wait_for_last_line('AND this', 1)
+call assert_equal('this', getline(line('$') - 2))
+call assert_equal('AND this', getline(line('$') - 1))
+bwipe!
+finally
+call job_stop(job)
+endtry
+endfunc
+func Test_write_to_buffer_and_scroll()
+if !CanRunVimInTerminal()
+throw 'Skipped: cannot make screendumps'
+endif
+let lines =<< trim END
+new Xscrollbuffer
+call setline(1, range(1, 200))
+$
+redraw
+wincmd w
+call deletebufline('Xscrollbuffer', 1, '$')
+if has('win32')
+	let cmd = ['cmd', '/c', 'echo sometext']
+else
+	let cmd = [&shell, &shellcmdflag, 'echo sometext']
+endif
+call job_start(cmd, #{out_io: 'buffer', out_name: 'Xscrollbuffer'})
+END
+call writefile(lines, 'XtestBufferScroll')
+let buf = RunVimInTerminal('-S XtestBufferScroll', #{rows: 10})
+call term_wait(buf, 100)
+call VerifyScreenDump(buf, 'Test_job_buffer_scroll_1', {})
+" clean up
+call StopVimInTerminal(buf)
+call delete('XtestBufferScroll')
+endfunc
+func Test_pipe_null()
+" We cannot check that no I/O works, we only check that the job starts
+" properly.
+let job = job_start(s:python . " test_channel_pipe.py something",
+	\ {'in_io': 'null'})
+call assert_equal("run", job_status(job))
+try
+call assert_equal('something', ch_read(job))
+finally
+call job_stop(job)
+endtry
+let job = job_start(s:python . " test_channel_pipe.py err-out",
+	\ {'out_io': 'null'})
+call assert_equal("run", job_status(job))
+try
+call assert_equal('err-out', ch_read(job, {"part": "err"}))
+finally
+call job_stop(job)
+endtry
+let job = job_start(s:python . " test_channel_pipe.py something",
+	\ {'err_io': 'null'})
+call assert_equal("run", job_status(job))
+try
+call assert_equal('something', ch_read(job))
+finally
+call job_stop(job)
+endtry
+let job = job_start(s:python . " test_channel_pipe.py something",
+	\ {'out_io': 'null', 'err_io': 'out'})
+call assert_equal("run", job_status(job))
+call job_stop(job)
+let job = job_start(s:python . " test_channel_pipe.py something",
+	\ {'in_io': 'null', 'out_io': 'null', 'err_io': 'null'})
+call assert_equal("run", job_status(job))
+call assert_equal('channel fail', string(job_getchannel(job)))
+call assert_equal('fail', ch_status(job))
+call job_stop(job)
+endfunc
+func Test_pipe_to_buffer_raw()
+let options = {'out_mode': 'raw', 'out_io': 'buffer', 'out_name': 'testout'}
+split testout
+let job = job_start([s:python, '-c',
+\ 'import sys; [sys.stdout.write(".") and sys.stdout.flush() for _ in range(10000)]'], options)
+" the job may be done quickly, also accept "dead"
+call assert_match('^\%(dead\|run\)$', job_status(job))
+call WaitFor('len(join(getline(1, "$"), "")) >= 10000')
+try
+let totlen = 0
+for line in getline(1, '$')
+call assert_equal('', substitute(line, '^\.*', '', ''))
+let totlen += len(line)
+endfor
+call assert_equal(10000, totlen)
+finally
+call job_stop(job)
+bwipe!
+endtry
+endfunc
+func Test_reuse_channel()
+let job = job_start(s:python . " test_channel_pipe.py")
+call assert_equal("run", job_status(job))
+let handle = job_getchannel(job)
+try
+call ch_sendraw(handle, "echo something\n")
+call assert_equal("something", ch_readraw(handle))
+finally
+call job_stop(job)
+endtry
+let job = job_start(s:python . " test_channel_pipe.py", {'channel': handle})
+call assert_equal("run", job_status(job))
+let handle = job_getchannel(job)
+try
+call ch_sendraw(handle, "echo again\n")
+call assert_equal("again", ch_readraw(handle))
+finally
+call job_stop(job)
+endtry
+endfunc
+func Test_out_cb()
+let dict = {'thisis': 'dict: '}
+func dict.outHandler(chan, msg) dict
+if type(a:msg) == v:t_string
+let g:Ch_outmsg = self.thisis . a:msg
+else
+let g:Ch_outobj = a:msg
+endif
+endfunc
+func dict.errHandler(chan, msg) dict
+let g:Ch_errmsg = self.thisis . a:msg
+endfunc
+let job = job_start(s:python . " test_channel_pipe.py",
+	\ {'out_cb': dict.outHandler,
+	\  'out_mode': 'json',
+	\  'err_cb': dict.errHandler,
+	\  'err_mode': 'json'})
+call assert_equal("run", job_status(job))
+try
+let g:Ch_outmsg = ''
+let g:Ch_errmsg = ''
+call ch_sendraw(job, "echo [0, \"hello\"]\n")
+call ch_sendraw(job, "echoerr [0, \"there\"]\n")
+call WaitForAssert({-> assert_equal("dict: hello", g:Ch_outmsg)})
+call WaitForAssert({-> assert_equal("dict: there", g:Ch_errmsg)})
+" Receive a json object split in pieces
+unlet! g:Ch_outobj
+call ch_sendraw(job, "echosplit [0, {\"one\": 1,| \"tw|o\": 2, \"three\": 3|}]\n")
+let g:Ch_outobj = ''
+call WaitForAssert({-> assert_equal({'one': 1, 'two': 2, 'three': 3}, g:Ch_outobj)})
+finally
+call job_stop(job)
+endtry
+endfunc
+func Test_out_close_cb()
+let s:counter = 1
+let g:Ch_msg1 = ''
+let g:Ch_closemsg = 0
+func! OutHandler(chan, msg)
+if s:counter == 1
+let g:Ch_msg1 = a:msg
+endif
+let s:counter += 1
+endfunc
+func! CloseHandler(chan)
+let g:Ch_closemsg = s:counter
+let s:counter += 1
+endfunc
+let job = job_start(s:python . " test_channel_pipe.py quit now",
+	\ {'out_cb': 'OutHandler',
+	\  'close_cb': 'CloseHandler'})
+" the job may be done quickly, also accept "dead"
+call assert_match('^\%(dead\|run\)$', job_status(job))
+try
+call WaitForAssert({-> assert_equal('quit', g:Ch_msg1)})
+call WaitForAssert({-> assert_equal(2, g:Ch_closemsg)})
+finally
+call job_stop(job)
+delfunc OutHandler
+delfunc CloseHandler
+endtry
+endfunc
+func Test_read_in_close_cb()
+let g:Ch_received = ''
+func! CloseHandler(chan)
+let g:Ch_received = ch_read(a:chan)
+endfunc
+let job = job_start(s:python . " test_channel_pipe.py quit now",
+	\ {'close_cb': 'CloseHandler'})
+" the job may be done quickly, also accept "dead"
+call assert_match('^\%(dead\|run\)$', job_status(job))
+try
+call WaitForAssert({-> assert_equal('quit', g:Ch_received)})
+finally
+call job_stop(job)
+delfunc CloseHandler
+endtry
+endfunc
+" Use channel in NL mode but received text does not end in NL.
+func Test_read_in_close_cb_incomplete()
+let g:Ch_received = ''
+func! CloseHandler(chan)
+while ch_status(a:chan, {'part': 'out'}) == 'buffered'
+let g:Ch_received .= ch_read(a:chan)
+endwhile
+endfunc
+let job = job_start(s:python . " test_channel_pipe.py incomplete",
+	\ {'close_cb': 'CloseHandler'})
+" the job may be done quickly, also accept "dead"
+call assert_match('^\%(dead\|run\)$', job_status(job))
+try
+call WaitForAssert({-> assert_equal('incomplete', g:Ch_received)})
+finally
+call job_stop(job)
+delfunc CloseHandler
+endtry
+endfunc
+func Test_out_cb_lambda()
+let job = job_start(s:python . " test_channel_pipe.py",
+\ {'out_cb': {ch, msg -> execute("let g:Ch_outmsg = 'lambda: ' . msg")},
+\  'out_mode': 'json',
+\  'err_cb': {ch, msg -> execute(":let g:Ch_errmsg = 'lambda: ' . msg")},
+\  'err_mode': 'json'})
+call assert_equal("run", job_status(job))
+try
+let g:Ch_outmsg = ''
+let g:Ch_errmsg = ''
+call ch_sendraw(job, "echo [0, \"hello\"]\n")
+call ch_sendraw(job, "echoerr [0, \"there\"]\n")
+call WaitForAssert({-> assert_equal("lambda: hello", g:Ch_outmsg)})
+call WaitForAssert({-> assert_equal("lambda: there", g:Ch_errmsg)})
+finally
+call job_stop(job)
+endtry
+endfunc
+func Test_close_and_exit_cb()
+let g:retdict = {'ret': {}}
+func g:retdict.close_cb(ch) dict
+let self.ret['close_cb'] = job_status(ch_getjob(a:ch))
+endfunc
+func g:retdict.exit_cb(job, status) dict
+let self.ret['exit_cb'] = job_status(a:job)
+endfunc
+let job = job_start([&shell, &shellcmdflag, 'echo'],
+\ {'close_cb': g:retdict.close_cb,
+\  'exit_cb': g:retdict.exit_cb})
+" the job may be done quickly, also accept "dead"
+call assert_match('^\%(dead\|run\)$', job_status(job))
+call WaitForAssert({-> assert_equal(2, len(g:retdict.ret))})
+call assert_match('^\%(dead\|run\)$', g:retdict.ret['close_cb'])
+call assert_equal('dead', g:retdict.ret['exit_cb'])
+unlet g:retdict
+endfunc
+""""""""""
+function ExitCbWipe(job, status)
+exe g:wipe_buf 'bw!'
+endfunction
+" This caused a crash, because messages were handled while peeking for a
+" character.
+func Test_exit_cb_wipes_buf()
+if !has('timers')
 return
 endif
+set cursorline lazyredraw
+call test_override('redraw_flag', 1)
+new
+let g:wipe_buf = bufnr('')
+let job = job_start(has('win32') ? 'cmd /c echo:' : ['true'],
+	\ {'exit_cb': 'ExitCbWipe'})
+let timer = timer_start(300, {-> feedkeys("\<Esc>", 'nt')}, {'repeat': 5})
+call feedkeys(repeat('g', 1000) . 'o', 'ntx!')
+call WaitForAssert({-> assert_equal("dead", job_status(job))})
+call timer_stop(timer)
+set nocursorline nolazyredraw
+unlet g:wipe_buf
+call test_override('ALL', 0)
+endfunc
+""""""""""
+let g:Ch_unletResponse = ''
+func s:UnletHandler(handle, msg)
+let g:Ch_unletResponse = a:msg
+unlet s:channelfd
+endfunc
+" Test that "unlet handle" in a handler doesn't crash Vim.
+func Ch_unlet_handle(port)
+let s:channelfd = ch_open('localhost:' . a:port, s:chopt)
+call ch_sendexpr(s:channelfd, "test", {'callback': function('s:UnletHandler')})
+call WaitForAssert({-> assert_equal('what?', g:Ch_unletResponse)})
+endfunc
+func Test_unlet_handle()
+call ch_log('Test_unlet_handle()')
+call s:run_server('Ch_unlet_handle')
+endfunc
+""""""""""
+let g:Ch_unletResponse = ''
+func Ch_CloseHandler(handle, msg)
+let g:Ch_unletResponse = a:msg
+call ch_close(s:channelfd)
+endfunc
+" Test that "unlet handle" in a handler doesn't crash Vim.
+func Ch_close_handle(port)
+let s:channelfd = ch_open('localhost:' . a:port, s:chopt)
+call ch_sendexpr(s:channelfd, "test", {'callback': function('Ch_CloseHandler')})
+call WaitForAssert({-> assert_equal('what?', g:Ch_unletResponse)})
+endfunc
+func Test_close_handle()
+call ch_log('Test_close_handle()')
+call s:run_server('Ch_close_handle')
+endfunc
+""""""""""
+func Test_open_fail()
+call ch_log('Test_open_fail()')
+silent! let ch = ch_open("noserver")
+echo ch
+let d = ch
+endfunc
+""""""""""
+func Ch_open_delay(port)
+" Wait up to a second for the port to open.
+let s:chopt.waittime = 1000
+let channel = ch_open('localhost:' . a:port, s:chopt)
+unlet s:chopt.waittime
+if ch_status(channel) == "fail"
+call assert_report("Can't open channel")
+return
+endif
+call assert_equal('got it', ch_evalexpr(channel, 'hello!'))
+call ch_close(channel)
+endfunc
+func Test_open_delay()
+call ch_log('Test_open_delay()')
+" The server will wait half a second before creating the port.
+call s:run_server('Ch_open_delay', 'delay')
+endfunc
+"""""""""
+function MyFunction(a,b,c)
+let g:Ch_call_ret = [a:a, a:b, a:c]
+endfunc
+function Ch_test_call(port)
+let handle = ch_open('localhost:' . a:port, s:chopt)
+if ch_status(handle) == "fail"
+call assert_report("Can't open channel")
+return
+endif
+let g:Ch_call_ret = []
+call assert_equal('ok', ch_evalexpr(handle, 'call-func'))
+call WaitForAssert({-> assert_equal([1, 2, 3], g:Ch_call_ret)})
+endfunc
+func Test_call()
+call ch_log('Test_call()')
+call s:run_server('Ch_test_call')
+endfunc
+"""""""""
+let g:Ch_job_exit_ret = 'not yet'
+function MyExitCb(job, status)
+let g:Ch_job_exit_ret = 'done'
+endfunc
+function Ch_test_exit_callback(port)
+call job_setoptions(g:currentJob, {'exit_cb': 'MyExitCb'})
+let g:Ch_exit_job = g:currentJob
+call assert_equal('MyExitCb', job_info(g:currentJob)['exit_cb'])
+endfunc
+func Test_exit_callback()
+call s:run_server('Ch_test_exit_callback')
+" wait up to a second for the job to exit
+for i in range(100)
+if g:Ch_job_exit_ret == 'done'
+break
+endif
+sleep 10m
+" calling job_status() triggers the callback
+call job_status(g:Ch_exit_job)
+endfor
+call assert_equal('done', g:Ch_job_exit_ret)
+call assert_equal('dead', job_info(g:Ch_exit_job).status)
+unlet g:Ch_exit_job
+endfunc
+function MyExitTimeCb(job, status)
+if job_info(a:job).process == g:exit_cb_val.process
+let g:exit_cb_val.end = reltime(g:exit_cb_val.start)
+endif
+call Resume()
+endfunction
+func Test_exit_callback_interval()
+let g:exit_cb_val = {'start': reltime(), 'end': 0, 'process': 0}
+let job = job_start([s:python, '-c', 'import time;time.sleep(0.5)'], {'exit_cb': 'MyExitTimeCb'})
+let g:exit_cb_val.process = job_info(job).process
+call WaitFor('type(g:exit_cb_val.end) != v:t_number || g:exit_cb_val.end != 0')
+let elapsed = reltimefloat(g:exit_cb_val.end)
+call assert_true(elapsed > 0.5)
+call assert_true(elapsed < 1.0)
+" case: unreferenced job, using timer
+if !has('timers')
+return
+endif
+let g:exit_cb_val = {'start': reltime(), 'end': 0, 'process': 0}
+let g:job = job_start([s:python, '-c', 'import time;time.sleep(0.5)'], {'exit_cb': 'MyExitTimeCb'})
+let g:exit_cb_val.process = job_info(g:job).process
+unlet g:job
+call Standby(1000)
+if type(g:exit_cb_val.end) != v:t_number || g:exit_cb_val.end != 0
+let elapsed = reltimefloat(g:exit_cb_val.end)
+else
+let elapsed = 1.0
+endif
+call assert_inrange(0.5, 1.0, elapsed)
+endfunc
+"""""""""
+let g:Ch_close_ret = 'alive'
+function MyCloseCb(ch)
+let g:Ch_close_ret = 'closed'
+endfunc
+function Ch_test_close_callback(port)
+let handle = ch_open('localhost:' . a:port, s:chopt)
+if ch_status(handle) == "fail"
+call assert_report("Can't open channel")
+return
+endif
+call ch_setoptions(handle, {'close_cb': 'MyCloseCb'})
+call assert_equal('', ch_evalexpr(handle, 'close me'))
+call WaitForAssert({-> assert_equal('closed', g:Ch_close_ret)})
+endfunc
+func Test_close_callback()
+call ch_log('Test_close_callback()')
+call s:run_server('Ch_test_close_callback')
+endfunc
+function Ch_test_close_partial(port)
+let handle = ch_open('localhost:' . a:port, s:chopt)
+if ch_status(handle) == "fail"
+call assert_report("Can't open channel")
+return
+endif
+let g:Ch_d = {}
+func g:Ch_d.closeCb(ch) dict
+let self.close_ret = 'closed'
+endfunc
+call ch_setoptions(handle, {'close_cb': g:Ch_d.closeCb})
+call assert_equal('', ch_evalexpr(handle, 'close me'))
+call WaitForAssert({-> assert_equal('closed', g:Ch_d.close_ret)})
+unlet g:Ch_d
+endfunc
+func Test_close_partial()
+call ch_log('Test_close_partial()')
+call s:run_server('Ch_test_close_partial')
+endfunc
+func Test_job_start_invalid()
+call assert_fails('call job_start($x)', 'E474:')
+call assert_fails('call job_start("")', 'E474:')
+endfunc
+func Test_job_stop_immediately()
+let g:job = job_start([s:python, '-c', 'import time;time.sleep(10)'])
+try
+call job_stop(g:job)
+call WaitForAssert({-> assert_equal('dead', job_status(g:job))})
+finally
+call job_stop(g:job, 'kill')
+unlet g:job
+endtry
+endfunc
+" This was leaking memory.
+func Test_partial_in_channel_cycle()
+let d = {}
+let d.a = function('string', [d])
+try
+let d.b = ch_open('nowhere:123', {'close_cb': d.a})
+catch
+call assert_exception('E901:')
+endtry
+unlet d
+endfunc
+func Test_using_freed_memory()
+let g:a = job_start(['ls'])
+sleep 10m
+call test_garbagecollect_now()
+endfunc
+func Test_collapse_buffers()
+if !executable('cat')
+throw 'Skipped: cat program not found'
+endif
+sp test_channel.vim
+let g:linecount = line('$')
+close
+split testout
+1,$delete
+call job_start('cat test_channel.vim', {'out_io': 'buffer', 'out_name': 'testout'})
+call WaitForAssert({-> assert_inrange(g:linecount, g:linecount + 1, line('$'))})
+bwipe!
+endfunc
+func Test_write_to_deleted_buffer()
+if !executable('echo')
+throw 'Skipped: echo program not found'
+endif
+let job = job_start('echo hello', {'out_io': 'buffer', 'out_name': 'test_buffer', 'out_msg': 0})
+let bufnr = bufnr('test_buffer')
+call WaitForAssert({-> assert_equal(['hello'], getbufline(bufnr, 1, '$'))})
+call assert_equal('nofile', getbufvar(bufnr, '&buftype'))
+call assert_equal('hide', getbufvar(bufnr, '&bufhidden'))
+bdel test_buffer
+call assert_equal([], getbufline(bufnr, 1, '$'))
+let job = job_start('echo hello', {'out_io': 'buffer', 'out_name': 'test_buffer', 'out_msg': 0})
+call WaitForAssert({-> assert_equal(['hello'], getbufline(bufnr, 1, '$'))})
+call assert_equal('nofile', getbufvar(bufnr, '&buftype'))
+call assert_equal('hide', getbufvar(bufnr, '&bufhidden'))
+bwipe! test_buffer
+endfunc
+func Test_cmd_parsing()
+if !has('unix')
+return
+endif
+call assert_false(filereadable("file with space"))
+let job = job_start('touch "file with space"')
+call WaitForAssert({-> assert_true(filereadable("file with space"))})
+call delete("file with space")
+let job = job_start('touch file\ with\ space')
+call WaitForAssert({-> assert_true(filereadable("file with space"))})
+call delete("file with space")
+endfunc
+func Test_raw_passes_nul()
+if !executable('cat')
+throw 'Skipped: cat program not found'
+endif
+" Test lines from the job containing NUL are stored correctly in a buffer.
+new
+call setline(1, ["asdf\nasdf", "xxx\n", "\nyyy"])
+w! Xtestread
+bwipe!
+split testout
+1,$delete
+call job_start('cat Xtestread', {'out_io': 'buffer', 'out_name': 'testout'})
+call WaitFor('line("$") > 2')
+call assert_equal("asdf\nasdf", getline(1))
+call assert_equal("xxx\n", getline(2))
+call assert_equal("\nyyy", getline(3))
+call delete('Xtestread')
+bwipe!
+" Test lines from a buffer with NUL bytes are written correctly to the job.
+new mybuffer
+call setline(1, ["asdf\nasdf", "xxx\n", "\nyyy"])
+let g:Ch_job = job_start('cat', {'in_io': 'buffer', 'in_name': 'mybuffer', 'out_io': 'file', 'out_name': 'Xtestwrite'})
+call WaitForAssert({-> assert_equal("dead", job_status(g:Ch_job))})
+bwipe!
+split Xtestwrite
+call assert_equal("asdf\nasdf", getline(1))
+call assert_equal("xxx\n", getline(2))
+call assert_equal("\nyyy", getline(3))
+call assert_equal(-1, match(s:get_resources(), '\(^\|/\)Xtestwrite$'))
+call delete('Xtestwrite')
+bwipe!
+endfunc
+func Test_read_nonl_line()
+let g:linecount = 0
+let arg = 'import sys;sys.stdout.write("1\n2\n3")'
+call job_start([s:python, '-c', arg], {'callback': {-> execute('let g:linecount += 1')}})
+call WaitForAssert({-> assert_equal(3, g:linecount)})
+unlet g:linecount
+endfunc
+func Test_read_nonl_in_close_cb()
+func s:close_cb(ch)
+while ch_status(a:ch) == 'buffered'
+let g:out .= ch_read(a:ch)
+endwhile
+endfunc
+let g:out = ''
+let arg = 'import sys;sys.stdout.write("1\n2\n3")'
+call job_start([s:python, '-c', arg], {'close_cb': function('s:close_cb')})
+call WaitForAssert({-> assert_equal('123', g:out)})
+unlet g:out
+delfunc s:close_cb
+endfunc
+func Test_read_from_terminated_job()
+let g:linecount = 0
+let arg = 'import os,sys;os.close(1);sys.stderr.write("test\n")'
+call job_start([s:python, '-c', arg], {'callback': {-> execute('let g:linecount += 1')}})
+call WaitForAssert({-> assert_equal(1, g:linecount)})
+unlet g:linecount
+endfunc
+func Test_job_start_windows()
+CheckMSWindows
+" Check that backslash in $COMSPEC is handled properly.
+let g:echostr = ''
+let cmd = $COMSPEC . ' /c echo 123'
+let job = job_start(cmd, {'callback': {ch,msg -> execute(":let g:echostr .= msg")}})
+let info = job_info(job)
+call assert_equal([$COMSPEC, '/c', 'echo', '123'], info.cmd)
+call WaitForAssert({-> assert_equal("123", g:echostr)})
+unlet g:echostr
+endfunc
+func Test_env()
+let g:envstr = ''
+if has('win32')
+let cmd = ['cmd', '/c', 'echo %FOO%']
+else
+let cmd = [&shell, &shellcmdflag, 'echo $FOO']
+endif
+call assert_fails('call job_start(cmd, {"env": 1})', 'E475:')
+call job_start(cmd, {'callback': {ch,msg -> execute(":let g:envstr .= msg")}, 'env': {'FOO': 'bar'}})
+call WaitForAssert({-> assert_equal("bar", g:envstr)})
+unlet g:envstr
+endfunc
+func Test_cwd()
+let g:envstr = ''
+if has('win32')
+let expect = $TEMP
+let cmd = ['cmd', '/c', 'echo %CD%']
+else
+let expect = $HOME
+let cmd = ['pwd']
+endif
+let job = job_start(cmd, {'callback': {ch,msg -> execute(":let g:envstr .= msg")}, 'cwd': expect})
+try
+call WaitForAssert({-> assert_notequal("", g:envstr)})
+let expect = substitute(expect, '[/\\]$', '', '')
+let g:envstr = substitute(g:envstr, '[/\\]$', '', '')
+if $CI != '' && stridx(g:envstr, '/private/') == 0
+let g:envstr = g:envstr[8:]
+endif
+call assert_equal(expect, g:envstr)
+finally
+call job_stop(job)
+unlet g:envstr
+endtry
+endfunc
+function Ch_test_close_lambda(port)
+let handle = ch_open('localhost:' . a:port, s:chopt)
+if ch_status(handle) == "fail"
+call assert_report("Can't open channel")
+return
+endif
+let g:Ch_close_ret = ''
+call ch_setoptions(handle, {'close_cb': {ch -> execute("let g:Ch_close_ret = 'closed'")}})
+call assert_equal('', ch_evalexpr(handle, 'close me'))
+call WaitForAssert({-> assert_equal('closed', g:Ch_close_ret)})
+endfunc
+func Test_close_lambda()
+call ch_log('Test_close_lambda()')
+call s:run_server('Ch_test_close_lambda')
+endfunc
+func s:test_list_args(cmd, out, remove_lf)
+try
+let g:out = ''
+let job = job_start([s:python, '-c', a:cmd], {'callback': {ch, msg -> execute('let g:out .= msg')}, 'out_mode': 'raw'})
+call WaitFor('"" != g:out')
+if has('win32')
+let g:out = substitute(g:out, '\r', '', 'g')
+endif
+if a:remove_lf
+let g:out = substitute(g:out, '\n$', '', 'g')
+endif
+call assert_equal(a:out, g:out)
+finally
+call job_stop(job)
+unlet g:out
+endtry
+endfunc
+func Test_list_args()
+call s:test_list_args('import sys;sys.stdout.write("hello world")', "hello world", 0)
+call s:test_list_args('import sys;sys.stdout.write("hello\nworld")', "hello\nworld", 0)
+call s:test_list_args('import sys;sys.stdout.write(''hello\nworld'')', "hello\nworld", 0)
+call s:test_list_args('import sys;sys.stdout.write(''hello"world'')', "hello\"world", 0)
+call s:test_list_args('import sys;sys.stdout.write(''hello^world'')', "hello^world", 0)
+call s:test_list_args('import sys;sys.stdout.write("hello&&world")', "hello&&world", 0)
+call s:test_list_args('import sys;sys.stdout.write(''hello\\world'')', "hello\\world", 0)
+call s:test_list_args('import sys;sys.stdout.write(''hello\\\\world'')', "hello\\\\world", 0)
+call s:test_list_args('import sys;sys.stdout.write("hello\"world\"")', 'hello"world"', 0)
+call s:test_list_args('import sys;sys.stdout.write("h\"ello worl\"d")', 'h"ello worl"d', 0)
+call s:test_list_args('import sys;sys.stdout.write("h\"e\\\"llo wor\\\"l\"d")', 'h"e\"llo wor\"l"d', 0)
+call s:test_list_args('import sys;sys.stdout.write("h\"e\\\"llo world")', 'h"e\"llo world', 0)
+call s:test_list_args('import sys;sys.stdout.write("hello\tworld")', "hello\tworld", 0)
+" tests which not contain spaces in the argument
+call s:test_list_args('print("hello\nworld")', "hello\nworld", 1)
+call s:test_list_args('print(''hello\nworld'')', "hello\nworld", 1)
+call s:test_list_args('print(''hello"world'')', "hello\"world", 1)
+call s:test_list_args('print(''hello^world'')', "hello^world", 1)
+call s:test_list_args('print("hello&&world")', "hello&&world", 1)
+call s:test_list_args('print(''hello\\world'')', "hello\\world", 1)
+call s:test_list_args('print(''hello\\\\world'')', "hello\\\\world", 1)
+call s:test_list_args('print("hello\"world\"")', 'hello"world"', 1)
+call s:test_list_args('print("hello\tworld")', "hello\tworld", 1)
+endfunc
+func Test_keep_pty_open()
+if !has('unix')
+return
+endif
+let job = job_start(s:python . ' -c "import time;time.sleep(0.2)"',
+\ {'out_io': 'null', 'err_io': 'null', 'pty': 1})
+let elapsed = WaitFor({-> job_status(job) ==# 'dead'})
+call assert_inrange(200, 1000, elapsed)
+call job_stop(job)
+endfunc
+func Test_job_start_in_timer()
+CheckFeature timers
+func OutCb(chan, msg)
+let g:val += 1
+endfunc
+func ExitCb(job, status)
+let g:val += 1
+call Resume()
+endfunc
+func TimerCb(timer)
+if has('win32')
+let cmd = ['cmd', '/c', 'echo.']
+else
+let cmd = ['echo']
+endif
+let g:job = job_start(cmd, {'out_cb': 'OutCb', 'exit_cb': 'ExitCb'})
+call substitute(repeat('a', 100000), '.', '', 'g')
+endfunc
+" We should be interrupted before 'updatetime' elapsed.
+let g:val = 0
+call timer_start(1, 'TimerCb')
+let elapsed = Standby(&ut)
+call assert_inrange(1, &ut / 2, elapsed)
+" Wait for both OutCb() and ExitCb() to have been called before deleting
+" them.
+call WaitForAssert({-> assert_equal(2, g:val)})
+call job_stop(g:job)
+delfunc OutCb
+delfunc ExitCb
+delfunc TimerCb
+unlet! g:val
+unlet! g:job
+endfunc
+func Test_raw_large_data()
+try
+let g:out = ''
+let job = job_start(s:python . " test_channel_pipe.py",
+\ {'mode': 'raw', 'drop': 'never', 'noblock': 1,
+\  'callback': {ch, msg -> execute('let g:out .= msg')}})
+let outlen = 79999
+let want = repeat('X', outlen) . "\n"
+call ch_sendraw(job, want)
+call WaitFor({-> len(g:out) >= outlen}, 10000)
+call WaitForAssert({-> assert_equal("dead", job_status(job))})
+call assert_equal(want, substitute(g:out, '\r', '', 'g'))
+finally
+call job_stop(job)
+unlet g:out
+endtry
+endfunc
+func Test_no_hang_windows()
+CheckMSWindows
+try
+let job = job_start(s:python . " test_channel_pipe.py busy",
+\ {'mode': 'raw', 'drop': 'never', 'noblock': 0})
+call assert_fails('call ch_sendraw(job, repeat("X", 80000))', 'E631:')
+finally
+call job_stop(job)
+endtry
+endfunc
+func Test_job_exitval_and_termsig()
+if !has('unix')
+return
+endif
+" Terminate job normally
+let cmd = ['echo']
+let job = job_start(cmd)
+call WaitForAssert({-> assert_equal("dead", job_status(job))})
+let info = job_info(job)
+call assert_equal(0, info.exitval)
+call assert_equal("", info.termsig)
+" Terminate job by signal
+let cmd = ['sleep', '10']
+let job = job_start(cmd)
+sleep 10m
+call job_stop(job)
+call WaitForAssert({-> assert_equal("dead", job_status(job))})
+let info = job_info(job)
+call assert_equal(-1, info.exitval)
+call assert_equal("term", info.termsig)
+endfunc
+func Test_job_tty_in_out()
+CheckUnix
+call writefile(['test'], 'Xtestin')
+let in_opts = [{},
+\ {'in_io': 'null'},
+\ {'in_io': 'file', 'in_name': 'Xtestin'}]
+let out_opts = [{},
+\ {'out_io': 'null'},
+\ {'out_io': 'file', 'out_name': 'Xtestout'}]
+let err_opts = [{},
+\ {'err_io': 'null'},
+\ {'err_io': 'file', 'err_name': 'Xtesterr'},
+\ {'err_io': 'out'}]
+let opts = []
+for in_opt in in_opts
+let x = copy(in_opt)
+for out_opt in out_opts
+let x = extend(copy(x), out_opt)
+for err_opt in err_opts
+let x = extend(copy(x), err_opt)
+let opts += [extend({'pty': 1}, x)]
+endfor
+endfor
+endfor
+for opt in opts
+let job = job_start('echo', opt)
+let info = job_info(job)
+let msg = printf('option={"in_io": "%s", "out_io": "%s", "err_io": "%s"}',
+\ get(opt, 'in_io', 'tty'),
+\ get(opt, 'out_io', 'tty'),
+\ get(opt, 'err_io', 'tty'))
+if !has_key(opt, 'in_io') || !has_key(opt, 'out_io') || !has_key(opt, 'err_io')
+call assert_notequal('', info.tty_in, msg)
+else
+call assert_equal('', info.tty_in, msg)
+endif
+call assert_equal(info.tty_in, info.tty_out, msg)
+call WaitForAssert({-> assert_equal('dead', job_status(job))})
+endfor
+call delete('Xtestin')
+call delete('Xtestout')
+call delete('Xtesterr')
+endfunc
+" Do this last, it stops any channel log.
+func Test_zz_nl_err_to_out_pipe()
 call ch_logfile('Xlog')
-call ch_log('Test_nl_err_to_out_pipe()')
+call ch_log('Test_zz_nl_err_to_out_pipe()')
 let job = job_start(s:python . " test_channel_pipe.py", {'err_io': 'out'})
 call assert_equal("run", job_status(job))
 try
 let handle = job_getchannel(job)
 call ch_sendraw(handle, "echo something\n")
 let found_test = 0
 let found_send = 0
 let found_recv = 0
 let found_stop = 0
 for l in loglines
-if l =~ 'Test_nl_err_to_out_pipe'
+if l =~ 'Test_zz_nl_err_to_out_pipe'
 	let found_test = 1
 endif
 if l =~ 'SEND on.*echo something'
 	let found_send = 1
 endif
 sleep 10m
 call delete('Xlog')
 endtry
 endfunc
-func Stop_g_job()
-call job_stop(g:job)
-if has('win32')
-" On MS-Windows the server must close the file handle before we are able
-" to delete the file.
-call WaitForAssert({-> assert_equal('dead', job_status(g:job))})
-sleep 10m
-endif
-endfunc
-func Test_nl_read_file()
-if !has('job')
-return
-endif
-call ch_log('Test_nl_read_file()')
-call writefile(['echo something', 'echoerr wrong', 'double this'], 'Xinput')
-let g:job = job_start(s:python . " test_channel_pipe.py",
-	\ {'in_io': 'file', 'in_name': 'Xinput'})
-call assert_equal("run", job_status(g:job))
-try
-let handle = job_getchannel(g:job)
-call assert_equal("something", ch_readraw(handle))
-call assert_equal("wrong", ch_readraw(handle, {'part': 'err'}))
-call assert_equal("this", ch_readraw(handle))
-call assert_equal("AND this", ch_readraw(handle))
-finally
-call Stop_g_job()
-call delete('Xinput')
-endtry
-endfunc
-func Test_nl_write_out_file()
-if !has('job')
-return
-endif
-call ch_log('Test_nl_write_out_file()')
-let g:job = job_start(s:python . " test_channel_pipe.py",
-	\ {'out_io': 'file', 'out_name': 'Xoutput'})
-call assert_equal("run", job_status(g:job))
-try
-let handle = job_getchannel(g:job)
-call ch_sendraw(handle, "echo line one\n")
-call ch_sendraw(handle, "echo line two\n")
-call ch_sendraw(handle, "double this\n")
-call WaitForAssert({-> assert_equal(['line one', 'line two', 'this', 'AND this'], readfile('Xoutput'))})
-finally
-call Stop_g_job()
-call assert_equal(-1, match(s:get_resources(), '\(^\|/\)Xoutput$'))
-call delete('Xoutput')
-endtry
-endfunc
-func Test_nl_write_err_file()
-if !has('job')
-return
-endif
-call ch_log('Test_nl_write_err_file()')
-let g:job = job_start(s:python . " test_channel_pipe.py",
-	\ {'err_io': 'file', 'err_name': 'Xoutput'})
-call assert_equal("run", job_status(g:job))
-try
-let handle = job_getchannel(g:job)
-call ch_sendraw(handle, "echoerr line one\n")
-call ch_sendraw(handle, "echoerr line two\n")
-call ch_sendraw(handle, "doubleerr this\n")
-call WaitForAssert({-> assert_equal(['line one', 'line two', 'this', 'AND this'], readfile('Xoutput'))})
-finally
-call Stop_g_job()
-call delete('Xoutput')
-endtry
-endfunc
-func Test_nl_write_both_file()
-if !has('job')
-return
-endif
-call ch_log('Test_nl_write_both_file()')
-let g:job = job_start(s:python . " test_channel_pipe.py",
-	\ {'out_io': 'file', 'out_name': 'Xoutput', 'err_io': 'out'})
-call assert_equal("run", job_status(g:job))
-try
-let handle = job_getchannel(g:job)
-call ch_sendraw(handle, "echoerr line one\n")
-call ch_sendraw(handle, "echo line two\n")
-call ch_sendraw(handle, "double this\n")
-call ch_sendraw(handle, "doubleerr that\n")
-call WaitForAssert({-> assert_equal(['line one', 'line two', 'this', 'AND this', 'that', 'AND that'], readfile('Xoutput'))})
-finally
-call Stop_g_job()
-call assert_equal(-1, match(s:get_resources(), '\(^\|/\)Xoutput$'))
-call delete('Xoutput')
-endtry
-endfunc
-func BufCloseCb(ch)
-let g:Ch_bufClosed = 'yes'
-endfunc
-func Run_test_pipe_to_buffer(use_name, nomod, do_msg)
-if !has('job')
-return
-endif
-call ch_log('Test_pipe_to_buffer()')
-let g:Ch_bufClosed = 'no'
-let options = {'out_io': 'buffer', 'close_cb': 'BufCloseCb'}
-let expected = ['', 'line one', 'line two', 'this', 'AND this', 'Goodbye!']
-if a:use_name
-let options['out_name'] = 'pipe-output'
-if a:do_msg
-let expected[0] = 'Reading from channel output...'
-else
-let options['out_msg'] = 0
-call remove(expected, 0)
-endif
-else
-sp pipe-output
-let options['out_buf'] = bufnr('%')
-quit
-call remove(expected, 0)
-endif
-if a:nomod
-let options['out_modifiable'] = 0
-endif
-let job = job_start(s:python . " test_channel_pipe.py", options)
-call assert_equal("run", job_status(job))
-try
-let handle = job_getchannel(job)
-call ch_sendraw(handle, "echo line one\n")
-call ch_sendraw(handle, "echo line two\n")
-call ch_sendraw(handle, "double this\n")
-call ch_sendraw(handle, "quit\n")
-sp pipe-output
-call WaitFor('line("$") == ' . len(expected) . ' && g:Ch_bufClosed == "yes"')
-call assert_equal(expected, getline(1, '$'))
-if a:nomod
-call assert_equal(0, &modifiable)
-else
-call assert_equal(1, &modifiable)
-endif
-call assert_equal('yes', g:Ch_bufClosed)
-bwipe!
-finally
-call job_stop(job)
-endtry
-endfunc
-func Test_pipe_to_buffer_name()
-call Run_test_pipe_to_buffer(1, 0, 1)
-endfunc
-func Test_pipe_to_buffer_nr()
-call Run_test_pipe_to_buffer(0, 0, 1)
-endfunc
-func Test_pipe_to_buffer_name_nomod()
-call Run_test_pipe_to_buffer(1, 1, 1)
-endfunc
-func Test_pipe_to_buffer_name_nomsg()
-call Run_test_pipe_to_buffer(1, 0, 1)
-endfunc
-func Test_close_output_buffer()
-if !has('job')
-return
-endif
-enew!
-let test_lines = ['one', 'two']
-call setline(1, test_lines)
-call ch_log('Test_close_output_buffer()')
-let options = {'out_io': 'buffer'}
-let options['out_name'] = 'buffer-output'
-let options['out_msg'] = 0
-split buffer-output
-let job = job_start(s:python . " test_channel_write.py", options)
-call assert_equal("run", job_status(job))
-try
-call WaitForAssert({-> assert_equal(3, line('$'))})
-quit!
-sleep 100m
-" Make sure the write didn't happen to the wrong buffer.
-call assert_equal(test_lines, getline(1, line('$')))
-call assert_equal(-1, bufwinnr('buffer-output'))
-sbuf buffer-output
-call assert_notequal(-1, bufwinnr('buffer-output'))
-sleep 100m
-close  " no more writes
-bwipe!
-finally
-call job_stop(job)
-endtry
-endfunc
-func Run_test_pipe_err_to_buffer(use_name, nomod, do_msg)
-if !has('job')
-return
-endif
-call ch_log('Test_pipe_err_to_buffer()')
-let options = {'err_io': 'buffer'}
-let expected = ['', 'line one', 'line two', 'this', 'AND this']
-if a:use_name
-let options['err_name'] = 'pipe-err'
-if a:do_msg
-let expected[0] = 'Reading from channel error...'
-else
-let options['err_msg'] = 0
-call remove(expected, 0)
-endif
-else
-sp pipe-err
-let options['err_buf'] = bufnr('%')
-quit
-call remove(expected, 0)
-endif
-if a:nomod
-let options['err_modifiable'] = 0
-endif
-let job = job_start(s:python . " test_channel_pipe.py", options)
-call assert_equal("run", job_status(job))
-try
-let handle = job_getchannel(job)
-call ch_sendraw(handle, "echoerr line one\n")
-call ch_sendraw(handle, "echoerr line two\n")
-call ch_sendraw(handle, "doubleerr this\n")
-call ch_sendraw(handle, "quit\n")
-sp pipe-err
-call WaitForAssert({-> assert_equal(expected, getline(1, '$'))})
-if a:nomod
-call assert_equal(0, &modifiable)
-else
-call assert_equal(1, &modifiable)
-endif
-bwipe!
-finally
-call job_stop(job)
-endtry
-endfunc
-func Test_pipe_err_to_buffer_name()
-call Run_test_pipe_err_to_buffer(1, 0, 1)
-endfunc
-func Test_pipe_err_to_buffer_nr()
-call Run_test_pipe_err_to_buffer(0, 0, 1)
-endfunc
-func Test_pipe_err_to_buffer_name_nomod()
-call Run_test_pipe_err_to_buffer(1, 1, 1)
-endfunc
-func Test_pipe_err_to_buffer_name_nomsg()
-call Run_test_pipe_err_to_buffer(1, 0, 0)
-endfunc
-func Test_pipe_both_to_buffer()
-if !has('job')
-return
-endif
-call ch_log('Test_pipe_both_to_buffer()')
-let job = job_start(s:python . " test_channel_pipe.py",
-	\ {'out_io': 'buffer', 'out_name': 'pipe-err', 'err_io': 'out'})
-call assert_equal("run", job_status(job))
-try
-let handle = job_getchannel(job)
-call ch_sendraw(handle, "echo line one\n")
-call ch_sendraw(handle, "echoerr line two\n")
-call ch_sendraw(handle, "double this\n")
-call ch_sendraw(handle, "doubleerr that\n")
-call ch_sendraw(handle, "quit\n")
-sp pipe-err
-call WaitForAssert({-> assert_equal(['Reading from channel output...', 'line one', 'line two', 'this', 'AND this', 'that', 'AND that', 'Goodbye!'], getline(1, '$'))})
-bwipe!
-finally
-call job_stop(job)
-endtry
-endfunc
-func Run_test_pipe_from_buffer(use_name)
-if !has('job')
-return
-endif
-call ch_log('Test_pipe_from_buffer()')
-sp pipe-input
-call setline(1, ['echo one', 'echo two', 'echo three'])
-let options = {'in_io': 'buffer', 'block_write': 1}
-if a:use_name
-let options['in_name'] = 'pipe-input'
-else
-let options['in_buf'] = bufnr('%')
-endif
-let job = job_start(s:python . " test_channel_pipe.py", options)
-call assert_equal("run", job_status(job))
-try
-let handle = job_getchannel(job)
-call assert_equal('one', ch_read(handle))
-call assert_equal('two', ch_read(handle))
-call assert_equal('three', ch_read(handle))
-bwipe!
-finally
-call job_stop(job)
-endtry
-endfunc
-func Test_pipe_from_buffer_name()
-call Run_test_pipe_from_buffer(1)
-endfunc
-func Test_pipe_from_buffer_nr()
-call Run_test_pipe_from_buffer(0)
-endfunc
-func Run_pipe_through_sort(all, use_buffer)
-if !executable('sort') || !has('job')
-return
-endif
-let options = {'out_io': 'buffer', 'out_name': 'sortout'}
-if a:use_buffer
-split sortin
-call setline(1, ['ccc', 'aaa', 'ddd', 'bbb', 'eee'])
-let options.in_io = 'buffer'
-let options.in_name = 'sortin'
-endif
-if !a:all
-let options.in_top = 2
-let options.in_bot = 4
-endif
-let job = job_start('sort', options)
-if !a:use_buffer
-call assert_equal("run", job_status(job))
-call ch_sendraw(job, "ccc\naaa\nddd\nbbb\neee\n")
-call ch_close_in(job)
-endif
-call WaitForAssert({-> assert_equal("dead", job_status(job))})
-sp sortout
-call WaitFor('line("$") > 3')
-call assert_equal('Reading from channel output...', getline(1))
-if a:all
-call assert_equal(['aaa', 'bbb', 'ccc', 'ddd', 'eee'], getline(2, 6))
-else
-call assert_equal(['aaa', 'bbb', 'ddd'], getline(2, 4))
-endif
-call job_stop(job)
-if a:use_buffer
-bwipe! sortin
-endif
-bwipe! sortout
-endfunc
-func Test_pipe_through_sort_all()
-call ch_log('Test_pipe_through_sort_all()')
-call Run_pipe_through_sort(1, 1)
-endfunc
-func Test_pipe_through_sort_some()
-call ch_log('Test_pipe_through_sort_some()')
-call Run_pipe_through_sort(0, 1)
-endfunc
-func Test_pipe_through_sort_feed()
-call ch_log('Test_pipe_through_sort_feed()')
-call Run_pipe_through_sort(1, 0)
-endfunc
-func Test_pipe_to_nameless_buffer()
-if !has('job')
-return
-endif
-call ch_log('Test_pipe_to_nameless_buffer()')
-let job = job_start(s:python . " test_channel_pipe.py",
-	\ {'out_io': 'buffer'})
-call assert_equal("run", job_status(job))
-try
-let handle = job_getchannel(job)
-call ch_sendraw(handle, "echo line one\n")
-call ch_sendraw(handle, "echo line two\n")
-exe ch_getbufnr(handle, "out") . 'sbuf'
-call WaitFor('line("$") >= 3')
-call assert_equal(['Reading from channel output...', 'line one', 'line two'], getline(1, '$'))
-bwipe!
-finally
-call job_stop(job)
-endtry
-endfunc
-func Test_pipe_to_buffer_json()
-if !has('job')
-return
-endif
-call ch_log('Test_pipe_to_buffer_json()')
-let job = job_start(s:python . " test_channel_pipe.py",
-	\ {'out_io': 'buffer', 'out_mode': 'json'})
-call assert_equal("run", job_status(job))
-try
-let handle = job_getchannel(job)
-call ch_sendraw(handle, "echo [0, \"hello\"]\n")
-call ch_sendraw(handle, "echo [-2, 12.34]\n")
-exe ch_getbufnr(handle, "out") . 'sbuf'
-call WaitFor('line("$") >= 3')
-call assert_equal(['Reading from channel output...', '[0,"hello"]', '[-2,12.34]'], getline(1, '$'))
-bwipe!
-finally
-call job_stop(job)
-endtry
-endfunc
-" Wait a little while for the last line, minus "offset", to equal "line".
-func s:wait_for_last_line(line, offset)
-for i in range(100)
-if getline(line('$') - a:offset) == a:line
-break
-endif
-sleep 10m
-endfor
-endfunc
-func Test_pipe_io_two_buffers()
-if !has('job')
-return
-endif
-call ch_log('Test_pipe_io_two_buffers()')
-" Create two buffers, one to read from and one to write to.
-split pipe-output
-set buftype=nofile
-split pipe-input
-set buftype=nofile
-let job = job_start(s:python . " test_channel_pipe.py",
-	\ {'in_io': 'buffer', 'in_name': 'pipe-input', 'in_top': 0,
-	\  'out_io': 'buffer', 'out_name': 'pipe-output',
-	\  'block_write': 1})
-call assert_equal("run", job_status(job))
-try
-exe "normal Gaecho hello\<CR>"
-exe bufwinnr('pipe-output') . "wincmd w"
-call s:wait_for_last_line('hello', 0)
-call assert_equal('hello', getline('$'))
-exe bufwinnr('pipe-input') . "wincmd w"
-exe "normal Gadouble this\<CR>"
-exe bufwinnr('pipe-output') . "wincmd w"
-call s:wait_for_last_line('AND this', 0)
-call assert_equal('this', getline(line('$') - 1))
-call assert_equal('AND this', getline('$'))
-bwipe!
-exe bufwinnr('pipe-input') . "wincmd w"
-bwipe!
-finally
-call job_stop(job)
-endtry
-endfunc
-func Test_pipe_io_one_buffer()
-if !has('job')
-return
-endif
-call ch_log('Test_pipe_io_one_buffer()')
-" Create one buffer to read from and to write to.
-split pipe-io
-set buftype=nofile
-let job = job_start(s:python . " test_channel_pipe.py",
-	\ {'in_io': 'buffer', 'in_name': 'pipe-io', 'in_top': 0,
-	\  'out_io': 'buffer', 'out_name': 'pipe-io',
-	\  'block_write': 1})
-call assert_equal("run", job_status(job))
-try
-exe "normal Goecho hello\<CR>"
-call s:wait_for_last_line('hello', 1)
-call assert_equal('hello', getline(line('$') - 1))
-exe "normal Gadouble this\<CR>"
-call s:wait_for_last_line('AND this', 1)
-call assert_equal('this', getline(line('$') - 2))
-call assert_equal('AND this', getline(line('$') - 1))
-bwipe!
-finally
-call job_stop(job)
-endtry
-endfunc
-func Test_write_to_buffer_and_scroll()
-CheckFeature job
-if !CanRunVimInTerminal()
-throw 'Skipped: cannot make screendumps'
-endif
-let lines =<< trim END
-new Xscrollbuffer
-call setline(1, range(1, 200))
-$
-redraw
-wincmd w
-call deletebufline('Xscrollbuffer', 1, '$')
-if has('win32')
-	let cmd = ['cmd', '/c', 'echo sometext']
-else
-	let cmd = [&shell, &shellcmdflag, 'echo sometext']
-endif
-call job_start(cmd, #{out_io: 'buffer', out_name: 'Xscrollbuffer'})
-END
-call writefile(lines, 'XtestBufferScroll')
-let buf = RunVimInTerminal('-S XtestBufferScroll', #{rows: 10})
-sleep 500m
-call VerifyScreenDump(buf, 'Test_job_buffer_scroll_1', {})
-" clean up
-call StopVimInTerminal(buf)
-call delete('XtestBufferScroll')
-endfunc
-func Test_pipe_null()
-if !has('job')
-return
-endif
-call ch_log('Test_pipe_null()')
-" We cannot check that no I/O works, we only check that the job starts
-" properly.
-let job = job_start(s:python . " test_channel_pipe.py something",
-	\ {'in_io': 'null'})
-call assert_equal("run", job_status(job))
-try
-call assert_equal('something', ch_read(job))
-finally
-call job_stop(job)
-endtry
-let job = job_start(s:python . " test_channel_pipe.py err-out",
-	\ {'out_io': 'null'})
-call assert_equal("run", job_status(job))
-try
-call assert_equal('err-out', ch_read(job, {"part": "err"}))
-finally
-call job_stop(job)
-endtry
-let job = job_start(s:python . " test_channel_pipe.py something",
-	\ {'err_io': 'null'})
-call assert_equal("run", job_status(job))
-try
-call assert_equal('something', ch_read(job))
-finally
-call job_stop(job)
-endtry
-let job = job_start(s:python . " test_channel_pipe.py something",
-	\ {'out_io': 'null', 'err_io': 'out'})
-call assert_equal("run", job_status(job))
-call job_stop(job)
-let job = job_start(s:python . " test_channel_pipe.py something",
-	\ {'in_io': 'null', 'out_io': 'null', 'err_io': 'null'})
-call assert_equal("run", job_status(job))
-call assert_equal('channel fail', string(job_getchannel(job)))
-call assert_equal('fail', ch_status(job))
-call job_stop(job)
-endfunc
-func Test_pipe_to_buffer_raw()
-if !has('job')
-return
-endif
-call ch_log('Test_raw_pipe_to_buffer()')
-let options = {'out_mode': 'raw', 'out_io': 'buffer', 'out_name': 'testout'}
-split testout
-let job = job_start([s:python, '-c',
-\ 'import sys; [sys.stdout.write(".") and sys.stdout.flush() for _ in range(10000)]'], options)
-" the job may be done quickly, also accept "dead"
-call assert_match('^\%(dead\|run\)$', job_status(job))
-call WaitFor('len(join(getline(1, "$"), "")) >= 10000')
-try
-let totlen = 0
-for line in getline(1, '$')
-call assert_equal('', substitute(line, '^\.*', '', ''))
-let totlen += len(line)
-endfor
-call assert_equal(10000, totlen)
-finally
-call job_stop(job)
-bwipe!
-endtry
-endfunc
-func Test_reuse_channel()
-if !has('job')
-return
-endif
-call ch_log('Test_reuse_channel()')
-let job = job_start(s:python . " test_channel_pipe.py")
-call assert_equal("run", job_status(job))
-let handle = job_getchannel(job)
-try
-call ch_sendraw(handle, "echo something\n")
-call assert_equal("something", ch_readraw(handle))
-finally
-call job_stop(job)
-endtry
-let job = job_start(s:python . " test_channel_pipe.py", {'channel': handle})
-call assert_equal("run", job_status(job))
-let handle = job_getchannel(job)
-try
-call ch_sendraw(handle, "echo again\n")
-call assert_equal("again", ch_readraw(handle))
-finally
-call job_stop(job)
-endtry
-endfunc
-func Test_out_cb()
-if !has('job')
-return
-endif
-call ch_log('Test_out_cb()')
-let dict = {'thisis': 'dict: '}
-func dict.outHandler(chan, msg) dict
-if type(a:msg) == v:t_string
-let g:Ch_outmsg = self.thisis . a:msg
-else
-let g:Ch_outobj = a:msg
-endif
-endfunc
-func dict.errHandler(chan, msg) dict
-let g:Ch_errmsg = self.thisis . a:msg
-endfunc
-let job = job_start(s:python . " test_channel_pipe.py",
-	\ {'out_cb': dict.outHandler,
-	\  'out_mode': 'json',
-	\  'err_cb': dict.errHandler,
-	\  'err_mode': 'json'})
-call assert_equal("run", job_status(job))
-try
-let g:Ch_outmsg = ''
-let g:Ch_errmsg = ''
-call ch_sendraw(job, "echo [0, \"hello\"]\n")
-call ch_sendraw(job, "echoerr [0, \"there\"]\n")
-call WaitForAssert({-> assert_equal("dict: hello", g:Ch_outmsg)})
-call WaitForAssert({-> assert_equal("dict: there", g:Ch_errmsg)})
-" Receive a json object split in pieces
-unlet! g:Ch_outobj
-call ch_sendraw(job, "echosplit [0, {\"one\": 1,| \"tw|o\": 2, \"three\": 3|}]\n")
-let g:Ch_outobj = ''
-call WaitForAssert({-> assert_equal({'one': 1, 'two': 2, 'three': 3}, g:Ch_outobj)})
-finally
-call job_stop(job)
-endtry
-endfunc
-func Test_out_close_cb()
-if !has('job')
-return
-endif
-call ch_log('Test_out_close_cb()')
-let s:counter = 1
-let g:Ch_msg1 = ''
-let g:Ch_closemsg = 0
-func! OutHandler(chan, msg)
-if s:counter == 1
-let g:Ch_msg1 = a:msg
-endif
-let s:counter += 1
-endfunc
-func! CloseHandler(chan)
-let g:Ch_closemsg = s:counter
-let s:counter += 1
-endfunc
-let job = job_start(s:python . " test_channel_pipe.py quit now",
-	\ {'out_cb': 'OutHandler',
-	\  'close_cb': 'CloseHandler'})
-" the job may be done quickly, also accept "dead"
-call assert_match('^\%(dead\|run\)$', job_status(job))
-try
-call WaitForAssert({-> assert_equal('quit', g:Ch_msg1)})
-call WaitForAssert({-> assert_equal(2, g:Ch_closemsg)})
-finally
-call job_stop(job)
-delfunc OutHandler
-delfunc CloseHandler
-endtry
-endfunc
-func Test_read_in_close_cb()
-if !has('job')
-return
-endif
-call ch_log('Test_read_in_close_cb()')
-let g:Ch_received = ''
-func! CloseHandler(chan)
-let g:Ch_received = ch_read(a:chan)
-endfunc
-let job = job_start(s:python . " test_channel_pipe.py quit now",
-	\ {'close_cb': 'CloseHandler'})
-" the job may be done quickly, also accept "dead"
-call assert_match('^\%(dead\|run\)$', job_status(job))
-try
-call WaitForAssert({-> assert_equal('quit', g:Ch_received)})
-finally
-call job_stop(job)
-delfunc CloseHandler
-endtry
-endfunc
-" Use channel in NL mode but received text does not end in NL.
-func Test_read_in_close_cb_incomplete()
-if !has('job')
-return
-endif
-call ch_log('Test_read_in_close_cb_incomplete()')
-let g:Ch_received = ''
-func! CloseHandler(chan)
-while ch_status(a:chan, {'part': 'out'}) == 'buffered'
-let g:Ch_received .= ch_read(a:chan)
-endwhile
-endfunc
-let job = job_start(s:python . " test_channel_pipe.py incomplete",
-	\ {'close_cb': 'CloseHandler'})
-" the job may be done quickly, also accept "dead"
-call assert_match('^\%(dead\|run\)$', job_status(job))
-try
-call WaitForAssert({-> assert_equal('incomplete', g:Ch_received)})
-finally
-call job_stop(job)
-delfunc CloseHandler
-endtry
-endfunc
-func Test_out_cb_lambda()
-if !has('job')
-return
-endif
-call ch_log('Test_out_cb_lambda()')
-let job = job_start(s:python . " test_channel_pipe.py",
-\ {'out_cb': {ch, msg -> execute("let g:Ch_outmsg = 'lambda: ' . msg")},
-\  'out_mode': 'json',
-\  'err_cb': {ch, msg -> execute(":let g:Ch_errmsg = 'lambda: ' . msg")},
-\  'err_mode': 'json'})
-call assert_equal("run", job_status(job))
-try
-let g:Ch_outmsg = ''
-let g:Ch_errmsg = ''
-call ch_sendraw(job, "echo [0, \"hello\"]\n")
-call ch_sendraw(job, "echoerr [0, \"there\"]\n")
-call WaitForAssert({-> assert_equal("lambda: hello", g:Ch_outmsg)})
-call WaitForAssert({-> assert_equal("lambda: there", g:Ch_errmsg)})
-finally
-call job_stop(job)
-endtry
-endfunc
-func Test_close_and_exit_cb()
-if !has('job')
-return
-endif
-call ch_log('Test_close_and_exit_cb')
-let g:retdict = {'ret': {}}
-func g:retdict.close_cb(ch) dict
-let self.ret['close_cb'] = job_status(ch_getjob(a:ch))
-endfunc
-func g:retdict.exit_cb(job, status) dict
-let self.ret['exit_cb'] = job_status(a:job)
-endfunc
-let job = job_start([&shell, &shellcmdflag, 'echo'],
-\ {'close_cb': g:retdict.close_cb,
-\  'exit_cb': g:retdict.exit_cb})
-" the job may be done quickly, also accept "dead"
-call assert_match('^\%(dead\|run\)$', job_status(job))
-call WaitForAssert({-> assert_equal(2, len(g:retdict.ret))})
-call assert_match('^\%(dead\|run\)$', g:retdict.ret['close_cb'])
-call assert_equal('dead', g:retdict.ret['exit_cb'])
-unlet g:retdict
-endfunc
-""""""""""
-function ExitCbWipe(job, status)
-exe g:wipe_buf 'bw!'
-endfunction
-" This caused a crash, because messages were handled while peeking for a
-" character.
-func Test_exit_cb_wipes_buf()
-if !has('timers')
-return
-endif
-set cursorline lazyredraw
-call test_override('redraw_flag', 1)
-new
-let g:wipe_buf = bufnr('')
-let job = job_start(has('win32') ? 'cmd /c echo:' : ['true'],
-	\ {'exit_cb': 'ExitCbWipe'})
-let timer = timer_start(300, {-> feedkeys("\<Esc>", 'nt')}, {'repeat': 5})
-call feedkeys(repeat('g', 1000) . 'o', 'ntx!')
-call WaitForAssert({-> assert_equal("dead", job_status(job))})
-call timer_stop(timer)
-set nocursorline nolazyredraw
-unlet g:wipe_buf
-call test_override('ALL', 0)
-endfunc
-""""""""""
-let g:Ch_unletResponse = ''
-func s:UnletHandler(handle, msg)
-let g:Ch_unletResponse = a:msg
-unlet s:channelfd
-endfunc
-" Test that "unlet handle" in a handler doesn't crash Vim.
-func Ch_unlet_handle(port)
-let s:channelfd = ch_open('localhost:' . a:port, s:chopt)
-call ch_sendexpr(s:channelfd, "test", {'callback': function('s:UnletHandler')})
-call WaitForAssert({-> assert_equal('what?', g:Ch_unletResponse)})
-endfunc
-func Test_unlet_handle()
-call ch_log('Test_unlet_handle()')
-call s:run_server('Ch_unlet_handle')
-endfunc
-""""""""""
-let g:Ch_unletResponse = ''
-func Ch_CloseHandler(handle, msg)
-let g:Ch_unletResponse = a:msg
-call ch_close(s:channelfd)
-endfunc
-" Test that "unlet handle" in a handler doesn't crash Vim.
-func Ch_close_handle(port)
-let s:channelfd = ch_open('localhost:' . a:port, s:chopt)
-call ch_sendexpr(s:channelfd, "test", {'callback': function('Ch_CloseHandler')})
-call WaitForAssert({-> assert_equal('what?', g:Ch_unletResponse)})
-endfunc
-func Test_close_handle()
-call ch_log('Test_close_handle()')
-call s:run_server('Ch_close_handle')
-endfunc
-""""""""""
-func Test_open_fail()
-call ch_log('Test_open_fail()')
-silent! let ch = ch_open("noserver")
-echo ch
-let d = ch
-endfunc
-""""""""""
-func Ch_open_delay(port)
-" Wait up to a second for the port to open.
-let s:chopt.waittime = 1000
-let channel = ch_open('localhost:' . a:port, s:chopt)
-unlet s:chopt.waittime
-if ch_status(channel) == "fail"
-call assert_report("Can't open channel")
-return
-endif
-call assert_equal('got it', ch_evalexpr(channel, 'hello!'))
-call ch_close(channel)
-endfunc
-func Test_open_delay()
-call ch_log('Test_open_delay()')
-" The server will wait half a second before creating the port.
-call s:run_server('Ch_open_delay', 'delay')
-endfunc
-"""""""""
-function MyFunction(a,b,c)
-let g:Ch_call_ret = [a:a, a:b, a:c]
-endfunc
-function Ch_test_call(port)
-let handle = ch_open('localhost:' . a:port, s:chopt)
-if ch_status(handle) == "fail"
-call assert_report("Can't open channel")
-return
-endif
-let g:Ch_call_ret = []
-call assert_equal('ok', ch_evalexpr(handle, 'call-func'))
-call WaitForAssert({-> assert_equal([1, 2, 3], g:Ch_call_ret)})
-endfunc
-func Test_call()
-call ch_log('Test_call()')
-call s:run_server('Ch_test_call')
-endfunc
-"""""""""
-let g:Ch_job_exit_ret = 'not yet'
-function MyExitCb(job, status)
-let g:Ch_job_exit_ret = 'done'
-endfunc
-function Ch_test_exit_callback(port)
-call job_setoptions(g:currentJob, {'exit_cb': 'MyExitCb'})
-let g:Ch_exit_job = g:currentJob
-call assert_equal('MyExitCb', job_info(g:currentJob)['exit_cb'])
-endfunc
-func Test_exit_callback()
-if has('job')
-call ch_log('Test_exit_callback()')
-call s:run_server('Ch_test_exit_callback')
-" wait up to a second for the job to exit
-for i in range(100)
-if g:Ch_job_exit_ret == 'done'
-	break
-endif
-sleep 10m
-" calling job_status() triggers the callback
-call job_status(g:Ch_exit_job)
-endfor
-call assert_equal('done', g:Ch_job_exit_ret)
-call assert_equal('dead', job_info(g:Ch_exit_job).status)
-unlet g:Ch_exit_job
-endif
-endfunc
-function MyExitTimeCb(job, status)
-if job_info(a:job).process == g:exit_cb_val.process
-let g:exit_cb_val.end = reltime(g:exit_cb_val.start)
-endif
-call Resume()
-endfunction
-func Test_exit_callback_interval()
-if !has('job')
-return
-endif
-let g:exit_cb_val = {'start': reltime(), 'end': 0, 'process': 0}
-let job = job_start([s:python, '-c', 'import time;time.sleep(0.5)'], {'exit_cb': 'MyExitTimeCb'})
-let g:exit_cb_val.process = job_info(job).process
-call WaitFor('type(g:exit_cb_val.end) != v:t_number || g:exit_cb_val.end != 0')
-let elapsed = reltimefloat(g:exit_cb_val.end)
-call assert_true(elapsed > 0.5)
-call assert_true(elapsed < 1.0)
-" case: unreferenced job, using timer
-if !has('timers')
-return
-endif
-let g:exit_cb_val = {'start': reltime(), 'end': 0, 'process': 0}
-let g:job = job_start([s:python, '-c', 'import time;time.sleep(0.5)'], {'exit_cb': 'MyExitTimeCb'})
-let g:exit_cb_val.process = job_info(g:job).process
-unlet g:job
-call Standby(1000)
-if type(g:exit_cb_val.end) != v:t_number || g:exit_cb_val.end != 0
-let elapsed = reltimefloat(g:exit_cb_val.end)
-else
-let elapsed = 1.0
-endif
-call assert_inrange(0.5, 1.0, elapsed)
-endfunc
-"""""""""
-let g:Ch_close_ret = 'alive'
-function MyCloseCb(ch)
-let g:Ch_close_ret = 'closed'
-endfunc
-function Ch_test_close_callback(port)
-let handle = ch_open('localhost:' . a:port, s:chopt)
-if ch_status(handle) == "fail"
-call assert_report("Can't open channel")
-return
-endif
-call ch_setoptions(handle, {'close_cb': 'MyCloseCb'})
-call assert_equal('', ch_evalexpr(handle, 'close me'))
-call WaitForAssert({-> assert_equal('closed', g:Ch_close_ret)})
-endfunc
-func Test_close_callback()
-call ch_log('Test_close_callback()')
-call s:run_server('Ch_test_close_callback')
-endfunc
-function Ch_test_close_partial(port)
-let handle = ch_open('localhost:' . a:port, s:chopt)
-if ch_status(handle) == "fail"
-call assert_report("Can't open channel")
-return
-endif
-let g:Ch_d = {}
-func g:Ch_d.closeCb(ch) dict
-let self.close_ret = 'closed'
-endfunc
-call ch_setoptions(handle, {'close_cb': g:Ch_d.closeCb})
-call assert_equal('', ch_evalexpr(handle, 'close me'))
-call WaitForAssert({-> assert_equal('closed', g:Ch_d.close_ret)})
-unlet g:Ch_d
-endfunc
-func Test_close_partial()
-call ch_log('Test_close_partial()')
-call s:run_server('Ch_test_close_partial')
-endfunc
-func Test_job_start_invalid()
-call assert_fails('call job_start($x)', 'E474:')
-call assert_fails('call job_start("")', 'E474:')
-endfunc
-func Test_job_stop_immediately()
-if !has('job')
-return
-endif
-let g:job = job_start([s:python, '-c', 'import time;time.sleep(10)'])
-try
-call job_stop(g:job)
-call WaitForAssert({-> assert_equal('dead', job_status(g:job))})
-finally
-call job_stop(g:job, 'kill')
-unlet g:job
-endtry
-endfunc
-" This was leaking memory.
-func Test_partial_in_channel_cycle()
-let d = {}
-let d.a = function('string', [d])
-try
-let d.b = ch_open('nowhere:123', {'close_cb': d.a})
-catch
-call assert_exception('E901:')
-endtry
-unlet d
-endfunc
-func Test_using_freed_memory()
-let g:a = job_start(['ls'])
-sleep 10m
-call test_garbagecollect_now()
-endfunc
-func Test_collapse_buffers()
-if !executable('cat') || !has('job')
-return
-endif
-sp test_channel.vim
-let g:linecount = line('$')
-close
-split testout
-1,$delete
-call job_start('cat test_channel.vim', {'out_io': 'buffer', 'out_name': 'testout'})
-call WaitForAssert({-> assert_inrange(g:linecount, g:linecount + 1, line('$'))})
-bwipe!
-endfunc
-func Test_write_to_deleted_buffer()
-if !executable('echo') || !has('job')
-return
-endif
-let job = job_start('echo hello', {'out_io': 'buffer', 'out_name': 'test_buffer', 'out_msg': 0})
-let bufnr = bufnr('test_buffer')
-call WaitForAssert({-> assert_equal(['hello'], getbufline(bufnr, 1, '$'))})
-call assert_equal('nofile', getbufvar(bufnr, '&buftype'))
-call assert_equal('hide', getbufvar(bufnr, '&bufhidden'))
-bdel test_buffer
-call assert_equal([], getbufline(bufnr, 1, '$'))
-let job = job_start('echo hello', {'out_io': 'buffer', 'out_name': 'test_buffer', 'out_msg': 0})
-call WaitForAssert({-> assert_equal(['hello'], getbufline(bufnr, 1, '$'))})
-call assert_equal('nofile', getbufvar(bufnr, '&buftype'))
-call assert_equal('hide', getbufvar(bufnr, '&bufhidden'))
-bwipe! test_buffer
-endfunc
-func Test_cmd_parsing()
-if !has('unix')
-return
-endif
-call assert_false(filereadable("file with space"))
-let job = job_start('touch "file with space"')
-call WaitForAssert({-> assert_true(filereadable("file with space"))})
-call delete("file with space")
-let job = job_start('touch file\ with\ space')
-call WaitForAssert({-> assert_true(filereadable("file with space"))})
-call delete("file with space")
-endfunc
-func Test_raw_passes_nul()
-if !executable('cat') || !has('job')
-return
-endif
-" Test lines from the job containing NUL are stored correctly in a buffer.
-new
-call setline(1, ["asdf\nasdf", "xxx\n", "\nyyy"])
-w! Xtestread
-bwipe!
-split testout
-1,$delete
-call job_start('cat Xtestread', {'out_io': 'buffer', 'out_name': 'testout'})
-call WaitFor('line("$") > 2')
-call assert_equal("asdf\nasdf", getline(1))
-call assert_equal("xxx\n", getline(2))
-call assert_equal("\nyyy", getline(3))
-call delete('Xtestread')
-bwipe!
-" Test lines from a buffer with NUL bytes are written correctly to the job.
-new mybuffer
-call setline(1, ["asdf\nasdf", "xxx\n", "\nyyy"])
-let g:Ch_job = job_start('cat', {'in_io': 'buffer', 'in_name': 'mybuffer', 'out_io': 'file', 'out_name': 'Xtestwrite'})
-call WaitForAssert({-> assert_equal("dead", job_status(g:Ch_job))})
-bwipe!
-split Xtestwrite
-call assert_equal("asdf\nasdf", getline(1))
-call assert_equal("xxx\n", getline(2))
-call assert_equal("\nyyy", getline(3))
-call assert_equal(-1, match(s:get_resources(), '\(^\|/\)Xtestwrite$'))
-call delete('Xtestwrite')
-bwipe!
-endfunc
-func Test_read_nonl_line()
-if !has('job')
-return
-endif
-let g:linecount = 0
-let arg = 'import sys;sys.stdout.write("1\n2\n3")'
-call job_start([s:python, '-c', arg], {'callback': {-> execute('let g:linecount += 1')}})
-call WaitForAssert({-> assert_equal(3, g:linecount)})
-unlet g:linecount
-endfunc
-func Test_read_nonl_in_close_cb()
-if !has('job')
-return
-endif
-func s:close_cb(ch)
-while ch_status(a:ch) == 'buffered'
-let g:out .= ch_read(a:ch)
-endwhile
-endfunc
-let g:out = ''
-let arg = 'import sys;sys.stdout.write("1\n2\n3")'
-call job_start([s:python, '-c', arg], {'close_cb': function('s:close_cb')})
-call WaitForAssert({-> assert_equal('123', g:out)})
-unlet g:out
-delfunc s:close_cb
-endfunc
-func Test_read_from_terminated_job()
-if !has('job')
-return
-endif
-let g:linecount = 0
-let arg = 'import os,sys;os.close(1);sys.stderr.write("test\n")'
-call job_start([s:python, '-c', arg], {'callback': {-> execute('let g:linecount += 1')}})
-call WaitForAssert({-> assert_equal(1, g:linecount)})
-unlet g:linecount
-endfunc
-func Test_job_start_windows()
-CheckFeature job
-CheckMSWindows
-" Check that backslash in $COMSPEC is handled properly.
-let g:echostr = ''
-let cmd = $COMSPEC . ' /c echo 123'
-let job = job_start(cmd, {'callback': {ch,msg -> execute(":let g:echostr .= msg")}})
-let info = job_info(job)
-call assert_equal([$COMSPEC, '/c', 'echo', '123'], info.cmd)
-call WaitForAssert({-> assert_equal("123", g:echostr)})
-unlet g:echostr
-endfunc
-func Test_env()
-CheckFeature job
-let g:envstr = ''
-if has('win32')
-let cmd = ['cmd', '/c', 'echo %FOO%']
-else
-let cmd = [&shell, &shellcmdflag, 'echo $FOO']
-endif
-call assert_fails('call job_start(cmd, {"env": 1})', 'E475:')
-call job_start(cmd, {'callback': {ch,msg -> execute(":let g:envstr .= msg")}, 'env': {'FOO': 'bar'}})
-call WaitForAssert({-> assert_equal("bar", g:envstr)})
-unlet g:envstr
-endfunc
-func Test_cwd()
-CheckFeature job
-let g:envstr = ''
-if has('win32')
-let expect = $TEMP
-let cmd = ['cmd', '/c', 'echo %CD%']
-else
-let expect = $HOME
-let cmd = ['pwd']
-endif
-let job = job_start(cmd, {'callback': {ch,msg -> execute(":let g:envstr .= msg")}, 'cwd': expect})
-try
-call WaitForAssert({-> assert_notequal("", g:envstr)})
-let expect = substitute(expect, '[/\\]$', '', '')
-let g:envstr = substitute(g:envstr, '[/\\]$', '', '')
-if $CI != '' && stridx(g:envstr, '/private/') == 0
-let g:envstr = g:envstr[8:]
-endif
-call assert_equal(expect, g:envstr)
-finally
-call job_stop(job)
-unlet g:envstr
-endtry
-endfunc
-function Ch_test_close_lambda(port)
-let handle = ch_open('localhost:' . a:port, s:chopt)
-if ch_status(handle) == "fail"
-call assert_report("Can't open channel")
-return
-endif
-let g:Ch_close_ret = ''
-call ch_setoptions(handle, {'close_cb': {ch -> execute("let g:Ch_close_ret = 'closed'")}})
-call assert_equal('', ch_evalexpr(handle, 'close me'))
-call WaitForAssert({-> assert_equal('closed', g:Ch_close_ret)})
-endfunc
-func Test_close_lambda()
-call ch_log('Test_close_lambda()')
-call s:run_server('Ch_test_close_lambda')
-endfunc
-func s:test_list_args(cmd, out, remove_lf)
-try
-let g:out = ''
-let job = job_start([s:python, '-c', a:cmd], {'callback': {ch, msg -> execute('let g:out .= msg')}, 'out_mode': 'raw'})
-call WaitFor('"" != g:out')
-if has('win32')
-let g:out = substitute(g:out, '\r', '', 'g')
-endif
-if a:remove_lf
-let g:out = substitute(g:out, '\n$', '', 'g')
-endif
-call assert_equal(a:out, g:out)
-finally
-call job_stop(job)
-unlet g:out
-endtry
-endfunc
-func Test_list_args()
-CheckFeature job
-call s:test_list_args('import sys;sys.stdout.write("hello world")', "hello world", 0)
-call s:test_list_args('import sys;sys.stdout.write("hello\nworld")', "hello\nworld", 0)
-call s:test_list_args('import sys;sys.stdout.write(''hello\nworld'')', "hello\nworld", 0)
-call s:test_list_args('import sys;sys.stdout.write(''hello"world'')', "hello\"world", 0)
-call s:test_list_args('import sys;sys.stdout.write(''hello^world'')', "hello^world", 0)
-call s:test_list_args('import sys;sys.stdout.write("hello&&world")', "hello&&world", 0)
-call s:test_list_args('import sys;sys.stdout.write(''hello\\world'')', "hello\\world", 0)
-call s:test_list_args('import sys;sys.stdout.write(''hello\\\\world'')', "hello\\\\world", 0)
-call s:test_list_args('import sys;sys.stdout.write("hello\"world\"")', 'hello"world"', 0)
-call s:test_list_args('import sys;sys.stdout.write("h\"ello worl\"d")', 'h"ello worl"d', 0)
-call s:test_list_args('import sys;sys.stdout.write("h\"e\\\"llo wor\\\"l\"d")', 'h"e\"llo wor\"l"d', 0)
-call s:test_list_args('import sys;sys.stdout.write("h\"e\\\"llo world")', 'h"e\"llo world', 0)
-call s:test_list_args('import sys;sys.stdout.write("hello\tworld")', "hello\tworld", 0)
-" tests which not contain spaces in the argument
-call s:test_list_args('print("hello\nworld")', "hello\nworld", 1)
-call s:test_list_args('print(''hello\nworld'')', "hello\nworld", 1)
-call s:test_list_args('print(''hello"world'')', "hello\"world", 1)
-call s:test_list_args('print(''hello^world'')', "hello^world", 1)
-call s:test_list_args('print("hello&&world")', "hello&&world", 1)
-call s:test_list_args('print(''hello\\world'')', "hello\\world", 1)
-call s:test_list_args('print(''hello\\\\world'')', "hello\\\\world", 1)
-call s:test_list_args('print("hello\"world\"")', 'hello"world"', 1)
-call s:test_list_args('print("hello\tworld")', "hello\tworld", 1)
-endfunc
 " Do this last, it stops any channel log.
 func Test_zz_ch_log()
 call ch_logfile('Xlog', 'w')
 call ch_log('hello there')
 call ch_log('%s%s')
 let text = readfile('Xlog')
 call assert_match("hello there", text[1])
 call assert_match("%s%s", text[2])
 call delete('Xlog')
 endfunc
-func Test_keep_pty_open()
-if !has('unix')
-return
-endif
-let job = job_start(s:python . ' -c "import time;time.sleep(0.2)"',
-\ {'out_io': 'null', 'err_io': 'null', 'pty': 1})
-let elapsed = WaitFor({-> job_status(job) ==# 'dead'})
-call assert_inrange(200, 1000, elapsed)
-call job_stop(job)
-endfunc
-func Test_job_start_in_timer()
-CheckFeature job
-CheckFeature timers
-func OutCb(chan, msg)
-let g:val += 1
-endfunc
-func ExitCb(job, status)
-let g:val += 1
-call Resume()
-endfunc
-func TimerCb(timer)
-if has('win32')
-let cmd = ['cmd', '/c', 'echo.']
-else
-let cmd = ['echo']
-endif
-let g:job = job_start(cmd, {'out_cb': 'OutCb', 'exit_cb': 'ExitCb'})
-call substitute(repeat('a', 100000), '.', '', 'g')
-endfunc
-" We should be interrupted before 'updatetime' elapsed.
-let g:val = 0
-call timer_start(1, 'TimerCb')
-let elapsed = Standby(&ut)
-call assert_inrange(1, &ut / 2, elapsed)
-" Wait for both OutCb() and ExitCb() to have been called before deleting
-" them.
-call WaitForAssert({-> assert_equal(2, g:val)})
-call job_stop(g:job)
-delfunc OutCb
-delfunc ExitCb
-delfunc TimerCb
-unlet! g:val
-unlet! g:job
-endfunc
-func Test_raw_large_data()
-try
-let g:out = ''
-let job = job_start(s:python . " test_channel_pipe.py",
-\ {'mode': 'raw', 'drop': 'never', 'noblock': 1,
-\  'callback': {ch, msg -> execute('let g:out .= msg')}})
-let outlen = 79999
-let want = repeat('X', outlen) . "\n"
-call ch_sendraw(job, want)
-call WaitFor({-> len(g:out) >= outlen}, 10000)
-call WaitForAssert({-> assert_equal("dead", job_status(job))})
-call assert_equal(want, substitute(g:out, '\r', '', 'g'))
-finally
-call job_stop(job)
-unlet g:out
-endtry
-endfunc
-func Test_no_hang_windows()
-CheckFeature job
-CheckMSWindows
-try
-let job = job_start(s:python . " test_channel_pipe.py busy",
-\ {'mode': 'raw', 'drop': 'never', 'noblock': 0})
-call assert_fails('call ch_sendraw(job, repeat("X", 80000))', 'E631:')
-finally
-call job_stop(job)
-endtry
-endfunc
-func Test_job_exitval_and_termsig()
-if !has('unix')
-return
-endif
-" Terminate job normally
-let cmd = ['echo']
-let job = job_start(cmd)
-call WaitForAssert({-> assert_equal("dead", job_status(job))})
-let info = job_info(job)
-call assert_equal(0, info.exitval)
-call assert_equal("", info.termsig)
-" Terminate job by signal
-let cmd = ['sleep', '10']
-let job = job_start(cmd)
-sleep 10m
-call job_stop(job)
-call WaitForAssert({-> assert_equal("dead", job_status(job))})
-let info = job_info(job)
-call assert_equal(-1, info.exitval)
-call assert_equal("term", info.termsig)
-endfunc
-func Test_job_tty_in_out()
-CheckFeature job
-CheckUnix
-call writefile(['test'], 'Xtestin')
-let in_opts = [{},
-\ {'in_io': 'null'},
-\ {'in_io': 'file', 'in_name': 'Xtestin'}]
-let out_opts = [{},
-\ {'out_io': 'null'},
-\ {'out_io': 'file', 'out_name': 'Xtestout'}]
-let err_opts = [{},
-\ {'err_io': 'null'},
-\ {'err_io': 'file', 'err_name': 'Xtesterr'},
-\ {'err_io': 'out'}]
-let opts = []
-for in_opt in in_opts
-let x = copy(in_opt)
-for out_opt in out_opts
-let x = extend(copy(x), out_opt)
-for err_opt in err_opts
-let x = extend(copy(x), err_opt)
-let opts += [extend({'pty': 1}, x)]
-endfor
-endfor
-endfor
-for opt in opts
-let job = job_start('echo', opt)
-let info = job_info(job)
-let msg = printf('option={"in_io": "%s", "out_io": "%s", "err_io": "%s"}',
-\ get(opt, 'in_io', 'tty'),
-\ get(opt, 'out_io', 'tty'),
-\ get(opt, 'err_io', 'tty'))
-if !has_key(opt, 'in_io') || !has_key(opt, 'out_io') || !has_key(opt, 'err_io')
-call assert_notequal('', info.tty_in, msg)
-else
-call assert_equal('', info.tty_in, msg)
-endif
-call assert_equal(info.tty_in, info.tty_out, msg)
-call WaitForAssert({-> assert_equal('dead', job_status(job))})
-endfor
-call delete('Xtestin')
-call delete('Xtestout')
-call delete('Xtesterr')
-endfunc

Mercurial > vim

comparison src/testdir/test_channel.vim @ 17559:0ba896d48a56 v8.1.1777