Lines Matching full:self
26 def __init__(self): argument
27 self.event_calls = []
30 def _store_event_data_string(self, event): argument
33 self.event_calls.append(formatter.format(event))
35 self.event_calls.append(bb.event.getName(event))
41 def __init__(self): argument
42 super(EventQueueStub, self).__init__()
44 def send(self, event): argument
45 super(EventQueueStub, self)._store_event_data_string(event)
51 def __init__(self): argument
52 super(PickleEventQueueStub, self).__init__()
54 def sendpickle(self, pickled_event): argument
56 super(PickleEventQueueStub, self)._store_event_data_string(event)
61 def __init__(self): argument
62 self.event = None
69 def setUp(self): argument
70 self._test_process = Mock()
73 self._test_ui1 = Mock(wraps=ui_client1)
74 self._test_ui2 = Mock(wraps=ui_client2)
77 def _create_test_handlers(self): argument
80 test_handlers["handler1"] = self._test_process.handler1
81 test_handlers["handler2"] = self._test_process.handler2
84 def test_class_handlers(self): argument
86 test_handlers = self._create_test_handlers()
88 self.assertEqual(test_handlers,
91 def test_handlers(self): argument
93 test_handlers = self._create_test_handlers()
95 self.assertEqual(test_handlers,
98 def test_clean_class_handlers(self): argument
101 self.assertEqual(cleanDict,
104 def test_register(self): argument
106 result = bb.event.register("handler", self._test_process.handler)
107 self.assertEqual(result, bb.event.Registered)
109 self.assertIn("handler", handlers_dict)
111 def test_already_registered(self): argument
113 bb.event.register("handler", self._test_process.handler)
115 self.assertIn("handler", handlers_dict)
116 result = bb.event.register("handler", self._test_process.handler)
117 self.assertEqual(result, bb.event.AlreadyRegistered)
119 def test_register_from_string(self): argument
122 self.assertEqual(result, bb.event.Registered)
124 self.assertIn("string_handler", handlers_dict)
126 def test_register_with_mask(self): argument
131 self._test_process.event_handler,
133 self.assertEqual(result, bb.event.Registered)
135 self.assertIn("event_handler", handlers_dict)
137 def test_remove(self): argument
139 test_handlers = self._create_test_handlers()
144 self.assertEqual(len(test_handlers), count - 1)
145 with self.assertRaises(KeyError):
148 def test_execute_handler(self): argument
152 self._test_process.event_handler,
154 self.assertEqual(result, bb.event.Registered)
157 self._test_process.event_handler,
160 self._test_process.event_handler.assert_called_once_with(event)
162 def test_fire_class_handlers(self): argument
166 self._test_process.event_handler1,
168 self.assertEqual(result, bb.event.Registered)
170 self._test_process.event_handler2,
172 self.assertEqual(result, bb.event.Registered)
182 self.assertEqual(self._test_process.event_handler1.call_args_list,
184 self.assertEqual(self._test_process.event_handler2.call_args_list,
187 def test_class_handler_filters(self): argument
191 self._test_process.event_handler1,
193 self.assertEqual(result, bb.event.Registered)
195 self._test_process.event_handler2,
197 self.assertEqual(result, bb.event.Registered)
209 self.assertEqual(self._test_process.event_handler1.call_args_list,
211 self.assertEqual(self._test_process.event_handler2.call_args_list,
214 def test_change_handler_event_mapping(self): argument
221 self._test_process.event_handler1,
223 self.assertEqual(result, bb.event.Registered)
227 self.assertEqual(self._test_process.event_handler1.call_args_list,
232 self._test_process.event_handler1)
235 self._test_process.event_handler1,
237 self.assertEqual(result, bb.event.Registered)
241 self.assertEqual(self._test_process.event_handler1.call_args_list,
246 self._test_process.event_handler1)
249 self._test_process.event_handler1,
251 self.assertEqual(result, bb.event.Registered)
255 self.assertEqual(self._test_process.event_handler1.call_args_list,
258 def test_register_UIHhandler(self): argument
260 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
261 self.assertEqual(result, 1)
263 def test_UIHhandler_already_registered(self): argument
265 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
266 self.assertEqual(result, 1)
267 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
268 self.assertEqual(result, 2)
270 def test_unregister_UIHhandler(self): argument
272 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
273 self.assertEqual(result, 1)
275 self.assertIs(result, None)
277 def test_fire_ui_handlers(self): argument
279 self._test_ui1.event = Mock(spec_set=EventQueueStub)
280 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
281 self.assertEqual(result, 1)
282 self._test_ui2.event = Mock(spec_set=PickleEventQueueStub)
283 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
284 self.assertEqual(result, 2)
288 self.assertEqual(self._test_ui1.event.send.call_args_list,
291 self.assertEqual(self._test_ui2.event.sendpickle.call_args_list,
294 def test_ui_handler_mask_filter(self): argument
298 self._test_ui1.event = Mock(spec_set=EventQueueStub)
299 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
301 self._test_ui2.event = Mock(spec_set=PickleEventQueueStub)
302 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
311 self.assertEqual(self._test_ui1.event.send.call_args_list,
314 self.assertEqual(self._test_ui2.event.sendpickle.call_args_list,
317 def test_ui_handler_log_filter(self): argument
322 self._test_ui1.event = EventQueueStub()
323 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
325 self._test_ui2.event = PickleEventQueueStub()
326 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
346 self.assertEqual(self._test_ui1.event.event_calls, expected)
347 self.assertEqual(self._test_ui2.event.event_calls, expected)
349 def test_fire(self): argument
353 self._test_process.event_handler1,
356 self._test_ui1.event = Mock(spec_set=EventQueueStub)
357 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
358 self.assertEqual(result, 1)
363 self.assertEqual(self._test_process.event_handler1.call_args_list,
365 self.assertEqual(self._test_ui1.event.send.call_args_list,
368 def test_fire_from_worker(self): argument
370 self._test_ui1.event = Mock(spec_set=EventQueueStub)
371 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
372 self.assertEqual(result, 1)
376 self.assertEqual(self._test_ui1.event.send.call_args_list,
379 def test_worker_fire(self): argument
385 self.assertEqual(bb.event.worker_fire.call_args_list, expected)
387 def test_print_ui_queue(self): argument
398 with self.assertLogs("BitBake", level="INFO") as cm:
401 self.assertEqual(cm.output,
405 def _set_threadlock_test_mockups(self): argument
410 self._threadlock_test_calls.append("w1_ui1")
412 self._threadlock_test_calls.append("w2_ui1")
417 self._threadlock_test_calls.append("w1_ui2")
419 self._threadlock_test_calls.append("w2_ui2")
422 self._threadlock_test_calls = []
423 self._test_ui1.event = EventQueueStub()
424 self._test_ui1.event.send = ui1_event_send
425 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
426 self.assertEqual(result, 1)
427 self._test_ui2.event = EventQueueStub()
428 self._test_ui2.event.send = ui2_event_send
429 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
430 self.assertEqual(result, 2)
432 def _set_and_run_threadlock_test_workers(self): argument
435 worker1 = threading.Thread(target=self._thread_lock_test_worker1)
436 worker2 = threading.Thread(target=self._thread_lock_test_worker2)
443 def _thread_lock_test_worker1(self): argument
448 def _thread_lock_test_worker2(self): argument
453 def test_enable_threadlock(self): argument
455 self._set_threadlock_test_mockups()
457 self._set_and_run_threadlock_test_workers()
461 self.assertEqual(self._threadlock_test_calls,
465 def test_disable_threadlock(self): argument
467 self._set_threadlock_test_mockups()
469 self._set_and_run_threadlock_test_workers()
474 self.assertEqual(self._threadlock_test_calls,
483 def setUp(self): argument
486 def test_Event(self): argument
489 self.assertEqual(event.pid, EventClassesTest._worker_pid)
491 def test_HeartbeatEvent(self): argument
495 self.assertEqual(event.time, time)
496 self.assertEqual(event.pid, EventClassesTest._worker_pid)
498 def test_OperationStarted(self): argument
502 self.assertEqual(event.msg, msg)
503 self.assertEqual(event.pid, EventClassesTest._worker_pid)
505 def test_OperationCompleted(self): argument
510 self.assertEqual(event.msg, msg)
511 self.assertEqual(event.total, total)
512 self.assertEqual(event.pid, EventClassesTest._worker_pid)
514 def test_OperationProgress(self): argument
520 self.assertEqual(event.msg, msg + ": %s/%s" % (current, total))
521 self.assertEqual(event.pid, EventClassesTest._worker_pid)
523 def test_ConfigParsed(self): argument
526 self.assertEqual(event.pid, EventClassesTest._worker_pid)
528 def test_MultiConfigParsed(self): argument
532 self.assertEqual(event.mcdata, mcdata)
533 self.assertEqual(event.pid, EventClassesTest._worker_pid)
535 def test_RecipeEvent(self): argument
539 self.assertEqual(event.fn(1), callback(1))
540 self.assertEqual(event.pid, EventClassesTest._worker_pid)
542 def test_RecipePreFinalise(self): argument
546 self.assertEqual(event.fn(1), callback(1))
547 self.assertEqual(event.pid, EventClassesTest._worker_pid)
549 def test_RecipeTaskPreProcess(self): argument
554 self.assertEqual(event.fn(1), callback(1))
555 self.assertEqual(event.tasklist, tasklist)
556 self.assertEqual(event.pid, EventClassesTest._worker_pid)
558 def test_RecipeParsed(self): argument
562 self.assertEqual(event.fn(1), callback(1))
563 self.assertEqual(event.pid, EventClassesTest._worker_pid)
565 def test_BuildBase(self): argument
571 self.assertEqual(event.name, name)
572 self.assertEqual(event.pkgs, pkgs)
573 self.assertEqual(event.getFailures(), failures)
576 self.assertEqual(event.name, name)
577 self.assertEqual(event.pkgs, pkgs)
578 self.assertEqual(event.getFailures(), failures)
579 self.assertEqual(event.pid, EventClassesTest._worker_pid)
581 def test_BuildInit(self): argument
584 self.assertEqual(event.name, None)
585 self.assertEqual(event.pkgs, [])
586 self.assertEqual(event.getFailures(), 0)
589 self.assertEqual(event.name, name)
590 self.assertEqual(event.pkgs, pkgs)
591 self.assertEqual(event.getFailures(), 0)
592 self.assertEqual(event.pid, EventClassesTest._worker_pid)
594 def test_BuildStarted(self): argument
600 self.assertEqual(event.name, name)
601 self.assertEqual(event.pkgs, pkgs)
602 self.assertEqual(event.getFailures(), failures)
603 self.assertEqual(event.msg, "Building Started")
607 self.assertEqual(event.name, name)
608 self.assertEqual(event.pkgs, pkgs)
609 self.assertEqual(event.getFailures(), failures)
610 self.assertEqual(event.msg, msg)
611 self.assertEqual(event.pid, EventClassesTest._worker_pid)
613 def test_BuildCompleted(self): argument
622 self.assertEqual(event.name, name)
623 self.assertEqual(event.pkgs, pkgs)
624 self.assertEqual(event.getFailures(), failures)
625 self.assertEqual(event.msg, "Building Failed")
627 self.assertEqual(event2.name, name)
628 self.assertEqual(event2.pkgs, pkgs)
629 self.assertEqual(event2.getFailures(), 0)
630 self.assertEqual(event2.msg, "Building Succeeded")
631 self.assertEqual(event2.pid, EventClassesTest._worker_pid)
633 def test_DiskFull(self): argument
640 self.assertEqual(event.pid, EventClassesTest._worker_pid)
642 def test_MonitorDiskEvent(self): argument
650 self.assertEqual(event.disk_usage.available_bytes, available_bytes)
651 self.assertEqual(event.disk_usage.free_bytes, free_bytes)
652 self.assertEqual(event.disk_usage.total_bytes, total_bytes)
653 self.assertEqual(event.pid, EventClassesTest._worker_pid)
655 def test_NoProvider(self): argument
659 self.assertEqual(event1.getItem(), item)
660 self.assertEqual(event1.isRuntime(), False)
661 self.assertEqual(str(event1), "Nothing PROVIDES 'foobar'")
668 self.assertEqual(event2.isRuntime(), True)
673 self.assertEqual(str(event2), expected)
681 self.assertEqual(str(event3), expected)
682 self.assertEqual(event3.pid, EventClassesTest._worker_pid)
684 def test_MultipleProviders(self): argument
689 self.assertEqual(event1.isRuntime(), False)
690 self.assertEqual(event1.getItem(), item)
691 self.assertEqual(event1.getCandidates(), candidates)
696 self.assertEqual(str(event1), expected)
699 self.assertEqual(event2.isRuntime(), runtime)
704 self.assertEqual(str(event2), expected)
705 self.assertEqual(event2.pid, EventClassesTest._worker_pid)
707 def test_ParseStarted(self): argument
711 self.assertEqual(event.msg, "Recipe parsing Started")
712 self.assertEqual(event.total, total)
713 self.assertEqual(event.pid, EventClassesTest._worker_pid)
715 def test_ParseCompleted(self): argument
726 self.assertEqual(event.msg, "Recipe parsing Completed")
731 self.assertEqual(str(actual), str(expected))
732 self.assertEqual(event.pid, EventClassesTest._worker_pid)
734 def test_ParseProgress(self): argument
739 self.assertEqual(event.msg,
741 self.assertEqual(event.pid, EventClassesTest._worker_pid)
743 def test_CacheLoadStarted(self): argument
747 self.assertEqual(event.msg, "Loading cache Started")
748 self.assertEqual(event.total, total)
749 self.assertEqual(event.pid, EventClassesTest._worker_pid)
751 def test_CacheLoadProgress(self): argument
756 self.assertEqual(event.msg,
758 self.assertEqual(event.pid, EventClassesTest._worker_pid)
760 def test_CacheLoadCompleted(self): argument
765 self.assertEqual(event.msg, "Loading cache Completed")
768 self.assertEqual(str(actual), str(expected))
769 self.assertEqual(event.pid, EventClassesTest._worker_pid)
771 def test_TreeDataPreparationStarted(self): argument
774 self.assertEqual(event.msg, "Preparing tree data Started")
775 self.assertEqual(event.pid, EventClassesTest._worker_pid)
777 def test_TreeDataPreparationProgress(self): argument
782 self.assertEqual(event.msg,
784 self.assertEqual(event.pid, EventClassesTest._worker_pid)
786 def test_TreeDataPreparationCompleted(self): argument
790 self.assertEqual(event.msg, "Preparing tree data Completed")
791 self.assertEqual(event.total, total)
792 self.assertEqual(event.pid, EventClassesTest._worker_pid)
794 def test_DepTreeGenerated(self): argument
798 self.assertEqual(event.pid, EventClassesTest._worker_pid)
800 def test_TargetsTreeGenerated(self): argument
804 self.assertEqual(event.pid, EventClassesTest._worker_pid)
806 def test_ReachableStamps(self): argument
810 self.assertEqual(event.stamps, stamps)
811 self.assertEqual(event.pid, EventClassesTest._worker_pid)
813 def test_FilesMatchingFound(self): argument
818 self.assertEqual(event.pid, EventClassesTest._worker_pid)
820 def test_ConfigFilesFound(self): argument
825 self.assertEqual(event.pid, EventClassesTest._worker_pid)
827 def test_ConfigFilePathFound(self): argument
831 self.assertEqual(event.pid, EventClassesTest._worker_pid)
833 def test_message_classes(self): argument
837 self.assertEqual(event.pid, EventClassesTest._worker_pid)
839 self.assertEqual(event.pid, EventClassesTest._worker_pid)
841 self.assertEqual(event.pid, EventClassesTest._worker_pid)
843 self.assertEqual(event.pid, EventClassesTest._worker_pid)
845 self.assertEqual(event.pid, EventClassesTest._worker_pid)
847 self.assertEqual(event.pid, EventClassesTest._worker_pid)
849 self.assertEqual(event.pid, EventClassesTest._worker_pid)
851 def test_LogExecTTY(self): argument
858 self.assertEqual(event.msg, msg)
859 self.assertEqual(event.prog, prog)
860 self.assertEqual(event.sleep_delay, sleep_delay)
861 self.assertEqual(event.retries, retries)
862 self.assertEqual(event.pid, EventClassesTest._worker_pid)
864 def _throw_zero_division_exception(self): argument
868 def _worker_handler(self, event, d): argument
869 self._returned_event = event
872 def test_LogHandler(self): argument
878 bb.event.worker_fire = self._worker_handler
880 self._throw_zero_division_exception()
883 event = self._returned_event
888 self.fail('Logged event is not serializable')
889 self.assertEqual(event.taskpid, EventClassesTest._worker_pid)
891 def test_MetadataEvent(self): argument
896 self.assertEqual(event.type, eventtype)
897 self.assertEqual(event.pid, EventClassesTest._worker_pid)
899 def test_ProcessStarted(self): argument
904 self.assertEqual(event.processname, processname)
905 self.assertEqual(event.total, total)
906 self.assertEqual(event.pid, EventClassesTest._worker_pid)
908 def test_ProcessProgress(self): argument
913 self.assertEqual(event.processname, processname)
914 self.assertEqual(event.progress, progress)
915 self.assertEqual(event.pid, EventClassesTest._worker_pid)
917 def test_ProcessFinished(self): argument
922 self.assertEqual(event.processname, processname)
923 self.assertEqual(event.pid, EventClassesTest._worker_pid)
925 def test_SanityCheck(self): argument
928 self.assertEqual(event1.generateevents, True)
929 self.assertEqual(event1.pid, EventClassesTest._worker_pid)
932 self.assertEqual(event2.generateevents, generateevents)
933 self.assertEqual(event2.pid, EventClassesTest._worker_pid)
935 def test_SanityCheckPassed(self): argument
938 self.assertEqual(event.pid, EventClassesTest._worker_pid)
940 def test_SanityCheckFailed(self): argument
944 self.assertEqual(event1.pid, EventClassesTest._worker_pid)
947 self.assertEqual(event2.pid, EventClassesTest._worker_pid)
949 def test_network_event_classes(self): argument
953 self.assertEqual(event1.pid, EventClassesTest._worker_pid)
955 self.assertEqual(event2.pid, EventClassesTest._worker_pid)
957 self.assertEqual(event3.pid, EventClassesTest._worker_pid)
959 self.assertEqual(event4.pid, EventClassesTest._worker_pid)
961 def test_FindSigInfoResult(self): argument
965 self.assertEqual(event.result, result)
966 self.assertEqual(event.pid, EventClassesTest._worker_pid)