diff --git a/mixing/mixpool/mixpool.go b/mixing/mixpool/mixpool.go index bf95cee15..6c00e58ab 100644 --- a/mixing/mixpool/mixpool.go +++ b/mixing/mixpool/mixpool.go @@ -1404,7 +1404,7 @@ func (p *Pool) acceptKE(ke *wire.MsgMixKeyExchange, hash *chainhash.Hash, id *id sid := ke.SessionID ses := p.sessions[sid] - // Create a session for the first run-0 KE + // Create a session for the first KE if ses == nil { expiry := ^uint32(0) for i := range prs { @@ -1415,6 +1415,7 @@ func (p *Pool) acceptKE(ke *wire.MsgMixKeyExchange, hash *chainhash.Hash, id *id } ses = &session{ sid: sid, + prs: ke.SeenPRs, expiry: expiry, hashes: make(map[chainhash.Hash]struct{}), bc: broadcast{ch: make(chan struct{})},