diff options
Diffstat (limited to 'src/nvim/event')
| -rw-r--r-- | src/nvim/event/process.c | 4 | ||||
| -rw-r--r-- | src/nvim/event/stream.c | 5 |
2 files changed, 5 insertions, 4 deletions
diff --git a/src/nvim/event/process.c b/src/nvim/event/process.c index 990dee0c7f..4410deadef 100644 --- a/src/nvim/event/process.c +++ b/src/nvim/event/process.c @@ -223,10 +223,6 @@ void process_stop(Process *proc) FUNC_ATTR_NONNULL_ALL switch (proc->type) { case kProcessTypeUv: - // Close the process's stdin. If the process doesn't close its own - // stdout/stderr, they will be closed when it exits(possibly due to being - // terminated after a timeout) - stream_may_close(&proc->in); os_proc_tree_kill(proc->pid, SIGTERM); break; case kProcessTypePty: diff --git a/src/nvim/event/stream.c b/src/nvim/event/stream.c index 7aaac0b03b..7c8014dead 100644 --- a/src/nvim/event/stream.c +++ b/src/nvim/event/stream.c @@ -113,6 +113,11 @@ void stream_close_handle(Stream *stream) FUNC_ATTR_NONNULL_ALL { if (stream->uvstream) { + if (uv_stream_get_write_queue_size(stream->uvstream) > 0) { + WLOG("closed Stream (%p) with %zu unwritten bytes", + (void *)stream, + uv_stream_get_write_queue_size(stream->uvstream)); + } uv_close((uv_handle_t *)stream->uvstream, close_cb); } else { uv_close((uv_handle_t *)&stream->uv.idle, close_cb); |