/** * mds — A micro-display server * Copyright © 2014, 2015, 2016, 2017 Mattias Andrée (m@maandree.se) * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ #include "queued-interception.h" #include /** * Calculate the buffer size need to marshal a queued interception * * @param this The client information * @return The number of bytes to allocate to the output buffer */ size_t queued_interception_marshal_size(void) { return sizeof(int64_t) + 3 * sizeof(int); } /** * Marshals a queued interception * * @param this The queued interception * @param data Output buffer for the marshalled data * @return The number of bytes that have been written (everything will be written) */ size_t queued_interception_marshal(const queued_interception_t *restrict this, char *restrict data) { buf_set_next(data, int, QUEUED_INTERCEPTION_T_VERSION); buf_set_next(data, int64_t, this->priority); buf_set_next(data, int, this->modifying); buf_set_next(data, int, this->client->socket_fd); return queued_interception_marshal_size(); } /** * Unmarshals a queued interception * * @param this Memory slot in which to store the new queued interception * @param data In buffer with the marshalled data * @return Zero on error, `errno` will be set accordingly, otherwise the number of read bytes. */ size_t queued_interception_unmarshal(queued_interception_t *restrict this, char *restrict data) { this->client = NULL; /* buf_get_next(data, int, QUEUED_INTERCEPTION_T_VERSION); */ buf_next(data, int, 1); buf_get_next(data, int64_t, this->priority); buf_get_next(data, int, this->modifying); buf_get_next(data, int, this->socket_fd); return queued_interception_marshal_size(); } /** * Pretend to unmarshal a queued interception * * @param data In buffer with the marshalled data * @return The number of read bytes */ size_t queued_interception_unmarshal_skip(void) { return queued_interception_marshal_size(); }