- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 713 for startLine (0.48 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)