aboutsummaryrefslogtreecommitdiff
path: root/src/nvim/msgpack_rpc
diff options
context:
space:
mode:
Diffstat (limited to 'src/nvim/msgpack_rpc')
-rw-r--r--src/nvim/msgpack_rpc/channel.c11
-rw-r--r--src/nvim/msgpack_rpc/unpacker.c4
2 files changed, 11 insertions, 4 deletions
diff --git a/src/nvim/msgpack_rpc/channel.c b/src/nvim/msgpack_rpc/channel.c
index b4f39c4c61..388fa2584c 100644
--- a/src/nvim/msgpack_rpc/channel.c
+++ b/src/nvim/msgpack_rpc/channel.c
@@ -360,6 +360,17 @@ free_ret:
api_clear_error(&error);
}
+bool rpc_write_raw(uint64_t id, WBuffer *buffer)
+{
+ Channel *channel = find_rpc_channel(id);
+ if (!channel) {
+ wstream_release_wbuffer(buffer);
+ return false;
+ }
+
+ return channel_write(channel, buffer);
+}
+
static bool channel_write(Channel *channel, WBuffer *buffer)
{
bool success;
diff --git a/src/nvim/msgpack_rpc/unpacker.c b/src/nvim/msgpack_rpc/unpacker.c
index 419349e74d..26c1843026 100644
--- a/src/nvim/msgpack_rpc/unpacker.c
+++ b/src/nvim/msgpack_rpc/unpacker.c
@@ -11,10 +11,6 @@
# include "msgpack_rpc/unpacker.c.generated.h"
#endif
-#define kv_fixsize_arena(a, v, s) \
- ((v).capacity = (s), \
- (v).items = (void *)arena_alloc(a, sizeof((v).items[0]) * (v).capacity, true))
-
Object unpack(const char *data, size_t size, Error *err)
{
Unpacker unpacker;