Mercurial > repos > borgend / file revision

#
# Borgend borg launcher / processor
#

import json
import subprocess
import config
import Queue
import Thread

def linereader(stream, instance, queue)
    # What to do on error?
    for line in iter(stream.readline, b''):
        status=json.loads(line)
        queue.put({'identifier': instance.identifier,
                   'operation': instance.operation,
                   'status': status})
    out.close()

class BorgInstance:

    def __init__(self, identifier, operation, args):
        self.identifier=identifier;
        self.operation=operation;
        self.args=args;

    def construct_cmdline(self):
        ???

    def launch(self, queue):
        # What to do with stderr? Is it needed?
        self.proc=subprocess.Popen(self.construct_cmdline(),
                                   stdout=subprocess.PIPE,
                                   stderr=subprocess.PIPE)
        linereaderargs=(self.proc.stdout, self, queue)
        self.t=Thread(target=linereader, args=linereaderargs)
        t.daemon=True
        t.start()

    def read_output():
        try:
            obj=self.queue.get_nowait()
        except Empty:
            obj=Empty
        return obj