queue-runner: try larger pipe buffer sizes

delroth · Feb 22, 2024 · 909f871 · 909f871
1 parent 838648c
commit 909f871
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/hydra-queue-runner/build-remote.cc b/src/hydra-queue-runner/build-remote.cc
@@ -100,6 +100,11 @@ static void openConnection(::Machine::ptr machine, Path tmpDir, int stderrFD, SS
 
     child.in = to.writeSide.release();
     child.out = from.readSide.release();
+
+    // XXX: determine the actual max value we can use from /proc.
+    int pipesize = 1024 * 1024;
+    fcntl(child.in.get(), F_SETPIPE_SZ, &pipesize);
+    fcntl(child.out.get(), F_SETPIPE_SZ, &pipesize);
 }