diff options
Diffstat (limited to 'distbuild/initiator_connection.py')
| -rw-r--r-- | distbuild/initiator_connection.py | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/distbuild/initiator_connection.py b/distbuild/initiator_connection.py index f0586d9d..72b3abfd 100644 --- a/distbuild/initiator_connection.py +++ b/distbuild/initiator_connection.py @@ -82,6 +82,12 @@ class InitiatorConnection(distbuild.StateMachine): 'idle', self._send_build_failed_message), ('idle', distbuild.BuildController, distbuild.BuildProgress, 'idle', self._send_build_progress_message), + ('idle', distbuild.BuildController, distbuild.GraphingStarted, + 'idle', self._send_graphing_started_message), + ('idle', distbuild.BuildController, distbuild.GraphingFinished, + 'idle', self._send_graphing_finished_message), + ('idle', distbuild.BuildController, distbuild.CacheState, + 'idle', self._send_cache_state_message), ('idle', distbuild.BuildController, distbuild.BuildCancel, 'idle', self._send_build_cancelled_message), ('idle', distbuild.BuildController, distbuild.BuildStepStarted, @@ -286,6 +292,34 @@ class InitiatorConnection(distbuild.StateMachine): self.jm.send(msg) self._log_send(msg) + def _send_graphing_started_message(self, event_source, event): + logging.debug('InitiatorConnection: graphing_started: id=%s', event.id) + + if event.id in self.our_ids: + msg = distbuild.message('graphing-started', id=event.id) + self.jm.send(msg) + self._log_send(msg) + + def _send_graphing_finished_message(self, event_source, event): + logging.debug('InitiatorConnection: graphing_finished: id=%s', + event.id) + + if event.id in self.our_ids: + msg = distbuild.message('graphing-finished', id=event.id) + self.jm.send(msg) + self._log_send(msg) + + def _send_cache_state_message(self, event_source, event): + logging.debug('InitiatorConnection: cache_state: id=%s', event.id) + + if event.id in self.our_ids: + msg = distbuild.message('cache-state', + id=event.id, + unbuilt=event.unbuilt, + total=event.total) + self.jm.send(msg) + self._log_send(msg) + def _send_build_step_started_message(self, event_source, event): logging.debug('InitiatorConnection: build_step_started: ' 'id=%s step_name=%s worker_name=%s' % |