# HG changeset patch
# User Christian Brabandt <cb@256bit.org>
# Date 1472733906 -7200
# Node ID c1ba49441c90391e0e31be747d74470a578cc121
# Parent  46763b01cd9a2629bb55d3fa6aa9369cc280be38
commit https://github.com/vim/vim/commit/d8b554904d18fe19bd9fa79dbda880845cb017d2
Author: Bram Moolenaar <Bram@vim.org>
Date:   Thu Sep 1 14:35:22 2016 +0200

    patch 7.4.2297
    Problem:    When starting a job that reads from a buffer and reaching the end,
                the job hangs.
    Solution:   Close the pipe or socket when all lines were read.

diff --git a/src/channel.c b/src/channel.c
--- a/src/channel.c
+++ b/src/channel.c
@@ -1424,11 +1424,14 @@ channel_write_in(channel_T *channel)
 	ch_logn(channel, "written %d lines to channel", written);
 
     in_part->ch_buf_top = lnum;
-    if (lnum > buf->b_ml.ml_line_count)
+    if (lnum > buf->b_ml.ml_line_count || lnum > in_part->ch_buf_bot)
     {
 	/* Writing is done, no longer need the buffer. */
 	in_part->ch_bufref.br_buf = NULL;
 	ch_log(channel, "Finished writing all lines to channel");
+
+	/* Close the pipe/socket, so that the other side gets EOF. */
+	may_close_part(&channel->CH_IN_FD);
     }
     else
 	ch_logn(channel, "Still %d more lines to write",
diff --git a/src/testdir/test_channel.vim b/src/testdir/test_channel.vim
--- a/src/testdir/test_channel.vim
+++ b/src/testdir/test_channel.vim
@@ -792,6 +792,46 @@ func Test_pipe_from_buffer_nr()
   call Run_test_pipe_from_buffer(0)
 endfunc
 
+func Run_pipe_through_sort(all)
+  if !executable('sort') || !has('job')
+    return
+  endif
+  split sortin
+  call setline(1, ['ccc', 'aaa', 'ddd', 'bbb', 'eee'])
+  let options = {'in_io': 'buffer', 'in_name': 'sortin',
+	\ 'out_io': 'buffer', 'out_name': 'sortout'}
+  if !a:all
+    let options.in_top = 2
+    let options.in_bot = 4
+  endif
+  let g:job = job_start('sort', options)
+  call assert_equal("run", job_status(g:job))
+  call WaitFor('job_status(g:job) == "dead"')
+  call assert_equal("dead", job_status(g:job))
+  sp sortout
+  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(g:job)
+  unlet g:job
+  bwipe! sortin
+  bwipe! sortout
+endfunc
+
+func Test_pipe_through_sort_all()
+  call ch_log('Test_pipe_through_sort_all()')
+  call Run_pipe_through_sort(1)
+endfunc
+
+func Test_pipe_through_sort_some()
+  call ch_log('Test_pipe_through_sort_some()')
+  call Run_pipe_through_sort(0)
+endfunc
+
 func Test_pipe_to_nameless_buffer()
   if !has('job')
     return
diff --git a/src/version.c b/src/version.c
--- a/src/version.c
+++ b/src/version.c
@@ -764,6 +764,8 @@ static char *(features[]) =
 static int included_patches[] =
 {   /* Add new patch number below this line */
 /**/
+    2297,
+/**/
     2296,
 /**/
     2295,