Zephyr Project API 4.4.99
A Scalable Open Source RTOS
Loading...
Searching...
No Matches
coap_service.h
Go to the documentation of this file.
1/*
2 * Copyright (c) 2023 Basalte bv
3 *
4 * SPDX-License-Identifier: Apache-2.0
5 */
6
12
13#ifndef ZEPHYR_INCLUDE_NET_COAP_SERVICE_H_
14#define ZEPHYR_INCLUDE_NET_COAP_SERVICE_H_
15
16#include <zephyr/net/coap.h>
17#include <zephyr/sys/iterable_sections.h>
18#include <zephyr/net/tls_credentials.h>
19
20#if defined(CONFIG_COAP_OSCORE)
21#include <zephyr/net/coap_oscore.h>
22#endif
23
24#ifdef __cplusplus
25extern "C" {
26#endif
27
36
42
44#define COAP_SERVICE_AUTOSTART BIT(0)
45
47
49
50struct coap_service_data {
51 int sock_fd;
52 struct coap_observer observers[CONFIG_COAP_SERVICE_OBSERVERS];
53 struct coap_pending pending[CONFIG_COAP_SERVICE_PENDING_MESSAGES];
54#if defined(CONFIG_COAP_OSCORE) || defined(__DOXYGEN__)
61 struct coap_oscore_exchange *oscore_exchange_cache;
62#endif /* CONFIG_COAP_OSCORE */
63};
64
65struct coap_service {
66 const char *name;
67 const char *host;
68 uint16_t *port;
69 uint8_t flags;
70 struct coap_resource *res_begin;
71 struct coap_resource *res_end;
72 struct coap_service_data *data;
73#if defined(CONFIG_NET_SOCKETS_ENABLE_DTLS)
74 const sec_tag_t *sec_tag_list;
75 size_t sec_tag_list_size;
76#endif
77#if defined(CONFIG_COAP_OSCORE) || defined(__DOXYGEN__)
82 bool oscore_required;
83#endif
84};
85
86#if defined(CONFIG_NET_SOCKETS_ENABLE_DTLS)
87#define __z_coap_service_secure(_sec_tag_list, _sec_tag_list_size) \
88 .sec_tag_list = _sec_tag_list, \
89 .sec_tag_list_size = _sec_tag_list_size,
90#else
91#define __z_coap_service_secure(...)
92#endif
93
94#if defined(CONFIG_COAP_OSCORE)
95/* Statically define the per-service OSCORE exchange cache. */
96#define __z_coap_oscore_cache_define(_name) \
97 static struct coap_oscore_exchange _CONCAT(coap_oscore_exchange_cache_, \
98 _name)[CONFIG_COAP_OSCORE_EXCHANGE_CACHE_SIZE];
99#define __z_coap_oscore_cache_ptr(_name) (_CONCAT(coap_oscore_exchange_cache_, _name))
100#define __z_coap_service_oscore(_required) .oscore_required = (_required),
101#define __z_coap_service_oscore_data(_cache) \
102 .oscore_exchange_cache = (_cache),
103#else
104#define __z_coap_service_oscore(...)
105#define __z_coap_oscore_cache_define(_name)
106#define __z_coap_oscore_cache_ptr(_name) NULL
107#define __z_coap_service_oscore_data(...)
108#endif
109
110/* clang-format off */
111#define __z_coap_service_define(_name, _host, _port, _flags, _res_begin, _res_end, _sec_tag_list, \
112 _sec_tag_list_size, _oscore_required, _oscore_cache) \
113 static struct coap_service_data _CONCAT(coap_service_data_, _name) = { \
114 .sock_fd = -1, \
115 __z_coap_service_oscore_data(_oscore_cache) \
116 }; \
117 const STRUCT_SECTION_ITERABLE(coap_service, _name) = { \
118 .name = STRINGIFY(_name), \
119 .host = _host, \
120 .port = (uint16_t *)(_port), \
121 .flags = _flags, \
122 .res_begin = (_res_begin), \
123 .res_end = (_res_end), \
124 .data = &_CONCAT(coap_service_data_, _name), \
125 __z_coap_service_secure(_sec_tag_list, _sec_tag_list_size) \
126 __z_coap_service_oscore(_oscore_required) \
127 }
128/* clang-format on */
129
131
168#define COAP_RESOURCE_DEFINE(_name, _service, ...) \
169 STRUCT_SECTION_ITERABLE_ALTERNATE(_CONCAT(coap_resource_, _service), coap_resource, \
170 _name) = __VA_ARGS__
171
189#define COAP_SERVICE_DEFINE(_name, _host, _port, _flags) \
190 extern struct coap_resource _CONCAT(_CONCAT(_coap_resource_, _name), _list_start)[]; \
191 extern struct coap_resource _CONCAT(_CONCAT(_coap_resource_, _name), _list_end)[]; \
192 __z_coap_service_define(_name, _host, _port, _flags, \
193 &_CONCAT(_CONCAT(_coap_resource_, _name), _list_start)[0], \
194 &_CONCAT(_CONCAT(_coap_resource_, _name), _list_end)[0], NULL, 0, \
195 false, NULL)
196
218#define COAPS_SERVICE_DEFINE(_name, _host, _port, _flags, _sec_tag_list, _sec_tag_list_size) \
219 BUILD_ASSERT(IS_ENABLED(CONFIG_NET_SOCKETS_ENABLE_DTLS), \
220 "DTLS is required for CoAP secure (CONFIG_NET_SOCKETS_ENABLE_DTLS)"); \
221 extern struct coap_resource _CONCAT(_CONCAT(_coap_resource_, _name), _list_start)[]; \
222 extern struct coap_resource _CONCAT(_CONCAT(_coap_resource_, _name), _list_end)[]; \
223 __z_coap_service_define(_name, _host, _port, _flags, \
224 &_CONCAT(_CONCAT(_coap_resource_, _name), _list_start)[0], \
225 &_CONCAT(_CONCAT(_coap_resource_, _name), _list_end)[0], \
226 _sec_tag_list, _sec_tag_list_size, false, NULL)
227
245#define COAP_SERVICE_DEFINE_OSCORE(_name, _host, _port, _flags, _oscore_required) \
246 extern struct coap_resource _CONCAT(_CONCAT(_coap_resource_, _name), _list_start)[]; \
247 extern struct coap_resource _CONCAT(_CONCAT(_coap_resource_, _name), _list_end)[]; \
248 __z_coap_oscore_cache_define(_name) __z_coap_service_define( \
249 _name, _host, _port, _flags, \
250 &_CONCAT(_CONCAT(_coap_resource_, _name), _list_start)[0], \
251 &_CONCAT(_CONCAT(_coap_resource_, _name), _list_end)[0], NULL, 0, \
252 (_oscore_required), __z_coap_oscore_cache_ptr(_name))
253
269#define COAPS_SERVICE_DEFINE_OSCORE(_name, _host, _port, _flags, _sec_tag_list, \
270 _sec_tag_list_size, _oscore_required) \
271 BUILD_ASSERT(IS_ENABLED(CONFIG_NET_SOCKETS_ENABLE_DTLS), \
272 "DTLS is required for CoAP secure (CONFIG_NET_SOCKETS_ENABLE_DTLS)"); \
273 extern struct coap_resource _CONCAT(_CONCAT(_coap_resource_, _name), _list_start)[]; \
274 extern struct coap_resource _CONCAT(_CONCAT(_coap_resource_, _name), _list_end)[]; \
275 __z_coap_oscore_cache_define(_name) \
276 __z_coap_service_define(_name, _host, _port, _flags, \
277 &_CONCAT(_CONCAT(_coap_resource_, _name), _list_start)[0], \
278 &_CONCAT(_CONCAT(_coap_resource_, _name), _list_end)[0], \
279 _sec_tag_list, _sec_tag_list_size, \
280 (_oscore_required), __z_coap_oscore_cache_ptr(_name))
281
287#define COAP_SERVICE_COUNT(_dst) STRUCT_SECTION_COUNT(coap_service, _dst)
288
294#define COAP_SERVICE_RESOURCE_COUNT(_service) ((_service)->res_end - (_service)->res_begin)
295
302#define COAP_SERVICE_HAS_RESOURCE(_service, _resource) \
303 ((_service)->res_begin <= _resource && _resource < (_service)->res_end)
304
310#define COAP_SERVICE_FOREACH(_it) STRUCT_SECTION_FOREACH(coap_service, _it)
311
320#define COAP_RESOURCE_FOREACH(_service, _it) \
321 STRUCT_SECTION_FOREACH_ALTERNATE(_CONCAT(coap_resource_, _service), coap_resource, _it)
322
331#define COAP_SERVICE_FOREACH_RESOURCE(_service, _it) \
332 for (struct coap_resource *_it = (_service)->res_begin; ({ \
333 __ASSERT(_it <= (_service)->res_end, "unexpected list end location"); \
334 _it < (_service)->res_end; \
335 }); _it++)
336
347int coap_service_start(const struct coap_service *service);
348
358int coap_service_stop(const struct coap_service *service);
359
370int coap_service_is_running(const struct coap_service *service);
371
384int coap_service_send(const struct coap_service *service, const struct coap_packet *cpkt,
385 const struct net_sockaddr *addr, net_socklen_t addr_len,
386 const struct coap_transmission_parameters *params);
387
400int coap_resource_send(const struct coap_resource *resource, const struct coap_packet *cpkt,
401 const struct net_sockaddr *addr, net_socklen_t addr_len,
402 const struct coap_transmission_parameters *params);
403
417int coap_resource_parse_observe(struct coap_resource *resource, const struct coap_packet *request,
418 const struct net_sockaddr *addr);
419
429int coap_resource_remove_observer_by_addr(struct coap_resource *resource,
430 const struct net_sockaddr *addr);
431
442int coap_resource_remove_observer_by_token(struct coap_resource *resource,
443 const uint8_t *token, uint8_t token_len);
444
448
449#ifdef __cplusplus
450}
451#endif
452
453#endif /* ZEPHYR_INCLUDE_NET_COAP_SERVICE_H_ */
coap.h
CoAP implementation for Zephyr.
coap_oscore.h
CoAP OSCORE API.
coap_service_is_running
int coap_service_is_running(const struct coap_service *service)
Query the provided service running state.
coap_service_send
int coap_service_send(const struct coap_service *service, const struct coap_packet *cpkt, const struct net_sockaddr *addr, net_socklen_t addr_len, const struct coap_transmission_parameters *params)
Send a CoAP message from the provided service .
coap_resource_send
int coap_resource_send(const struct coap_resource *resource, const struct coap_packet *cpkt, const struct net_sockaddr *addr, net_socklen_t addr_len, const struct coap_transmission_parameters *params)
Send a CoAP message from the provided resource .
coap_service_stop
int coap_service_stop(const struct coap_service *service)
Stop the provided service .
coap_resource_remove_observer_by_addr
int coap_resource_remove_observer_by_addr(struct coap_resource *resource, const struct net_sockaddr *addr)
Lookup an observer by address and remove it from the resource .
coap_resource_parse_observe
int coap_resource_parse_observe(struct coap_resource *resource, const struct coap_packet *request, const struct net_sockaddr *addr)
Parse a CoAP observe request for the provided resource .
coap_service_start
int coap_service_start(const struct coap_service *service)
Start the provided service .
coap_resource_remove_observer_by_token
int coap_resource_remove_observer_by_token(struct coap_resource *resource, const uint8_t *token, uint8_t token_len)
Lookup an observer by token and remove it from the resource .
net_socklen_t
uint32_t net_socklen_t
Length of a socket address.
Definition net_ip.h:172
sec_tag_t
int sec_tag_t
Secure tag, a reference to TLS credential.
Definition tls_credentials.h:90
flags
flags
Definition parser.h:97
uint8_t
__UINT8_TYPE__ uint8_t
Definition stdint.h:88
uint16_t
__UINT16_TYPE__ uint16_t
Definition stdint.h:89
coap_observer
Represents a remote device that is observing a local resource.
Definition coap.h:333
coap_oscore_exchange
OSCORE exchange entry.
Definition coap_oscore.h:163
coap_packet
Representation of a CoAP Packet.
Definition coap.h:354
coap_pending
Represents a request awaiting for an acknowledgment (ACK).
Definition coap.h:425
coap_resource
Description of CoAP resource.
Definition coap.h:313
coap_transmission_parameters
CoAP transmission parameters.
Definition coap.h:406
net_sockaddr
Generic sockaddr struct.
Definition net_ip.h:455
iterable_sections.h
Iterable sections helpers.
tls_credentials.h
TLS credentials management.