diff --git a/src/box/CMakeLists.txt b/src/box/CMakeLists.txt index e32bbca9136a9c5ce82bc8c55ccfab0bebf2d3f7..7dc94d8933c46c03f52a83c4cbfa22ae3837ab00 100644 --- a/src/box/CMakeLists.txt +++ b/src/box/CMakeLists.txt @@ -71,6 +71,7 @@ add_library(xlog STATIC xlog.c) target_link_libraries(xlog core box_error crc32 ${ZSTD_LIBRARIES}) add_library(box STATIC + msgpack.c iproto.cc xrow_io.cc tuple_convert.c diff --git a/src/box/box.cc b/src/box/box.cc index e4a156307eb99e4da9d31a284b06cd53519994af..96557651bcb88af1bc541509c3a7b5f7baf306bc 100644 --- a/src/box/box.cc +++ b/src/box/box.cc @@ -76,6 +76,7 @@ #include "func.h" #include "sequence.h" #include "sql_stmt_cache.h" +#include "msgpack.h" static char status[64] = "unknown"; @@ -2346,6 +2347,7 @@ on_wal_checkpoint_threshold(void) void box_init(void) { + msgpack_init(); fiber_cond_create(&ro_cond); user_cache_init(); diff --git a/src/box/msgpack.c b/src/box/msgpack.c new file mode 100644 index 0000000000000000000000000000000000000000..1723dea4ca3e0c05a2b75770ad40f01e112111ed --- /dev/null +++ b/src/box/msgpack.c @@ -0,0 +1,80 @@ +/* + * Copyright 2020, Tarantool AUTHORS, please see AUTHORS file. + * + * Redistribution and use in source and binary forms, with or + * without modification, are permitted provided that the following + * conditions are met: + * + * 1. Redistributions of source code must retain the above + * copyright notice, this list of conditions and the + * following disclaimer. + * + * 2. Redistributions in binary form must reproduce the above + * copyright notice, this list of conditions and the following + * disclaimer in the documentation and/or other materials + * provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY <COPYRIGHT HOLDER> ``AS IS'' AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED + * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR + * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL + * <COPYRIGHT HOLDER> OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, + * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF + * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR + * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF + * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF + * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + */ +#include "msgpack.h" +#include "msgpuck/msgpuck.h" + +#include "mp_extension_types.h" +#include "mp_decimal.h" +#include "uuid/mp_uuid.h" +#include "mp_error.h" + +static int +msgpack_fprint_ext(FILE *file, const char **data, int depth) +{ + const char **orig = data; + int8_t type; + uint32_t len = mp_decode_extl(data, &type); + switch(type) { + case MP_DECIMAL: + return mp_fprint_decimal(file, data, len); + case MP_UUID: + return mp_fprint_uuid(file, data, len); + case MP_ERROR: + return mp_fprint_error(file, data, depth); + default: + return mp_fprint_ext_default(file, orig, depth); + } +} + +static int +msgpack_snprint_ext(char *buf, int size, const char **data, int depth) +{ + const char **orig = data; + int8_t type; + uint32_t len = mp_decode_extl(data, &type); + switch(type) { + case MP_DECIMAL: + return mp_snprint_decimal(buf, size, data, len); + case MP_UUID: + return mp_snprint_uuid(buf, size, data, len); + case MP_ERROR: + return mp_snprint_error(buf, size, data, depth); + default: + return mp_snprint_ext_default(buf, size, orig, depth); + } +} + +void +msgpack_init(void) +{ + mp_fprint_ext = msgpack_fprint_ext; + mp_snprint_ext = msgpack_snprint_ext; +} diff --git a/src/box/msgpack.h b/src/box/msgpack.h new file mode 100644 index 0000000000000000000000000000000000000000..a7ccc7f90063fe2a9f6f1ea88740407ff44cbdae --- /dev/null +++ b/src/box/msgpack.h @@ -0,0 +1,41 @@ +#pragma once +/* + * Copyright 2020, Tarantool AUTHORS, please see AUTHORS file. + * + * Redistribution and use in source and binary forms, with or + * without modification, are permitted provided that the following + * conditions are met: + * + * 1. Redistributions of source code must retain the above + * copyright notice, this list of conditions and the + * following disclaimer. + * + * 2. Redistributions in binary form must reproduce the above + * copyright notice, this list of conditions and the following + * disclaimer in the documentation and/or other materials + * provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY <COPYRIGHT HOLDER> ``AS IS'' AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED + * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR + * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL + * <COPYRIGHT HOLDER> OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, + * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF + * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR + * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF + * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF + * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + */ +#if defined(__cplusplus) +extern "C" { +#endif /* defined(__cplusplus) */ + +void +msgpack_init(void); + +#if defined(__cplusplus) +} +#endif /* defined(__cplusplus) */