mirror of
https://github.com/eclipse/tinydtls.git
synced 2025-05-08 11:27:36 +08:00
5e37fb8cdf
Sending Alert according RFC6347 without retransmission is not reliable. Therefore a dummy retransmission entry is used for outgoing Alerts. On retransmission, the Alert is not retransmitted, instead handle_alert is called to emulate receiving the response. Fixes: Issue #95 Signed-off-by: Achim Kraus <achim.kraus@bosch.io>
123 lines
3.7 KiB
C
123 lines
3.7 KiB
C
/*******************************************************************************
|
|
*
|
|
* Copyright (c) 2011, 2012, 2013, 2014, 2015 Olaf Bergmann (TZI) and others.
|
|
* All rights reserved. This program and the accompanying materials
|
|
* are made available under the terms of the Eclipse Public License v1.0
|
|
* and Eclipse Distribution License v. 1.0 which accompanies this distribution.
|
|
*
|
|
* The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
|
|
* and the Eclipse Distribution License is available at
|
|
* http://www.eclipse.org/org/documents/edl-v10.php.
|
|
*
|
|
* Contributors:
|
|
* Olaf Bergmann - initial API and implementation
|
|
* Hauke Mehrtens - memory optimization, ECC integration
|
|
*
|
|
*******************************************************************************/
|
|
|
|
#ifndef _DTLS_NETQ_H_
|
|
#define _DTLS_NETQ_H_
|
|
|
|
#include "tinydtls.h"
|
|
#include "global.h"
|
|
#include "dtls.h"
|
|
#include "dtls_time.h"
|
|
|
|
/**
|
|
* \defgroup netq Network Packet Queue
|
|
* The netq utility functions implement an ordered queue of data packets
|
|
* to send over the network and can also be used to queue received packets
|
|
* from the network.
|
|
* @{
|
|
*/
|
|
|
|
#ifndef NETQ_MAXCNT
|
|
#ifdef DTLS_ECC
|
|
#define NETQ_MAXCNT 5 /**< maximum number of elements in netq structure */
|
|
#elif defined(DTLS_PSK)
|
|
#define NETQ_MAXCNT 3 /**< maximum number of elements in netq structure */
|
|
#endif
|
|
#endif
|
|
|
|
/**
|
|
* Job to be executed for the timer entry in the netq.
|
|
*/
|
|
typedef enum netq_job_type_t {
|
|
RESEND, /**< resend related message on timeout */
|
|
TIMEOUT /**< timeout of the related alert */
|
|
} netq_job_type_t;
|
|
|
|
/**
|
|
* Datagrams in the netq_t structure have a fixed maximum size of
|
|
* DTLS_MAX_BUF to simplify memory management on constrained nodes. */
|
|
typedef unsigned char netq_packet_t[DTLS_MAX_BUF];
|
|
|
|
typedef struct netq_t {
|
|
struct netq_t *next;
|
|
|
|
clock_time_t t; /**< when to send PDU for the next time */
|
|
unsigned int timeout; /**< randomized timeout value */
|
|
|
|
netq_job_type_t job; /**< job to be executed on timeout */
|
|
|
|
dtls_peer_t *peer; /**< remote address */
|
|
uint16_t epoch;
|
|
uint8_t type;
|
|
unsigned char retransmit_cnt; /**< retransmission counter, will be removed when zero */
|
|
|
|
size_t length; /**< actual length of data */
|
|
#if !(defined (WITH_CONTIKI)) && !(defined (RIOT_VERSION))
|
|
unsigned char data[]; /**< the datagram to send */
|
|
#else
|
|
netq_packet_t data; /**< the datagram to send */
|
|
#endif
|
|
} netq_t;
|
|
|
|
#if !(defined (WITH_CONTIKI)) && !(defined (RIOT_VERSION))
|
|
static inline void netq_init(void)
|
|
{ }
|
|
#else
|
|
void netq_init(void);
|
|
#endif
|
|
|
|
/**
|
|
* Adds a node to the given queue, ordered by their time-stamp t.
|
|
* This function returns @c 0 on error, or non-zero if @p node has
|
|
* been added successfully.
|
|
*
|
|
* @param queue A pointer to the queue head where @p node will be added.
|
|
* @param node The new item to add.
|
|
* @return @c 0 on error, or non-zero if the new item was added.
|
|
*/
|
|
int netq_insert_node(netq_t **queue, netq_t *node);
|
|
|
|
/** Destroys specified node and releases any memory that was allocated
|
|
* for the associated datagram. */
|
|
void netq_node_free(netq_t *node);
|
|
|
|
/** Removes all items from given queue and frees the allocated storage */
|
|
void netq_delete_all(netq_t **queue);
|
|
|
|
/** Creates a new node suitable for adding to a netq_t queue. */
|
|
netq_t *netq_node_new(size_t size);
|
|
|
|
/**
|
|
* Returns a pointer to the first item in given queue or NULL if
|
|
* empty.
|
|
*/
|
|
netq_t *netq_head(netq_t **queue);
|
|
|
|
netq_t *netq_next(netq_t *p);
|
|
void netq_remove(netq_t **queue, netq_t *p);
|
|
|
|
/**
|
|
* Removes the first item in given queue and returns a pointer to the
|
|
* removed element. If queue is empty when netq_pop_first() is called,
|
|
* this function returns NULL.
|
|
*/
|
|
netq_t *netq_pop_first(netq_t **queue);
|
|
|
|
/**@}*/
|
|
|
|
#endif /* _DTLS_NETQ_H_ */
|