              If it doesn't exist, create it """
          logger.debug("QueueManager getting: '%s'", name)
          queue = self.queues.get(name, None)
          if not queue:
              self.add_queue(name, maxsize)
              queue = self.queues[name]
          logger.debug("QueueManager got: '%s'", name)
          return queue
  
      def terminate_queues(self):
 
</s> remove     def get_queue(self, name, maxsize=0):
 </s> add     def get_queue(self, name, maxsize=0, multiprocessing_queue=True): </s> remove         if scale == 1.0:
            return image

 </s> add  </s> remove         image = self.scale_image(image, scale)
        return [image, scale]
 </s> add         image = self.scale_image(image, scale, pad_to)
        if pad_to is None:
            return [image, scale]
        pad_left = int(pad_to[0] - int(input_image.shape[1] * scale)) // 2
        pad_top = int(pad_to[1] - int(input_image.shape[0] * scale)) // 2
        return [image, scale, (pad_left, pad_top)]
            self.add_queue(name, maxsize, multiprocessing_queue)
              If it doesn't exist, create it """
          logger.debug("QueueManager getting: '%s'", name)
          queue = self.queues.get(name, None)
          if not queue:
            self.add_queue(name, maxsize, multiprocessing_queue)
              queue = self.queues[name]
          logger.debug("QueueManager got: '%s'", name)
          return queue
  
      def terminate_queues(self):
keep keep keep keep replace keep keep keep keep keep
 Added s3fd-amd + minor fixes (#837) 
lib/queue_manager.py