Changes in uspace/srv/net/loopip/loopip.c [5a6cc679:a35b458] in mainline

File:

• uspace/srv/net/loopip/loopip.c (modified) (15 diffs)

uspace/srv/net/loopip/loopip.c

@@ -45 +45 @@
 #include <stdio.h>
 #include <stdlib.h>
+#include <str.h>
 #include <task.h>
 
@@ -76 +77 @@
 typedef struct {
         link_t link;
-        
+
         /* XXX Version should be part of SDU */
         ip_ver_t ver;
@@ -89 +90 @@
                 rqueue_entry_t *rqe =
                     list_get_instance(link, rqueue_entry_t, link);
-                
+
                 (void) iplink_ev_recv(&loopip_iplink, &rqe->sdu, rqe->ver);
-                
+
                 free(rqe->sdu.data);
                 free(rqe);
         }
-        
+
         return 0;
 }
@@ -102 +103 @@
 {
         async_set_fallback_port_handler(loopip_client_conn, NULL);
-        
+
         errno_t rc = loc_server_register(NAME);
         if (rc != EOK) {
@@ -108 +109 @@
                 return rc;
         }
-        
+
         iplink_srv_init(&loopip_iplink);
         loopip_iplink.ops = &loopip_iplink_ops;
         loopip_iplink.arg = NULL;
-        
+
         prodcons_initialize(&loopip_rcv_queue);
-        
+
         const char *svc_name = "net/loopback";
         service_id_t sid;
@@ -123 +124 @@
                 return rc;
         }
-        
+
         category_id_t iplink_cat;
         rc = loc_category_get_id("iplink", &iplink_cat, IPC_FLAG_BLOCKING);
@@ -130 +131 @@
                 return rc;
         }
-        
+
         rc = loc_service_add_to_cat(sid, iplink_cat);
         if (rc != EOK) {
@@ -137 +138 @@
                 return rc;
         }
-        
+
         fid_t fid = fibril_create(loopip_recv_fibril, NULL);
         if (fid == 0)
                 return ENOMEM;
-        
+
         fibril_add_ready(fid);
-        
+
         return EOK;
 }
@@ -168 +169 @@
 {
         log_msg(LOG_DEFAULT, LVL_DEBUG, "loopip_send()");
-        
+
         rqueue_entry_t *rqe = calloc(1, sizeof(rqueue_entry_t));
         if (rqe == NULL)
                 return ENOMEM;
-        
+
         /*
          * Clone SDU
@@ -182 +183 @@
                 return ENOMEM;
         }
-        
+
         memcpy(rqe->sdu.data, sdu->data, sdu->size);
         rqe->sdu.size = sdu->size;
-        
+
         /*
          * Insert to receive queue
          */
         prodcons_produce(&loopip_rcv_queue, &rqe->link);
-        
+
         return EOK;
 }
@@ -197 +198 @@
 {
         log_msg(LOG_DEFAULT, LVL_DEBUG, "loopip6_send()");
-        
+
         rqueue_entry_t *rqe = calloc(1, sizeof(rqueue_entry_t));
         if (rqe == NULL)
                 return ENOMEM;
-        
+
         /*
          * Clone SDU
@@ -211 +212 @@
                 return ENOMEM;
         }
-        
+
         memcpy(rqe->sdu.data, sdu->data, sdu->size);
         rqe->sdu.size = sdu->size;
-        
+
         /*
          * Insert to receive queue
          */
         prodcons_produce(&loopip_rcv_queue, &rqe->link);
-        
+
         return EOK;
 }
@@ -249 +250 @@
 {
         printf("%s: HelenOS loopback IP link provider\n", NAME);
-        
+
         errno_t rc = log_init(NAME);
         if (rc != EOK) {
@@ -255 +256 @@
                 return rc;
         }
-        
+
         rc = loopip_init();
         if (rc != EOK) {
@@ -261 +262 @@
                 return rc;
         }
-        
+
         printf("%s: Accepting connections.\n", NAME);
         task_retval(0);
         async_manager();
-        
+
         /* Not reached */
         return 0;