LearnerSessionTracker.java 文件源码

public void setOwner(long sessionId, Object owner)
        throws SessionExpiredException {
    if (localSessionTracker != null) {
        try {
            localSessionTracker.setOwner(sessionId, owner);
            return;
        } catch (SessionExpiredException e) {
            // Check whether it's a global session. We can ignore those
            // because they are handled at the leader, but if not, rethrow.
            // We check local session status first to avoid race condition
            // with session upgrading.
            if (!isGlobalSession(sessionId)) {
                throw e;
            }
        }
    }
}