Index: scripts/slave/recipe_modules/goma/api.py |
diff --git a/scripts/slave/recipe_modules/goma/api.py b/scripts/slave/recipe_modules/goma/api.py |
index 97c12f3f6e200a5787d3a682631de8b9f410a1b0..79636d7707f67889b6e1ea4d12c4f5d830481d14 100644 |
--- a/scripts/slave/recipe_modules/goma/api.py |
+++ b/scripts/slave/recipe_modules/goma/api.py |
@@ -14,6 +14,7 @@ class GomaApi(recipe_api.RecipeApi): |
self._goma_ctl_env = {} |
self._cloudtail_pid = None |
+ self._goma_jobs = None |
@property |
def service_account_json_path(self): |
@@ -31,6 +32,40 @@ class GomaApi(recipe_api.RecipeApi): |
assert self._goma_dir |
return self.m.path.join(self._goma_dir, 'jsonstatus') |
+ @property |
+ def recommended_goma_jobs(self): |
+ """ |
+ Return recommended the number of jobs for parallel build using Goma. |
Yoshisato Yanagisawa
2016/09/06 06:03:51
nit: the recommended number of jobs?
tikuta
2016/09/06 06:09:52
Done.
|
+ |
+ This function caches the _goma_jobs. |
+ """ |
+ if self._goma_jobs: |
+ return self._goma_jobs |
+ |
+ # Use 80 for linux not to load goma backend. |
+ if self.m.platform.is_linux: |
+ return 80 |
+ |
+ step_result = self.m.python.inline( |
+ 'get the number of cpus', |
Yoshisato Yanagisawa
2016/09/06 06:03:51
nit: get the number of recommended jobs based on #
tikuta
2016/09/06 06:09:52
Done.
|
+ """ |
+ import multiprocessing |
+ |
+ try: |
+ jobs = min(200, multiprocessing.cpu_count() * 10) |
+ except NotImplementedError: |
+ jobs = 50 |
+ |
+ print jobs |
+ """, |
+ stdout=self.m.raw_io.output(), |
+ step_test_data=( |
+ lambda: self.m.raw_io.test_api.stream_output('50\n')) |
+ ) |
+ self._goma_jobs = int(step_result.stdout) |
+ |
+ return self._goma_jobs |
+ |
def ensure_goma(self, canary=False): |
with self.m.step.nest('ensure_goma'): |
with self.m.step.context({'infra_step': True}): |