Method findSession

proxy/proxy.go:341–350

(version primitive.ProtocolVersion, keyspace, compression string)

}

func (p *Proxy) findSession(version primitive.ProtocolVersion, keyspace, compression string) (*proxycore.Session, error) {
	p.sessionsMu.RLock()
	defer p.sessionsMu.RUnlock()
	key := sessionKey{version: version, keyspace: keyspace, compression: compression}
	if s, ok := p.sessions[key]; ok {
		return s, nil
	} else {
		return p.maybeCreateSessionUnlocked(version, keyspace, compression)
	}
}

func (p *Proxy) maybeCreateSessionUnlocked(version primitive.ProtocolVersion, keyspace, compression string) (*proxycore.Session, error) {
	key := sessionKey{version: version, keyspace: keyspace, compression: compression}