if thread_id is *, post to the '*' queue
(self, int_cmd, thread_id)
| 1606 | self.post_internal_command(internal_cmd, thread_id) |
| 1607 | |
| 1608 | def post_internal_command(self, int_cmd, thread_id): |
| 1609 | """if thread_id is *, post to the '*' queue""" |
| 1610 | queue, event = self.get_internal_queue_and_event(thread_id) |
| 1611 | queue.put(int_cmd) |
| 1612 | if thread_id == "*": |
| 1613 | self._py_db_command_thread_event.set() |
| 1614 | else: |
| 1615 | event.set() |
| 1616 | |
| 1617 | def enable_output_redirection(self, redirect_stdout, redirect_stderr): |
| 1618 | global _global_redirect_stdout_to_server |
no test coverage detected