use sys(read|write) with coro

rcaputo · Sep 25, 2009 · 66db46e · 66db46e
1 parent 1f71dc0
commit 66db46e
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/echo-coro.pl b/echo-coro.pl
@@ -20,8 +20,15 @@
 while (1) {
     my $csock = $sock->accept;
     async_pool {
-        while (my $line = <$csock>) {
-            print $csock $line;
+        my $nb_fh = $csock->fh;
+        my $buf   = \$csock->rbuf;
+        while (1) {
+            $csock->readable or last;
+            unless (sysread($nb_fh, $$buf, 8192)) {
+                last;
+            }
+            $csock->writable or last;
+            syswrite($csock, $$buf);
         }
     };
 }