- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of about 10,000 for emptied (0.31 sec)
-
src/runtime/arena_test.go
t.Fatal("finalizer queue was never emptied") } } else { // Free the arena explicitly. arena.Free() } // Try to queue the object's finalizer that we set earlier. GC() GC() if !BlockUntilEmptyFinalizerQueue(int64(2 * time.Second)) { t.Fatal("finalizer queue was never emptied") } if !finalized.Load() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 13.4K bytes - Viewed (0) -
platforms/core-execution/execution-e2e-tests/src/integTest/groovy/org/gradle/integtests/StaleOutputIntegrationTest.groovy
import spock.lang.Issue class StaleOutputIntegrationTest extends AbstractIntegrationSpec { @Issue(['GRADLE-2440', 'GRADLE-2579']) def 'stale output file is removed after input source directory is emptied.'() { def taskWithSources = new TaskWithSources() taskWithSources.createInputs() buildScript(taskWithSources.buildScript) when: succeeds(taskWithSources.taskPath)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 04 10:15:40 UTC 2024 - 23K bytes - Viewed (0) -
src/runtime/mfinal.go
return true } } return false } // blockUntilEmptyFinalizerQueue blocks until either the finalizer // queue is emptied (and the finalizers have executed) or the timeout // is reached. Returns true if the finalizer queue was emptied. // This is used by the runtime and sync tests. func blockUntilEmptyFinalizerQueue(timeout int64) bool { start := nanotime() for nanotime()-start < timeout {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 01:56:56 UTC 2024 - 19K bytes - Viewed (0) -
src/internal/poll/splice_linux.go
} return written, true, nil } // spliceDrain moves data from a socket to a pipe. // // Invariant: when entering spliceDrain, the pipe is empty. It is either in its // initial state, or splicePump has emptied it previously. // // Given this, spliceDrain can reasonably assume that the pipe is ready for // writing, so if splice returns EAGAIN, it must be because the socket is not // ready for reading. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
case nodeUpdate := <-tc.nodeUpdateChannels[worker]: tc.handleNodeUpdate(ctx, nodeUpdate) tc.nodeUpdateQueue.Done(nodeUpdate) default: break priority } } // After Node queue is emptied we process podUpdate. tc.handlePodUpdate(ctx, podUpdate) tc.podUpdateQueue.Done(podUpdate) } } } // PodUpdated is used to notify NoExecuteTaintManager about Pod changes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
src/runtime/mgclimit.go
l.enabled.Store(true) l.lastEnabledCycle.Store(memstats.numgc + 1) } return } // Handle non-limiting cases. if change < 0 && l.bucket.fill <= uint64(-change) { // Bucket emptied. l.bucket.fill = 0 } else { // All other cases. l.bucket.fill -= uint64(-change) } if change != 0 && enabled { l.enabled.Store(false) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 22:07:41 UTC 2024 - 17.3K bytes - Viewed (0) -
cmd/metacache-entries.go
} // mergeEntryChannels will merge entries from in and return them sorted on out. // To signify no more results are on an input channel, close it. // The output channel will be closed when all inputs are emptied. // If file names are equal, compareMeta is called to select which one to choose. // The entry not chosen will be discarded. // If the context is canceled the function will return the error,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 04:34:26 UTC 2024 - 24K bytes - Viewed (0) -
src/encoding/json/encode.go
var encodeStatePool sync.Pool func newEncodeState() *encodeState { if v := encodeStatePool.Get(); v != nil { e := v.(*encodeState) e.Reset() if len(e.ptrSeen) > 0 { panic("ptrEncoder.encode should have emptied ptrSeen via defers") } e.ptrLevel = 0 return e } return &encodeState{ptrSeen: make(map[any]struct{})} } // jsonError is an error wrapper type for internal use only.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:55 UTC 2024 - 36.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go
return e.DefaultQualifiedResource } var ( errAlreadyDeleting = fmt.Errorf("abort delete") errDeleteNow = fmt.Errorf("delete now") errEmptiedFinalizers = fmt.Errorf("emptied finalizers") ) // shouldOrphanDependents returns true if the finalizer for orphaning should be set // updated for FinalizerOrphanDependents. In the order of highest to lowest
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 23:22:44 UTC 2024 - 60.8K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
t.Fatalf("%s: expected exactly 1 retry, got %d", job.Name, retries) } // await for the actual requeue after processing of the pending queue is done awaitForQueueLen(ctx, t, manager, 1) // the queue is emptied on success fakePodControl.Err = nil manager.processNextWorkItem(context.TODO()) verifyEmptyQueue(ctx, t, manager) } var _ workqueue.TypedRateLimitingInterface[string] = &fakeRateLimitingQueue{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)