BufferedLogger.push method

logging.py

    def push(self, limit=None):
        """ Push some queued items out of the queue.
            
            This method causes queued items to be written to be saved to a file.
            
            Only `limit` items will be pushed out of the queue. If `limit` is
            `0`, then all items will be pushed from the queue.
        """
        if limit is None:
            limit = self.default_push
        
        if limit < 0:
            return
        
        if self.queue.empty():
            return
        
        sdata = {}
        iter = 0
        
        # First we sort the data we want into lists of messages that will be
        # saved in the same file. This way we don't have to keep opening and
        # closing files.
        while not self.queue.empty():
            item = self.queue.get()
            fname = self._fname(item[3], **item[4])
            
            try:
                sdata[fname].append(item)
            except KeyError:
                sdata[fname] = []
                sdata[fname].append(item)
            
            iter+= 1
            
            if limit == iter:
                break
        
        # The following two lines make the above loop pointless save for the
        # purpose of syphoning the queue.
        if not self.save_logs:
            return
        
        for fname in sdata:
            self._save(fname, sdata[fname])