net: added RD client for simplified registration
This commit is contained in:
parent
f12d85d032
commit
108284670c
15
Makefile.dep
15
Makefile.dep
@ -708,11 +708,22 @@ ifneq (,$(filter skald,$(USEMODULE)))
|
|||||||
USEMODULE += random
|
USEMODULE += random
|
||||||
endif
|
endif
|
||||||
|
|
||||||
ifneq (,$(filter rdcli_common,$(USEMODULE)))
|
ifneq (,$(filter rdcli_simple_standalone,$(USEMODULE)))
|
||||||
USEMODULE += luid
|
USEMODULE += rdcli_simple
|
||||||
|
USEMODULE += xtimer
|
||||||
|
endif
|
||||||
|
|
||||||
|
ifneq (,$(filter rdcli_simple,$(USEMODULE)))
|
||||||
|
USEMODULE += rdcli_common
|
||||||
USEMODULE += fmt
|
USEMODULE += fmt
|
||||||
endif
|
endif
|
||||||
|
|
||||||
|
ifneq (,$(filter rdcli_common,$(USEMODULE)))
|
||||||
|
USEMODULE += fmt
|
||||||
|
USEMODULE += gcoap
|
||||||
|
USEMODULE += luid
|
||||||
|
endif
|
||||||
|
|
||||||
# always select gpio (until explicit dependencies are sorted out)
|
# always select gpio (until explicit dependencies are sorted out)
|
||||||
FEATURES_OPTIONAL += periph_gpio
|
FEATURES_OPTIONAL += periph_gpio
|
||||||
|
|
||||||
|
|||||||
@ -64,6 +64,7 @@ PSEUDOMODULES += pktqueue
|
|||||||
PSEUDOMODULES += printf_float
|
PSEUDOMODULES += printf_float
|
||||||
PSEUDOMODULES += prng
|
PSEUDOMODULES += prng
|
||||||
PSEUDOMODULES += prng_%
|
PSEUDOMODULES += prng_%
|
||||||
|
PSEUDOMODULES += rdcli_simple_standalone
|
||||||
PSEUDOMODULES += saul_adc
|
PSEUDOMODULES += saul_adc
|
||||||
PSEUDOMODULES += saul_default
|
PSEUDOMODULES += saul_default
|
||||||
PSEUDOMODULES += saul_gpio
|
PSEUDOMODULES += saul_gpio
|
||||||
|
|||||||
@ -130,6 +130,9 @@ endif
|
|||||||
ifneq (,$(filter rdcli_common,$(USEMODULE)))
|
ifneq (,$(filter rdcli_common,$(USEMODULE)))
|
||||||
DIRS += net/application_layer/rdcli_common
|
DIRS += net/application_layer/rdcli_common
|
||||||
endif
|
endif
|
||||||
|
ifneq (,$(filter rdcli_simple,$(USEMODULE)))
|
||||||
|
DIRS += net/application_layer/rdcli_simple
|
||||||
|
endif
|
||||||
|
|
||||||
DIRS += $(dir $(wildcard $(addsuffix /Makefile, $(USEMODULE))))
|
DIRS += $(dir $(wildcard $(addsuffix /Makefile, $(USEMODULE))))
|
||||||
|
|
||||||
|
|||||||
@ -164,6 +164,11 @@ void auto_init(void)
|
|||||||
extern void rdcli_common_init(void);
|
extern void rdcli_common_init(void);
|
||||||
rdcli_common_init();
|
rdcli_common_init();
|
||||||
#endif
|
#endif
|
||||||
|
#ifdef MODULE_RDCLI_SIMPLE_STANDALONE
|
||||||
|
DEBUG("Auto init rdcli_simple module\n");
|
||||||
|
extern void rdcli_simple_run(void);
|
||||||
|
rdcli_simple_run();
|
||||||
|
#endif
|
||||||
|
|
||||||
/* initialize network devices */
|
/* initialize network devices */
|
||||||
#ifdef MODULE_AUTO_INIT_GNRC_NETIF
|
#ifdef MODULE_AUTO_INIT_GNRC_NETIF
|
||||||
|
|||||||
@ -46,6 +46,19 @@ static inline const char *rdcli_common_get_ep(void)
|
|||||||
return (const char *)rdcli_ep;
|
return (const char *)rdcli_ep;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief Add selected query string options to a gcoap request
|
||||||
|
*
|
||||||
|
* This function adds:
|
||||||
|
* - `ep` -> as extracted by rdcli_commont_get_ep()
|
||||||
|
* - [optional] `lt` -> if defined by RDCLI_LT
|
||||||
|
* - [optional] 'd' -> if defined by RDCLI_D
|
||||||
|
*
|
||||||
|
* @return 0 on success
|
||||||
|
* @return <0 on error
|
||||||
|
*/
|
||||||
|
int rdcli_common_add_qstring(coap_pkt_t *pkt);
|
||||||
|
|
||||||
#ifdef __cplusplus
|
#ifdef __cplusplus
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|||||||
@ -26,6 +26,27 @@
|
|||||||
extern "C" {
|
extern "C" {
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief Default lifetime in seconds (the default is 1 day)
|
||||||
|
*/
|
||||||
|
#ifndef RDCLI_LT
|
||||||
|
#define RDCLI_LT (86400UL)
|
||||||
|
#endif
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief Delay until the RD client starts to try registering (in seconds)
|
||||||
|
*/
|
||||||
|
#ifndef RDCLI_STARTUP_DELAY
|
||||||
|
#define RDCLI_STARTUP_DELAY (3U)
|
||||||
|
#endif
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief Default client update interval (default is half the lifetime)
|
||||||
|
*/
|
||||||
|
#ifndef RDCLI_UPDATE_INTERVAL
|
||||||
|
#define RDCLI_UPDATE_INTERVAL (RDCLI_LT / 2)
|
||||||
|
#endif
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @name Endpoint ID definition
|
* @name Endpoint ID definition
|
||||||
*
|
*
|
||||||
@ -52,6 +73,20 @@ extern "C" {
|
|||||||
#endif
|
#endif
|
||||||
/** @} */
|
/** @} */
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief Default IPv6 address to use when looking for RDs
|
||||||
|
*/
|
||||||
|
#ifndef RDCLI_SERVER_ADDR
|
||||||
|
#define RDCLI_SERVER_ADDR IPV6_ADDR_ALL_NODES_LINK_LOCAL
|
||||||
|
#endif
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief Default Port to use when looking for RDs
|
||||||
|
*/
|
||||||
|
#ifndef RDCLI_SERVER_PORT
|
||||||
|
#define RDCLI_SERVER_PORT COAP_PORT
|
||||||
|
#endif
|
||||||
|
|
||||||
#ifdef __cplusplus
|
#ifdef __cplusplus
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|||||||
47
sys/include/net/rdcli_simple.h
Normal file
47
sys/include/net/rdcli_simple.h
Normal file
@ -0,0 +1,47 @@
|
|||||||
|
/*
|
||||||
|
* Copyright (C) 2017 Freie Universität Berlin
|
||||||
|
*
|
||||||
|
* This file is subject to the terms and conditions of the GNU Lesser
|
||||||
|
* General Public License v2.1. See the file LICENSE in the top level
|
||||||
|
* directory for more details.
|
||||||
|
*/
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @defgroup net_rdcli_simple Simple CoRE Resource Directory Registration
|
||||||
|
* @ingroup net_rdcli
|
||||||
|
* @brief CoAP-based CoRE Resource Directory client supporting the simple
|
||||||
|
* registration only
|
||||||
|
* @{
|
||||||
|
*
|
||||||
|
* @file
|
||||||
|
* @brief Interface for a simple CoRE RD registration
|
||||||
|
*
|
||||||
|
* @author Hauke Petersen <hauke.petersen@fu-berlin.de>
|
||||||
|
*/
|
||||||
|
|
||||||
|
#ifndef NET_RDCLI_SIMPLE_H
|
||||||
|
#define NET_RDCLI_SIMPLE_H
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
extern "C" {
|
||||||
|
#endif
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief Initiate the node registration by sending an empty CoAP POST message
|
||||||
|
* to the RD server's /.well-known/core resource
|
||||||
|
*/
|
||||||
|
int rdcli_simple_register(void);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief Spawn a new thread that registers the node and updates the
|
||||||
|
* registration with all responding RDs using the simple registration
|
||||||
|
* process
|
||||||
|
*/
|
||||||
|
void rdcli_simple_run(void);
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
|
#endif /* NET_RDCLI_SIMPLE_H */
|
||||||
|
/** @} */
|
||||||
@ -21,6 +21,7 @@
|
|||||||
#include "fmt.h"
|
#include "fmt.h"
|
||||||
#include "luid.h"
|
#include "luid.h"
|
||||||
|
|
||||||
|
#include "net/gcoap.h"
|
||||||
#include "net/rdcli_common.h"
|
#include "net/rdcli_common.h"
|
||||||
|
|
||||||
#define ENABLE_DEBUG (0)
|
#define ENABLE_DEBUG (0)
|
||||||
@ -58,3 +59,32 @@ void rdcli_common_init(void)
|
|||||||
|
|
||||||
rdcli_ep[pos] = '\0';
|
rdcli_ep[pos] = '\0';
|
||||||
}
|
}
|
||||||
|
|
||||||
|
int rdcli_common_add_qstring(coap_pkt_t *pkt)
|
||||||
|
{
|
||||||
|
/* extend the url with some query string options */
|
||||||
|
int res = gcoap_add_qstring(pkt, "ep", rdcli_ep);
|
||||||
|
if (res < 0) {
|
||||||
|
return res;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* [optional] set the lifetime parameter */
|
||||||
|
#if RDCLI_LT
|
||||||
|
char lt[11];
|
||||||
|
lt[fmt_u32_dec(lt, RDCLI_LT)] = '\0';
|
||||||
|
res = gcoap_add_qstring(pkt, "lt", lt);
|
||||||
|
if (res < 0) {
|
||||||
|
return res;
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
|
/* [optional] set the domain parameter */
|
||||||
|
#ifdef RDCLI_D
|
||||||
|
res = gcoap_add_qstring(pkt, "d", RDCLI_D);
|
||||||
|
if (res < 0) {
|
||||||
|
return res;
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|||||||
7
sys/net/application_layer/rdcli_simple/Makefile
Normal file
7
sys/net/application_layer/rdcli_simple/Makefile
Normal file
@ -0,0 +1,7 @@
|
|||||||
|
SRC = rdcli_simple.c
|
||||||
|
|
||||||
|
ifneq (,$(filter rdcli_simple_standalone,$(USEMODULE)))
|
||||||
|
SRC += rdcli_simple_standalone.c
|
||||||
|
endif
|
||||||
|
|
||||||
|
include $(RIOTBASE)/Makefile.base
|
||||||
60
sys/net/application_layer/rdcli_simple/rdcli_simple.c
Normal file
60
sys/net/application_layer/rdcli_simple/rdcli_simple.c
Normal file
@ -0,0 +1,60 @@
|
|||||||
|
/*
|
||||||
|
* Copyright (C) 2017 Freie Universität Berlin
|
||||||
|
*
|
||||||
|
* This file is subject to the terms and conditions of the GNU Lesser
|
||||||
|
* General Public License v2.1. See the file LICENSE in the top level
|
||||||
|
* directory for more details.
|
||||||
|
*/
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @ingroup net_rdcli_simple
|
||||||
|
* @{
|
||||||
|
*
|
||||||
|
* @file
|
||||||
|
* @brief Simplified CoAP resource directory client implementation
|
||||||
|
*
|
||||||
|
* @author Hauke Petersen <hauke.petersen@fu-berlin.de>
|
||||||
|
*
|
||||||
|
* @}
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include <string.h>
|
||||||
|
|
||||||
|
#include "fmt.h"
|
||||||
|
#include "net/gcoap.h"
|
||||||
|
#include "net/rdcli_config.h"
|
||||||
|
#include "net/rdcli_common.h"
|
||||||
|
#include "net/rdcli_simple.h"
|
||||||
|
|
||||||
|
#define BUFSIZE (128U)
|
||||||
|
|
||||||
|
static coap_pkt_t pkt;
|
||||||
|
static uint8_t buf[BUFSIZE];
|
||||||
|
|
||||||
|
/* allocate an UDP endpoint to the RD server */
|
||||||
|
static const sock_udp_ep_t remote = {
|
||||||
|
.family = AF_INET6,
|
||||||
|
.netif = SOCK_ADDR_ANY_NETIF,
|
||||||
|
.addr = RDCLI_SERVER_ADDR ,
|
||||||
|
.port = RDCLI_SERVER_PORT
|
||||||
|
};
|
||||||
|
|
||||||
|
int rdcli_simple_register(void)
|
||||||
|
{
|
||||||
|
/* build the initial CON packet */
|
||||||
|
int res = gcoap_req_init(&pkt, buf, sizeof(buf), COAP_METHOD_POST,
|
||||||
|
"/.well-known/core");
|
||||||
|
if (res < 0) {
|
||||||
|
return res;
|
||||||
|
}
|
||||||
|
/* make packet confirmable */
|
||||||
|
coap_hdr_set_type(pkt.hdr, COAP_TYPE_CON);
|
||||||
|
/* add Uri-Query options */
|
||||||
|
res = rdcli_common_add_qstring(&pkt);
|
||||||
|
if (res < 0) {
|
||||||
|
return res;
|
||||||
|
}
|
||||||
|
/* finish, we don't have any payload */
|
||||||
|
ssize_t len = gcoap_finish(&pkt, 0, COAP_FORMAT_LINK);
|
||||||
|
return (int)gcoap_req_send2(buf, len, &remote, NULL);
|
||||||
|
}
|
||||||
@ -0,0 +1,54 @@
|
|||||||
|
/*
|
||||||
|
* Copyright (C) 2017 Freie Universität Berlin
|
||||||
|
*
|
||||||
|
* This file is subject to the terms and conditions of the GNU Lesser
|
||||||
|
* General Public License v2.1. See the file LICENSE in the top level
|
||||||
|
* directory for more details.
|
||||||
|
*/
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @ingroup net_rdcli_simple
|
||||||
|
* @{
|
||||||
|
*
|
||||||
|
* @file
|
||||||
|
* @brief Standalone extension for the simple RD registration client
|
||||||
|
*
|
||||||
|
* @author Hauke Petersen <hauke.petersen@fu-berlin.de>
|
||||||
|
*
|
||||||
|
* @}
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include "log.h"
|
||||||
|
#include "thread.h"
|
||||||
|
#include "xtimer.h"
|
||||||
|
#include "net/rdcli_config.h"
|
||||||
|
#include "net/rdcli_simple.h"
|
||||||
|
|
||||||
|
#define STACKSIZE (THREAD_STACKSIZE_DEFAULT)
|
||||||
|
#define PRIO (THREAD_PRIORITY_MAIN - 1)
|
||||||
|
#define TNAME "rdcli_simple"
|
||||||
|
|
||||||
|
static char _stack[STACKSIZE];
|
||||||
|
|
||||||
|
static void *reg_runner(void *arg)
|
||||||
|
{
|
||||||
|
(void)arg;
|
||||||
|
|
||||||
|
/* wait some seconds to give the address configuration some time to settle */
|
||||||
|
xtimer_sleep(RDCLI_STARTUP_DELAY);
|
||||||
|
|
||||||
|
while (1) {
|
||||||
|
int res = rdcli_simple_register();
|
||||||
|
if (res < 0) {
|
||||||
|
LOG_ERROR("[rdcli_simple] error: unable to trigger registration\n");
|
||||||
|
}
|
||||||
|
xtimer_sleep(RDCLI_UPDATE_INTERVAL);
|
||||||
|
}
|
||||||
|
|
||||||
|
return NULL; /* should never be reached */
|
||||||
|
}
|
||||||
|
|
||||||
|
void rdcli_simple_run(void)
|
||||||
|
{
|
||||||
|
thread_create(_stack, sizeof(_stack), PRIO, 0, reg_runner, NULL, TNAME);
|
||||||
|
}
|
||||||
Loading…
x
Reference in New Issue
Block a user