Changes in uspace/srv/net/slip/slip.c [c1694b6b:e141281] in mainline

File:

• uspace/srv/net/slip/slip.c (modified) (14 diffs)

uspace/srv/net/slip/slip.c

@@ -37 +37 @@
 #include <stdio.h>
 #include <stdint.h>
-#include <stdlib.h>
 #include <loc.h>
 #include <inet/addr.h>
 #include <inet/iplink_srv.h>
-#include <io/chardev.h>
+#include <char_dev_iface.h>
 #include <io/log.h>
 #include <errno.h>
-#include <str_error.h>
 #include <task.h>
 
@@ -98 +96 @@
 }
 
-static void write_flush(chardev_t *chardev)
+static void write_flush(async_sess_t *sess)
 {
         size_t written = 0;
 
         while (slip_send_pending > 0) {
-                int rc;
-                size_t nwr;
-
-                rc = chardev_write(chardev, &slip_send_buf[written],
-                    slip_send_pending, &nwr);
-                if (rc != EOK) {
+                ssize_t size;
+
+                size = char_dev_write(sess, &slip_send_buf[written],
+                    slip_send_pending);
+                if (size < 0) {
                         log_msg(LOG_DEFAULT, LVL_ERROR,
-                            "chardev_write() -> %s", str_error_name(rc));
+                            "char_dev_write() returned %d",
+                            (int) size);
                         slip_send_pending = 0;
                         break;
                 }
-                written += nwr;
-                slip_send_pending -= nwr;
-        }
-}
-
-static void write_buffered(chardev_t *chardev, uint8_t ch)
+                written += size;
+                slip_send_pending -= size;
+        }
+}
+
+static void write_buffered(async_sess_t *sess, uint8_t ch)
 {
         if (slip_send_pending == sizeof(slip_send_buf))
-                write_flush(chardev);
+                write_flush(sess);
         slip_send_buf[slip_send_pending++] = ch;
 }
@@ -130 +128 @@
         log_msg(LOG_DEFAULT, LVL_DEBUG, "slip_send()");
         
-        chardev_t *chardev = (chardev_t *) srv->arg;
+        async_sess_t *sess = (async_sess_t *) srv->arg;
         uint8_t *data = sdu->data;
         
@@ -138 +136 @@
          * measure for dealing with previous possible noise on the line.
          */
-        write_buffered(chardev, SLIP_END);
+        write_buffered(sess, SLIP_END);
         
         for (size_t i = 0; i < sdu->size; i++) {
                 switch (data[i]) {
                 case SLIP_END:
-                        write_buffered(chardev, SLIP_ESC);
-                        write_buffered(chardev, SLIP_ESC_END);
+                        write_buffered(sess, SLIP_ESC);
+                        write_buffered(sess, SLIP_ESC_END);
                         break;
                 case SLIP_ESC:
-                        write_buffered(chardev, SLIP_ESC);
-                        write_buffered(chardev, SLIP_ESC_ESC);
+                        write_buffered(sess, SLIP_ESC);
+                        write_buffered(sess, SLIP_ESC_ESC);
                         break;
                 default:
-                        write_buffered(chardev, data[i]);
+                        write_buffered(sess, data[i]);
                         break;
                 }
         }
         
-        write_buffered(chardev, SLIP_END);
-        write_flush(chardev);
+        write_buffered(sess, SLIP_END);
+        write_flush(sess);
         
         return EOK;
@@ -205 +203 @@
 }
 
-static uint8_t read_buffered(chardev_t *chardev)
+static uint8_t read_buffered(async_sess_t *sess)
 {
         while (slip_recv_pending == 0) {
-                int rc;
-                size_t nread;
-
-                rc = chardev_read(chardev, slip_recv_buf,
-                    sizeof(slip_recv_buf), &nread);
-                if (rc != EOK) {
+                ssize_t size;
+
+                size = char_dev_read(sess, slip_recv_buf,
+                    sizeof(slip_recv_buf));
+                if (size < 0) {
                         log_msg(LOG_DEFAULT, LVL_ERROR,
-                            "char_dev_read() -> %s", str_error_name(rc));
+                            "char_dev_read() returned %d", (int) size);
+                        return SLIP_END;
                 }
-
-                if (nread == 0)
-                        return SLIP_END;
-
-                slip_recv_pending = nread;
+                slip_recv_pending = size;
                 slip_recv_read = 0;
         }
@@ -230 +224 @@
 static int slip_recv_fibril(void *arg)
 {
-        chardev_t *chardev = (chardev_t *) arg;
+        async_sess_t *sess = (async_sess_t *) arg;
         static uint8_t recv_final[SLIP_MTU];
         iplink_recv_sdu_t sdu;
@@ -240 +234 @@
         while (true) {
                 for (sdu.size = 0; sdu.size < sizeof(recv_final); /**/) {
-                        ch = read_buffered(chardev);
+                        ch = read_buffered(sess);
                         switch (ch) {
                         case SLIP_END:
@@ -252 +246 @@
 
                         case SLIP_ESC:
-                                ch = read_buffered(chardev);
+                                ch = read_buffered(sess);
                                 if (ch == SLIP_ESC_END) {
                                         recv_final[sdu.size++] = SLIP_END;
                                         break;
-                                } else if (ch == SLIP_ESC_ESC) {
+                                } else if (ch ==  SLIP_ESC_ESC) {
                                         recv_final[sdu.size++] = SLIP_ESC;
                                         break;
@@ -287 +281 @@
                 if (rc != EOK) {
                         log_msg(LOG_DEFAULT, LVL_ERROR,
-                            "iplink_ev_recv() -> %s", str_error_name(rc));
+                            "iplink_ev_recv() returned %d", rc);
                 }
         }
@@ -301 +295 @@
         async_sess_t *sess_in = NULL;
         async_sess_t *sess_out = NULL;
-        chardev_t *chardev_in = NULL;
-        chardev_t *chardev_out = NULL;
         fid_t fid;
         int rc;
@@ -344 +336 @@
                 return ENOENT;
         }
-
-        rc = chardev_open(sess_out, &chardev_out);
-        if (rc != EOK) {
-                log_msg(LOG_DEFAULT, LVL_ERROR,
-                    "Failed opening character device.");
-                return ENOENT;
-        }
-
-        slip_iplink.arg = chardev_out;
+        slip_iplink.arg = sess_out;
 
         sess_in = loc_service_connect(svcid, INTERFACE_DDF, 0);
@@ -363 +347 @@
         }
 
-        rc = chardev_open(sess_in, &chardev_in);
-        if (rc != EOK) {
-                log_msg(LOG_DEFAULT, LVL_ERROR,
-                    "Failed opening character device.");
-                return ENOENT;
-        }
-
         rc = loc_service_register(linkstr, &linksid);
         if (rc != EOK) {
@@ -386 +363 @@
         }
 
-        fid = fibril_create(slip_recv_fibril, chardev_in);
+        fid = fibril_create(slip_recv_fibril, sess_in);
         if (!fid) {
                 log_msg(LOG_DEFAULT, LVL_ERROR,
@@ -398 +375 @@
 
 fail:
-        chardev_close(chardev_out);
         if (sess_out)
                 async_hangup(sess_out);
-        chardev_close(chardev_in);
         if (sess_in)
                 async_hangup(sess_in);