retrieve session info using session id
(sessionID int64)
| 587 | |
| 588 | // retrieve session info using session id |
| 589 | func (p *PeerDataNodeServerImpl) getSession(sessionID int64) (*sessionInfo, error) { |
| 590 | p.RLock() |
| 591 | defer p.RUnlock() |
| 592 | |
| 593 | session, ok := p.sessions[sessionID] |
| 594 | if !ok { |
| 595 | return nil, errInvalidSessionID |
| 596 | } |
| 597 | return session, nil |
| 598 | } |
| 599 | |
| 600 | // check if request table/shard is valid |
| 601 | func (p *PeerDataNodeServerImpl) validateTable(tableName string, shardID uint32) error { |
no test coverage detected