def process_input(self):
try:<EOL><INDENT>pyngus.read_socket_input(self.connection, self.socket)<EOL><DEDENT>except Exception as e:<EOL><INDENT>LOG.error("<STR_LIT>", str(e))<EOL>self.connection.close_input()<EOL>self.connection.close()<EOL><DEDENT>self.connection.process(time.time())<EOL>
Called when socket is read-ready