diff options
| author | Thiago de Arruda <tpadilha84@gmail.com> | 2014-08-14 11:46:56 -0300 |
|---|---|---|
| committer | Thiago de Arruda <tpadilha84@gmail.com> | 2014-08-28 14:18:05 -0300 |
| commit | 8e683a0ae90dd3ec339e39117e825a180af4c4c0 (patch) | |
| tree | b5b45f5e5df5920e8a3ccfa69ccb80d6c96bac01 | |
| parent | dc34f9fc94e6a155e33f3c7d996f1a0b801ba8a7 (diff) | |
| download | rneovim-8e683a0ae90dd3ec339e39117e825a180af4c4c0.tar.gz rneovim-8e683a0ae90dd3ec339e39117e825a180af4c4c0.tar.bz2 rneovim-8e683a0ae90dd3ec339e39117e825a180af4c4c0.zip | |
channel: fix channel buffer size
| -rw-r--r-- | src/nvim/os/channel.c | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/nvim/os/channel.c b/src/nvim/os/channel.c index 8e02478eff..c082f56d81 100644 --- a/src/nvim/os/channel.c +++ b/src/nvim/os/channel.c @@ -25,6 +25,8 @@ #include "nvim/log.h" #include "nvim/lib/kvec.h" +#define CHANNEL_BUFFER_SIZE 0xffff + typedef struct { uint64_t request_id; bool errored; @@ -117,7 +119,10 @@ void channel_from_stream(uv_stream_t *stream) stream->data = NULL; channel->is_job = false; // read stream - channel->data.streams.read = rstream_new(parse_msgpack, 1024, channel, NULL); + channel->data.streams.read = rstream_new(parse_msgpack, + CHANNEL_BUFFER_SIZE, + channel, + NULL); rstream_set_stream(channel->data.streams.read, stream); rstream_start(channel->data.streams.read); // write stream |