danderson/ofborg
0
0
Fork 0
forked from the-distro/ofborg
Code Pull requests Activity

only fetch onee jbo at a time

Browse source
This commit is contained in:
Graham Christensen 2017-11-24 14:15:46 -05:00
parent e35c3d7575
commit 62d9869f8c
No known key found for this signature in database
GPG key ID: ACA1C1D120C83D5C
3 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
ofborg/src/bin/builder.rs
View file

@ -49,6 +49,7 @@ fn main() {
let cloner = checkout::cached_cloner(Path::new(&cfg.checkout.root)); let cloner = checkout::cached_cloner(Path::new(&cfg.checkout.root));
let nix = cfg.nix(); let nix = cfg.nix();
channel.basic_prefetch(1).unwrap();
channel.basic_consume( channel.basic_consume(
worker::new(tasks::build::BuildWorker::new(cloner, nix, cfg.nix.system.clone())), worker::new(tasks::build::BuildWorker::new(cloner, nix, cfg.nix.system.clone())),
format!("build-inputs-{}", cfg.nix.system.clone()).as_ref(), format!("build-inputs-{}", cfg.nix.system.clone()).as_ref(),

1
ofborg/src/bin/github-comment-filter.rs
View file

@ -38,6 +38,7 @@ fn main() {
let mut channel = session.open_channel(2).unwrap(); let mut channel = session.open_channel(2).unwrap();
channel.basic_prefetch(1).unwrap();
channel.basic_consume( channel.basic_consume(
worker::new(tasks::githubcommentfilter::GitHubCommentWorker::new( worker::new(tasks::githubcommentfilter::GitHubCommentWorker::new(
cfg.acl(), cfg.acl(),

2
ofborg/src/bin/mass-rebuilder.rs
View file

@ -69,7 +69,7 @@ fn main() {
})); }));
*/ */
channel.basic_prefetch(1); channel.basic_prefetch(1).unwrap();
channel.basic_consume( channel.basic_consume(
worker::new(mrw), worker::new(mrw),
"mass-rebuild-check-jobs", "mass-rebuild-check-jobs",