- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 858 for syncAt (0.52 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/AsyncDispatchTest.groovy
message1: { parallel.syncAt(1) parallel.syncAt(2) }, message3: { parallel.syncAt(3) }) Dispatch<String> target2 = new DispatchStub( message2: { parallel.syncAt(2) parallel.syncAt(3) }) when: parallel.run {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 6.5K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
* have called {@link #syncAt(int)} or {@link #expectBlocksUntil(int, groovy.lang.Closure)} with the given tick, and * there are least 2 test threads. * * @param tick The expected clock tick */ public void syncAt(int tick) { LOGGER.debug("Thread {} synching at tick {}", Thread.currentThread(), tick);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
pkg/kube/krt/sync.go
import "istio.io/istio/pkg/kube" type Syncer interface { WaitUntilSynced(stop <-chan struct{}) bool HasSynced() bool } var ( _ Syncer = channelSyncer{} _ Syncer = pollSyncer{} ) type channelSyncer struct { name string synced <-chan struct{} } func (c channelSyncer) WaitUntilSynced(stop <-chan struct{}) bool { return waitForCacheSync(c.name, stop, c.synced) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 03 14:25:07 UTC 2024 - 1.8K bytes - Viewed (0) -
pkg/kube/krt/join.go
return res } func (j *join[T]) Register(f func(o Event[T])) Syncer { return registerHandlerAsBatched[T](j, f) } func (j *join[T]) RegisterBatch(f func(o []Event[T], initialSync bool), runExistingState bool) Syncer { sync := multiSyncer{} for _, c := range j.collections { sync.syncers = append(sync.syncers, c.RegisterBatch(f, runExistingState)) } return sync } // nolint: unused // (not true, its to implement an interface)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 3.3K bytes - Viewed (0) -
testing/integ-test/src/integTest/groovy/org/gradle/integtests/SyncTaskIntegrationTest.groovy
then: executedAndNotSkipped ':sync' } @NotYetImplemented def 'sync is not up to date when files are added to the destination dir'() { given: defaultSourceFileTree() file('dest').create {} buildScript ''' task sync(type: Sync) { from 'source' into 'dest' }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 18.9K bytes - Viewed (0) -
pkg/kube/krt/static.go
return maps.Values(s.vals) } func (s *staticList[T]) Register(f func(o Event[T])) Syncer { return registerHandlerAsBatched(s, f) } func (s *staticList[T]) Synced() Syncer { return alwaysSynced{} } func (s *staticList[T]) RegisterBatch(f func(o []Event[T], initialSync bool), runExistingState bool) Syncer { if runExistingState { f(slices.Map(s.List(), func(e T) Event[T] { return Event[T]{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/kube/krt/collection.go
type multiIndex[I, O any] struct { outputs map[Key[O]]O inputs map[Key[I]]I mappings map[Key[I]]sets.Set[Key[O]] } func (h *manyCollection[I, O]) Synced() Syncer { return channelSyncer{ name: h.collectionName, synced: h.synced, } } // nolint: unused // (not true, its to implement an interface) func (h *manyCollection[I, O]) dump() { h.recomputeMu.Lock() defer h.recomputeMu.Unlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kube/krt/informer.go
var _ internalCollection[controllers.Object] = &informer[controllers.Object]{} func (i *informer[I]) _internalHandler() {} func (i *informer[I]) Synced() Syncer { return channelSyncer{ name: i.collectionName, synced: i.synced, } } // nolint: unused // (not true, its to implement an interface) func (i *informer[I]) dump() { i.log.Errorf(">>> BEGIN DUMP") for _, obj := range i.inf.List(metav1.NamespaceAll, klabels.Everything()) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
pvcListerSynced cache.InformerSynced // revListerSynced returns true if the rev shared informer has synced at least once revListerSynced cache.InformerSynced // StatefulSets that need to be synced. queue workqueue.TypedRateLimitingInterface[string] // eventBroadcaster is the core of event processing pipeline. eventBroadcaster record.EventBroadcaster }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/kube/krt/core.go
// using krt), registering directly is expected. Register(f func(o Event[T])) Syncer // Synced returns a Syncer which can be used to determine if the collection has synced. Once its synced, all dependencies have // been processed, and all handlers have been called with the results. Synced() Syncer // RegisterBatch registers a handler that accepts multiple events at once. This can be useful as an optimization.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 6.9K bytes - Viewed (0)