Changeset 86dc95d for libcfa/src/concurrency/clib

Timestamp:

Mar 25, 2021, 1:48:09 PM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

3143f28

Parents:

8d4c9f4

Message:

Re-implemented the work around I forgot about in memcached.
Namely read/write vs send/recv matters in io_uring.

File:

• libcfa/src/concurrency/clib/cfathread.cfa (modified) (2 diffs)

libcfa/src/concurrency/clib/cfathread.cfa

@@ -312 +312 @@
 
         ssize_t cfathread_write(int fildes, const void *buf, size_t nbyte) {
-                return cfa_write(fildes, buf, nbyte, CFA_IO_LAZY);
+                // Use send rather then write for socket since it's faster
+                return cfa_send(fildes, buf, nbyte, 0, CFA_IO_LAZY);
         }
 
@@ -335 +336 @@
 
         ssize_t cfathread_read(int fildes, void *buf, size_t nbyte) {
-                return cfa_read(fildes, buf, nbyte, CFA_IO_LAZY);
-        }
-
-}
+                // Use recv rather then read for socket since it's faster
+                return cfa_recv(fildes, buf, nbyte, 0, CFA_IO_LAZY);
+        }
+
+}