(self)
Run the pipe dispatcher.
Run the pipe dispatcher.
Run the pipe dispatcher .
def run(self):
        """Run the pipe dispatcher."""
        buf = create_string_buffer(BUFSIZE)
        bytes_written = c_uint()

        while self.do_run:
            message = self._read_message(buf)
            if not message:
                break

            response = self.dispatcher.dispatch(message) or "OK"

            KERNEL32.WriteFile(
                self.pipe_handle, response, len(response),
                byref(bytes_written), None
            )

        KERNEL32.CloseHandle(self.pipe_handle)
def run ( self ) : buf = create_string_buffer ( BUFSIZE ) bytes_written = c_uint ( ) while self . do_run : message = self . _read_message ( buf ) if not message : break response = self . dispatcher . dispatch ( message ) or "OK" KERNEL32 . WriteFile ( self . pipe_handle , response , len ( response ) , byref ( bytes_written ) , None ) KERNEL32 . CloseHandle ( self . pipe_handle )