event.py 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824
  1. # ex:ts=4:sw=4:sts=4:et
  2. # -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*-
  3. """
  4. BitBake 'Event' implementation
  5. Classes and functions for manipulating 'events' in the
  6. BitBake build tools.
  7. """
  8. # Copyright (C) 2003, 2004 Chris Larson
  9. #
  10. # SPDX-License-Identifier: GPL-2.0-only
  11. #
  12. import os, sys
  13. import warnings
  14. import pickle
  15. import logging
  16. import atexit
  17. import traceback
  18. import ast
  19. import threading
  20. import bb.utils
  21. import bb.compat
  22. import bb.exceptions
  23. # This is the pid for which we should generate the event. This is set when
  24. # the runqueue forks off.
  25. worker_pid = 0
  26. worker_fire = None
  27. logger = logging.getLogger('BitBake.Event')
  28. class Event(object):
  29. """Base class for events"""
  30. def __init__(self):
  31. self.pid = worker_pid
  32. class HeartbeatEvent(Event):
  33. """Triggered at regular time intervals of 10 seconds. Other events can fire much more often
  34. (runQueueTaskStarted when there are many short tasks) or not at all for long periods
  35. of time (again runQueueTaskStarted, when there is just one long-running task), so this
  36. event is more suitable for doing some task-independent work occassionally."""
  37. def __init__(self, time):
  38. Event.__init__(self)
  39. self.time = time
  40. Registered = 10
  41. AlreadyRegistered = 14
  42. def get_class_handlers():
  43. return _handlers
  44. def set_class_handlers(h):
  45. global _handlers
  46. _handlers = h
  47. def clean_class_handlers():
  48. return bb.compat.OrderedDict()
  49. # Internal
  50. _handlers = clean_class_handlers()
  51. _ui_handlers = {}
  52. _ui_logfilters = {}
  53. _ui_handler_seq = 0
  54. _event_handler_map = {}
  55. _catchall_handlers = {}
  56. _eventfilter = None
  57. _uiready = False
  58. _thread_lock = threading.Lock()
  59. _thread_lock_enabled = False
  60. if hasattr(__builtins__, '__setitem__'):
  61. builtins = __builtins__
  62. else:
  63. builtins = __builtins__.__dict__
  64. def enable_threadlock():
  65. global _thread_lock_enabled
  66. _thread_lock_enabled = True
  67. def disable_threadlock():
  68. global _thread_lock_enabled
  69. _thread_lock_enabled = False
  70. def execute_handler(name, handler, event, d):
  71. event.data = d
  72. addedd = False
  73. if 'd' not in builtins:
  74. builtins['d'] = d
  75. addedd = True
  76. try:
  77. ret = handler(event)
  78. except (bb.parse.SkipRecipe, bb.BBHandledException):
  79. raise
  80. except Exception:
  81. etype, value, tb = sys.exc_info()
  82. logger.error("Execution of event handler '%s' failed" % name,
  83. exc_info=(etype, value, tb.tb_next))
  84. raise
  85. except SystemExit as exc:
  86. if exc.code != 0:
  87. logger.error("Execution of event handler '%s' failed" % name)
  88. raise
  89. finally:
  90. del event.data
  91. if addedd:
  92. del builtins['d']
  93. def fire_class_handlers(event, d):
  94. if isinstance(event, logging.LogRecord):
  95. return
  96. eid = str(event.__class__)[8:-2]
  97. evt_hmap = _event_handler_map.get(eid, {})
  98. for name, handler in list(_handlers.items()):
  99. if name in _catchall_handlers or name in evt_hmap:
  100. if _eventfilter:
  101. if not _eventfilter(name, handler, event, d):
  102. continue
  103. execute_handler(name, handler, event, d)
  104. ui_queue = []
  105. @atexit.register
  106. def print_ui_queue():
  107. """If we're exiting before a UI has been spawned, display any queued
  108. LogRecords to the console."""
  109. logger = logging.getLogger("BitBake")
  110. if not _uiready:
  111. from bb.msg import BBLogFormatter
  112. # Flush any existing buffered content
  113. sys.stdout.flush()
  114. sys.stderr.flush()
  115. stdout = logging.StreamHandler(sys.stdout)
  116. stderr = logging.StreamHandler(sys.stderr)
  117. formatter = BBLogFormatter("%(levelname)s: %(message)s")
  118. stdout.setFormatter(formatter)
  119. stderr.setFormatter(formatter)
  120. # First check to see if we have any proper messages
  121. msgprint = False
  122. msgerrs = False
  123. # Should we print to stderr?
  124. for event in ui_queue[:]:
  125. if isinstance(event, logging.LogRecord) and event.levelno >= logging.WARNING:
  126. msgerrs = True
  127. break
  128. if msgerrs:
  129. logger.addHandler(stderr)
  130. else:
  131. logger.addHandler(stdout)
  132. for event in ui_queue[:]:
  133. if isinstance(event, logging.LogRecord):
  134. if event.levelno > logging.DEBUG:
  135. logger.handle(event)
  136. msgprint = True
  137. # Nope, so just print all of the messages we have (including debug messages)
  138. if not msgprint:
  139. for event in ui_queue[:]:
  140. if isinstance(event, logging.LogRecord):
  141. logger.handle(event)
  142. if msgerrs:
  143. logger.removeHandler(stderr)
  144. else:
  145. logger.removeHandler(stdout)
  146. def fire_ui_handlers(event, d):
  147. global _thread_lock
  148. global _thread_lock_enabled
  149. if not _uiready:
  150. # No UI handlers registered yet, queue up the messages
  151. ui_queue.append(event)
  152. return
  153. if _thread_lock_enabled:
  154. _thread_lock.acquire()
  155. errors = []
  156. for h in _ui_handlers:
  157. #print "Sending event %s" % event
  158. try:
  159. if not _ui_logfilters[h].filter(event):
  160. continue
  161. # We use pickle here since it better handles object instances
  162. # which xmlrpc's marshaller does not. Events *must* be serializable
  163. # by pickle.
  164. if hasattr(_ui_handlers[h].event, "sendpickle"):
  165. _ui_handlers[h].event.sendpickle((pickle.dumps(event)))
  166. else:
  167. _ui_handlers[h].event.send(event)
  168. except:
  169. errors.append(h)
  170. for h in errors:
  171. del _ui_handlers[h]
  172. if _thread_lock_enabled:
  173. _thread_lock.release()
  174. def fire(event, d):
  175. """Fire off an Event"""
  176. # We can fire class handlers in the worker process context and this is
  177. # desired so they get the task based datastore.
  178. # UI handlers need to be fired in the server context so we defer this. They
  179. # don't have a datastore so the datastore context isn't a problem.
  180. fire_class_handlers(event, d)
  181. if worker_fire:
  182. worker_fire(event, d)
  183. else:
  184. # If messages have been queued up, clear the queue
  185. global _uiready, ui_queue
  186. if _uiready and ui_queue:
  187. for queue_event in ui_queue:
  188. fire_ui_handlers(queue_event, d)
  189. ui_queue = []
  190. fire_ui_handlers(event, d)
  191. def fire_from_worker(event, d):
  192. fire_ui_handlers(event, d)
  193. noop = lambda _: None
  194. def register(name, handler, mask=None, filename=None, lineno=None):
  195. """Register an Event handler"""
  196. # already registered
  197. if name in _handlers:
  198. return AlreadyRegistered
  199. if handler is not None:
  200. # handle string containing python code
  201. if isinstance(handler, str):
  202. tmp = "def %s(e):\n%s" % (name, handler)
  203. try:
  204. code = bb.methodpool.compile_cache(tmp)
  205. if not code:
  206. if filename is None:
  207. filename = "%s(e)" % name
  208. code = compile(tmp, filename, "exec", ast.PyCF_ONLY_AST)
  209. if lineno is not None:
  210. ast.increment_lineno(code, lineno-1)
  211. code = compile(code, filename, "exec")
  212. bb.methodpool.compile_cache_add(tmp, code)
  213. except SyntaxError:
  214. logger.error("Unable to register event handler '%s':\n%s", name,
  215. ''.join(traceback.format_exc(limit=0)))
  216. _handlers[name] = noop
  217. return
  218. env = {}
  219. bb.utils.better_exec(code, env)
  220. func = bb.utils.better_eval(name, env)
  221. _handlers[name] = func
  222. else:
  223. _handlers[name] = handler
  224. if not mask or '*' in mask:
  225. _catchall_handlers[name] = True
  226. else:
  227. for m in mask:
  228. if _event_handler_map.get(m, None) is None:
  229. _event_handler_map[m] = {}
  230. _event_handler_map[m][name] = True
  231. return Registered
  232. def remove(name, handler):
  233. """Remove an Event handler"""
  234. _handlers.pop(name)
  235. if name in _catchall_handlers:
  236. _catchall_handlers.pop(name)
  237. for event in _event_handler_map.keys():
  238. if name in _event_handler_map[event]:
  239. _event_handler_map[event].pop(name)
  240. def get_handlers():
  241. return _handlers
  242. def set_handlers(handlers):
  243. global _handlers
  244. _handlers = handlers
  245. def set_eventfilter(func):
  246. global _eventfilter
  247. _eventfilter = func
  248. def register_UIHhandler(handler, mainui=False):
  249. bb.event._ui_handler_seq = bb.event._ui_handler_seq + 1
  250. _ui_handlers[_ui_handler_seq] = handler
  251. level, debug_domains = bb.msg.constructLogOptions()
  252. _ui_logfilters[_ui_handler_seq] = UIEventFilter(level, debug_domains)
  253. if mainui:
  254. global _uiready
  255. _uiready = _ui_handler_seq
  256. return _ui_handler_seq
  257. def unregister_UIHhandler(handlerNum, mainui=False):
  258. if mainui:
  259. global _uiready
  260. _uiready = False
  261. if handlerNum in _ui_handlers:
  262. del _ui_handlers[handlerNum]
  263. return
  264. def get_uihandler():
  265. if _uiready is False:
  266. return None
  267. return _uiready
  268. # Class to allow filtering of events and specific filtering of LogRecords *before* we put them over the IPC
  269. class UIEventFilter(object):
  270. def __init__(self, level, debug_domains):
  271. self.update(None, level, debug_domains)
  272. def update(self, eventmask, level, debug_domains):
  273. self.eventmask = eventmask
  274. self.stdlevel = level
  275. self.debug_domains = debug_domains
  276. def filter(self, event):
  277. if isinstance(event, logging.LogRecord):
  278. if event.levelno >= self.stdlevel:
  279. return True
  280. if event.name in self.debug_domains and event.levelno >= self.debug_domains[event.name]:
  281. return True
  282. return False
  283. eid = str(event.__class__)[8:-2]
  284. if self.eventmask and eid not in self.eventmask:
  285. return False
  286. return True
  287. def set_UIHmask(handlerNum, level, debug_domains, mask):
  288. if not handlerNum in _ui_handlers:
  289. return False
  290. if '*' in mask:
  291. _ui_logfilters[handlerNum].update(None, level, debug_domains)
  292. else:
  293. _ui_logfilters[handlerNum].update(mask, level, debug_domains)
  294. return True
  295. def getName(e):
  296. """Returns the name of a class or class instance"""
  297. if getattr(e, "__name__", None) == None:
  298. return e.__class__.__name__
  299. else:
  300. return e.__name__
  301. class OperationStarted(Event):
  302. """An operation has begun"""
  303. def __init__(self, msg = "Operation Started"):
  304. Event.__init__(self)
  305. self.msg = msg
  306. class OperationCompleted(Event):
  307. """An operation has completed"""
  308. def __init__(self, total, msg = "Operation Completed"):
  309. Event.__init__(self)
  310. self.total = total
  311. self.msg = msg
  312. class OperationProgress(Event):
  313. """An operation is in progress"""
  314. def __init__(self, current, total, msg = "Operation in Progress"):
  315. Event.__init__(self)
  316. self.current = current
  317. self.total = total
  318. self.msg = msg + ": %s/%s" % (current, total);
  319. class ConfigParsed(Event):
  320. """Configuration Parsing Complete"""
  321. class MultiConfigParsed(Event):
  322. """Multi-Config Parsing Complete"""
  323. def __init__(self, mcdata):
  324. self.mcdata = mcdata
  325. Event.__init__(self)
  326. class RecipeEvent(Event):
  327. def __init__(self, fn):
  328. self.fn = fn
  329. Event.__init__(self)
  330. class RecipePreFinalise(RecipeEvent):
  331. """ Recipe Parsing Complete but not yet finalised"""
  332. class RecipeTaskPreProcess(RecipeEvent):
  333. """
  334. Recipe Tasks about to be finalised
  335. The list of tasks should be final at this point and handlers
  336. are only able to change interdependencies
  337. """
  338. def __init__(self, fn, tasklist):
  339. self.fn = fn
  340. self.tasklist = tasklist
  341. Event.__init__(self)
  342. class RecipeParsed(RecipeEvent):
  343. """ Recipe Parsing Complete """
  344. class StampUpdate(Event):
  345. """Trigger for any adjustment of the stamp files to happen"""
  346. def __init__(self, targets, stampfns):
  347. self._targets = targets
  348. self._stampfns = stampfns
  349. Event.__init__(self)
  350. def getStampPrefix(self):
  351. return self._stampfns
  352. def getTargets(self):
  353. return self._targets
  354. stampPrefix = property(getStampPrefix)
  355. targets = property(getTargets)
  356. class BuildBase(Event):
  357. """Base class for bitbake build events"""
  358. def __init__(self, n, p, failures = 0):
  359. self._name = n
  360. self._pkgs = p
  361. Event.__init__(self)
  362. self._failures = failures
  363. def getPkgs(self):
  364. return self._pkgs
  365. def setPkgs(self, pkgs):
  366. self._pkgs = pkgs
  367. def getName(self):
  368. return self._name
  369. def setName(self, name):
  370. self._name = name
  371. def getFailures(self):
  372. """
  373. Return the number of failed packages
  374. """
  375. return self._failures
  376. pkgs = property(getPkgs, setPkgs, None, "pkgs property")
  377. name = property(getName, setName, None, "name property")
  378. class BuildInit(BuildBase):
  379. """buildFile or buildTargets was invoked"""
  380. def __init__(self, p=[]):
  381. name = None
  382. BuildBase.__init__(self, name, p)
  383. class BuildStarted(BuildBase, OperationStarted):
  384. """Event when builds start"""
  385. def __init__(self, n, p, failures = 0):
  386. OperationStarted.__init__(self, "Building Started")
  387. BuildBase.__init__(self, n, p, failures)
  388. class BuildCompleted(BuildBase, OperationCompleted):
  389. """Event when builds have completed"""
  390. def __init__(self, total, n, p, failures=0, interrupted=0):
  391. if not failures:
  392. OperationCompleted.__init__(self, total, "Building Succeeded")
  393. else:
  394. OperationCompleted.__init__(self, total, "Building Failed")
  395. self._interrupted = interrupted
  396. BuildBase.__init__(self, n, p, failures)
  397. class DiskFull(Event):
  398. """Disk full case build aborted"""
  399. def __init__(self, dev, type, freespace, mountpoint):
  400. Event.__init__(self)
  401. self._dev = dev
  402. self._type = type
  403. self._free = freespace
  404. self._mountpoint = mountpoint
  405. class DiskUsageSample:
  406. def __init__(self, available_bytes, free_bytes, total_bytes):
  407. # Number of bytes available to non-root processes.
  408. self.available_bytes = available_bytes
  409. # Number of bytes available to root processes.
  410. self.free_bytes = free_bytes
  411. # Total capacity of the volume.
  412. self.total_bytes = total_bytes
  413. class MonitorDiskEvent(Event):
  414. """If BB_DISKMON_DIRS is set, then this event gets triggered each time disk space is checked.
  415. Provides information about devices that are getting monitored."""
  416. def __init__(self, disk_usage):
  417. Event.__init__(self)
  418. # hash of device root path -> DiskUsageSample
  419. self.disk_usage = disk_usage
  420. class NoProvider(Event):
  421. """No Provider for an Event"""
  422. def __init__(self, item, runtime=False, dependees=None, reasons=None, close_matches=None):
  423. Event.__init__(self)
  424. self._item = item
  425. self._runtime = runtime
  426. self._dependees = dependees
  427. self._reasons = reasons
  428. self._close_matches = close_matches
  429. def getItem(self):
  430. return self._item
  431. def isRuntime(self):
  432. return self._runtime
  433. def __str__(self):
  434. msg = ''
  435. if self._runtime:
  436. r = "R"
  437. else:
  438. r = ""
  439. extra = ''
  440. if not self._reasons:
  441. if self._close_matches:
  442. extra = ". Close matches:\n %s" % '\n '.join(self._close_matches)
  443. if self._dependees:
  444. msg = "Nothing %sPROVIDES '%s' (but %s %sDEPENDS on or otherwise requires it)%s" % (r, self._item, ", ".join(self._dependees), r, extra)
  445. else:
  446. msg = "Nothing %sPROVIDES '%s'%s" % (r, self._item, extra)
  447. if self._reasons:
  448. for reason in self._reasons:
  449. msg += '\n' + reason
  450. return msg
  451. class MultipleProviders(Event):
  452. """Multiple Providers"""
  453. def __init__(self, item, candidates, runtime = False):
  454. Event.__init__(self)
  455. self._item = item
  456. self._candidates = candidates
  457. self._is_runtime = runtime
  458. def isRuntime(self):
  459. """
  460. Is this a runtime issue?
  461. """
  462. return self._is_runtime
  463. def getItem(self):
  464. """
  465. The name for the to be build item
  466. """
  467. return self._item
  468. def getCandidates(self):
  469. """
  470. Get the possible Candidates for a PROVIDER.
  471. """
  472. return self._candidates
  473. def __str__(self):
  474. msg = "Multiple providers are available for %s%s (%s)" % (self._is_runtime and "runtime " or "",
  475. self._item,
  476. ", ".join(self._candidates))
  477. rtime = ""
  478. if self._is_runtime:
  479. rtime = "R"
  480. msg += "\nConsider defining a PREFERRED_%sPROVIDER entry to match %s" % (rtime, self._item)
  481. return msg
  482. class ParseStarted(OperationStarted):
  483. """Recipe parsing for the runqueue has begun"""
  484. def __init__(self, total):
  485. OperationStarted.__init__(self, "Recipe parsing Started")
  486. self.total = total
  487. class ParseCompleted(OperationCompleted):
  488. """Recipe parsing for the runqueue has completed"""
  489. def __init__(self, cached, parsed, skipped, masked, virtuals, errors, total):
  490. OperationCompleted.__init__(self, total, "Recipe parsing Completed")
  491. self.cached = cached
  492. self.parsed = parsed
  493. self.skipped = skipped
  494. self.virtuals = virtuals
  495. self.masked = masked
  496. self.errors = errors
  497. self.sofar = cached + parsed
  498. class ParseProgress(OperationProgress):
  499. """Recipe parsing progress"""
  500. def __init__(self, current, total):
  501. OperationProgress.__init__(self, current, total, "Recipe parsing")
  502. class CacheLoadStarted(OperationStarted):
  503. """Loading of the dependency cache has begun"""
  504. def __init__(self, total):
  505. OperationStarted.__init__(self, "Loading cache Started")
  506. self.total = total
  507. class CacheLoadProgress(OperationProgress):
  508. """Cache loading progress"""
  509. def __init__(self, current, total):
  510. OperationProgress.__init__(self, current, total, "Loading cache")
  511. class CacheLoadCompleted(OperationCompleted):
  512. """Cache loading is complete"""
  513. def __init__(self, total, num_entries):
  514. OperationCompleted.__init__(self, total, "Loading cache Completed")
  515. self.num_entries = num_entries
  516. class TreeDataPreparationStarted(OperationStarted):
  517. """Tree data preparation started"""
  518. def __init__(self):
  519. OperationStarted.__init__(self, "Preparing tree data Started")
  520. class TreeDataPreparationProgress(OperationProgress):
  521. """Tree data preparation is in progress"""
  522. def __init__(self, current, total):
  523. OperationProgress.__init__(self, current, total, "Preparing tree data")
  524. class TreeDataPreparationCompleted(OperationCompleted):
  525. """Tree data preparation completed"""
  526. def __init__(self, total):
  527. OperationCompleted.__init__(self, total, "Preparing tree data Completed")
  528. class DepTreeGenerated(Event):
  529. """
  530. Event when a dependency tree has been generated
  531. """
  532. def __init__(self, depgraph):
  533. Event.__init__(self)
  534. self._depgraph = depgraph
  535. class TargetsTreeGenerated(Event):
  536. """
  537. Event when a set of buildable targets has been generated
  538. """
  539. def __init__(self, model):
  540. Event.__init__(self)
  541. self._model = model
  542. class ReachableStamps(Event):
  543. """
  544. An event listing all stamps reachable after parsing
  545. which the metadata may use to clean up stale data
  546. """
  547. def __init__(self, stamps):
  548. Event.__init__(self)
  549. self.stamps = stamps
  550. class FilesMatchingFound(Event):
  551. """
  552. Event when a list of files matching the supplied pattern has
  553. been generated
  554. """
  555. def __init__(self, pattern, matches):
  556. Event.__init__(self)
  557. self._pattern = pattern
  558. self._matches = matches
  559. class ConfigFilesFound(Event):
  560. """
  561. Event when a list of appropriate config files has been generated
  562. """
  563. def __init__(self, variable, values):
  564. Event.__init__(self)
  565. self._variable = variable
  566. self._values = values
  567. class ConfigFilePathFound(Event):
  568. """
  569. Event when a path for a config file has been found
  570. """
  571. def __init__(self, path):
  572. Event.__init__(self)
  573. self._path = path
  574. class MsgBase(Event):
  575. """Base class for messages"""
  576. def __init__(self, msg):
  577. self._message = msg
  578. Event.__init__(self)
  579. class MsgDebug(MsgBase):
  580. """Debug Message"""
  581. class MsgNote(MsgBase):
  582. """Note Message"""
  583. class MsgWarn(MsgBase):
  584. """Warning Message"""
  585. class MsgError(MsgBase):
  586. """Error Message"""
  587. class MsgFatal(MsgBase):
  588. """Fatal Message"""
  589. class MsgPlain(MsgBase):
  590. """General output"""
  591. class LogExecTTY(Event):
  592. """Send event containing program to spawn on tty of the logger"""
  593. def __init__(self, msg, prog, sleep_delay, retries):
  594. Event.__init__(self)
  595. self.msg = msg
  596. self.prog = prog
  597. self.sleep_delay = sleep_delay
  598. self.retries = retries
  599. class LogHandler(logging.Handler):
  600. """Dispatch logging messages as bitbake events"""
  601. def emit(self, record):
  602. if record.exc_info:
  603. etype, value, tb = record.exc_info
  604. if hasattr(tb, 'tb_next'):
  605. tb = list(bb.exceptions.extract_traceback(tb, context=3))
  606. # Need to turn the value into something the logging system can pickle
  607. record.bb_exc_info = (etype, value, tb)
  608. record.bb_exc_formatted = bb.exceptions.format_exception(etype, value, tb, limit=5)
  609. value = str(value)
  610. record.exc_info = None
  611. fire(record, None)
  612. def filter(self, record):
  613. record.taskpid = worker_pid
  614. return True
  615. class MetadataEvent(Event):
  616. """
  617. Generic event that target for OE-Core classes
  618. to report information during asynchrous execution
  619. """
  620. def __init__(self, eventtype, eventdata):
  621. Event.__init__(self)
  622. self.type = eventtype
  623. self._localdata = eventdata
  624. class ProcessStarted(Event):
  625. """
  626. Generic process started event (usually part of the initial startup)
  627. where further progress events will be delivered
  628. """
  629. def __init__(self, processname, total):
  630. Event.__init__(self)
  631. self.processname = processname
  632. self.total = total
  633. class ProcessProgress(Event):
  634. """
  635. Generic process progress event (usually part of the initial startup)
  636. """
  637. def __init__(self, processname, progress):
  638. Event.__init__(self)
  639. self.processname = processname
  640. self.progress = progress
  641. class ProcessFinished(Event):
  642. """
  643. Generic process finished event (usually part of the initial startup)
  644. """
  645. def __init__(self, processname):
  646. Event.__init__(self)
  647. self.processname = processname
  648. class SanityCheck(Event):
  649. """
  650. Event to run sanity checks, either raise errors or generate events as return status.
  651. """
  652. def __init__(self, generateevents = True):
  653. Event.__init__(self)
  654. self.generateevents = generateevents
  655. class SanityCheckPassed(Event):
  656. """
  657. Event to indicate sanity check has passed
  658. """
  659. class SanityCheckFailed(Event):
  660. """
  661. Event to indicate sanity check has failed
  662. """
  663. def __init__(self, msg, network_error=False):
  664. Event.__init__(self)
  665. self._msg = msg
  666. self._network_error = network_error
  667. class NetworkTest(Event):
  668. """
  669. Event to run network connectivity tests, either raise errors or generate events as return status.
  670. """
  671. def __init__(self, generateevents = True):
  672. Event.__init__(self)
  673. self.generateevents = generateevents
  674. class NetworkTestPassed(Event):
  675. """
  676. Event to indicate network test has passed
  677. """
  678. class NetworkTestFailed(Event):
  679. """
  680. Event to indicate network test has failed
  681. """
  682. class FindSigInfoResult(Event):
  683. """
  684. Event to return results from findSigInfo command
  685. """
  686. def __init__(self, result):
  687. Event.__init__(self)
  688. self.result = result