Lines Matching refs:manager

82         self.manager = drone_manager.DroneManager()
83         self.god.stub_with(self.manager, '_results_dir', self._RESULTS_DIR)
90         self.god.stub_with(self.manager, 'refresh_drone_configs', do_nothing)
94         self.manager._drones[self.mock_drone.name] = self.mock_drone
96         self.manager._results_drone = self.results_drone
109             self.manager._enqueue_drone(
114         return self.manager._choose_drone_for_execution(
144         self.manager._enqueue_drone(MockDrone(1, max_processes=10,
147         self.manager._enqueue_drone(MockDrone(2, max_processes=2,
151                           self.manager.max_runnable_processes(self._USERNAME,
153         drone = self.manager._choose_drone_for_execution(
160         self.manager._enqueue_drone(MockDrone(1, max_processes=10,
163         self.manager._enqueue_drone(MockDrone(2, active_processes=3,
168                           self.manager.max_runnable_processes(self._USERNAME,
170         drone = self.manager._choose_drone_for_execution(
176         self.manager._enqueue_drone(MockDrone(
178         self.manager._enqueue_drone(MockDrone(
180         self.manager._enqueue_drone(MockDrone(
187                           self.manager.max_runnable_processes(self._USERNAME,
189         drone = self.manager._choose_drone_for_execution(
198                 5, self.manager.max_runnable_processes(self._USERNAME,
200         drone = self.manager._choose_drone_for_execution(
211                 0, self.manager.max_runnable_processes(self._USERNAME,
213         drone = self.manager._choose_drone_for_execution(
223                 0, self.manager.max_runnable_processes(self._USERNAME,
225         drone = self.manager._choose_drone_for_execution(
246         self.manager.initialize(base_results_dir=self._RESULTS_DIR,
256         self.manager._enqueue_drone(self.mock_drone)
261         pidfile_id = self.manager.execute_command(
279         self.manager._enqueue_drone(self.mock_drone)
282         attached_path = self.manager.attach_file_to_execution(
284         self.manager.execute_command(command=['test'],
297         self.manager.copy_results_on_drone(self.mock_drone_process,
308         self.manager._copy_to_results_repository(self.mock_drone_process,
322         self.manager.write_lines_to_file(file_path, lines)
328         self.manager.write_lines_to_file(
336         self.god.stub_with(self.manager, '_get_max_pidfile_refreshes',
338         pidfile_id = self.manager.get_pidfile_id_from('tag', 'name')
339         self.manager.register_pidfile(pidfile_id)
340         self.manager._drop_old_pidfiles()
341         self.manager._drop_old_pidfiles()
342         self.assertFalse(self.manager._registered_pidfile_info)
368         pidfile_id = self.manager.get_pidfile_id_from(tag, name)
369         self.manager.register_pidfile(pidfile_id)
370         return self.manager._registered_pidfile_info
377         self.manager = drone_manager.DroneManager()
378         self.god.stub_with(self.manager, '_results_dir', self._RESULTS_DIR)
385         self.god.stub_with(self.manager, 'refresh_drone_configs', do_nothing)
388         self.manager._results_drone = self.results_drone
402         self.manager._drones[mock_drone.hostname] = mock_drone
415         for drone in self.manager.get_drones():
422         self.manager.trigger_refresh()
423         self.assertTrue(self.manager._refresh_task_queue.get_results() ==
432         self.manager._drones[mock_drone.hostname] = mock_drone
452         self.god.stub_with(drone_manager, '_the_instance', self.manager)
455         self.manager.register_pidfile(monitor.pidfile_id)
458         self.manager._refresh_task_queue.results_queue.put(
461         self.manager.sync_refresh()
462         pidfiles = self.manager._pidfiles