Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 529 for atomics (0.14 sec)

  1. src/cmd/cgo/internal/test/testx.go

    //export Issue1560FromC
    func Issue1560FromC() {
    	for atomic.LoadInt32(&issue1560) != 1 {
    		runtime.Gosched()
    	}
    	atomic.AddInt32(&issue1560, 1)
    	for atomic.LoadInt32(&issue1560) != 3 {
    		runtime.Gosched()
    	}
    	issue1560Ch <- true
    }
    
    func Issue1560FromGo() {
    	atomic.AddInt32(&issue1560, 1)
    	for atomic.LoadInt32(&issue1560) != 2 {
    		runtime.Gosched()
    	}
    	atomic.AddInt32(&issue1560, 1)
    	issue1560Ch <- true
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 17 21:53:11 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/cel/common/equality_test.go

                `),
    		},
    		{
    			Name: "unchanged list type set with atomic map values",
    			Schema: mustSchema(`
                    properties:
                        foo:
                            type: array
                            items:
                                type: object
                                x-kubernetes-map-type: atomic
                                properties:
                                    key:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 13 21:36:46 UTC 2023
    - 21.1K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/telemetry/internal/counter/file.go

    func (m *mappedFile) writeEntryAt(off uint32, name string) (next *atomic.Uint32, v *atomic.Uint64, ok bool) {
    	if off < m.hdrLen+hashOff || int64(off)+16+int64(len(name)) > int64(len(m.mapping.Data)) {
    		return nil, nil, false
    	}
    	copy(m.mapping.Data[off+16:], name)
    	atomic.StoreUint32((*uint32)(unsafe.Pointer(&m.mapping.Data[off+8])), uint32(len(name))|0xff000000)
    	next = (*atomic.Uint32)(unsafe.Pointer(&m.mapping.Data[off+12]))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/rbac/v1alpha1/types.go

    	// +optional
    	// +listType=atomic
    	APIGroups []string `json:"apiGroups,omitempty" protobuf:"bytes,3,rep,name=apiGroups"`
    	// Resources is a list of resources this rule applies to. '*' represents all resources.
    	// +optional
    	// +listType=atomic
    	Resources []string `json:"resources,omitempty" protobuf:"bytes,4,rep,name=resources"`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 22:49:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  5. pkg/kube/multicluster/secretcontroller_test.go

    	tc.controller.ClientBuilder = TestingBuildClientsFromConfig
    	iter := atomic.NewInt32(0)
    	tc.component = BuildMultiClusterComponent(tc.controller, func(cluster *Cluster) testHandler {
    		it := iter.Inc()
    		return testHandler{
    			ID:     cluster.ID,
    			Iter:   int(it),
    			Closed: atomic.NewBool(false),
    			Synced: atomic.NewBool(synced),
    		}
    	})
    	return tc
    }
    
    var kubeconfig = 0
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/rbac/v1beta1/types.go

    	// +optional
    	// +listType=atomic
    	APIGroups []string `json:"apiGroups,omitempty" protobuf:"bytes,2,rep,name=apiGroups"`
    	// Resources is a list of resources this rule applies to.  '*' represents all resources in the specified apiGroups.
    	// '*/foo' represents the subresource 'foo' for all resources in the specified apiGroups.
    	// +optional
    	// +listType=atomic
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 22:49:19 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  7. docs/bigdata/README.md

    the connector to use S3 and other S3-compatible object stores such as MinIO. MapReduce workloads typically interact with object stores in the same way they do with HDFS. These workloads rely on HDFS atomic rename functionality to complete writing data to the datastore. Object storage operations are atomic by nature and they do not require/implement rename API. The default S3A committer emulates renames through copy and delete APIs. This interaction pattern causes significant loss of performance because...
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/authorization/v1beta1/types.go

    	// +listType=atomic
    	ResourceRules []ResourceRule `json:"resourceRules" protobuf:"bytes,1,rep,name=resourceRules"`
    	// NonResourceRules is the list of actions the subject is allowed to perform on non-resources.
    	// The list ordering isn't significant, may contain duplicates, and possibly be incomplete.
    	// +listType=atomic
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 27 20:06:26 UTC 2023
    - 15.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/authorization/v1/generated.proto

      // +listType=atomic
      repeated string verbs = 1;
    
      // NonResourceURLs is a set of partial urls that a user should have access to.  *s are allowed, but only as the full,
      // final step in the path.  "*" means all.
      // +optional
      // +listType=atomic
      repeated string nonResourceURLs = 2;
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/authorization/v1beta1/generated.proto

      // +listType=atomic
      repeated string verbs = 1;
    
      // NonResourceURLs is a set of partial urls that a user should have access to.  *s are allowed, but only as the full,
      // final step in the path.  "*" means all.
      // +optional
      // +listType=atomic
      repeated string nonResourceURLs = 2;
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 12.1K bytes
    - Viewed (0)
Back to top