mirror of
https://github.com/Chia-Network/chia-blockchain.git
synced 2026-08-24 10:05:29 -05:00
server: Drop unused send messages (#16215)
* Drop unused `WSChiaConnection.send_messages` * Drop unused `WSChiaConnection.send_to_others`
This commit is contained in:
@@ -554,19 +554,6 @@ class ChiaServer:
|
||||
if on_disconnect is not None:
|
||||
on_disconnect(connection)
|
||||
|
||||
async def send_to_others(
|
||||
self,
|
||||
messages: List[Message],
|
||||
node_type: NodeType,
|
||||
origin_peer: WSChiaConnection,
|
||||
) -> None:
|
||||
for node_id, connection in self.all_connections.items():
|
||||
if node_id == origin_peer.peer_node_id:
|
||||
continue
|
||||
if connection.connection_type is node_type:
|
||||
for message in messages:
|
||||
await connection.send_message(message)
|
||||
|
||||
async def validate_broadcast_message_type(self, messages: List[Message], node_type: NodeType) -> None:
|
||||
for message in messages:
|
||||
if message_requires_reply(ProtocolMessageTypes(message.type)):
|
||||
|
||||
@@ -570,12 +570,6 @@ class WSChiaConnection:
|
||||
|
||||
return result
|
||||
|
||||
async def send_messages(self, messages: List[Message]) -> None:
|
||||
if self.closed:
|
||||
return None
|
||||
for message in messages:
|
||||
await self.outgoing_queue.put(message)
|
||||
|
||||
async def _wait_and_retry(self, msg: Message) -> None:
|
||||
try:
|
||||
await asyncio.sleep(1)
|
||||
|
||||
Reference in New Issue
Block a user