sessionwantlist

package

v0.2.13 Latest Latest Go to latest Published: Apr 23, 2020 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type SessionWantlist struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

The SessionWantList keeps track of which sessions want a CID

func NewSessionWantlist() *SessionWantlist

func (swl *SessionWantlist) Add(ks []cid.Cid, ses uint64)

The given session wants the keys

func (swl *SessionWantlist) Has(ks []cid.Cid) *cid.Set

Filter for keys that at least one session wants

func (swl *SessionWantlist) Keys() []cid.Cid

All keys wanted by all sessions

func (swl *SessionWantlist) RemoveKeys(ks []cid.Cid)

Remove the keys for all sessions. Called when blocks are received.

func (swl *SessionWantlist) RemoveSession(ses uint64) []cid.Cid

Remove the session's wants, and return wants that are no longer wanted by any session.

func (swl *SessionWantlist) RemoveSessionKeys(ses uint64, ks []cid.Cid)

Remove the session's wants

func (swl *SessionWantlist) SessionHas(ses uint64, ks []cid.Cid) *cid.Set

Filter for keys that the given session wants

func (swl *SessionWantlist) SessionsFor(ks []cid.Cid) []uint64

All sessions that want the given keys