riot-ci/RIOT
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

tests/pkg_semtech-loramac: add RX thread for downlink messages

Browse Source
This commit is contained in:
Alexandre Abadie 2019-05-17 11:33:17 +02:00
parent b7890b3031
commit 0838cf99bb
No known key found for this signature in database
GPG Key ID: 1C919A403CAE1405
1 changed files with 43 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
tests/pkg_semtech-loramac/main.c
View File

@ -20,6 +20,7 @@
#include <string.h> #include <string.h>
#include <inttypes.h> #include <inttypes.h>
#include "thread.h"
#include "msg.h" #include "msg.h"
#include "shell.h" #include "shell.h"
#include "fmt.h" #include "fmt.h"
@ -27,12 +28,50 @@
#include "net/loramac.h" #include "net/loramac.h"
#include "semtech_loramac.h" #include "semtech_loramac.h"
#define LORAMAC_RECV_MSG_QUEUE (4U)
static msg_t _loramac_recv_queue[LORAMAC_RECV_MSG_QUEUE];
semtech_loramac_t loramac; semtech_loramac_t loramac;
/* Application key is 16 bytes long (e.g. 32 hex chars), and thus the longest /* Application key is 16 bytes long (e.g. 32 hex chars), and thus the longest
possible size (with application session and network session keys) */ possible size (with application session and network session keys) */
static char print_buf[LORAMAC_APPKEY_LEN * 2 + 1]; static char print_buf[LORAMAC_APPKEY_LEN * 2 + 1];
static char _recv_stack[THREAD_STACKSIZE_DEFAULT];
static void *_wait_recv(void *arg)
{
msg_init_queue(_loramac_recv_queue, LORAMAC_RECV_MSG_QUEUE);
(void)arg;
while (1) {
/* blocks until something is received */
switch (semtech_loramac_recv(&loramac)) {
case SEMTECH_LORAMAC_RX_DATA:
loramac.rx_data.payload[loramac.rx_data.payload_len] = 0;
printf("Data received: %s, port: %d\n",
(char *)loramac.rx_data.payload, loramac.rx_data.port);
break;
case SEMTECH_LORAMAC_RX_LINK_CHECK:
printf("Link check information:\n"
" - Demodulation margin: %d\n"
" - Number of gateways: %d\n",
loramac.link_chk.demod_margin,
loramac.link_chk.nb_gateways);
break;
case SEMTECH_LORAMAC_RX_CONFIRMED:
puts("Received ACK from network");
break;
default:
break;
}
}
return NULL;
}
static void _loramac_usage(void) static void _loramac_usage(void)
{ {
puts("Usage: loramac <get|set|join|tx|link_check" puts("Usage: loramac <get|set|join|tx|link_check"
@ -430,39 +469,7 @@ static int _cmd_loramac(int argc, char **argv)
return 1; return 1;
} }
/* wait for receive windows */ puts("Message sent with success");
switch (semtech_loramac_recv(&loramac)) {
case SEMTECH_LORAMAC_DATA_RECEIVED:
loramac.rx_data.payload[loramac.rx_data.payload_len] = 0;
printf("Data received: %s, port: %d\n",
(char *)loramac.rx_data.payload, loramac.rx_data.port);
break;
case SEMTECH_LORAMAC_DUTYCYCLE_RESTRICTED:
puts("Cannot send: dutycycle restriction");
return 1;
case SEMTECH_LORAMAC_BUSY:
puts("Cannot send: MAC is busy");
return 1;
case SEMTECH_LORAMAC_TX_ERROR:
puts("Cannot send: error");
return 1;
case SEMTECH_LORAMAC_TX_DONE:
puts("TX complete, no data received");
break;
}
if (loramac.link_chk.available) {
printf("Link check information:\n"
" - Demodulation margin: %d\n"
" - Number of gateways: %d\n",
loramac.link_chk.demod_margin,
loramac.link_chk.nb_gateways);
}
return 0; return 0;
} }
else if (strcmp(argv[1], "link_check") == 0) { else if (strcmp(argv[1], "link_check") == 0) {
@ -509,6 +516,9 @@ int main(void)
{ {
semtech_loramac_init(&loramac); semtech_loramac_init(&loramac);
thread_create(_recv_stack, sizeof(_recv_stack),
THREAD_PRIORITY_MAIN - 1, 0, _wait_recv, NULL, "recv thread");
puts("All up, running the shell now"); puts("All up, running the shell now");
char line_buf[SHELL_DEFAULT_BUFSIZE]; char line_buf[SHELL_DEFAULT_BUFSIZE];
shell_run(shell_commands, line_buf, SHELL_DEFAULT_BUFSIZE); shell_run(shell_commands, line_buf, SHELL_DEFAULT_BUFSIZE);