We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4251795 commit 26f6d7dCopy full SHA for 26f6d7d
src/aleph/services/p2p/protocol.py
@@ -32,7 +32,7 @@ async def incoming_channel(
32
peer_id,
33
)
34
35
- # we should check the sender here to avoid spam
+ # We should check the sender here to avoid spam
36
# and such things...
37
try:
38
message_dict = await decode_pubsub_message(message.body)
@@ -42,7 +42,8 @@ async def incoming_channel(
42
message_dict["item_hash"],
43
message_dict["signature"],
44
) in seen_hashes:
45
- await message.ack()
+ # Messages are already ACKed on underlying implementation in p2p_client.receive_messages()
46
+ # if the process don't have issues
47
continue
48
49
seen_hashes.append(
0 commit comments