diff options
author | 2019-05-22 20:33:08 +0300 | |
---|---|---|
committer | 2019-05-22 20:33:08 +0300 | |
commit | 28b26ca86cf18947d6d9543ad753ef112ff4da89 (patch) | |
tree | 00a9205e36efe91e4229ad1c17750aa6aaf0fa68 /src/device | |
parent | f810b277752fc42f3a0e951c7501670a596eb387 (diff) | |
download | usurpation-28b26ca86cf18947d6d9543ad753ef112ff4da89.tar.gz usurpation-28b26ca86cf18947d6d9543ad753ef112ff4da89.tar.bz2 usurpation-28b26ca86cf18947d6d9543ad753ef112ff4da89.zip |
Protocol: interface redesign.
Every function is a stub now. Reimplementaion coming up.
Signed-off-by: Ramūnas Mažeikis <ramunasnezinomas@gmail.com>
Diffstat (limited to 'src/device')
-rw-r--r-- | src/device/protocol_device.c | 121 | ||||
-rw-r--r-- | src/device/protocol_device_private.h | 59 |
2 files changed, 0 insertions, 180 deletions
diff --git a/src/device/protocol_device.c b/src/device/protocol_device.c deleted file mode 100644 index d5ec62d..0000000 --- a/src/device/protocol_device.c +++ /dev/null @@ -1,121 +0,0 @@ -/* - * Usurpation – wearable device udp packet handling - * - * Copyright (C) 2019 Ramūnas Mažeikis - * - * This program is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; version 2.1 - * of the License. - * - * 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 - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this program; if not, write to the Free Software - * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA - */ - -#include <time.h> -#include <stdlib.h> -#include <string.h> -#include "net.h" -#include "protocol.h" -#include "protocol_private.h" -#include "protocol_device_private.h" -#include "settings.h" - -#define READ_AS(type, from) (*((type*)(from))) - -static struct connection_t connection; - -cd_t protocol_init(void) -{ - connection.is_live = 1; - connection.nd = net_init(setting_port()); - return 0; -} - -int clear_data(cd_t cd) -{ - int ret = 0; - if (cd >= MAX_CONNECTIONS) { - ret = E_IVALID_DESCRIPTOR; - } else { - connection.inp_crs = 0; - } - return ret; -} - -static int push_bytes(cd_t cd, const char *data, size_t size) -{ - int ret = 0; - - if (cd >= MAX_CONNECTIONS) { - ret = E_IVALID_DESCRIPTOR; - } else if (connection.outp_crs + size >= sizeof(connection.outp_buf)) { - ret = E_PACKET_OVERFLOW; - } else { - memcpy(connection.outp_buf, data, size); - connection.outp_crs += size; - } - return ret; -} - -static int push_tlv_header(cd_t cd, enum tlv_type type, size_t size) -{ - int ret = 0; - - if (cd >= MAX_CONNECTIONS) { - errno = E_IVALID_DESCRIPTOR; - ret = NULL; - } else if (connection.outp_crs >= MAX_PACKET_SIZE_IN) { - errno = E_TLV_OVERFLOW; - ret = NULL; - } else { - READ_AS(enum tlv_type, connection.outp_buf + connection.outp_crs) - = type; - connection.outp_crs += sizeof(enum tlv_type); - READ_AS(size_t, connection.outp_buf + connection.outp_crs) = size; - connection.outp_crs += sizeof(size_t); - } - return ret; -} - -struct tlv * get_tlv(cd_t cd) -{ - struct tlv *ret = &connection.next_tlv; - size_t offset = connection.inp_crs; - char *data = connection.inp_buf; - - if (cd >= MAX_CONNECTIONS) { - errno = E_IVALID_DESCRIPTOR; - ret = NULL; - } else if (offset >= MAX_PACKET_SIZE_IN) { - errno = E_TLV_OVERFLOW; - ret = NULL; - } else { - ret->type = READ_AS(enum tlv_type, data + offset); - offset += sizeof(enum tlv_type); - ret->length = READ_AS(size_t, data + offset); - offset += sizeof(size_t); - ret->data = data + offset; - connection.inp_crs = offset; - } - return ret; -} - -int flush_data(cd_t cd) -{ - return 0; -} - -int get_last_data(cd_t cd) -{ - if (cd >= MAX_CONNECTIONS) { - return E_IVALID_DESCRIPTOR; - } - net_getlastdata(connection.nd, connection.inp_buf); -} diff --git a/src/device/protocol_device_private.h b/src/device/protocol_device_private.h deleted file mode 100644 index 6754ecf..0000000 --- a/src/device/protocol_device_private.h +++ /dev/null @@ -1,59 +0,0 @@ -#ifndef PROTOCOL_DEVICE_PRIVATE_H -#define PROTOCOL_DEVICE_PRIVATE_H - -#include "net.h" - -#define MAX_PACKET_SIZE_OUT (64) - -/* Maximum size of packet that can fit into the packet buffer. UDP can carry - * bigger packets but memory is hard to come by and more won't be needed - * anyway. - * */ -#define MAX_PACKET_SIZE_IN 512 -/** - * Device only gets one connection. Because daemon. - */ -#define MAX_CONNECTIONS (1UL) - -/** - * Error which says that writing any more to packet buffer will overflow - * outgoing buffer. - */ -#define E_PACKET_OVERFLOW (1 << 0) - -/** - * Device's view of connection to daemon. - */ -struct connection_t { - /** - * Initially 0, non-zero when connection is open, 0 when connection - * is closed again. - */ - int is_live; - - /** Network descriptor that maps to daemon */ - int nd; - - /** Time last packet was reveived */ - time_t last_packet_sec; - - /** Incoming packet buffer */ - char inp_buf[MAX_PACKET_SIZE_IN]; - - /** Incoming packet cursor */ - size_t inp_crs; - - /** Outgoing packet buffer */ - char outp_buf[MAX_PACKET_SIZE_OUT]; - - /** Outgoing packet cursor */ - size_t outp_crs; - - /** - * Next tlv to be returned via get_tlv. NULL initially and after last - * element. - * */ - struct tlv next_tlv; -}; - -#endif /* PROTOCOL_DEVICE_PRIVATE_H */
\ No newline at end of file |