summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--include/protocol.h4
-rw-r--r--src/common/protocol.c38
2 files changed, 34 insertions, 8 deletions
diff --git a/include/protocol.h b/include/protocol.h
index 4721a22..1f941a4 100644
--- a/include/protocol.h
+++ b/include/protocol.h
@@ -112,8 +112,10 @@ int get_tlv(struct tlv_parser *parser, struct tlv *ret);
* Appends data to the next packet to be sent. Type of data is determined by
* enum tlv_type.
* */
-int push_tlv(struct tlv_packet *packet, const char *data, enum tlv_type);
+int push_data(struct tlv_packet *packet, enum tlv_type type, char *data);
void clear_data(struct tlv_packet *packet);
+size_t tlv_data_size(struct tlv_parser *parser);
+
#endif /* PROTOCOL_H_INCLUDED */
diff --git a/src/common/protocol.c b/src/common/protocol.c
index 5498704..8fbd197 100644
--- a/src/common/protocol.c
+++ b/src/common/protocol.c
@@ -34,9 +34,11 @@
#define READ_AS(type, from) (*((type*)(from)))
-int push_data(enum tlv_type type)
+int push_tlv(struct tlv_packet *packet, enum tlv_type type, char *data)
{
int ret = 0;
+ size_t size;
+
switch (type) {
case TEXT:
break;
@@ -56,11 +58,6 @@ int push_data(enum tlv_type type)
return ret;
}
-size_t parse_tlv(const char *data, size_t cursor, struct tlv *t)
-{
- return 0;
-}
-
void clear_data(struct tlv_packet *packet)
{
return 0;
@@ -78,5 +75,32 @@ static int push_tlv_header(struct tlv_packet *packet, enum tlv_type type, size_t
int get_tlv(struct tlv_parser *parser, struct tlv *ret)
{
- return 0;
+ int ret = 0;
+
+ if (parser->offset + sizeof(ret->type) + sizeof(ret->length) >= parser->size) {
+ ret = E_TLV_OVERFLOW;
+ } else {
+ ret->type = memcpy(&ret->type, parser->data + parser->offset, sizeof(ret->type));
+ parser->size += sizeof(ret->type);
+ ret->length = memcpy(&ret->length, parser->data + parser->offset, sizeof(ret->length));
+ parser->offset += sizeof(ret->length);
+ if (parser->offset + ret->length >= parser->size) {
+ ret = E_TLV_OVERFLOW;
+ } else {
+ memcpy(ret->data, parser->data, ret->length);
+ }
+ }
+ return ret;
}
+
+size_t tlv_data_size(struct tlv_parser *parser)
+{
+ size_t size;
+
+ if (parser->offset + sizeof(enum tlv_type) + sizeof(size_t) >= parser->size) {
+ size = 0;
+ } else {
+ memcpy(&size, parser->data + parser->offset + sizeof(enum tlv_type), sizeof(size_t));
+ }
+ return size;
+} \ No newline at end of file