private void initWatcher()

in server/src/jetbrains/buildServer/queueManager/server/FreeSpaceQueuePauser.java [88:102]

15 lines of code
2 McCabe index (conditional complexity)


  private void initWatcher() {
    int dswRepeatDelay = TeamCityProperties.getInteger("teamcity.diskSpaceWatcher.repeatDelay", 120 * 1000); // 120 seconds
    int qpRepeatDelay = TeamCityProperties.getInteger("teamcity.queuePauser.repeatDelay", dswRepeatDelay);
    qpRepeatDelay = Math.max(dswRepeatDelay + 1000, qpRepeatDelay); // no use updating more frequently than dsw
    if (myWatcher == null) {
      myWatcher = new Alarm("Queue pause/resume watcher");
      myWatcher.addRepeatableRequest(this::check, qpRepeatDelay, qpRepeatDelay);
      myDispatcher.addListener(new BuildServerAdapter() {
        @Override
        public void serverShutdown() {
          myWatcher.dispose();
        }
      });
    }
  }