You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
StartRequest(Subscriber) // Subscriber is the subscriber that *Shouldn't* be notified
FinishRequest(Subscriber) // Subscriber is the subscriber that *Shouldn't* be notified
// ChoosePeer should run the Peer.StartRequest and Peer.FinishRequest (through it's onFinish closure)
ChoosePeer(context.Context, *transport.Request) (p Peer, onFinish func(error), error)
This will allow the PeerLists to safely update their own internal state (within a lock) and remove the opportunity for a deadlock from the Notify.
The text was updated successfully, but these errors were encountered:
StartRequest(Subscriber) // Subscriber is the subscriber that *Shouldn't* be
notified
FinishRequest(Subscriber) // Subscriber is the subscriber that *Shouldn't* be notified
That's a weird interface. StartRequest(Subscriber) sounds like the complete
opposite of that.
Peer Interface Old world:
Peer Interface New World:
PeerList old ChoosePeer func:
PeerList New ChoosePeer func:
This will allow the PeerLists to safely update their own internal state (within a lock) and remove the opportunity for a deadlock from the Notify.
The text was updated successfully, but these errors were encountered: