chore: 优化在 Windows 下 anyio accept socket 失败的问题

Author: tianxiu2b2t

core/__init__.py

@@ -92,9 +92,10 @@ async def main():
 
             # serve
             await clusters.serve()
-
+    except asyncio.CancelledError:
+        ...
     except:
-        logger.debug_traceback()
+        logger.traceback()
 
     finally:
         await clusters.stop()

core/cluster.py

@@ -243,7 +243,7 @@ async def keepalive(self):
                 if res.err is not None or res.ack is None or not isinstance(res.ack, str):
                     self._failed_keepalive += 1
                     if self._failed_keepalive >= 3:
-                        logger.terror("cluster.kicked", id=self.id)
+                        logger.terror("cluster.kicked", id=self.id, name=self.display_name)
                         await self.disable()
                     else:
                         logger.twarning("cluster.keepalive", id=self.id, name=self.display_name, failed=self._failed_keepalive)
@@ -695,7 +695,6 @@ async def fetch_cluster_name(self):
                 "/openbmclapi/metric/rank"
             ) as response:
                 for resp_cluster in await response.json():
-                    print(resp_cluster)
                     id = resp_cluster["_id"]
                     name = resp_cluster["name"]
                     if id in self._clusters:
@@ -720,7 +719,12 @@ async def get_response_file(self, hash: str) -> ResponseFile:
             return ResponseFile(
                 0
             )
-        return await storage.get_response_file(hash)
+        try:
+            return await storage.get_response_file(hash)
+        except:
+            return ResponseFile(
+                0
+            )
 
     async def get_measure_file(self, size: int) -> ResponseFile:
         if not self.storages._online_storages:

core/web.py

@@ -65,7 +65,9 @@ async def pub_listener(
     )
 
     tls_listener = streams.AutoTLSListener(
-        listener,
+        streams.FixedSocketListener(
+            listener
+        ),
     )
     task_group.start_soon(serve, tls_listener)
 
@@ -92,7 +94,6 @@ async def pub_handler(
     except Exception as e:
         logger.debug_traceback()
 
-
 async def forward(
     sock: streams.BufferedByteStream,
     port: int,