WIP: get unicoap to work with dtls

Author: mguetschow

sys/net/application_layer/unicoap/drivers/rfc7252/dtls/transport.c

@@ -58,14 +58,15 @@ static void _dtls_session_triage(unicoap_scheduled_event_t* event)
 }
 
 static void _dtls_on_event(sock_dtls_t* sock, sock_async_flags_t type, void* arg)
-{DTLS_DEBUG("received event from network backend %x\n", type);
+{
     (void)arg;
     sock_dtls_session_t session = { 0 };
 
     if (type & SOCK_ASYNC_CONN_RECV) {
         DTLS_DEBUG("establishing session\n");
-        ssize_t res = sock_dtls_recv(sock, &session, unicoap_receiver_buffer,
-                                     sizeof(unicoap_receiver_buffer),
+
+        uint8_t buf[1];
+        ssize_t res = sock_dtls_recv(sock, &session, buf, sizeof(buf),
                                      CONFIG_UNICOAP_DTLS_HANDSHAKE_TIMEOUT_MS * US_PER_MS);
 
         if (res != -SOCK_DTLS_HANDSHAKE) {
@@ -102,27 +103,6 @@ static void _dtls_on_event(sock_dtls_t* sock, sock_async_flags_t type, void* arg
         }
     }
 
-    if (type & SOCK_ASYNC_CONN_FIN) {
-        DTLS_DEBUG("closing session\n");
-        if (sock_dtls_get_event_session(sock, &session)) {
-            /* Session is already destroyed, only remove it from session mgmt. */
-            dsm_remove(sock, &session);
-        }
-        else {
-            DTLS_DEBUG("session was closed, but the corresponding session "
-                       "could not be retrieved from the socket\n");
-            return;
-        }
-
-        DTLS_DEBUG("session ended, removing associated endpoint state\n");
-
-        unicoap_endpoint_t endpoint = { .proto = UNICOAP_PROTO_DTLS };
-        sock_dtls_session_get_udp_ep(&session, unicoap_endpoint_get_dtls(&endpoint));
-        unicoap_exchange_release_endpoint_state(&endpoint);
-        /* It is safe to ignore the result of exchange_release_endpoint state as this logic follows
-         * a best-effort philosophy. */
-    }
-
     if (type & SOCK_ASYNC_CONN_RDY) {
         DTLS_DEBUG("connection ready\n");
     }
@@ -141,11 +121,6 @@ static void _dtls_on_event(sock_dtls_t* sock, sock_async_flags_t type, void* arg
             DTLS_DEBUG("recv failure: %" PRIdSIZE "\n", received);
             return;
         }
-        /* FIXME: sock_dtls_recv_buf_aux fails on second read due to sock->buf_ctx not being NULL */
-        // sock->buf_ctx = NULL;
-        if (received == 0) {
-            return;
-        }
 
         assert(pdu);
 
@@ -165,6 +140,29 @@ static void _dtls_on_event(sock_dtls_t* sock, sock_async_flags_t type, void* arg
 
         /* Truncated DTLS messages would already have gotten lost at verification */
         unicoap_messaging_process_rfc7252((uint8_t*)pdu, received, false, &packet);
+
+        received = sock_dtls_recv_buf_aux(sock, &session, &pdu, &buffer_ctx, 0, &aux_rx);
+        /* If the networking backends holds its zero-copy guarantee, then trying to read
+         * another chunk must not yield any more data. */
+        assert(received == 0);
+    }
+
+    if (type & SOCK_ASYNC_CONN_FIN) {
+        if (sock_dtls_get_event_session(sock, &session)) {
+            /* Session is already destroyed, only remove it from dsm */
+            dsm_remove(sock, &session);
+        }
+        else {
+            DTLS_DEBUG("session was closed, but the corresponding session "
+                       "could not be retrieved from the socket\n");
+            return;
+        }
+
+        DTLS_DEBUG("session ended, removing associated endpoint state\n");
+
+        unicoap_endpoint_t endpoint = { .proto = UNICOAP_PROTO_DTLS };
+        sock_dtls_session_get_udp_ep(&session, unicoap_endpoint_get_dtls(&endpoint));
+        unicoap_exchange_release_endpoint_state(&endpoint);
     }
 
     return;
@@ -236,18 +234,19 @@ int unicoap_transport_sendv_dtls(iolist_t* iolist, const sock_udp_ep_t* remote,
             return res;
         }
     }
-    /* prepare session */
-    sock_dtls_session_set_udp_ep(session, remote);
-    dsm_state_t session_state = dsm_store(&_dtls_socket, session, SESSION_STATE_HANDSHAKE, true);
-    if (session_state == NO_SPACE) {
-        return -1;
-    }
+    // todo: not needed, already done in _dtls_authenticate, or session is already established?!
+    // /* prepare session */
+    // sock_dtls_session_set_udp_ep(session, remote);
+    // dsm_state_t session_state = dsm_store(&_dtls_socket, session, SESSION_STATE_HANDSHAKE, true);
+    // if (session_state == NO_SPACE) {
+    //     return -1;
+    // }
 
     DTLS_DEBUG("started sending\n");
 
     if (unlikely(local)) {
         sock_dtls_aux_tx_t aux_tx = { .flags = SOCK_AUX_SET_LOCAL, .local = *local };
-        res = sock_dtls_sendv_aux(&_dtls_socket, session, iolist, SOCK_NO_TIMEOUT, &aux_tx);
+        res = sock_dtls_sendv_aux(&_dtls_socket, session, iolist, 500000, &aux_tx);
     }
     else {
         res = sock_dtls_sendv_aux(&_dtls_socket, session, iolist,
@@ -256,8 +255,9 @@ int unicoap_transport_sendv_dtls(iolist_t* iolist, const sock_udp_ep_t* remote,
     DTLS_DEBUG("done sending\n");
 
     switch (res) {
-    case -EHOSTUNREACH:
+    case -EHOSTUNREACH: // todo: not one of the return values
     case -ENOTCONN:
+    case -ETIMEDOUT:
     case 0:
         DTLS_DEBUG("DTLS sock not connected or remote unreachable. "
                    "Destroying session.\n");

sys/net/application_layer/unicoap/drivers/rfc7252/udp/transport.c

@@ -69,6 +69,7 @@ static void _udp_on_event(sock_udp_t* sock, sock_async_flags_t type, void* arg)
         }
         else {
             pdu = unicoap_receiver_buffer;
+            // todo: shouldn't this check truncated somewhere and bail out?
             while (true) {
                 ssize_t chunk_size = sock_udp_recv_buf_aux(
                     sock, &stackbuf, &buffer_ctx, 0, unicoap_endpoint_get_udp(&remote), &aux_rx);