- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 601 for syncAt (0.13 sec)
-
src/os/user/lookup_unix_test.go
root:x:0:0:root:/root:/bin/bash daemon:x:1:1:daemon:/usr/sbin:/usr/sbin/nologin bin:x:2:3:bin:/bin:/usr/sbin/nologin indented:x:3:3:indented:/dev:/usr/sbin/nologin sync:x:4:65534:sync:/bin:/bin/sync negative:x:-5:60:games:/usr/games:/usr/sbin/nologin man:x:6:12:man:/var/cache/man:/usr/sbin/nologin allfields:x:6:12:mansplit,man2,man3,man4:/home/allfields:/usr/sbin/nologin
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 11 04:31:34 UTC 2022 - 7.3K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status.go
c.ingresses.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) // For any class change, sync all ingress; the handler will filter non-matching ones already c.ingressClasses.AddEventHandler(controllers.ObjectHandler(func(o controllers.Object) { // Just sync them all c.enqueueAll() })) // For services, we queue all Ingress if its the ingress service
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.9K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/endpointslicecontroller.go
errs = append(errs, fmt.Errorf("concurrent-service-endpoint-syncs must not be less than %d, but got %d", minConcurrentServiceEndpointSyncs, o.ConcurrentServiceEndpointSyncs)) } else if o.ConcurrentServiceEndpointSyncs > maxConcurrentServiceEndpointSyncs { errs = append(errs, fmt.Errorf("concurrent-service-endpoint-syncs must not be more than %d, but got %d", maxConcurrentServiceEndpointSyncs, o.ConcurrentServiceEndpointSyncs))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 03 07:16:42 UTC 2020 - 3.7K bytes - Viewed (0) -
src/runtime/race/testdata/waitgroup_test.go
package race_test import ( "runtime" "sync" "testing" "time" ) func TestNoRaceWaitGroup(t *testing.T) { var x int _ = x var wg sync.WaitGroup n := 1 for i := 0; i < n; i++ { wg.Add(1) j := i go func() { x = j wg.Done() }() } wg.Wait() } func TestRaceWaitGroup(t *testing.T) { var x int _ = x var wg sync.WaitGroup n := 2 for i := 0; i < n; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 03 22:09:38 UTC 2017 - 5.3K bytes - Viewed (0) -
test/fixedbugs/issue27938.go
// a qualified identifier with non-existing package. package p type _ struct { F sync.Mutex // ERROR "undefined: sync|expected package|reference to undefined name" } type _ struct { sync.Mutex // ERROR "undefined: sync|expected package|reference to undefined name" } type _ interface { sync.Mutex // ERROR "undefined: sync|expected package|expected signature or type name|reference to undefined name"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 06 00:02:11 UTC 2022 - 696 bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r22/CancellationCrossVersionSpec.groovy
def sync = server.expectAndBlock("registered") def resultHandler = new TestResultHandler() when: withConnection { ProjectConnection connection -> def build = connection.newBuild() build.forTasks(':sub:broken') build.withCancellationToken(cancel.token()) build.run(resultHandler) sync.waitForAllPendingCalls(resultHandler)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 8.2K bytes - Viewed (0) -
api/go1.23.txt
pkg sync/atomic, func OrInt64(*int64, int64) int64 #61395 pkg sync/atomic, func OrUint32(*uint32, uint32) uint32 #61395 pkg sync/atomic, func OrUint64(*uint64, uint64) uint64 #61395 pkg sync/atomic, func OrUintptr(*uintptr, uintptr) uintptr #61395 pkg sync/atomic, method (*Int32) And(int32) int32 #61395 pkg sync/atomic, method (*Int32) Or(int32) int32 #61395 pkg sync/atomic, method (*Int64) And(int64) int64 #61395
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 05 20:48:49 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/controller/deployment/progress.go
} } return conditions } // used for unit testing var nowFn = func() time.Time { return time.Now() } // requeueStuckDeployment checks whether the provided deployment needs to be synced for a progress // check. It returns the time after the deployment will be requeued for the progress check, 0 if it // will be requeued now, or -1 if it does not need to be requeued.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 11:00:44 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/proxy/ipvs/ipset_test.go
expectedEntries []string }{ { name: "normal ipset sync", set: &utilipset.IPSet{ Name: "foo", }, setType: utilipset.HashIPPort, ipv6: false, activeEntries: []string{"172.17.0.4,tcp:80"}, currentEntries: nil, expectedEntries: []string{"172.17.0.4,tcp:80"}, }, { name: "ipset IPv6 sync with no new entries", set: &utilipset.IPSet{ Name: "abz", },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 7.5K bytes - Viewed (0) -
test/assign.go
// Does not compile. package main import "sync" type T struct { int sync.Mutex } func main() { { var x, y sync.Mutex x = y // ok _ = x } { var x, y T x = y // ok _ = x } { var x, y [2]sync.Mutex x = y // ok _ = x } { var x, y [2]T x = y // ok _ = x } { x := sync.Mutex{0, 0} // ERROR "assignment.*Mutex" _ = x }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 14 20:13:36 UTC 2020 - 1K bytes - Viewed (0)