From 62d9869f8c134b0e985706ac50cb2716303e7c41 Mon Sep 17 00:00:00 2001
From: Graham Christensen <graham@grahamc.com>
Date: Fri, 24 Nov 2017 14:15:46 -0500
Subject: [PATCH] only fetch onee jbo at a time

---
 ofborg/src/bin/builder.rs               | 1 +
 ofborg/src/bin/github-comment-filter.rs | 1 +
 ofborg/src/bin/mass-rebuilder.rs        | 2 +-
 3 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/ofborg/src/bin/builder.rs b/ofborg/src/bin/builder.rs
index 1504625..671c131 100644
--- a/ofborg/src/bin/builder.rs
+++ b/ofborg/src/bin/builder.rs
@@ -49,6 +49,7 @@ fn main() {
     let cloner = checkout::cached_cloner(Path::new(&cfg.checkout.root));
     let nix = cfg.nix();
 
+    channel.basic_prefetch(1).unwrap();
     channel.basic_consume(
         worker::new(tasks::build::BuildWorker::new(cloner, nix, cfg.nix.system.clone())),
         format!("build-inputs-{}", cfg.nix.system.clone()).as_ref(),
diff --git a/ofborg/src/bin/github-comment-filter.rs b/ofborg/src/bin/github-comment-filter.rs
index 9745c9e..4dea059 100644
--- a/ofborg/src/bin/github-comment-filter.rs
+++ b/ofborg/src/bin/github-comment-filter.rs
@@ -38,6 +38,7 @@ fn main() {
 
     let mut channel = session.open_channel(2).unwrap();
 
+    channel.basic_prefetch(1).unwrap();
     channel.basic_consume(
         worker::new(tasks::githubcommentfilter::GitHubCommentWorker::new(
             cfg.acl(),
diff --git a/ofborg/src/bin/mass-rebuilder.rs b/ofborg/src/bin/mass-rebuilder.rs
index 2b080df..4ecd362 100644
--- a/ofborg/src/bin/mass-rebuilder.rs
+++ b/ofborg/src/bin/mass-rebuilder.rs
@@ -69,7 +69,7 @@ fn main() {
     }));
      */
 
-    channel.basic_prefetch(1);
+    channel.basic_prefetch(1).unwrap();
     channel.basic_consume(
         worker::new(mrw),
         "mass-rebuild-check-jobs",