1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
VILLASnode/common/lib/buffer.cpp
Steffen Vogel 7d10544d79 Apply clang-format changes
Signed-off-by: Steffen Vogel <steffen.vogel@opal-rt.com>
2024-02-29 18:58:07 +01:00

38 lines
912 B
C++

/* A simple buffer for encoding streamed JSON messages.
*
* Author: Steffen Vogel <post@steffenvogel.de>
* SPDX-FileCopyrightText: 2014-2023 Institute for Automation of Complex Power Systems, RWTH Aachen University
* SPDX-License-Identifier: Apache-2.0
*/
#include <villas/buffer.hpp>
#include <villas/compat.hpp>
using namespace villas;
json_t *Buffer::decode() {
json_t *j;
json_error_t err;
j = json_loadb(data(), size(), JSON_DISABLE_EOF_CHECK, &err);
if (!j)
return nullptr;
// Remove decoded JSON document from beginning
erase(begin(), begin() + err.position);
return j;
}
int Buffer::encode(json_t *j, int flags) {
return json_dump_callback(j, callback, this, flags);
}
int Buffer::callback(const char *data, size_t len, void *ctx) {
Buffer *b = static_cast<Buffer *>(ctx);
// Append junk of JSON to buffer
b->insert(b->end(), &data[0], &data[len]);
return 0;
}