mirrors/neovim
1
0
Fork 0
mirror of https://github.com/neovim/neovim.git synced 2025-10-16 06:46:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

channel: Implement channel_from_stdio function

Browse Source 
This function can be used to create an API channel that reads/writes from/to
stdin/stdout
This commit is contained in:
Thiago de Arruda
2014-08-12 15:03:12 -03:00
parent 8e683a0ae9
commit a1400896b3
1 changed files with 26 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/nvim/os/channel.c
View File

@@ -20,6 +20,7 @@
#include "nvim/vim.h" #include "nvim/vim.h"
#include "nvim/ascii.h" #include "nvim/ascii.h"
#include "nvim/memory.h" #include "nvim/memory.h"
#include "nvim/os_unix.h"
#include "nvim/message.h" #include "nvim/message.h"
#include "nvim/map.h" #include "nvim/map.h"
#include "nvim/log.h" #include "nvim/log.h"
@@ -261,6 +262,25 @@ void channel_unsubscribe(uint64_t id, char *event)
unsubscribe(channel, event); unsubscribe(channel, event);
} }
/// Creates an API channel from stdin/stdout. This is used when embedding
/// Neovim
static void channel_from_stdio(void)
{
Channel *channel = register_channel();
channel->is_job = false;
// read stream
channel->data.streams.read = rstream_new(parse_msgpack,
CHANNEL_BUFFER_SIZE,
channel,
NULL);
rstream_set_file(channel->data.streams.read, 0);
rstream_start(channel->data.streams.read);
// write stream
channel->data.streams.write = wstream_new(0);
wstream_set_file(channel->data.streams.write, 1);
channel->data.streams.uv = NULL;
}
static void job_out(RStream *rstream, void *data, bool eof) static void job_out(RStream *rstream, void *data, bool eof)
{ {
Job *job = data; Job *job = data;
@@ -474,7 +494,12 @@ static void close_channel(Channel *channel)
} else { } else {
rstream_free(channel->data.streams.read); rstream_free(channel->data.streams.read);
wstream_free(channel->data.streams.write); wstream_free(channel->data.streams.write);
uv_close((uv_handle_t *)channel->data.streams.uv, close_cb); if (channel->data.streams.uv) {
uv_close((uv_handle_t *)channel->data.streams.uv, close_cb);
} else {
// When the stdin channel closes, it's time to go
mch_exit(0);
}
} }
free(channel); free(channel);