Java 类org.apache.zookeeper.KeeperException.SessionMovedException 实例源码

项目：https-github.com-apache-zookeeper 文件：LearnerSessionTracker.java

public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException  {
    if (localSessionTracker != null) {
        try {
            localSessionTracker.checkSession(sessionId, owner);
            return;
        } catch (UnknownSessionException 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 new SessionExpiredException();
            }
        }
    }
}

项目：SecureKeeper 文件：LearnerSessionTracker.java

public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException  {
    if (localSessionTracker != null) {
        try {
            localSessionTracker.checkSession(sessionId, owner);
            return;
        } catch (UnknownSessionException 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 new SessionExpiredException();
            }
        }
    }
}

项目：SecureKeeper 文件：LearnerSessionTracker.java

public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException  {
    if (localSessionTracker != null) {
        try {
            localSessionTracker.checkSession(sessionId, owner);
            return;
        } catch (UnknownSessionException 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 new SessionExpiredException();
            }
        }
    }
}

项目：https-github.com-apache-zookeeper 文件：LeaderSessionTracker.java

public void checkGlobalSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    try {
        globalSessionTracker.checkSession(sessionId, owner);
    } catch (UnknownSessionException e) {
        // For global session, if we don't know it, it is already expired
        throw new SessionExpiredException();
    }
}

项目：SecureKeeper 文件：LeaderSessionTracker.java

public void checkGlobalSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    try {
        globalSessionTracker.checkSession(sessionId, owner);
    } catch (UnknownSessionException e) {
        // For global session, if we don't know it, it is already expired
        throw new SessionExpiredException();
    }
}

项目：SecureKeeper 文件：LeaderSessionTracker.java

public void checkGlobalSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    try {
        globalSessionTracker.checkSession(sessionId, owner);
    } catch (UnknownSessionException e) {
        // For global session, if we don't know it, it is already expired
        throw new SessionExpiredException();
    }
}

项目：fuck_zookeeper 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub

}

项目：https-github.com-apache-zookeeper 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub
}

项目：https-github.com-apache-zookeeper 文件：PrepRequestProcessorTest.java

@Override
public void checkGlobalSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub
}

项目：ZooKeeper 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub

}

项目：StreamProcessingInfrastructure 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub

}

项目：bigstreams 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub

}

项目：zookeeper 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub

}

项目：SecureKeeper 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub
}

项目：SecureKeeper 文件：PrepRequestProcessorTest.java

@Override
public void checkGlobalSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub
}

项目：SecureKeeper 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub
}

项目：SecureKeeper 文件：PrepRequestProcessorTest.java

@Override
public void checkGlobalSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub
}

项目：StreamBench 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub

}

项目：LoadBalanced_zk 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub

}

项目：LoadBalanced_zk 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub

}

项目：zookeeper-pkg 文件：PrepRequestProcessorTest.java

@Override
public void checkSession(long sessionId, Object owner)
        throws SessionExpiredException, SessionMovedException {
    // TODO Auto-generated method stub

}

项目：https-github.com-apache-zookeeper 文件：SessionTracker.java

/**
 * Checks whether the SessionTracker is aware of this session, the session
 * is still active, and the owner matches. If the owner wasn't previously
 * set, this sets the owner of the session.
 *
 * UnknownSessionException should never been thrown to the client. It is
 * only used internally to deal with possible local session from other
 * machine
 *
 * @param sessionId
 * @param owner
 */
public void checkSession(long sessionId, Object owner)
        throws KeeperException.SessionExpiredException,
        KeeperException.SessionMovedException,
        KeeperException.UnknownSessionException;

项目：https-github.com-apache-zookeeper 文件：SessionTracker.java

/**
 * Strictly check that a given session is a global session or not
 * @param sessionId
 * @param owner
 * @throws KeeperException.SessionExpiredException
 * @throws KeeperException.SessionMovedException
 */
public void checkGlobalSession(long sessionId, Object owner)
        throws KeeperException.SessionExpiredException,
        KeeperException.SessionMovedException;

项目：SecureKeeper 文件：SessionTracker.java

/**
 * Checks whether the SessionTracker is aware of this session, the session
 * is still active, and the owner matches. If the owner wasn't previously
 * set, this sets the owner of the session.
 *
 * UnknownSessionException should never been thrown to the client. It is
 * only used internally to deal with possible local session from other
 * machine
 *
 * @param sessionId
 * @param owner
 */
public void checkSession(long sessionId, Object owner)
        throws KeeperException.SessionExpiredException,
        KeeperException.SessionMovedException,
        KeeperException.UnknownSessionException;

项目：SecureKeeper 文件：SessionTracker.java

/**
 * Strictly check that a given session is a global session or not
 * @param sessionId
 * @param owner
 * @throws KeeperException.SessionExpiredException
 * @throws KeeperException.SessionMovedException
 */
public void checkGlobalSession(long sessionId, Object owner)
        throws KeeperException.SessionExpiredException,
        KeeperException.SessionMovedException;

项目：SecureKeeper 文件：SessionTracker.java

/**
 * Checks whether the SessionTracker is aware of this session, the session
 * is still active, and the owner matches. If the owner wasn't previously
 * set, this sets the owner of the session.
 *
 * UnknownSessionException should never been thrown to the client. It is
 * only used internally to deal with possible local session from other
 * machine
 *
 * @param sessionId
 * @param owner
 */
public void checkSession(long sessionId, Object owner)
        throws KeeperException.SessionExpiredException,
        KeeperException.SessionMovedException,
        KeeperException.UnknownSessionException;

项目：SecureKeeper 文件：SessionTracker.java

/**
 * Strictly check that a given session is a global session or not
 * @param sessionId
 * @param owner
 * @throws KeeperException.SessionExpiredException
 * @throws KeeperException.SessionMovedException
 */
public void checkGlobalSession(long sessionId, Object owner)
        throws KeeperException.SessionExpiredException,
        KeeperException.SessionMovedException;

项目：fuck_zookeeper 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：ZooKeeper 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：StreamProcessingInfrastructure 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：bigstreams 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：bigstreams 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：zookeeper-src-learning 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：zookeeper 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：StreamBench 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：ACaZoo 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：LoadBalanced_zk 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：LoadBalanced_zk 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：zookeeper.dsc 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;

项目：zookeeper-pkg 文件：SessionTracker.java

void checkSession(long sessionId, Object owner) throws KeeperException.SessionExpiredException, SessionMovedException;