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

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

MockCommitProcessor() {
    super(new RequestProcessor() {
        public void processRequest(Request request)
                throws RequestProcessorException {
            processedRequests.offer(request);
        }

        public void shutdown() {
        }
    }, "0", false, new ZooKeeperServerListener() {

        @Override
        public void notifyStopping(String threadName, int errorCode) {
            Assert.fail("Commit processor crashed " + errorCode);
        }
    });
}

项目：SecureKeeper 文件：CommitProcessorConcurrencyTest.java

MockCommitProcessor() {
  super( 
          new RequestProcessor() {
              public void processRequest(Request request) 
                      throws RequestProcessorException {
                  executedFlag = true;
              }
              public void shutdown(){}
  },
  "0",
  false, new ZooKeeperServerListener(){

      @Override
      public void notifyStopping(String errMsg, int exitCode) {

      }});
}

项目：SecureKeeper 文件：CommitProcessorConcurrencyTest.java

MockCommitProcessor() {
  super( 
          new RequestProcessor() {
              public void processRequest(Request request) 
                      throws RequestProcessorException {
                  executedFlag = true;
              }
              public void shutdown(){}
  },
  "0",
  false, new ZooKeeperServerListener(){

      @Override
      public void notifyStopping(String errMsg, int exitCode) {

      }});
}

项目：fuck_zookeeper 文件：LearnerSessionTracker.java

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);

}

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

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);
    }
}

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

public void createLocalSessionTracker(SessionExpirer expirer,
        int tickTime, long id, ZooKeeperServerListener listener) {
    this.localSessionsWithTimeouts =
        new ConcurrentHashMap<Long, Integer>();
    this.localSessionTracker = new LocalSessionTracker(
        expirer, this.localSessionsWithTimeouts, tickTime, id, listener);
}

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

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;
}

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

ZooKeeperServerListener testZKSListener() {
    return new ZooKeeperServerListener() {

        @Override
        public void notifyStopping(String errMsg, int exitCode) {

        }
    };
}

项目：ZooKeeper 文件：LearnerSessionTracker.java

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);

}

项目：StreamProcessingInfrastructure 文件：LearnerSessionTracker.java

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);

}

项目：zookeeper 文件：LearnerSessionTracker.java

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);

}

项目：SecureKeeper 文件：LearnerSessionTracker.java

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);
    }
}

项目：SecureKeeper 文件：UpgradeableSessionTracker.java

public void createLocalSessionTracker(SessionExpirer expirer,
        int tickTime, long id, ZooKeeperServerListener listener) {
    this.localSessionsWithTimeouts =
        new ConcurrentHashMap<Long, Integer>();
    this.localSessionTracker = new LocalSessionTracker(
        expirer, this.localSessionsWithTimeouts, tickTime, id, listener);
}

项目：SecureKeeper 文件：LeaderSessionTracker.java

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;
}

项目：SecureKeeper 文件：SessionTrackerCheckTest.java

ZooKeeperServerListener testZKSListener() {
    return new ZooKeeperServerListener() {

        @Override
        public void notifyStopping(String errMsg, int exitCode) {

        }
    };
}

项目：SecureKeeper 文件：LearnerSessionTracker.java

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);
    }
}

项目：SecureKeeper 文件：UpgradeableSessionTracker.java

public void createLocalSessionTracker(SessionExpirer expirer,
        int tickTime, long id, ZooKeeperServerListener listener) {
    this.localSessionsWithTimeouts =
        new ConcurrentHashMap<Long, Integer>();
    this.localSessionTracker = new LocalSessionTracker(
        expirer, this.localSessionsWithTimeouts, tickTime, id, listener);
}

项目：SecureKeeper 文件：LeaderSessionTracker.java

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;
}

项目：SecureKeeper 文件：SessionTrackerCheckTest.java

ZooKeeperServerListener testZKSListener() {
    return new ZooKeeperServerListener() {

        @Override
        public void notifyStopping(String errMsg, int exitCode) {

        }
    };
}

项目：fuck_zookeeper 文件：CommitProcessor.java

public CommitProcessor(RequestProcessor nextProcessor, String id,
        boolean matchSyncs, ZooKeeperServerListener listener) {
    super("CommitProcessor:" + id, listener);
    this.nextProcessor = nextProcessor;
    this.matchSyncs = matchSyncs;
}

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

public CommitProcessor(RequestProcessor nextProcessor, String id,
                       boolean matchSyncs, ZooKeeperServerListener listener) {
    super("CommitProcessor:" + id, listener);
    this.nextProcessor = nextProcessor;
    this.matchSyncs = matchSyncs;
}

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

public LocalSessionTracker(SessionExpirer expirer,
        ConcurrentMap<Long, Integer> sessionsWithTimeouts,
        int tickTime, long id, ZooKeeperServerListener listener) {
    super(expirer, sessionsWithTimeouts, tickTime, id, listener);
}

项目：ZooKeeper 文件：CommitProcessor.java

public CommitProcessor(RequestProcessor nextProcessor, String id,
        boolean matchSyncs, ZooKeeperServerListener listener) {
    super("CommitProcessor:" + id, listener);
    this.nextProcessor = nextProcessor;
    this.matchSyncs = matchSyncs;
}

项目：StreamProcessingInfrastructure 文件：CommitProcessor.java

public CommitProcessor(RequestProcessor nextProcessor, String id,
        boolean matchSyncs, ZooKeeperServerListener listener) {
    super("CommitProcessor:" + id, listener);
    this.nextProcessor = nextProcessor;
    this.matchSyncs = matchSyncs;
}

项目：zookeeper 文件：CommitProcessor.java

public CommitProcessor(RequestProcessor nextProcessor, String id,
        boolean matchSyncs, ZooKeeperServerListener listener) {
    super("CommitProcessor:" + id, listener);
    this.nextProcessor = nextProcessor;
    this.matchSyncs = matchSyncs;
}

项目：SecureKeeper 文件：CommitProcessor.java

public CommitProcessor(RequestProcessor nextProcessor, String id,
                       boolean matchSyncs, ZooKeeperServerListener listener) {
    super("CommitProcessor:" + id, listener);
    this.nextProcessor = nextProcessor;
    this.matchSyncs = matchSyncs;
}

项目：SecureKeeper 文件：LocalSessionTracker.java

public LocalSessionTracker(SessionExpirer expirer,
        ConcurrentMap<Long, Integer> sessionsWithTimeouts,
        int tickTime, long id, ZooKeeperServerListener listener) {
    super(expirer, sessionsWithTimeouts, tickTime, id, listener);
}

项目：SecureKeeper 文件：CommitProcessor.java

public CommitProcessor(RequestProcessor nextProcessor, String id,
                       boolean matchSyncs, ZooKeeperServerListener listener) {
    super("CommitProcessor:" + id, listener);
    this.nextProcessor = nextProcessor;
    this.matchSyncs = matchSyncs;
}

项目：SecureKeeper 文件：LocalSessionTracker.java

public LocalSessionTracker(SessionExpirer expirer,
        ConcurrentMap<Long, Integer> sessionsWithTimeouts,
        int tickTime, long id, ZooKeeperServerListener listener) {
    super(expirer, sessionsWithTimeouts, tickTime, id, listener);
}