Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 713 for startLine (0.48 sec)

  1. guava/src/com/google/common/util/concurrent/Monitor.java

          return 0L;
        } else {
          long startTime = System.nanoTime();
          return (startTime == 0L) ? 1L : startTime;
        }
      }
    
      /**
       * Returns the remaining nanos until the given timeout, or 0L if the timeout has already elapsed.
       * Caller must have previously sanitized timeoutNanos using toSafeNanos.
       */
      private static long remainingNanos(long startTime, long timeoutNanos) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Dec 04 18:22:01 UTC 2023
    - 42.5K bytes
    - Viewed (0)
  2. pkg/controller/volume/pvcprotection/pvc_protection_controller.go

    	logger := klog.FromContext(ctx)
    	logger.V(4).Info("Processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName))
    	startTime := time.Now()
    	defer func() {
    		logger.V(4).Info("Finished processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName), "duration", time.Since(startTime))
    	}()
    
    	pvc, err := c.pvcLister.PersistentVolumeClaims(pvcNamespace).Get(pvcName)
    	if apierrors.IsNotFound(err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 14K bytes
    - Viewed (0)
  3. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go

    func (c *Controller) syncEndpoints(logger klog.Logger, key string) error {
    	startTime := time.Now()
    	defer func() {
    		syncDuration := float64(time.Since(startTime).Milliseconds()) / 1000
    		metrics.EndpointsSyncDuration.WithLabelValues().Observe(syncDuration)
    		logger.V(4).Info("Finished syncing EndpointSlices for Endpoints", "key", key, "elapsedTime", time.Since(startTime))
    	}()
    
    	logger.V(4).Info("syncEndpoints", "key", key)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 23:18:31 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  4. platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/junit/result/JUnitXmlResultWriterSpec.groovy

            result.add(new TestMethodResult(1, "some test", "some test displayName", SUCCESS, 15, startTime + 25))
            result.add(new TestMethodResult(2, "some test two", "some test two displayName", SUCCESS, 15, startTime + 30))
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Mar 25 18:51:05 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  5. pkg/kubelet/status/status_manager.go

    	}
    
    	// ensure that the start time does not change across updates.
    	if oldStatus.StartTime != nil && !oldStatus.StartTime.IsZero() {
    		status.StartTime = oldStatus.StartTime
    	} else if status.StartTime.IsZero() {
    		// if the status has no start time, we need to set an initial time
    		now := metav1.Now()
    		status.StartTime = &now
    	}
    
    	normalizeStatus(pod, &status)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
  6. platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/server/health/gc/GarbageCollectionMonitoringIntegrationTest.groovy

            events.each { Map event ->
                builder.append("${getter}.slideAndInsert(new GarbageCollectionEvent(startTime + ${fromSeconds(event.timeOffset)}, ${usageFrom(initial, max, event.poolUsage)}, ${event.gcCount}))\n")
            }
            return builder.toString()
        }
    
        /**
         * Generates garbage collection events starting at initial heap size (MB) and increasing by
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  7. 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)
  8. src/cmd/trace/gen.go

    	// Collect information about the task.
    	var startStack, endStack trace.Stack
    	var startG, endG trace.GoID
    	startTime, endTime := ctx.startTime, ctx.endTime
    	if task.Start != nil {
    		startStack = task.Start.Stack()
    		startG = task.Start.Goroutine()
    		startTime = task.Start.Time()
    	}
    	if task.End != nil {
    		endStack = task.End.Stack()
    		endG = task.End.Goroutine()
    		endTime = task.End.Time()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top