diff options
author | Thiago de Arruda <tpadilha84@gmail.com> | 2014-08-28 15:46:21 -0300 |
---|---|---|
committer | Thiago de Arruda <tpadilha84@gmail.com> | 2014-08-29 22:08:58 -0300 |
commit | aa23d2f835e32c01b318712459ba7b9f55922469 (patch) | |
tree | 8476c7d99b32b8e4faea05ddfdb8cd1f4e6f370f /src | |
parent | 9d5e2c34c95739c8130f33aad8a18b19a281a1ad (diff) | |
download | rneovim-aa23d2f835e32c01b318712459ba7b9f55922469.tar.gz rneovim-aa23d2f835e32c01b318712459ba7b9f55922469.tar.bz2 rneovim-aa23d2f835e32c01b318712459ba7b9f55922469.zip |
msgpack-rpc: Accept method names in requests
Diffstat (limited to 'src')
-rw-r--r-- | src/nvim/os/msgpack_rpc.c | 12 | ||||
-rw-r--r-- | src/nvim/os/msgpack_rpc.h | 7 | ||||
-rw-r--r-- | src/nvim/os_unix.c | 2 |
3 files changed, 14 insertions, 7 deletions
diff --git a/src/nvim/os/msgpack_rpc.c b/src/nvim/os/msgpack_rpc.c index c03d8dccca..90673fef13 100644 --- a/src/nvim/os/msgpack_rpc.c +++ b/src/nvim/os/msgpack_rpc.c @@ -39,15 +39,14 @@ WBuffer *msgpack_rpc_call(uint64_t channel_id, return serialize_response(response_id, err, NIL, sbuffer); } - uint64_t method_id = req->via.array.ptr[2].via.u64; - - if (method_id == 0) { + if (req->via.array.ptr[2].type == MSGPACK_OBJECT_POSITIVE_INTEGER + && req->via.array.ptr[2].via.u64 == 0) { return serialize_metadata(response_id, channel_id, sbuffer); } // dispatch the call Error error = { .set = false }; - Object rv = msgpack_rpc_dispatch(channel_id, method_id, req, &error); + Object rv = msgpack_rpc_dispatch(channel_id, req, &error); // send the response msgpack_packer response; msgpack_packer_init(&response, sbuffer, msgpack_sbuffer_write); @@ -235,8 +234,9 @@ static char *msgpack_rpc_validate(uint64_t *response_id, msgpack_object *req) return "Message type must be 0"; } - if (req->via.array.ptr[2].type != MSGPACK_OBJECT_POSITIVE_INTEGER) { - return "Method id must be a positive integer"; + if (req->via.array.ptr[2].type != MSGPACK_OBJECT_POSITIVE_INTEGER + && req->via.array.ptr[2].type != MSGPACK_OBJECT_RAW) { + return "Method must be a positive integer or a string"; } if (req->via.array.ptr[3].type != MSGPACK_OBJECT_ARRAY) { diff --git a/src/nvim/os/msgpack_rpc.h b/src/nvim/os/msgpack_rpc.h index 5aca900d2e..35f175d2a0 100644 --- a/src/nvim/os/msgpack_rpc.h +++ b/src/nvim/os/msgpack_rpc.h @@ -21,6 +21,11 @@ typedef Object (*rpc_method_handler_fn)(uint64_t channel_id, msgpack_object *req, Error *error); + +/// Initializes the msgpack-rpc method table +void msgpack_rpc_init(void); + + /// Dispatches to the actual API function after basic payload validation by /// `msgpack_rpc_call`. It is responsible for validating/converting arguments /// to C types, and converting the return value back to msgpack types. @@ -33,11 +38,11 @@ typedef Object (*rpc_method_handler_fn)(uint64_t channel_id, /// @param error Pointer to error structure /// @return Some object Object msgpack_rpc_dispatch(uint64_t channel_id, - uint64_t method_id, msgpack_object *req, Error *error) FUNC_ATTR_NONNULL_ARG(2) FUNC_ATTR_NONNULL_ARG(3); + #ifdef INCLUDE_GENERATED_DECLARATIONS # include "os/msgpack_rpc.h.generated.h" #endif diff --git a/src/nvim/os_unix.c b/src/nvim/os_unix.c index 1b092c8261..33b08d7df6 100644 --- a/src/nvim/os_unix.c +++ b/src/nvim/os_unix.c @@ -54,6 +54,7 @@ #include "nvim/os/shell.h" #include "nvim/os/signal.h" #include "nvim/os/job.h" +#include "nvim/os/msgpack_rpc.h" #if defined(HAVE_SYS_IOCTL_H) # include <sys/ioctl.h> @@ -164,6 +165,7 @@ void mch_init(void) mac_conv_init(); #endif + msgpack_rpc_init(); event_init(); } |