#!/usr/bin/python

  import cProfile

  from functools import partial

  import hashlib

  import dateutil

  import koji as _koji  # koji declared using profile module in main()

  import rpm

  logger = logging.getLogger('koji.checkbuilds')

  # an event to indicate that the feeder is done

  feeder_done = multiprocessing.Event()

  # queue to hold actions in the pipeline

  queue = multiprocessing.Queue()

      # wait for the queue to be empty

      queue.close()

      logger.info('Finished. Waiting for workers to stop.')

      for worker in workers:

          worker.join()

      logger.info('Workers finished')

      s_thread.join()

      while True:

          try:

              method, args, kw = stats_queue.get(block=True, timeout=5)

                  # is this enough?

                  break

              continue

      while True:

          try:

              build, opts = queue.get(block=True, timeout=5)

              if feeder_done.is_set():

                  # is this enough?

                  break

      def verify_rpm(self, fn, ts, n_bytes):

          logger.debug('Verifying rpm %s', fn)

          start = time.time()

              try:

                  ts.hdrFromFdno(fp.fileno())

              except rpm.error as ex:

          for rpminfo, [sigs] in zip(self.rpms, session.multiCall(strict=True)):

              for sig in sigs:

                  sig_idx.setdefault(sig['sigkey'], []).append([rpminfo, sig])

          for sigkey in sig_idx:

              cachedir = os.path.join(self.build_dir, 'data/sigcache/%s' % sigkey)

              if not os.path.isdir(cachedir):

                      logger.warn("Cached signature missing: %s", cachefile)

                      self.fail('sigcache.missing')

                      continue

                  if sighash != sig['sighash']:

                      logger.warn('Cached signature mismatch for %s\n'

                              '  db: %s, file:%s',

              sumtype = koji.CHECKSUM_TYPES[sumtype]

          except KeyError:

              logger.error('Unknown sum type %s for %s', sumtype, fn)

              return

          if sumtype == 'md5':

              chk = hashlib.md5()

          elif sumtype == 'sha1':

              chk = hashlib.sha1()

          else:

              logger.error('Unsupported sum type %s for %s', sumtype, fn)

              return

          logger.debug('Checking %s for %s', sumtype, fn)

          stats.increment('checksum.checked')

          start = time.time()

              chunks = iter(partial(fp.read, 819200), b'')

              [chk.update(b) for b in chunks]

              n_bytes = fp.tell()

  #!/usr/bin/python

  import cProfile

  import grp

  import logging

  import dateutil

  import koji as _koji  # koji declared using profile module in main()

  koji = _koji  # until main() replaces

      while True:

          try:

              method, args, kw = stats_queue.get(block=True, timeout=5)

              if workers_done.is_set():

                  # is this enough?

                  break

      while True:

          try:

              build, opts = build_queue.get(block=True, timeout=5)

              if feeder_done.is_set():

                  # is this enough?

                  break