RIOT-OS/RIOT
RIOT-OS/RIOT
1
0
Fork 0
mirror of https://github.com/RIOT-OS/RIOT.git synced 2024-12-29 04:50:03 +01:00
Code Releases Activity

examples/asymcute_mqttsn: adapt to API change

Browse Source
This commit is contained in:
Hauke Petersen 2020-12-16 12:34:21 +01:00
parent ee01950ed7
commit 8e19d539a8
1 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
examples/asymcute_mqttsn/main.c
View File

@ -48,10 +48,6 @@
#define MAIN_QUEUE_SIZE (8)
static msg_t _main_msg_queue[MAIN_QUEUE_SIZE];
#define LISTENER_PRIO (THREAD_PRIORITY_MAIN - 1)
static char listener_stack[ASYMCUTE_LISTENER_STACKSIZE];
static asymcute_con_t _connection;
static asymcute_req_t _reqs[REQ_CTX_NUMOF];
static asymcute_sub_t _subscriptions[SUB_CTX_NUMOF];
@ -264,8 +260,8 @@ static int _cmd_connect(int argc, char **argv)
return 1;
}
if (asymcute_connect(&_connection, req, &ep, argv[1], true, NULL)
!= ASYMCUTE_OK) {
if (asymcute_connect(&_connection, req, &ep, argv[1],
true, NULL, _on_con_evt) != ASYMCUTE_OK) {
puts("error: failed to issue CONNECT request");
return 1;
}
@ -555,10 +551,6 @@ int main(void)
puts("Type 'help' to get started and have a look at the README.md for more"
"information.");
/* setup the connection context */
asymcute_listener_run(&_connection, listener_stack, sizeof(listener_stack),
LISTENER_PRIO, _on_con_evt);
/* we need a message queue for the thread running the shell in order to
* receive potentially fast incoming networking packets */
msg_init_queue(_main_msg_queue, MAIN_QUEUE_SIZE);