Dec 08 11:20: INFO:Prefetcher:cancelled; prefetcher stopping Dec 08 11:20: CancelledError Dec 08 11:20: ╰──────────────────────────────────────────────────────────────────────────────╯ Dec 08 11:20: │ ╰──────────────────────────────────────────────────────────────────────────╯ │ Dec 08 11:20: │ │ 'Fri, 08 Dec 2023 10:20:23 GMT', 'Content-Length': '660')> │ │ Dec 08 11:20: │ │ │ │ Dec 08 11:20: │ ╭───────────────────────────────── locals ─────────────────────────────────╮ │ Dec 08 11:20: │ │ Dec 08 11:20: │ 1083 │ def _cleanup_writer(self) -> None: │ Dec 08 11:20: │ 1082 │ │ Dec 08 11:20: │ 1081 │ │ self._release_connection() │ Dec 08 11:20: │ ❱ 1080 │ │ │ await self._writer │ Dec 08 11:20: │ 1079 │ │ if self._writer is not None: │ Dec 08 11:20: │ 1078 │ async def _wait_released(self) -> None: │ Dec 08 11:20: │ 1077 │ │ Dec 08 11:20: │ │ Dec 08 11:20: │ y:1080 in _wait_released │ Dec 08 11:20: │ /opt/electrumx/env/lib64/python3.9/site-packages/aiohttp/client_reqrep.p │ Dec 08 11:20: │ │ Dec 08 11:20: │ ╰──────────────────────────────────────────────────────────────────────────╯ │ Dec 08 11:20: │ │ 'Fri, 08 Dec 2023 10:20:23 GMT', 'Content-Length': '660')> │ │ Dec 08 11:20: │ │ │ │ Dec 08 11:20: │ ╭───────────────────────────────── locals ─────────────────────────────────╮ │ Dec 08 11:20: │ │ Dec 08 11:20: │ 1117 │ def get_encoding(self) -> str: │ Dec 08 11:20: │ 1116 │ │ Dec 08 11:20: │ 1115 │ │ return self._body # type: ignore[no-any-return] │ Dec 08 11:20: │ ❱ 1114 │ │ await self._wait_released() # Underlying connection released │ Dec 08 11:20: │ 1113 │ │ │ Dec 08 11:20: │ 1112 │ │ │ raise ClientConnectionError("Connection closed") │ Dec 08 11:20: │ 1111 │ │ elif self._released: # Response explicitly released │ Dec 08 11:20: │ │ Dec 08 11:20: │ y:1114 in read │ Dec 08 11:20: │ /opt/electrumx/env/lib64/python3.9/site-packages/aiohttp/client_reqrep.p │ Dec 08 11:20: │ │ Dec 08 11:20: │ ╰──────────────────────────────────────────────────────────────────────────╯ │ Dec 08 11:20: │ │ 'Content-Length': '660')> │ │ Dec 08 11:20: │ │ 'Date': 'Fri, 08 Dec 2023 10:20:23 GMT', │ │ Dec 08 11:20: │ │ │ │ Dec 08 11:20: │ │ loads = │ │ Dec 08 11:20: │ │ encoding = None │ │ Dec 08 11:20: │ │ content_type = 'application/json' │ │ Dec 08 11:20: │ ╭───────────────────────────────── locals ─────────────────────────────────╮ │ Dec 08 11:20: │ │ Dec 08 11:20: │ 1164 │ │ │ ctype = self.headers.get(hdrs.CONTENT_TYPE, "").lower() │ Dec 08 11:20: │ 1163 │ │ if content_type: │ Dec 08 11:20: │ 1162 │ │ │ Dec 08 11:20: │ ❱ 1161 │ │ │ await self.read() │ Dec 08 11:20: │ 1160 │ │ if self._body is None: │ Dec 08 11:20: │ 1159 │ │ """Read and decodes JSON response.""" │ Dec 08 11:20: │ 1158 │ ) -> Any: │ Dec 08 11:20: │ │ Dec 08 11:20: │ y:1161 in json │ Dec 08 11:20: │ /opt/electrumx/env/lib64/python3.9/site-packages/aiohttp/client_reqrep.p │ Dec 08 11:20: │ │ Dec 08 11:20: │ ╰──────────────────────────────────────────────────────────────────────────╯ │ Dec 08 11:20: │ │ self = │ │ Dec 08 11:20: │ │ 'Fri, 08 Dec 2023 10:20:23 GMT', 'Content-Length': '660')> │ │ Dec 08 11:20: │ │ │ │ Dec 08 11:20: │ │ kind = 'application/json' │ │ Dec 08 11:20: │ │ data = '{"method": "getblockcount", "id": 75371}' │ │ Dec 08 11:20: │ ╭───────────────────────────────── locals ─────────────────────────────────╮ │ Dec 08 11:20: │ │ Dec 08 11:20: │ 126 │ │ │ │ raise ServiceRefusedError(text) │ Dec 08 11:20: │ 125 │ │ │ │ text = text.strip() or resp.reason │ Dec 08 11:20: │ 124 │ │ │ │ text = await resp.text() │ Dec 08 11:20: │ ❱ 123 │ │ │ │ │ return await resp.json(loads=json_deserialize) │ Dec 08 11:20: │ 122 │ │ │ │ if kind == 'application/json': │ Dec 08 11:20: │ 121 │ │ │ │ kind = resp.headers.get('Content-Type', None) │ Dec 08 11:20: │ 120 │ │ │ async with self.session.post(self.current_url(), data=data │ Dec 08 11:20: │ │ Dec 08 11:20: │ y:123 in _send_data │ Dec 08 11:20: │ /opt/electrumx/env/lib/python3.9/site-packages/electrumx/server/daemon.p │ Dec 08 11:20: │ │ Dec 08 11:20: │ ╰──────────────────────────────────────────────────────────────────────────╯ │ Dec 08 11:20: │ │ 0x7f2859f8b700> │ │ Dec 08 11:20: │ │ self = │ │ Dec 08 11:20: │ │ processor = .processor at │ │ Dec 08 11:20: │ │ payload = {'method': 'getblockcount', 'id': 75371} │ │ Dec 08 11:20: │ │ on_good_message = 'running normally' │ │ Dec 08 11:20: │ │ 0x7f2842a66550> │ │ Dec 08 11:20: │ │ log_error = .log_error at │ │ Dec 08 11:20: │ │ last_error_log = 1776533.851677362 │ │ Dec 08 11:20: │ │ data = '{"method": "getblockcount", "id": 75371}' │ │ Dec 08 11:20: │ ╭───────────────────────────────── locals ─────────────────────────────────╮ │ Dec 08 11:20: │ │ Dec 08 11:20: │ 152 │ │ │ │ │ self.logger.info(on_good_message) │ Dec 08 11:20: │ 151 │ │ │ │ if on_good_message: │ Dec 08 11:20: │ 150 │ │ │ │ result = processor(result) │ Dec 08 11:20: │ ❱ 149 │ │ │ │ result = await self._send_data(data) │ Dec 08 11:20: │ 148 │ │ │ try: │ Dec 08 11:20: │ 147 │ │ while True: │ Dec 08 11:20: │ 146 │ │ retry = self.init_retry │ Dec 08 11:20: │ │ Dec 08 11:20: │ y:149 in _send │ Dec 08 11:20: │ /opt/electrumx/env/lib/python3.9/site-packages/electrumx/server/daemon.p │ Dec 08 11:20: │ │ Dec 08 11:20: │ ╰──────────────────────────────────────────────────────────────────────────╯ │ Dec 08 11:20: │ │ self = │ │ Dec 08 11:20: │ │ 0x7f2842a668b0> │ │ Dec 08 11:20: │ │ processor = .processor at │ │ Dec 08 11:20: │ │ payload = {'method': 'getblockcount', 'id': 75371} │ │ Dec 08 11:20: │ │ params = None │ │ Dec 08 11:20: │ │ method = 'getblockcount' │ │ Dec 08 11:20: │ ╭───────────────────────────────── locals ─────────────────────────────────╮ │ Dec 08 11:20: │ │ Dec 08 11:20: │ 194 │ │ '''Send several requests of the same method. │ Dec 08 11:20: │ 193 │ async def _send_vector(self, method, params_iterable, replace_errs │ Dec 08 11:20: │ 192 │ │ Dec 08 11:20: │ ❱ 191 │ │ return await self._send(payload, processor) │ Dec 08 11:20: │ 190 │ │ │ payload['params'] = params │ Dec 08 11:20: │ 189 │ │ if params: │ Dec 08 11:20: │ 188 │ │ payload = {'method': method, 'id': next(self.id_counter)} │ Dec 08 11:20: │ │ Dec 08 11:20: │ y:191 in _send_single │ Dec 08 11:20: │ /opt/electrumx/env/lib/python3.9/site-packages/electrumx/server/daemon.p │ Dec 08 11:20: │ │ Dec 08 11:20: │ ╰──────────────────────────────────────────────────────────────────╯ │ Dec 08 11:20: │ │ self = │ │ Dec 08 11:20: │ ╭───────────────────────────── locals ─────────────────────────────╮ │ Dec 08 11:20: │ │ Dec 08 11:20: │ 305 │ def cached_height(self): │ Dec 08 11:20: │ 304 │ │ Dec 08 11:20: │ 303 │ │ return self._height │ Dec 08 11:20: │ ❱ 302 │ │ self._height = await self._send_single('getblockcount') │ Dec 08 11:20: │ 301 │ │ '''Query the daemon for its current height.''' │ Dec 08 11:20: │ 300 │ async def height(self): │ Dec 08 11:20: │ 299 │ │ Dec 08 11:20: │ │ Dec 08 11:20: │ y:302 in height │ Dec 08 11:20: │ /opt/electrumx/env/lib/python3.9/site-packages/electrumx/server/daemon.p │ Dec 08 11:20: │ │ Dec 08 11:20: │ ╰──────────────────────────────────────────────────────────────────────────╯ │ Dec 08 11:20: │ │ 0x7f2859fa26d0> │ │ Dec 08 11:20: │ │ self = │ │ Dec 08 11:20: │ ╭───────────────────────────────── locals ─────────────────────────────────╮ │ Dec 08 11:20: │ │ Dec 08 11:20: │ 123 │ │ │ │ first = self.fetched_height + 1 │ Dec 08 11:20: │ 122 │ │ │ while self.cache_size < self.min_cache_size: │ Dec 08 11:20: │ 121 │ │ async with self.semaphore: │ Dec 08 11:20: │ ❱ 120 │ │ daemon_height = await daemon.height() │ Dec 08 11:20: │ 119 │ │ daemon = self.daemon │ Dec 08 11:20: │ 118 │ │ ''' │ Dec 08 11:20: │ 117 │ │ Repeats until the queue is full or caught up. │ Dec 08 11:20: │ │ Dec 08 11:20: │ ocessor.py:120 in _prefetch_blocks │ Dec 08 11:20: │ /opt/electrumx/env/lib/python3.9/site-packages/electrumx/server/block_pr │ Dec 08 11:20: │ │ Dec 08 11:20: │ ╰──────────────────────────────────────────────────────────────────────────╯ │ Dec 08 11:20: │ │ 0x7f2859fa26d0> │ │ Dec 08 11:20: │ │ self = │ │ Dec 08 11:20: │ │ bp_height = 2589692 │ │ Dec 08 11:20: │ ╭───────────────────────────────── locals ─────────────────────────────────╮ │ Dec 08 11:20: │ │ Dec 08 11:20: │ 74 │ │ │ │ self.logger.info(f'ignoring daemon error: {e}') │ Dec 08 11:20: │ 73 │ │ │ except DaemonError as e: │ Dec 08 11:20: │ 72 │ │ │ │ │ await asyncio.sleep(self.polling_delay) │ Dec 08 11:20: │ ❱ 71 │ │ │ │ if not await self._prefetch_blocks(): │ Dec 08 11:20: │ 70 │ │ │ │ await self.refill_event.wait() │ Dec 08 11:20: │ 69 │ │ │ │ # Sleep a while if there is nothing to prefetch │ Dec 08 11:20: │ 68 │ │ │ try: │ Dec 08 11:20: │ │ Dec 08 11:20: │ ocessor.py:71 in main_loop │ Dec 08 11:20: │ /opt/electrumx/env/lib/python3.9/site-packages/electrumx/server/block_pr │ Dec 08 11:20: ╭───────────────────── Traceback (most recent call last) ──────────────────────╮ Dec 08 11:20: During handling of the above exception, another exception occurred: Dec 08 11:20: CancelledError Dec 08 11:20: ╰──────────────────────────────────────────────────────────────────────────────╯ Dec 08 11:20: │ ╰──────────────────────────────────────────────────────────────────────────╯ │ Dec 08 11:20: │ │ writer = │ │ Dec 08 11:20: │ │ self = │ │ Dec 08 11:20: │ │ proxy_headers_hash=None)> │ │ Dec 08 11:20: │ │ is_ssl=False, ssl=None, proxy=None, proxy_auth=None, │ │ Dec 08 11:20: │ │ conn = Connection None: │ Dec 08 11:20: │ 610 │ │ self, writer: AbstractStreamWriter, conn: "Connection" │ Dec 08 11:20: │ ❱ 609 │ async def write_bytes( │ Dec 08 11:20: │ 608 │ │ Dec 08 11:20: │ 607 │ │ return True │ Dec 08 11:20: │ 606 │ │ │ Dec 08 11:20: │ │ Dec 08 11:20: │ y:609 in write_bytes │ Dec 08 11:20: │ /opt/electrumx/env/lib64/python3.9/site-packages/aiohttp/client_reqrep.p │ Dec 08 11:20: ╭───────────────────── Traceback (most recent call last) ──────────────────────╮ Dec 08 11:20: . Retrying occasionally... Dec 08 11:20:

Bad Request

Dec 08 11:20: Dec 08 11:20: 400 Bad Request Dec 08 11:20: ERROR:Daemon:daemon service refused: Dec 08 11:20: INFO:Prefetcher:ignoring daemon error: {'code': -32700, 'message': 'Parse error'}