- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 118 for uid4 (0.03 sec)
-
cmd/local-locker.go
- defer l.mutex.Unlock()
- if len(args.UID) == 0 {
- for _, resource := range args.Resources {
- lris, ok := l.lockMap[resource]
- if !ok {
- continue
- }
- // Collect uids, so we don't mutate while we delete
- uids := make([]string, 0, len(lris))
- for _, lri := range lris {
- uids = append(uids, lri.UID)
- }
- // Delete collected uids:
- for _, uid := range uids {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 10.7K bytes - Viewed (0) -
cmd/local-locker_test.go
- t.Fatal("did not get write lock")
- }
- rUIDs = append(rUIDs, uid)
- // RLock twice, different uid
- uid = mustGetUUID()
- arg.UID = uid
- ok, err = l.RLock(ctx, arg)
- if err != nil {
- t.Fatal(err)
- }
- if !ok {
- t.Fatal("did not get write lock")
- }
- rResources[i] = name
- rUIDs = append(rUIDs, uid)
- }
- // Each Lock has m entries
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 11.9K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_test.go
- n := NewPodNetnsProcFinder(fakeFs())
- pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{
- Name: "foo",
- Namespace: "bar",
- UID: types.UID("863b91d4-4b68-4efa-917f-4b560e3e86aa"),
- }}
- podUIDNetns, err := n.FindNetnsForPods(map[types.UID]*corev1.Pod{
- pod.UID: pod,
- })
- if err != nil {
- panic(err)
- }
- defer podUIDNetns.Close()
- if len(podUIDNetns) == 0 {
- t.Fatal("expected to find pod netns")
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Oct 24 17:36:49 UTC 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
- // dashes, which is how the UID is represented within Kubernetes.
- func canonicalizePodUID(uid string) types.UID {
- return types.UID(strings.Map(func(r rune) rune {
- if unicode.IsPunct(r) {
- r = '-'
- }
- return r
- }, uid))
- }
- // Cgroup represents a linux cgroup.
- type Cgroup struct {
- HierarchyID string
- ControllerList string
- GroupPath string
- }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 11K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
- func (s *NetServer) buildZtunnelSnapshot(ambientPodUIDs map[types.UID]*corev1.Pod) error {
- // first add all the pods as empty:
- for uid := range ambientPodUIDs {
- s.currentPodSnapshot.Ensure(string(uid))
- }
- // populate full pod snapshot from cgroups
- return s.scanProcForPodsAndCache(ambientPodUIDs)
- }
- func (s *NetServer) scanProcForPodsAndCache(pods map[types.UID]*corev1.Pod) error {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Oct 21 16:48:55 UTC 2024 - 9.1K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
- // Instead, we track which UIDs we repaired and skip them if already repaired.
- //
- // An alternative would be to write something to the Pod (status, annotation, etc).
- // However, this requires elevated privileges we want to avoid
- if uid, f := c.repairedPods[key]; f {
- if uid == pod.UID {
- log.Debugf("Skipping pod, already repaired")
- } else {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
common-protos/k8s.io/api/authentication/v1/generated.proto
- optional string username = 1;
- // A unique value that identifies this user across time. If this user is
- // deleted and another user by the same name is added, they will have
- // different UIDs.
- // +optional
- optional string uid = 2;
- // The names of groups this user is a part of.
- // +optional
- repeated string groups = 3;
- // Any additional information provided by the authenticator.
- // +optional
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 6.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Ordering.java
- private final ConcurrentMap<Object, Integer> uids =
- Platform.tryWeakKeys(new MapMaker()).makeMap();
- private Integer getUid(Object obj) {
- Integer uid = uids.get(obj);
- if (uid == null) {
- // One or more integer values could be skipped in the event of a race
- // to generate a UID for the same object from multiple threads, but
- // that shouldn't be a problem.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 39.4K bytes - Viewed (0) -
common-protos/k8s.io/api/batch/v1/generated.proto
- }
- // UncountedTerminatedPods holds UIDs of Pods that have terminated but haven't
- // been accounted in Job status counters.
- message UncountedTerminatedPods {
- // succeeded holds UIDs of succeeded Pods.
- // +listType=set
- // +optional
- repeated string succeeded = 1;
- // failed holds UIDs of failed Pods.
- // +listType=set
- // +optional
- repeated string failed = 2;
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 21.1K bytes - Viewed (0) -
common-protos/k8s.io/api/authentication/v1beta1/generated.proto
- optional string username = 1;
- // A unique value that identifies this user across time. If this user is
- // deleted and another user by the same name is added, they will have
- // different UIDs.
- // +optional
- optional string uid = 2;
- // The names of groups this user is a part of.
- // +optional
- repeated string groups = 3;
- // Any additional information provided by the authenticator.
- // +optional
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 5.2K bytes - Viewed (0)