Lines Matching refs:event
21 import bb.event
31 def _store_event_data_string(self, event): argument
32 if isinstance(event, logging.LogRecord):
34 self.event_calls.append(formatter.format(event))
36 self.event_calls.append(bb.event.getName(event))
45 def send(self, event): argument
46 super(EventQueueStub, self)._store_event_data_string(event)
56 event = pickle.loads(pickled_event)
57 super(PickleEventQueueStub, self)._store_event_data_string(event)
63 self.event = None
76 importlib.reload(bb.event)
88 bb.event.set_class_handlers(test_handlers)
90 bb.event.get_class_handlers())
95 bb.event.set_handlers(test_handlers)
97 bb.event.get_handlers())
103 bb.event.clean_class_handlers())
107 result = bb.event.register("handler", self._test_process.handler)
108 self.assertEqual(result, bb.event.Registered)
109 handlers_dict = bb.event.get_class_handlers()
114 bb.event.register("handler", self._test_process.handler)
115 handlers_dict = bb.event.get_class_handlers()
117 result = bb.event.register("handler", self._test_process.handler)
118 self.assertEqual(result, bb.event.AlreadyRegistered)
122 result = bb.event.register("string_handler", " return True")
123 self.assertEqual(result, bb.event.Registered)
124 handlers_dict = bb.event.get_class_handlers()
131 result = bb.event.register("event_handler",
134 self.assertEqual(result, bb.event.Registered)
135 handlers_dict = bb.event.get_class_handlers()
141 bb.event.set_class_handlers(test_handlers)
143 bb.event.remove("handler1", None)
144 test_handlers = bb.event.get_class_handlers()
147 bb.event.remove("handler1", None)
152 result = bb.event.register("event_handler",
155 self.assertEqual(result, bb.event.Registered)
156 event = bb.event.OperationProgress(current=10, total=100)
157 bb.event.execute_handler("event_handler",
159 event,
161 self._test_process.event_handler.assert_called_once_with(event, None)
166 result = bb.event.register("event_handler1",
169 self.assertEqual(result, bb.event.Registered)
170 result = bb.event.register("event_handler2",
173 self.assertEqual(result, bb.event.Registered)
174 event1 = bb.event.OperationStarted()
175 event2 = bb.event.OperationCompleted(total=123)
176 bb.event.fire_class_handlers(event1, None)
177 bb.event.fire_class_handlers(event2, None)
178 bb.event.fire_class_handlers(event2, None)
191 result = bb.event.register("event_handler1",
194 self.assertEqual(result, bb.event.Registered)
195 result = bb.event.register("event_handler2",
198 self.assertEqual(result, bb.event.Registered)
199 bb.event.set_eventfilter(
200 lambda name, handler, event, d :
202 bb.event.getName(event) == "OperationStarted")
203 event1 = bb.event.OperationStarted()
204 event2 = bb.event.OperationCompleted(total=123)
205 bb.event.fire_class_handlers(event1, None)
206 bb.event.fire_class_handlers(event2, None)
207 bb.event.fire_class_handlers(event2, None)
217 event1 = bb.event.OperationStarted()
218 event2 = bb.event.OperationCompleted(total=123)
221 result = bb.event.register("event_handler1",
224 self.assertEqual(result, bb.event.Registered)
225 bb.event.fire_class_handlers(event1, None)
226 bb.event.fire_class_handlers(event2, None)
232 bb.event.remove("event_handler1",
235 result = bb.event.register("event_handler1",
238 self.assertEqual(result, bb.event.Registered)
239 bb.event.fire_class_handlers(event1, None)
240 bb.event.fire_class_handlers(event2, None)
246 bb.event.remove("event_handler1",
249 result = bb.event.register("event_handler1",
252 self.assertEqual(result, bb.event.Registered)
253 bb.event.fire_class_handlers(event1, None)
254 bb.event.fire_class_handlers(event2, None)
261 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
266 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
268 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
273 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
275 result = bb.event.unregister_UIHhandler(1)
280 self._test_ui1.event = Mock(spec_set=EventQueueStub)
281 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
283 self._test_ui2.event = Mock(spec_set=PickleEventQueueStub)
284 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
286 event1 = bb.event.OperationStarted()
287 bb.event.fire_ui_handlers(event1, None)
289 self.assertEqual(self._test_ui1.event.send.call_args_list,
292 self.assertEqual(self._test_ui2.event.sendpickle.call_args_list,
299 self._test_ui1.event = Mock(spec_set=EventQueueStub)
300 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
301 bb.event.set_UIHmask(result, logging.INFO, debug_domains, mask)
302 self._test_ui2.event = Mock(spec_set=PickleEventQueueStub)
303 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
304 bb.event.set_UIHmask(result, logging.INFO, debug_domains, mask)
306 event1 = bb.event.OperationStarted()
307 event2 = bb.event.OperationCompleted(total=1)
309 bb.event.fire_ui_handlers(event1, None)
310 bb.event.fire_ui_handlers(event2, None)
312 self.assertEqual(self._test_ui1.event.send.call_args_list,
315 self.assertEqual(self._test_ui2.event.sendpickle.call_args_list,
323 self._test_ui1.event = EventQueueStub()
324 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
325 bb.event.set_UIHmask(result, logging.ERROR, debug_domains, mask)
326 self._test_ui2.event = PickleEventQueueStub()
327 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
328 bb.event.set_UIHmask(result, logging.ERROR, debug_domains, mask)
330 event1 = bb.event.OperationStarted()
331 bb.event.fire_ui_handlers(event1, None) # All events match
333 event_log_handler = bb.event.LogHandler()
347 self.assertEqual(self._test_ui1.event.event_calls, expected)
348 self.assertEqual(self._test_ui2.event.event_calls, expected)
353 result = bb.event.register("event_handler1",
357 self._test_ui1.event = Mock(spec_set=EventQueueStub)
358 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
361 event1 = bb.event.ConfigParsed()
362 bb.event.fire(event1, None)
367 self.assertEqual(self._test_ui1.event.send.call_args_list,
372 self._test_ui1.event = Mock(spec_set=EventQueueStub)
373 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
375 event1 = bb.event.ConfigParsed()
376 bb.event.fire_from_worker(event1, None)
378 self.assertEqual(self._test_ui1.event.send.call_args_list,
383 bb.event.worker_fire = Mock()
384 event = bb.event.Event()
385 bb.event.fire(event, None)
386 expected = [call(event, None)]
387 self.assertEqual(bb.event.worker_fire.call_args_list, expected)
391 event1 = bb.event.OperationStarted()
392 event2 = bb.event.OperationCompleted(total=123)
393 bb.event.fire(event1, None)
394 bb.event.fire(event2, None)
395 event_log_handler = bb.event.LogHandler()
401 bb.event.print_ui_queue()
410 def ui1_event_send(event): argument
411 if type(event) is bb.event.ConfigParsed:
413 if type(event) is bb.event.OperationStarted:
417 def ui2_event_send(event): argument
418 if type(event) is bb.event.ConfigParsed:
420 if type(event) is bb.event.OperationStarted:
425 self._test_ui1.event = EventQueueStub()
426 self._test_ui1.event.send = ui1_event_send
427 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
429 self._test_ui2.event = EventQueueStub()
430 self._test_ui2.event.send = ui2_event_send
431 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
448 bb.event.fire(bb.event.ConfigParsed(), None)
453 bb.event.fire(bb.event.OperationStarted(), None)
471 bb.event.worker_pid = EventClassesTest._worker_pid
477 event = bb.event.Event()
478 self.assertEqual(event.pid, EventClassesTest._worker_pid)
483 event = bb.event.HeartbeatEvent(time)
484 self.assertEqual(event.time, time)
485 self.assertEqual(event.pid, EventClassesTest._worker_pid)
490 event = bb.event.OperationStarted(msg)
491 self.assertEqual(event.msg, msg)
492 self.assertEqual(event.pid, EventClassesTest._worker_pid)
498 event = bb.event.OperationCompleted(total, msg)
499 self.assertEqual(event.msg, msg)
500 self.assertEqual(event.total, total)
501 self.assertEqual(event.pid, EventClassesTest._worker_pid)
508 event = bb.event.OperationProgress(current, total, msg)
509 self.assertEqual(event.msg, msg + ": %s/%s" % (current, total))
510 self.assertEqual(event.pid, EventClassesTest._worker_pid)
514 event = bb.event.ConfigParsed()
515 self.assertEqual(event.pid, EventClassesTest._worker_pid)
520 event = bb.event.MultiConfigParsed(mcdata)
521 self.assertEqual(event.mcdata, mcdata)
522 self.assertEqual(event.pid, EventClassesTest._worker_pid)
527 event = bb.event.RecipeEvent(callback)
528 self.assertEqual(event.fn(1), callback(1))
529 self.assertEqual(event.pid, EventClassesTest._worker_pid)
534 event = bb.event.RecipePreFinalise(callback)
535 self.assertEqual(event.fn(1), callback(1))
536 self.assertEqual(event.pid, EventClassesTest._worker_pid)
542 event = bb.event.RecipeTaskPreProcess(callback, tasklist)
543 self.assertEqual(event.fn(1), callback(1))
544 self.assertEqual(event.tasklist, tasklist)
545 self.assertEqual(event.pid, EventClassesTest._worker_pid)
550 event = bb.event.RecipeParsed(callback)
551 self.assertEqual(event.fn(1), callback(1))
552 self.assertEqual(event.pid, EventClassesTest._worker_pid)
559 event = bb.event.BuildBase(name, pkgs, failures)
560 self.assertEqual(event.name, name)
561 self.assertEqual(event.pkgs, pkgs)
562 self.assertEqual(event.getFailures(), failures)
563 name = event.name = "bar"
564 pkgs = event.pkgs = ["foo"]
565 self.assertEqual(event.name, name)
566 self.assertEqual(event.pkgs, pkgs)
567 self.assertEqual(event.getFailures(), failures)
568 self.assertEqual(event.pid, EventClassesTest._worker_pid)
572 event = bb.event.BuildInit()
573 self.assertEqual(event.name, None)
574 self.assertEqual(event.pkgs, [])
575 self.assertEqual(event.getFailures(), 0)
576 name = event.name = "bar"
577 pkgs = event.pkgs = ["foo"]
578 self.assertEqual(event.name, name)
579 self.assertEqual(event.pkgs, pkgs)
580 self.assertEqual(event.getFailures(), 0)
581 self.assertEqual(event.pid, EventClassesTest._worker_pid)
588 event = bb.event.BuildStarted(name, pkgs, failures)
589 self.assertEqual(event.name, name)
590 self.assertEqual(event.pkgs, pkgs)
591 self.assertEqual(event.getFailures(), failures)
592 self.assertEqual(event.msg, "Building Started")
593 name = event.name = "bar"
594 pkgs = event.pkgs = ["foo"]
595 msg = event.msg = "foobar"
596 self.assertEqual(event.name, name)
597 self.assertEqual(event.pkgs, pkgs)
598 self.assertEqual(event.getFailures(), failures)
599 self.assertEqual(event.msg, msg)
600 self.assertEqual(event.pid, EventClassesTest._worker_pid)
609 event = bb.event.BuildCompleted(total, name, pkgs, failures,
611 self.assertEqual(event.name, name)
612 self.assertEqual(event.pkgs, pkgs)
613 self.assertEqual(event.getFailures(), failures)
614 self.assertEqual(event.msg, "Building Failed")
615 event2 = bb.event.BuildCompleted(total, name, pkgs)
628 event = bb.event.DiskFull(dev, type, freespace, mountpoint)
629 self.assertEqual(event.pid, EventClassesTest._worker_pid)
636 du = bb.event.DiskUsageSample(available_bytes, free_bytes,
638 event = bb.event.MonitorDiskEvent(du)
639 self.assertEqual(event.disk_usage.available_bytes, available_bytes)
640 self.assertEqual(event.disk_usage.free_bytes, free_bytes)
641 self.assertEqual(event.disk_usage.total_bytes, total_bytes)
642 self.assertEqual(event.pid, EventClassesTest._worker_pid)
647 event1 = bb.event.NoProvider(item)
655 event2 = bb.event.NoProvider(item, runtime, dependees, reasons,
665 event3 = bb.event.NoProvider(item, runtime, dependees, reasons,
677 event1 = bb.event.MultipleProviders(item, candidates)
687 event2 = bb.event.MultipleProviders(item, candidates, runtime)
699 event = bb.event.ParseStarted(total)
700 self.assertEqual(event.msg, "Recipe parsing Started")
701 self.assertEqual(event.total, total)
702 self.assertEqual(event.pid, EventClassesTest._worker_pid)
713 event = bb.event.ParseCompleted(cached, parsed, skipped, masked,
715 self.assertEqual(event.msg, "Recipe parsing Completed")
718 actual = [event.cached, event.parsed, event.skipped, event.virtuals,
719 event.masked, event.errors, event.sofar, event.total]
721 self.assertEqual(event.pid, EventClassesTest._worker_pid)
727 event = bb.event.ParseProgress(current, total)
728 self.assertEqual(event.msg,
730 self.assertEqual(event.pid, EventClassesTest._worker_pid)
735 event = bb.event.CacheLoadStarted(total)
736 self.assertEqual(event.msg, "Loading cache Started")
737 self.assertEqual(event.total, total)
738 self.assertEqual(event.pid, EventClassesTest._worker_pid)
744 event = bb.event.CacheLoadProgress(current, total)
745 self.assertEqual(event.msg,
747 self.assertEqual(event.pid, EventClassesTest._worker_pid)
753 event = bb.event.CacheLoadCompleted(total, num_entries)
754 self.assertEqual(event.msg, "Loading cache Completed")
756 actual = [event.total, event.num_entries]
758 self.assertEqual(event.pid, EventClassesTest._worker_pid)
762 event = bb.event.TreeDataPreparationStarted()
763 self.assertEqual(event.msg, "Preparing tree data Started")
764 self.assertEqual(event.pid, EventClassesTest._worker_pid)
770 event = bb.event.TreeDataPreparationProgress(current, total)
771 self.assertEqual(event.msg,
773 self.assertEqual(event.pid, EventClassesTest._worker_pid)
778 event = bb.event.TreeDataPreparationCompleted(total)
779 self.assertEqual(event.msg, "Preparing tree data Completed")
780 self.assertEqual(event.total, total)
781 self.assertEqual(event.pid, EventClassesTest._worker_pid)
786 event = bb.event.DepTreeGenerated(depgraph)
787 self.assertEqual(event.pid, EventClassesTest._worker_pid)
792 event = bb.event.TargetsTreeGenerated(model)
793 self.assertEqual(event.pid, EventClassesTest._worker_pid)
798 event = bb.event.ReachableStamps(stamps)
799 self.assertEqual(event.stamps, stamps)
800 self.assertEqual(event.pid, EventClassesTest._worker_pid)
806 event = bb.event.FilesMatchingFound(pattern, matches)
807 self.assertEqual(event.pid, EventClassesTest._worker_pid)
813 event = bb.event.ConfigFilesFound(variable, values)
814 self.assertEqual(event.pid, EventClassesTest._worker_pid)
819 event = bb.event.ConfigFilePathFound(path)
820 self.assertEqual(event.pid, EventClassesTest._worker_pid)
825 event = bb.event.MsgBase(msg)
826 self.assertEqual(event.pid, EventClassesTest._worker_pid)
827 event = bb.event.MsgDebug(msg)
828 self.assertEqual(event.pid, EventClassesTest._worker_pid)
829 event = bb.event.MsgNote(msg)
830 self.assertEqual(event.pid, EventClassesTest._worker_pid)
831 event = bb.event.MsgWarn(msg)
832 self.assertEqual(event.pid, EventClassesTest._worker_pid)
833 event = bb.event.MsgError(msg)
834 self.assertEqual(event.pid, EventClassesTest._worker_pid)
835 event = bb.event.MsgFatal(msg)
836 self.assertEqual(event.pid, EventClassesTest._worker_pid)
837 event = bb.event.MsgPlain(msg)
838 self.assertEqual(event.pid, EventClassesTest._worker_pid)
846 event = bb.event.LogExecTTY(msg, prog, sleep_delay, retries)
847 self.assertEqual(event.msg, msg)
848 self.assertEqual(event.prog, prog)
849 self.assertEqual(event.sleep_delay, sleep_delay)
850 self.assertEqual(event.retries, retries)
851 self.assertEqual(event.pid, EventClassesTest._worker_pid)
857 def _worker_handler(self, event, d): argument
858 self._returned_event = event
865 handler = bb.event.LogHandler(logging.INFO)
867 bb.event.worker_fire = self._worker_handler
872 event = self._returned_event
874 pe = pickle.dumps(event)
878 self.assertEqual(event.taskpid, EventClassesTest._worker_pid)
884 event = bb.event.MetadataEvent(eventtype, eventdata)
885 self.assertEqual(event.type, eventtype)
886 self.assertEqual(event.pid, EventClassesTest._worker_pid)
892 event = bb.event.ProcessStarted(processname, total)
893 self.assertEqual(event.processname, processname)
894 self.assertEqual(event.total, total)
895 self.assertEqual(event.pid, EventClassesTest._worker_pid)
901 event = bb.event.ProcessProgress(processname, progress)
902 self.assertEqual(event.processname, processname)
903 self.assertEqual(event.progress, progress)
904 self.assertEqual(event.pid, EventClassesTest._worker_pid)
910 event = bb.event.ProcessFinished(processname)
911 self.assertEqual(event.processname, processname)
912 self.assertEqual(event.pid, EventClassesTest._worker_pid)
916 event1 = bb.event.SanityCheck()
920 event2 = bb.event.SanityCheck(generateevents)
926 event = bb.event.SanityCheckPassed()
927 self.assertEqual(event.pid, EventClassesTest._worker_pid)
932 event1 = bb.event.SanityCheckFailed(msg)
935 event2 = bb.event.SanityCheckFailed(msg, network_error)
940 event1 = bb.event.NetworkTest()
943 event2 = bb.event.NetworkTest(generateevents)
945 event3 = bb.event.NetworkTestPassed()
947 event4 = bb.event.NetworkTestFailed()
953 event = bb.event.FindSigInfoResult(result)
954 self.assertEqual(event.result, result)
955 self.assertEqual(event.pid, EventClassesTest._worker_pid)