Method validateRequest

datanode/bootstrap/bootstrap_server.go:529–548

(sessionID int64, nodeID string, table string, shard uint32)

}

func (p *PeerDataNodeServerImpl) validateRequest(sessionID int64, nodeID string, table string, shard uint32) error {
	if sessionID == 0 {
		return errNoSessionID
	}
	if len(nodeID) == 0 {
		return errNoCallerID
	}
	sessionInfo, err := p.getSession(sessionID)
	if err != nil {
		return err
	}
	if sessionInfo.nodeID != nodeID {
		return errInvalidRequset
	}

	if sessionInfo.table != table || sessionInfo.shardID != shard {
		return errInvalidRequset
	}
	return nil
}

// record new requested session
func (p *PeerDataNodeServerImpl) addSession(session *sessionInfo) {