Method flush

sshuttle/ssnet.py:448–457

(self)

                callback(cmd, data)

    def flush(self):
        set_non_blocking_io(self.wfile.fileno())
        if self.outbuf and self.outbuf[0]:
            wrote = _nb_clean(self.wfile.write, self.outbuf[0])
            # self.wfile.flush()
            debug2('mux wrote: %r/%d' % (wrote, len(self.outbuf[0])))
            if wrote:
                self.outbuf[0] = self.outbuf[0][wrote:]
        while self.outbuf and not self.outbuf[0]:
            self.outbuf[0:1] = []

    def fill(self):
        set_non_blocking_io(self.rfile.fileno())