Changeset ee603c4 in mainline for uspace/srv/udp/ucall.c

Timestamp:

2012-04-04T21:10:22Z (13 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

92b42442

Parents:

4794417

Message:

UDP associations, sending datagrams.

File:

• uspace/srv/udp/ucall.c (modified) (6 diffs)

uspace/srv/udp/ucall.c

@@ -37 +37 @@
 #include <io/log.h>
 
-//#include "conn.h"
+#include "assoc.h"
 #include "udp_type.h"
 #include "ucall.h"
@@ -43 +43 @@
 udp_error_t udp_uc_create(udp_assoc_t **assoc)
 {
-//      udo_assoc_t *nassoc;
+        udp_assoc_t *nassoc;
 
         log_msg(LVL_DEBUG, "udp_uc_create()");
+        nassoc = udp_assoc_new(NULL, NULL);
+        if (nassoc == NULL)
+                return UDP_ENORES;
 
+        udp_assoc_add(nassoc);
+        *assoc = nassoc;
         return UDP_EOK;
 }
@@ -52 +57 @@
 udp_error_t udp_uc_set_foreign(udp_assoc_t *assoc, udp_sock_t *fsock)
 {
-//      udo_assoc_t *nconn;
-
         log_msg(LVL_DEBUG, "udp_uc_set_foreign(%p, %p)", assoc, fsock);
 
+        udp_assoc_set_foreign(assoc, fsock);
         return UDP_EOK;
 }
@@ -61 +65 @@
 udp_error_t udp_uc_set_local(udp_assoc_t *assoc, udp_sock_t *lsock)
 {
-//      udo_assoc_t *nconn;
-
         log_msg(LVL_DEBUG, "udp_uc_set_local(%p, %p)", assoc, lsock);
 
+        udp_assoc_set_local(assoc, lsock);
         return UDP_EOK;
 }
@@ -71 +74 @@
     size_t size, xflags_t flags)
 {
+        int rc;
+        udp_msg_t msg;
+
         log_msg(LVL_DEBUG, "%s: udp_uc_send()", assoc->name);
+
+        msg.data = data;
+        msg.data_size = size;
+
+        rc = udp_assoc_send(assoc, fsock, &msg);
+        switch (rc) {
+        case ENOMEM:
+                return UDP_ENORES;
+        case EINVAL:
+                return UDP_EUNSPEC;
+        case EIO:
+                return UDP_ENOROUTE;
+        }
         return UDP_EOK;
 }
@@ -92 +111 @@
 void udp_uc_destroy(udp_assoc_t *assoc)
 {
-        log_msg(LVL_DEBUG, "udp_uc_delete()");
-//      udp_assoc_destroy(assoc);
+        log_msg(LVL_DEBUG, "udp_uc_destroy()");
+        udp_assoc_remove(assoc);
+        udp_assoc_delete(assoc);
 }