diff --git a/hbs2-peer/app/RPC2/Poll.hs b/hbs2-peer/app/RPC2/Poll.hs index ec895721..2d0082b2 100644 --- a/hbs2-peer/app/RPC2/Poll.hs +++ b/hbs2-peer/app/RPC2/Poll.hs @@ -24,7 +24,9 @@ instance (MonadIO m, HasRpcContext PeerAPI RPC2Context m) => HandleMethod m RpcP handleMethod (r,t,i) = do brains <- getRpcContext @PeerAPI <&> rpcBrains debug $ "rpc.pollAdd" - addPolledRef @L4Proto brains r t i + polled <- isPolledRef @L4Proto brains t r + unless polled do + addPolledRef @L4Proto brains r t i instance (MonadIO m, HasRpcContext PeerAPI RPC2Context m) => HandleMethod m RpcPollDel where