Lines Matching refs:event
20 import bb.event
30 def _store_event_data_string(self, event): argument
31 if isinstance(event, logging.LogRecord):
33 self.event_calls.append(formatter.format(event))
35 self.event_calls.append(bb.event.getName(event))
44 def send(self, event): argument
45 super(EventQueueStub, self)._store_event_data_string(event)
55 event = pickle.loads(pickled_event)
56 super(PickleEventQueueStub, self)._store_event_data_string(event)
62 self.event = None
75 importlib.reload(bb.event)
87 bb.event.set_class_handlers(test_handlers)
89 bb.event.get_class_handlers())
94 bb.event.set_handlers(test_handlers)
96 bb.event.get_handlers())
102 bb.event.clean_class_handlers())
106 result = bb.event.register("handler", self._test_process.handler)
107 self.assertEqual(result, bb.event.Registered)
108 handlers_dict = bb.event.get_class_handlers()
113 bb.event.register("handler", self._test_process.handler)
114 handlers_dict = bb.event.get_class_handlers()
116 result = bb.event.register("handler", self._test_process.handler)
117 self.assertEqual(result, bb.event.AlreadyRegistered)
121 result = bb.event.register("string_handler", " return True")
122 self.assertEqual(result, bb.event.Registered)
123 handlers_dict = bb.event.get_class_handlers()
130 result = bb.event.register("event_handler",
133 self.assertEqual(result, bb.event.Registered)
134 handlers_dict = bb.event.get_class_handlers()
140 bb.event.set_class_handlers(test_handlers)
142 bb.event.remove("handler1", None)
143 test_handlers = bb.event.get_class_handlers()
146 bb.event.remove("handler1", None)
151 result = bb.event.register("event_handler",
154 self.assertEqual(result, bb.event.Registered)
155 event = bb.event.OperationProgress(current=10, total=100)
156 bb.event.execute_handler("event_handler",
158 event,
160 self._test_process.event_handler.assert_called_once_with(event)
165 result = bb.event.register("event_handler1",
168 self.assertEqual(result, bb.event.Registered)
169 result = bb.event.register("event_handler2",
172 self.assertEqual(result, bb.event.Registered)
173 event1 = bb.event.OperationStarted()
174 event2 = bb.event.OperationCompleted(total=123)
175 bb.event.fire_class_handlers(event1, None)
176 bb.event.fire_class_handlers(event2, None)
177 bb.event.fire_class_handlers(event2, None)
190 result = bb.event.register("event_handler1",
193 self.assertEqual(result, bb.event.Registered)
194 result = bb.event.register("event_handler2",
197 self.assertEqual(result, bb.event.Registered)
198 bb.event.set_eventfilter(
199 lambda name, handler, event, d :
201 bb.event.getName(event) == "OperationStarted")
202 event1 = bb.event.OperationStarted()
203 event2 = bb.event.OperationCompleted(total=123)
204 bb.event.fire_class_handlers(event1, None)
205 bb.event.fire_class_handlers(event2, None)
206 bb.event.fire_class_handlers(event2, None)
216 event1 = bb.event.OperationStarted()
217 event2 = bb.event.OperationCompleted(total=123)
220 result = bb.event.register("event_handler1",
223 self.assertEqual(result, bb.event.Registered)
224 bb.event.fire_class_handlers(event1, None)
225 bb.event.fire_class_handlers(event2, None)
231 bb.event.remove("event_handler1",
234 result = bb.event.register("event_handler1",
237 self.assertEqual(result, bb.event.Registered)
238 bb.event.fire_class_handlers(event1, None)
239 bb.event.fire_class_handlers(event2, None)
245 bb.event.remove("event_handler1",
248 result = bb.event.register("event_handler1",
251 self.assertEqual(result, bb.event.Registered)
252 bb.event.fire_class_handlers(event1, None)
253 bb.event.fire_class_handlers(event2, None)
260 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
265 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
267 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
272 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
274 result = bb.event.unregister_UIHhandler(1)
279 self._test_ui1.event = Mock(spec_set=EventQueueStub)
280 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
282 self._test_ui2.event = Mock(spec_set=PickleEventQueueStub)
283 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
285 event1 = bb.event.OperationStarted()
286 bb.event.fire_ui_handlers(event1, None)
288 self.assertEqual(self._test_ui1.event.send.call_args_list,
291 self.assertEqual(self._test_ui2.event.sendpickle.call_args_list,
298 self._test_ui1.event = Mock(spec_set=EventQueueStub)
299 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
300 bb.event.set_UIHmask(result, logging.INFO, debug_domains, mask)
301 self._test_ui2.event = Mock(spec_set=PickleEventQueueStub)
302 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
303 bb.event.set_UIHmask(result, logging.INFO, debug_domains, mask)
305 event1 = bb.event.OperationStarted()
306 event2 = bb.event.OperationCompleted(total=1)
308 bb.event.fire_ui_handlers(event1, None)
309 bb.event.fire_ui_handlers(event2, None)
311 self.assertEqual(self._test_ui1.event.send.call_args_list,
314 self.assertEqual(self._test_ui2.event.sendpickle.call_args_list,
322 self._test_ui1.event = EventQueueStub()
323 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
324 bb.event.set_UIHmask(result, logging.ERROR, debug_domains, mask)
325 self._test_ui2.event = PickleEventQueueStub()
326 result = bb.event.register_UIHhandler(self._test_ui2, mainui=True)
327 bb.event.set_UIHmask(result, logging.ERROR, debug_domains, mask)
329 event1 = bb.event.OperationStarted()
330 bb.event.fire_ui_handlers(event1, None) # All events match
332 event_log_handler = bb.event.LogHandler()
346 self.assertEqual(self._test_ui1.event.event_calls, expected)
347 self.assertEqual(self._test_ui2.event.event_calls, expected)
352 result = bb.event.register("event_handler1",
356 self._test_ui1.event = Mock(spec_set=EventQueueStub)
357 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
360 event1 = bb.event.ConfigParsed()
361 bb.event.fire(event1, None)
365 self.assertEqual(self._test_ui1.event.send.call_args_list,
370 self._test_ui1.event = Mock(spec_set=EventQueueStub)
371 result = bb.event.register_UIHhandler(self._test_ui1, mainui=True)
373 event1 = bb.event.ConfigParsed()
374 bb.event.fire_from_worker(event1, None)
376 self.assertEqual(self._test_ui1.event.send.call_args_list,
381 bb.event.worker_fire = Mock()
382 event = bb.event.Event()
383 bb.event.fire(event, None)
384 expected = [call(event, None)]
385 self.assertEqual(bb.event.worker_fire.call_args_list, expected)
389 event1 = bb.event.OperationStarted()
390 event2 = bb.event.OperationCompleted(total=123)
391 bb.event.fire(event1, None)
392 bb.event.fire(event2, None)
393 event_log_handler = bb.event.LogHandler()
399 bb.event.print_ui_queue()
408 def ui1_event_send(event): argument
409 if type(event) is bb.event.ConfigParsed:
411 if type(event) is bb.event.OperationStarted:
415 def ui2_event_send(event): argument
416 if type(event) is bb.event.ConfigParsed:
418 if type(event) is bb.event.OperationStarted:
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)
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)
446 bb.event.fire(bb.event.ConfigParsed(), None)
451 bb.event.fire(bb.event.OperationStarted(), None)
456 bb.event.enable_threadlock()
468 bb.event.disable_threadlock()
484 bb.event.worker_pid = EventClassesTest._worker_pid
488 event = bb.event.Event()
489 self.assertEqual(event.pid, EventClassesTest._worker_pid)
494 event = bb.event.HeartbeatEvent(time)
495 self.assertEqual(event.time, time)
496 self.assertEqual(event.pid, EventClassesTest._worker_pid)
501 event = bb.event.OperationStarted(msg)
502 self.assertEqual(event.msg, msg)
503 self.assertEqual(event.pid, EventClassesTest._worker_pid)
509 event = bb.event.OperationCompleted(total, msg)
510 self.assertEqual(event.msg, msg)
511 self.assertEqual(event.total, total)
512 self.assertEqual(event.pid, EventClassesTest._worker_pid)
519 event = bb.event.OperationProgress(current, total, msg)
520 self.assertEqual(event.msg, msg + ": %s/%s" % (current, total))
521 self.assertEqual(event.pid, EventClassesTest._worker_pid)
525 event = bb.event.ConfigParsed()
526 self.assertEqual(event.pid, EventClassesTest._worker_pid)
531 event = bb.event.MultiConfigParsed(mcdata)
532 self.assertEqual(event.mcdata, mcdata)
533 self.assertEqual(event.pid, EventClassesTest._worker_pid)
538 event = bb.event.RecipeEvent(callback)
539 self.assertEqual(event.fn(1), callback(1))
540 self.assertEqual(event.pid, EventClassesTest._worker_pid)
545 event = bb.event.RecipePreFinalise(callback)
546 self.assertEqual(event.fn(1), callback(1))
547 self.assertEqual(event.pid, EventClassesTest._worker_pid)
553 event = bb.event.RecipeTaskPreProcess(callback, tasklist)
554 self.assertEqual(event.fn(1), callback(1))
555 self.assertEqual(event.tasklist, tasklist)
556 self.assertEqual(event.pid, EventClassesTest._worker_pid)
561 event = bb.event.RecipeParsed(callback)
562 self.assertEqual(event.fn(1), callback(1))
563 self.assertEqual(event.pid, EventClassesTest._worker_pid)
570 event = bb.event.BuildBase(name, pkgs, failures)
571 self.assertEqual(event.name, name)
572 self.assertEqual(event.pkgs, pkgs)
573 self.assertEqual(event.getFailures(), failures)
574 name = event.name = "bar"
575 pkgs = event.pkgs = ["foo"]
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)
583 event = bb.event.BuildInit()
584 self.assertEqual(event.name, None)
585 self.assertEqual(event.pkgs, [])
586 self.assertEqual(event.getFailures(), 0)
587 name = event.name = "bar"
588 pkgs = event.pkgs = ["foo"]
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)
599 event = bb.event.BuildStarted(name, pkgs, failures)
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")
604 name = event.name = "bar"
605 pkgs = event.pkgs = ["foo"]
606 msg = event.msg = "foobar"
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)
620 event = bb.event.BuildCompleted(total, name, pkgs, failures,
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")
626 event2 = bb.event.BuildCompleted(total, name, pkgs)
639 event = bb.event.DiskFull(dev, type, freespace, mountpoint)
640 self.assertEqual(event.pid, EventClassesTest._worker_pid)
647 du = bb.event.DiskUsageSample(available_bytes, free_bytes,
649 event = bb.event.MonitorDiskEvent(du)
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)
658 event1 = bb.event.NoProvider(item)
666 event2 = bb.event.NoProvider(item, runtime, dependees, reasons,
676 event3 = bb.event.NoProvider(item, runtime, dependees, reasons,
688 event1 = bb.event.MultipleProviders(item, candidates)
698 event2 = bb.event.MultipleProviders(item, candidates, runtime)
710 event = bb.event.ParseStarted(total)
711 self.assertEqual(event.msg, "Recipe parsing Started")
712 self.assertEqual(event.total, total)
713 self.assertEqual(event.pid, EventClassesTest._worker_pid)
724 event = bb.event.ParseCompleted(cached, parsed, skipped, masked,
726 self.assertEqual(event.msg, "Recipe parsing Completed")
729 actual = [event.cached, event.parsed, event.skipped, event.virtuals,
730 event.masked, event.errors, event.sofar, event.total]
732 self.assertEqual(event.pid, EventClassesTest._worker_pid)
738 event = bb.event.ParseProgress(current, total)
739 self.assertEqual(event.msg,
741 self.assertEqual(event.pid, EventClassesTest._worker_pid)
746 event = bb.event.CacheLoadStarted(total)
747 self.assertEqual(event.msg, "Loading cache Started")
748 self.assertEqual(event.total, total)
749 self.assertEqual(event.pid, EventClassesTest._worker_pid)
755 event = bb.event.CacheLoadProgress(current, total)
756 self.assertEqual(event.msg,
758 self.assertEqual(event.pid, EventClassesTest._worker_pid)
764 event = bb.event.CacheLoadCompleted(total, num_entries)
765 self.assertEqual(event.msg, "Loading cache Completed")
767 actual = [event.total, event.num_entries]
769 self.assertEqual(event.pid, EventClassesTest._worker_pid)
773 event = bb.event.TreeDataPreparationStarted()
774 self.assertEqual(event.msg, "Preparing tree data Started")
775 self.assertEqual(event.pid, EventClassesTest._worker_pid)
781 event = bb.event.TreeDataPreparationProgress(current, total)
782 self.assertEqual(event.msg,
784 self.assertEqual(event.pid, EventClassesTest._worker_pid)
789 event = bb.event.TreeDataPreparationCompleted(total)
790 self.assertEqual(event.msg, "Preparing tree data Completed")
791 self.assertEqual(event.total, total)
792 self.assertEqual(event.pid, EventClassesTest._worker_pid)
797 event = bb.event.DepTreeGenerated(depgraph)
798 self.assertEqual(event.pid, EventClassesTest._worker_pid)
803 event = bb.event.TargetsTreeGenerated(model)
804 self.assertEqual(event.pid, EventClassesTest._worker_pid)
809 event = bb.event.ReachableStamps(stamps)
810 self.assertEqual(event.stamps, stamps)
811 self.assertEqual(event.pid, EventClassesTest._worker_pid)
817 event = bb.event.FilesMatchingFound(pattern, matches)
818 self.assertEqual(event.pid, EventClassesTest._worker_pid)
824 event = bb.event.ConfigFilesFound(variable, values)
825 self.assertEqual(event.pid, EventClassesTest._worker_pid)
830 event = bb.event.ConfigFilePathFound(path)
831 self.assertEqual(event.pid, EventClassesTest._worker_pid)
836 event = bb.event.MsgBase(msg)
837 self.assertEqual(event.pid, EventClassesTest._worker_pid)
838 event = bb.event.MsgDebug(msg)
839 self.assertEqual(event.pid, EventClassesTest._worker_pid)
840 event = bb.event.MsgNote(msg)
841 self.assertEqual(event.pid, EventClassesTest._worker_pid)
842 event = bb.event.MsgWarn(msg)
843 self.assertEqual(event.pid, EventClassesTest._worker_pid)
844 event = bb.event.MsgError(msg)
845 self.assertEqual(event.pid, EventClassesTest._worker_pid)
846 event = bb.event.MsgFatal(msg)
847 self.assertEqual(event.pid, EventClassesTest._worker_pid)
848 event = bb.event.MsgPlain(msg)
849 self.assertEqual(event.pid, EventClassesTest._worker_pid)
857 event = bb.event.LogExecTTY(msg, prog, sleep_delay, retries)
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)
868 def _worker_handler(self, event, d): argument
869 self._returned_event = event
876 handler = bb.event.LogHandler(logging.INFO)
878 bb.event.worker_fire = self._worker_handler
883 event = self._returned_event
885 pe = pickle.dumps(event)
889 self.assertEqual(event.taskpid, EventClassesTest._worker_pid)
895 event = bb.event.MetadataEvent(eventtype, eventdata)
896 self.assertEqual(event.type, eventtype)
897 self.assertEqual(event.pid, EventClassesTest._worker_pid)
903 event = bb.event.ProcessStarted(processname, total)
904 self.assertEqual(event.processname, processname)
905 self.assertEqual(event.total, total)
906 self.assertEqual(event.pid, EventClassesTest._worker_pid)
912 event = bb.event.ProcessProgress(processname, progress)
913 self.assertEqual(event.processname, processname)
914 self.assertEqual(event.progress, progress)
915 self.assertEqual(event.pid, EventClassesTest._worker_pid)
921 event = bb.event.ProcessFinished(processname)
922 self.assertEqual(event.processname, processname)
923 self.assertEqual(event.pid, EventClassesTest._worker_pid)
927 event1 = bb.event.SanityCheck()
931 event2 = bb.event.SanityCheck(generateevents)
937 event = bb.event.SanityCheckPassed()
938 self.assertEqual(event.pid, EventClassesTest._worker_pid)
943 event1 = bb.event.SanityCheckFailed(msg)
946 event2 = bb.event.SanityCheckFailed(msg, network_error)
951 event1 = bb.event.NetworkTest()
954 event2 = bb.event.NetworkTest(generateevents)
956 event3 = bb.event.NetworkTestPassed()
958 event4 = bb.event.NetworkTestFailed()
964 event = bb.event.FindSigInfoResult(result)
965 self.assertEqual(event.result, result)
966 self.assertEqual(event.pid, EventClassesTest._worker_pid)