code: def fill_initial_broks(self, broker_name):
          broker_uuid = None
          logger.debug("My brokers: %s", self.my_daemon.brokers)
          for broker_link in list(self.my_daemon.brokers.values()):
              logger.debug("Searching broker: %s", broker_link)
              if broker_name == broker_link.name:
                  broker_uuid = broker_link.uuid
                  logger.info("Filling initial broks for: %s (%s)", broker_name, broker_uuid)
                  break
          else:
              if self.pushed_conf:
                  logger.error("Requested initial broks for an unknown broker: %s", broker_name)
              else:
                  logger.info("Requested initial broks for an unknown broker: %s", broker_name)
              return 0
          if self.my_daemon.brokers[broker_uuid].initialized:
              logger.warning("The broker %s still got its initial broks...", broker_name)
              return 0
          initial_broks_count = len(self.my_daemon.brokers[broker_uuid].broks)
          brok = self.get_program_status_brok()
          self.add_brok(brok, broker_uuid)
          initial_status_types = (self.timeperiods, self.commands,
                                  self.contacts, self.contactgroups,
                                  self.hosts, self.hostgroups,
                                  self.services, self.servicegroups)
          self.pushed_conf.skip_initial_broks = getattr(self.pushed_conf, 'skip_initial_broks', False)
          logger.debug("Skipping initial broks? %s", str(self.pushed_conf.skip_initial_broks))
          if not self.pushed_conf.skip_initial_broks:
              initial_status_types = (self.realms, self.timeperiods, self.commands,
                                      self.notificationways, self.contacts, self.contactgroups,
                                      self.hosts, self.hostgroups, self.hostdependencies,
                                      self.services, self.servicegroups, self.servicedependencies,
                                      self.escalations)
              for tab in initial_status_types:
                  for item in tab:
                      member_items = None
                      if hasattr(item, 'members'):
                          member_items = getattr(self, item.my_type.replace("group", "s"))
                      brok = item.get_initial_status_brok(member_items)
                      self.add_brok(brok, broker_uuid)
          brok = Brok({'type': 'initial_broks_done', 'data': {'instance_id': self.instance_id}})
          self.add_brok(brok, broker_uuid)
          final_broks_count = len(self.my_daemon.brokers[broker_uuid].broks)
          self.my_daemon.brokers[broker_uuid].initialized = True
          self.send_broks_to_modules()
          self.raised_initial_broks = True
          logger.info("Created %d initial broks for %s",
                      final_broks_count - initial_broks_count, broker_name)
          return final_broks_count - initial_broks_count