hare

commit 10b50024da5e3871bdcc14e95c28d4f1768662bc
parent 567121abf3244212b1495007879a323499661251
Author: Drew DeVault <sir@cmpwn.com>
Date:   Wed, 20 Oct 2021 11:08:36 +0200

iobus::io_uring: reduce default SQE queue size

Signed-off-by: Drew DeVault <sir@cmpwn.com>

Diffstat:
M
iobus/io_uring/bus.ha
 | 
9
++++-----

1 file changed, 4 insertions(+), 5 deletions(-)
diff --git a/iobus/io_uring/bus.ha b/iobus/io_uring/bus.ha
@@ -2,7 +2,7 @@ use errors;
 use io;
 use linux::io_uring;
 
-def DEFAULT_RING_SIZE: u32 = 512;
+def DEFAULT_RING_SIZE: u32 = 256;
 
 // Creates a new I/O bus.
 export fn new() (*bus | error) = {
@@ -83,13 +83,12 @@ fn _dispatch(bus: *bus) (result | error) = {
 // use for I/O operations. It is not necessary to register files to use them for
 // I/O, but it improves performance if you do.
 export fn register_file(bus: *bus, file: io::file) registered_file = {
-	let registered: int = -1;
-	if (bus.lastfd >= len(bus.fdset)) {
+	let registered: int = if (bus.lastfd >= len(bus.fdset)) {
 		static const init: [256]int = [-1...];
 		append(bus.fdset, init...);
 		bus.fdset[bus.lastfd] = file;
-		registered = bus.lastfd: int;
 		io_uring::register_files(&bus.uring, bus.fdset)!;
+		yield bus.lastfd: int;
 	} else {
 		let updates = [
 			io_uring::files_update {
@@ -98,8 +97,8 @@ export fn register_file(bus: *bus, file: io::file) registered_file = {
 			},
 		];
 		bus.fdset[bus.lastfd] = file;
-		registered = bus.lastfd: int;
 		io_uring::register_files_update(&bus.uring, updates)!;
+		yield bus.lastfd: int;
 	};
 	for (bus.fdset[bus.lastfd] != -1; bus.lastfd += 1) void;
 	return registered;