- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 41 for UID (0.16 sec)
-
cmd/local-locker.go
if !ok { // Inconsistent. Delete UID. delete(l.lockUID, formatUUID(args.UID, idx)) return idx > 0, nil } for i := range lris { if lris[i].UID == args.UID { lris[i].TimeLastRefresh = UTCNow() } } idx++ resource, ok = l.lockUID[formatUUID(args.UID, idx)] if !ok { // No more resources for UID, but we did update at least one. return true, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 10.6K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache_test.go
pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{UID: "testUID"}} ns := newFakeNs(inc()) wl := WorkloadInfo{ Workload: podToWorkload(pod), Netns: ns, } netns1 := p.UpsertPodCacheWithNetns(string(pod.UID), wl) netnsTaken := p.Take(string(pod.UID)) if netns1 != netnsTaken { t.Fatalf("Expected the original Netns for the same uid, got %p and %p", netns1, ns) } if nil != p.Take(string(pod.UID)) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.2K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret_test.go
"istio.io/istio/pkg/kube/multicluster" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/env" ) var ( kubeSystemNamespaceUID = types.UID("54643f96-eca0-11e9-bb97-42010a80000a") kubeSystemNamespace = &v1.Namespace{ ObjectMeta: metav1.ObjectMeta{ Name: "kube-system", UID: kubeSystemNamespaceUID, }, } ) const ( testNamespace = "istio-system-test"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 20.6K bytes - Viewed (0) -
internal/dsync/drwmutex.go
func sendRelease(ctx context.Context, ds *Dsync, c NetLocker, owner string, uid string, isReadLock bool, names ...string) bool { if c == nil { log("Unable to call RUnlock failed with %s\n", errors.New("netLocker is offline")) return false } if len(uid) == 0 { return false } args := LockArgs{ Owner: owner, UID: uid, Resources: names, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/lock-rest-server-common_test.go
Writer: true, UID: "89ab-cdef", Timestamp: UTCNow(), TimeLastRefresh: UTCNow(), } locker.ll.lockMap["name"] = []lockRequesterInfo{ lockRequesterInfo1, lockRequesterInfo2, } lri := locker.ll.lockMap["name"] // test unknown uid if locker.ll.removeEntry("name", dsync.LockArgs{ Owner: "owner", UID: "unknown-uid", }, &lri) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 23 17:26:21 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/dsync/lock-args_gen.go
zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "UID": z.UID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "UID") return } case "Resources": var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "Resources")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 9.5K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
// generate the clusterName if not specified if opt.ClusterName == "" { uid, err := clusterUID(client.Kube()) if err != nil { return nil, nil, err } opt.ClusterName = string(uid) } var secretName string switch opt.Type { case SecretTypeRemote: secretName = remoteSecretNameFromClusterName(opt.ClusterName)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0) -
cmd/admin-handlers_test.go
resource := fmt.Sprintf("bucket/get-object-%d", i) lri := lockRequesterInfo{ Name: resource, UID: mustGetUUID(), Owner: owners[i%len(owners)], Quorum: 2, } lris = append(lris, lri) locksHeld[resource] = append(locksHeld[resource], lri) // concurrent read lock, same resource different uid lri.UID = mustGetUUID() lris = append(lris, lri) locksHeld[resource] = append(locksHeld[resource], lri) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue1435.go
{call: "Setreuid(1,0)", fn: func() error { return syscall.Setreuid(1, 0) }, filter: "Uid:", expect: "\t1\t0\t0\t0"}, {call: "Setreuid(0,2)", fn: func() error { return syscall.Setreuid(0, 2) }, filter: "Uid:", expect: "\t0\t2\t2\t2"}, {call: "Setreuid(0,0)", fn: func() error { return syscall.Setreuid(0, 0) }, filter: "Uid:", expect: "\t0\t0\t0\t0"},
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Jul 28 21:31:41 GMT 2023 - 7.5K bytes - Viewed (0) -
cmd/local-locker_test.go
uid := mustGetUUID() arg := dsync.LockArgs{ UID: uid, Resources: []string{name}, Source: t.Name(), Owner: "owner", Quorum: 0, } ok, err := l.RLock(ctx, arg) if err != nil { t.Fatal(err) } if !ok { t.Fatal("did not get write lock") } rUIDs = append(rUIDs, uid) // RLock twice, different uid uid = mustGetUUID()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 11.8K bytes - Viewed (0)