(version primitive.ProtocolVersion, keyspace, compression string)
| 333 | } |
| 334 | |
| 335 | func (p *Proxy) maybeCreateSession(version primitive.ProtocolVersion, keyspace, compression string) (*proxycore.Session, error) { |
| 336 | p.sessionsMu.RLock() |
| 337 | defer p.sessionsMu.RUnlock() |
| 338 | return p.maybeCreateSessionUnlocked(version, keyspace, compression) |
| 339 | } |
| 340 | |
| 341 | func (p *Proxy) findSession(version primitive.ProtocolVersion, keyspace, compression string) (*proxycore.Session, error) { |
| 342 | p.sessionsMu.RLock() |
no test coverage detected