- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 101 for bursty (0.14 sec)
-
guava/src/com/google/common/cache/LongAdder.java
s.defaultWriteObject(); s.writeLong(sum()); } private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException { s.defaultReadObject(); busy = 0; cells = null; base = s.readLong(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 5.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonServices.java
new CleanUpVirtualFileSystemAfterBuild(executorFactory, userHomeServiceRegistry), new ReturnResult(), new StartBuildOrRespondWithBusy(daemonDiagnostics), // from this point down, the daemon is 'busy' new EstablishBuildEnvironment(processEnvironment), new LogToClient(loggingManager, daemonDiagnostics), // from this point down, logging is sent back to the client
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 9.7K bytes - Viewed (0) -
cmd/metrics-v3-system-drive.go
driveWritesAwaitMD = NewGaugeMD(driveWritesAwait, "Average time for write requests served on a drive", allDriveLabels...) drivePercUtilMD = NewGaugeMD(drivePercUtil, "Percentage of time the disk was busy", allDriveLabels...) ) func getCurrentDriveIOStats() map[string]madmin.DiskIOStats { var types madmin.MetricType = madmin.MetricsDisk driveRealtimeMetrics := collectLocalMetrics(types, collectMetricsOpts{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun May 12 17:23:50 UTC 2024 - 7.9K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LongAdder.java
s.defaultWriteObject(); s.writeLong(sum()); } private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException { s.defaultReadObject(); busy = 0; cells = null; base = s.readLong(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 5.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/AbstractDaemonLifecycleSpec.groovy
run { doDaemonContext(foregroundDaemons[num], assertions) } } void doDaemonContext(gradleHandle, Closure assertions) { // poll here since even though the daemon has been marked as busy in the registry, the context may not have been // flushed to the log yet. DaemonContext context poll(5) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 13:32:55 UTC 2024 - 7.1K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/IncrementalBuildSymlinkHandlingIntegrationTest.groovy
executer.requireDaemon() executer.requireIsolatedDaemons() buildFile << """ // This is a workaround to bust the JVM's file canonicalization cache def f = file("delete-me") f.createNewFile() f.delete() // invalidates cache task work { inputs.file('in.txt') inputs.dir('in-dir') def outTxt = file('out.txt')
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 01 14:30:36 UTC 2024 - 8K bytes - Viewed (0) -
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager.go
ctbInformer: bundles.Informer(), ctbLister: bundles.Lister(), normalizationCache: lrucache.NewLRUExpireCache(cacheSize), cacheTTL: cacheTTL, } // Have the informer bust cache entries when it sees updates that could // apply to them. _, err := m.ctbInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj any) { ctb, ok := obj.(*certificatesv1alpha1.ClusterTrustBundle)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 8.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/registry/PersistentDaemonRegistry.java
lock.unlock(); } } @Override public void markState(final Address address, final State state) { lock.lock(); try { LOGGER.debug("Marking busy by address: {}", address); cache.update(new ObjectHolder.UpdateAction<DaemonRegistryContent>() { @Override public DaemonRegistryContent update(DaemonRegistryContent oldValue) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 8.9K bytes - Viewed (0) -
internal/config/cache/cache.go
} buf, err := r.MarshalMsg(nil) if err != nil { return nil, err } // We do not want Gets to take so much time, anything // beyond 250ms we should cut it, remote cache is too // busy already. ctx, cancel := context.WithTimeout(context.Background(), 250*time.Millisecond) defer cancel() req, err := http.NewRequestWithContext(ctx, http.MethodPost, c.Endpoint+mcacheV1Check, bytes.NewReader(buf))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
if (activeTask == null && futureTasks.isEmpty()) { return CountDownLatch(0) } // If there's an existing AwaitIdleTask, use it. This is necessary when the executor is // shutdown but still busy as we can't enqueue in that case. val existingTask = activeTask if (existingTask is AwaitIdleTask) { return existingTask.latch } for (futureTask in futureTasks) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0)