refactor: add a async read/write variant to device ops, with allow async io to be...

[lunaix-os.git] / lunaix-os / hal / term / term_io.c

diff --git a/lunaix-os/hal/term/term_io.c b/lunaix-os/hal/term/term_io.c
index 94e61d6cc3ff23f71d22e743c4d1bd8a1e9c806e..729e5496b083bc22e51b2bac9ec1c31f407c0152 100644 (file)
--- a/lunaix-os/hal/term/term_io.c
+++ b/lunaix-os/hal/term/term_io.c
@@ -20,7 +20,7 @@ do_read_raw(struct term* tdev)
 
     char* inbuffer = line_in->current->buffer;
     size_t min = tdev->cc[_VMIN] - 1;
 
     char* inbuffer = line_in->current->buffer;
     size_t min = tdev->cc[_VMIN] - 1;

-    size_t sz = chdev->ops.read(chdev, inbuffer, 0, max_lb_sz);
+    size_t sz = chdev->ops.read_async(chdev, inbuffer, 0, max_lb_sz);

     time_t t = clock_systime(), dt = 0;
     time_t expr = (tdev->cc[_VTIME] * 100) - 1;
 
     time_t t = clock_systime(), dt = 0;
     time_t expr = (tdev->cc[_VTIME] * 100) - 1;
 


@@ -33,8 +33,7 @@ do_read_raw(struct term* tdev)
         max_lb_sz -= sz;
 
         // TODO pass a flags to read to indicate it is non blocking ops
         max_lb_sz -= sz;
 
         // TODO pass a flags to read to indicate it is non blocking ops

-        sz +=
-        chdev->ops.read(chdev, inbuffer, sz, max_lb_sz);
+        sz += chdev->ops.read_async(chdev, inbuffer, sz, max_lb_sz);

     }
 
     rbuffer_puts(line_in->next, inbuffer, sz);
     }
 
     rbuffer_puts(line_in->next, inbuffer, sz);


@@ -44,7 +43,8 @@ do_read_raw(struct term* tdev)
 }
 
 static int
 }
 
 static int

-do_read_raw_canno(struct term* tdev) {
+do_read_raw_canno(struct term* tdev)
+{

     struct device* chdev = tdev->chdev;
     struct linebuffer* line_in = &tdev->line_in;
     struct rbuffer* current_buf = line_in->current;
     struct device* chdev = tdev->chdev;
     struct linebuffer* line_in = &tdev->line_in;
     struct rbuffer* current_buf = line_in->current;


@@ -60,7 +60,8 @@ static int
 term_read_noncano(struct term* tdev)
 {
     struct device* chdev = tdev->chdev;
 term_read_noncano(struct term* tdev)
 {
     struct device* chdev = tdev->chdev;

-    return do_read_raw(tdev);;
+    return do_read_raw(tdev);
+    ;

 }
 
 static int
 }
 
 static int