1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
/******************************************************************************
** COPYRIGHT NOTICE
** (c) 2012 The Johns Hopkins University Applied Physics Laboratory
** All rights reserved.
**
** This material may only be used, modified, or reproduced by or for the
** U.S. Government pursuant to the license rights granted under
** FAR clause 52.227-14 or DFARS clauses 252.227-7013/7014
**
** For any other permissions, please contact the Legal Office at JHU/APL.
******************************************************************************/
/*****************************************************************************
**
** \file pdu.h
**
**
** Description:
**
** Notes:
**
** Assumptions:
**
** Modification History:
** MM/DD/YY AUTHOR DESCRIPTION
** -------- ------------ ---------------------------------------------
** 09/24/12 E. Birrane Initial Implementation
** 11/01/12 E. Birrane Redesign of messaging architecture.
** 06/25/13 E. Birrane Renamed message "bundle" message "group".
** 06/26/13 E. Birrane Added group timestamp
*****************************************************************************/
#ifndef DTNMPDU_H_
#define DTNMPDU_H_
#include "lyst.h"
#include "stdint.h"
#include "shared/utils/nm_types.h"
typedef struct
{
/** The EID of the last node of this message. */
eid_t senderEid;
/** The EID of the message originator. */
eid_t originatorEid;
/** The EID of the message recipient. */
eid_t recipientEid;
} pdu_metadata_t;
typedef struct
{
/** Message type */
uint8_t type; /**> The opcode field identifying the message opcode. */
uint8_t context; /**> Message category. */
uint8_t ack; /**> Whether the message must be ACK'd. */
uint8_t nack; /**> Whether the message must send error on failure. */
uint8_t acl; /**> Whether the message has an ACL appended to it. */
uint8_t id; /**> Combination of type and category. */
} pdu_header_t;
/*
* \todo Support this...
*/
typedef struct
{
} pdu_acl_t;
typedef struct
{
pdu_header_t *hdr;
pdu_metadata_t meta;
uint8_t *contents;
uint32_t size;
pdu_acl_t *acl;
} pdu_msg_t;
typedef struct
{
Lyst msgs;
time_t time;
} pdu_group_t;
pdu_group_t *pdu_create_empty_group();
pdu_group_t *pdu_create_group(pdu_msg_t *msg);
pdu_header_t *pdu_create_hdr(uint8_t id, uint8_t ack, uint8_t nack, uint8_t acl);
pdu_msg_t *pdu_create_msg(uint8_t id,
uint8_t *data,
uint32_t data_size,
pdu_acl_t *acl);
void pdu_release_hdr(pdu_header_t *hdr);
void pdu_release_meta(pdu_metadata_t *meta);
void pdu_release_acl(pdu_acl_t *acl);
void pdu_release_msg(pdu_msg_t *pdu);
void pdu_release_group(pdu_group_t *group);
uint8_t *pdu_serialize_hdr(pdu_header_t *hdr, uint32_t *len);
uint8_t *pdu_serialize_acl(pdu_acl_t *acl, uint32_t *len);
uint8_t *pdu_serialize_msg(pdu_msg_t *msg, uint32_t *len);
uint8_t *pdu_serialize_group(pdu_group_t *group, uint32_t *len);
pdu_header_t *pdu_deserialize_hdr(uint8_t *cursor,
uint32_t size,
uint32_t *bytes_used);
pdu_acl_t *pdu_deserialize_acl(uint8_t *cursor,
uint32_t size,
uint32_t *bytes_used);
int pdu_add_msg_to_group(pdu_group_t *group, pdu_msg_t *msg);
#endif /* DTNMPDU_H_ */
|
