Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 562 for startingAt (0.37 sec)

  1. android/guava/src/com/google/common/util/concurrent/AbstractService.java

              case NEW:
                snapshot = new StateSnapshot(TERMINATED);
                enqueueTerminatedEvent(NEW);
                break;
              case STARTING:
                snapshot = new StateSnapshot(STARTING, true, null);
                enqueueStoppingEvent(STARTING);
                doCancelStart();
                break;
              case RUNNING:
                snapshot = new StateSnapshot(STOPPING);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt

          "FINE: Q10000 scheduled after 100 µs: task",
          "FINE: Q10000 starting              : task",
          "FINE: Q10000 run again after  50 µs: task",
          "FINE: Q10000 finished run in   0 µs: task",
          "FINE: Q10000 starting              : task",
          "FINE: Q10000 run again after 150 µs: task",
          "FINE: Q10000 finished run in   0 µs: task",
          "FINE: Q10000 starting              : task",
          "FINE: Q10000 finished run in   0 µs: task",
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 23K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractService.java

              case NEW:
                snapshot = new StateSnapshot(TERMINATED);
                enqueueTerminatedEvent(NEW);
                break;
              case STARTING:
                snapshot = new StateSnapshot(STARTING, true, null);
                enqueueStoppingEvent(STARTING);
                doCancelStart();
                break;
              case RUNNING:
                snapshot = new StateSnapshot(STOPPING);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

          }
        }
    
        @Override
        public synchronized void starting() {
          assertTrue(stateHistory.isEmpty());
          assertNotSame(State.NEW, service.state());
          stateHistory.add(State.STARTING);
        }
    
        @Override
        public synchronized void running() {
          assertEquals(State.STARTING, Iterables.getOnlyElement(stateHistory));
          stateHistory.add(State.RUNNING);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 29.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

          }
        }
    
        @Override
        public synchronized void starting() {
          assertTrue(stateHistory.isEmpty());
          assertNotSame(State.NEW, service.state());
          stateHistory.add(State.STARTING);
        }
    
        @Override
        public synchronized void running() {
          assertEquals(State.STARTING, Iterables.getOnlyElement(stateHistory));
          stateHistory.add(State.RUNNING);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 29.3K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/Service.java

        /**
         * Called when the service transitions from {@linkplain State#NEW NEW} to {@linkplain
         * State#STARTING STARTING}. This occurs when {@link Service#startAsync} is called the first
         * time.
         */
        public void starting() {}
    
        /**
         * Called when the service transitions from {@linkplain State#STARTING STARTING} to {@linkplain
         * State#RUNNING RUNNING}. This occurs when a service has successfully started.
         */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/Service.java

        /**
         * Called when the service transitions from {@linkplain State#NEW NEW} to {@linkplain
         * State#STARTING STARTING}. This occurs when {@link Service#startAsync} is called the first
         * time.
         */
        public void starting() {}
    
        /**
         * Called when the service transitions from {@linkplain State#STARTING STARTING} to {@linkplain
         * State#RUNNING RUNNING}. This occurs when a service has successfully started.
         */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  8. pkg/kubelet/volumemanager/reconciler/reconciler_common.go

    		if !rc.desiredStateOfWorld.PodExistsInVolume(mountedVolume.PodName, mountedVolume.VolumeName, mountedVolume.SELinuxMountContext) {
    			// Volume is mounted, unmount it
    			klog.V(5).InfoS(mountedVolume.GenerateMsgDetailed("Starting operationExecutor.UnmountVolume", ""))
    			err := rc.operationExecutor.UnmountVolume(
    				mountedVolume.MountedVolume, rc.actualStateOfWorld, rc.kubeletPodsDir)
    			if err != nil && !isExpectedError(err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:23:12 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ServiceManager.java

          this.state = state;
        }
    
        @Override
        public void starting() {
          ServiceManagerState state = this.state.get();
          if (state != null) {
            state.transitionService(service, NEW, STARTING);
            if (!(service instanceof NoOpService)) {
              logger.get().log(Level.FINE, "Starting {0}.", service);
            }
          }
        }
    
        @Override
        public void running() {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:41:16 UTC 2024
    - 33K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

          this.state = state;
        }
    
        @Override
        public void starting() {
          ServiceManagerState state = this.state.get();
          if (state != null) {
            state.transitionService(service, NEW, STARTING);
            if (!(service instanceof NoOpService)) {
              logger.get().log(Level.FINE, "Starting {0}.", service);
            }
          }
        }
    
        @Override
        public void running() {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:41:16 UTC 2024
    - 31.1K bytes
    - Viewed (0)
Back to top