Quick command on fresh connection.
(cmd, session_id=None, timeout=10)
| 48 | return False, f"Failed to parse: {data.decode()[:500]}" |
| 49 | |
| 50 | def send_cmd_quick(cmd, session_id=None, timeout=10): |
| 51 | """Quick command on fresh connection.""" |
| 52 | sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) |
| 53 | sock.connect(SOCKET_PATH) |
| 54 | try: |
| 55 | return send_cmd_blocking(sock, cmd, session_id, timeout) |
| 56 | finally: |
| 57 | sock.close() |
| 58 | |
| 59 | def send_message_async(msg, session_id, result_queue): |
| 60 | """Send message in a thread.""" |
no test coverage detected