Java 类org.apache.zookeeper.server.SessionTrackerImpl 实例源码

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id,
        ZooKeeperServerListener listener) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentMap<Long, Integer> sessionsWithTimeouts,
        int tickTime, long id, boolean localSessionsEnabled,
        ZooKeeperServerListener listener) {
    this.expirer = expirer;
    this.touchTable.set(new ConcurrentHashMap<Long, Integer>());
    this.globalSessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId.set(SessionTrackerImpl.initializeNextSession(serverId));

    this.localSessionsEnabled = localSessionsEnabled;
    if (this.localSessionsEnabled) {
        createLocalSessionTracker(expirer, tickTime, id, listener);
    }
}

public LeaderSessionTracker(SessionExpirer expirer,
        ConcurrentMap<Long, Integer> sessionsWithTimeouts,
        int tickTime, long id, boolean localSessionsEnabled,
        ZooKeeperServerListener listener) {

    this.globalSessionTracker = new SessionTrackerImpl(
        expirer, sessionsWithTimeouts, tickTime, id, listener);

    this.localSessionsEnabled = localSessionsEnabled;
    if (this.localSessionsEnabled) {
        createLocalSessionTracker(expirer, tickTime, id, listener);
    }
    serverId = id;
}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id,
        ZooKeeperServerListener listener) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id,
        ZooKeeperServerListener listener) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id,
        ZooKeeperServerListener listener) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentMap<Long, Integer> sessionsWithTimeouts,
        int tickTime, long id, boolean localSessionsEnabled,
        ZooKeeperServerListener listener) {
    this.expirer = expirer;
    this.touchTable.set(new ConcurrentHashMap<Long, Integer>());
    this.globalSessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId.set(SessionTrackerImpl.initializeNextSession(serverId));

    this.localSessionsEnabled = localSessionsEnabled;
    if (this.localSessionsEnabled) {
        createLocalSessionTracker(expirer, tickTime, id, listener);
    }
}

public LeaderSessionTracker(SessionExpirer expirer,
        ConcurrentMap<Long, Integer> sessionsWithTimeouts,
        int tickTime, long id, boolean localSessionsEnabled,
        ZooKeeperServerListener listener) {

    this.globalSessionTracker = new SessionTrackerImpl(
        expirer, sessionsWithTimeouts, tickTime, id, listener);

    this.localSessionsEnabled = localSessionsEnabled;
    if (this.localSessionsEnabled) {
        createLocalSessionTracker(expirer, tickTime, id, listener);
    }
    serverId = id;
}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentMap<Long, Integer> sessionsWithTimeouts,
        int tickTime, long id, boolean localSessionsEnabled,
        ZooKeeperServerListener listener) {
    this.expirer = expirer;
    this.touchTable.set(new ConcurrentHashMap<Long, Integer>());
    this.globalSessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId.set(SessionTrackerImpl.initializeNextSession(serverId));

    this.localSessionsEnabled = localSessionsEnabled;
    if (this.localSessionsEnabled) {
        createLocalSessionTracker(expirer, tickTime, id, listener);
    }
}

public LeaderSessionTracker(SessionExpirer expirer,
        ConcurrentMap<Long, Integer> sessionsWithTimeouts,
        int tickTime, long id, boolean localSessionsEnabled,
        ZooKeeperServerListener listener) {

    this.globalSessionTracker = new SessionTrackerImpl(
        expirer, sessionsWithTimeouts, tickTime, id, listener);

    this.localSessionsEnabled = localSessionsEnabled;
    if (this.localSessionsEnabled) {
        createLocalSessionTracker(expirer, tickTime, id, listener);
    }
    serverId = id;
}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

public LearnerSessionTracker(SessionExpirer expirer,
        ConcurrentHashMap<Long, Integer> sessionsWithTimeouts, long id) {
    this.expirer = expirer;
    this.sessionsWithTimeouts = sessionsWithTimeouts;
    this.serverId = id;
    nextSessionId = SessionTrackerImpl.initializeNextSession(this.serverId);

}

@Override
public void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase()
            .getSessionWithTimeOuts(), tickTime, self.getId(),
            getZooKeeperServerListener());
}

@Override
protected void startSessionTracker() {
    ((SessionTrackerImpl)sessionTracker).start();
}

@Override
public void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase()
            .getSessionWithTimeOuts(), tickTime, self.getId(),
            getZooKeeperServerListener());
}

@Override
protected void startSessionTracker() {
    ((SessionTrackerImpl)sessionTracker).start();
}

@Override
public void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase()
            .getSessionWithTimeOuts(), tickTime, self.getId(),
            getZooKeeperServerListener());
}

@Override
protected void startSessionTracker() {
    ((SessionTrackerImpl)sessionTracker).start();
}

@Override
public void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase().getSessionWithTimeOuts(),
            tickTime, self.getId());
}

@Override
protected void startSessionTracker() {
    ((SessionTrackerImpl)sessionTracker).start();
}

@Override
protected void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase().getSessionWithTimeOuts(),
            tickTime, self.getId());
    ((SessionTrackerImpl)sessionTracker).start();
}

@Override
public void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase().getSessionWithTimeOuts(),
            tickTime, self.getId());
}

@Override
protected void startSessionTracker() {
    ((SessionTrackerImpl)sessionTracker).start();
}

@Override
public void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase()
            .getSessionWithTimeOuts(), tickTime, self.getId(),
            getZooKeeperServerListener());
}

@Override
protected void startSessionTracker() {
    ((SessionTrackerImpl)sessionTracker).start();
}

@Override
public void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase().getSessionWithTimeOuts(),
            tickTime, self.getId());
}

@Override
protected void startSessionTracker() {
    ((SessionTrackerImpl)sessionTracker).start();
}

@Override
public void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase().getSessionWithTimeOuts(),
            tickTime, self.getId());
}

@Override
protected void startSessionTracker() {
    ((SessionTrackerImpl)sessionTracker).start();
}

@Override
public void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase().getSessionWithTimeOuts(),
            tickTime, self.getId());
}

@Override
protected void startSessionTracker() {
    ((SessionTrackerImpl)sessionTracker).start();
}

@Override
public void createSessionTracker() {
    sessionTracker = new SessionTrackerImpl(this, getZKDatabase().getSessionWithTimeOuts(),
            tickTime, self.getId());
}

@Override
protected void startSessionTracker() {
    ((SessionTrackerImpl)sessionTracker).start();
}