diff options
| author | bfredl <bjorn.linse@gmail.com> | 2024-06-08 14:19:30 +0200 |
|---|---|---|
| committer | bfredl <bjorn.linse@gmail.com> | 2024-06-11 11:11:38 +0200 |
| commit | 19052e0a06240be018a234d87f51113eca6d17fa (patch) | |
| tree | da5d0eb9c4bcb26d7947d9708cd2d4676f7a1fa5 /src/nvim/msgpack_rpc/channel.c | |
| parent | d8e384b7bfd5829e5ff5006202faa584b3211e84 (diff) | |
| download | rneovim-19052e0a06240be018a234d87f51113eca6d17fa.tar.gz rneovim-19052e0a06240be018a234d87f51113eca6d17fa.tar.bz2 rneovim-19052e0a06240be018a234d87f51113eca6d17fa.zip | |
refactor(shada): use msgpack_sbuffer less
Work towards getting rid of libmsgpack depedency eventually.
msgpack_sbuffer is just a string buffer, we can use our own
String type.
Diffstat (limited to 'src/nvim/msgpack_rpc/channel.c')
| -rw-r--r-- | src/nvim/msgpack_rpc/channel.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/nvim/msgpack_rpc/channel.c b/src/nvim/msgpack_rpc/channel.c index 6a0dc10214..0930f0c7b3 100644 --- a/src/nvim/msgpack_rpc/channel.c +++ b/src/nvim/msgpack_rpc/channel.c @@ -590,16 +590,16 @@ static void packer_buffer_init_channels(Channel **chans, size_t nchans, PackerBu packer->endptr = packer->startptr + ARENA_BLOCK_SIZE; packer->packer_flush = channel_flush_callback; packer->anydata = chans; - packer->anylen = nchans; + packer->anyint = (int64_t)nchans; } static void packer_buffer_finish_channels(PackerBuffer *packer) { size_t len = (size_t)(packer->ptr - packer->startptr); if (len > 0) { - WBuffer *buf = wstream_new_buffer(packer->startptr, len, packer->anylen, free_block); + WBuffer *buf = wstream_new_buffer(packer->startptr, len, (size_t)packer->anyint, free_block); Channel **chans = packer->anydata; - for (size_t i = 0; i < packer->anylen; i++) { + for (int64_t i = 0; i < packer->anyint; i++) { channel_write(chans[i], buf); } } else { @@ -610,7 +610,7 @@ static void packer_buffer_finish_channels(PackerBuffer *packer) static void channel_flush_callback(PackerBuffer *packer) { packer_buffer_finish_channels(packer); - packer_buffer_init_channels(packer->anydata, packer->anylen, packer); + packer_buffer_init_channels(packer->anydata, (size_t)packer->anyint, packer); } void rpc_set_client_info(uint64_t id, Dictionary info) |