Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 697 for chan (0.1 sec)

  1. cmd/iam.go

    // policy for the STS credential. The policy mapping can be updated by the
    // administrator.
    //
    // - from `Subject.CommonName` field from the STS request for
    // AssumeRoleWithCertificate. In this case, the policy for the STS credential
    // has the same name as the value of this field.
    //
    // - from special JWT claim from STS request for AssumeRoleWithOIDC API (when
    // not using RoleARN). The claim value can be a string or a list and refers to
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    	poolIndex int
    
    	// Distribution algorithm of choice.
    	distributionAlgo string
    	deploymentID     [16]byte
    
    	lastConnectDisksOpTime time.Time
    }
    
    var staleUploadsCleanupIntervalChangedCh = make(chan struct{})
    
    func (s *erasureSets) getDiskMap() map[Endpoint]StorageAPI {
    	diskMap := make(map[Endpoint]StorageAPI)
    
    	s.erasureDisksMu.RLock()
    	defer s.erasureDisksMu.RUnlock()
    
    	for i := range s.setCount {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  3. cmd/bucket-policy-handlers_test.go

    	credentials auth.Credentials, t *testing.T,
    ) {
    	bucketName1 := fmt.Sprintf("%s-1", bucketName)
    
    	const n = 100
    	start := make(chan struct{})
    	var ok, errs int
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	wg.Add(n)
    	for range n {
    		go func() {
    			defer wg.Done()
    			// Sync start.
    			<-start
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    	for i := range errs {
    		errs[i] = errDiskOngoingReq
    	}
    
    	done := make(chan bool, er.setDriveCount)
    	disks := er.getDisks()
    
    	ropts := ReadOptions{
    		ReadData:         readData,
    		InclFreeVersions: opts.InclFreeVersions,
    		Healing:          false,
    	}
    
    	mrfCheck := make(chan FileInfo)
    	defer xioutil.SafeClose(mrfCheck)
    
    	var rw sync.Mutex
    
    	// Ask for all disks first;
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  5. cmd/object-api-utils.go

    		opts = append([]s2.WriterOption{s2.WriterPadding(compPadEncrypted), s2.WriterPaddingSrc(rng)}, compressOpts...)
    	}
    	comp := s2.NewWriter(pw, opts...)
    	indexCh := make(chan []byte, 1)
    	go func() {
    		defer xioutil.SafeClose(indexCh)
    		cn, err := io.Copy(comp, r)
    		if err != nil {
    			comp.Close()
    			pw.CloseWithError(err)
    			return
    		}
    		if on > 0 && on != cn {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  6. src/archive/zip/reader_test.go

    	}
    
    	// test read of each file
    	for i, ft := range zt.File {
    		readTestFile(t, zt, ft, z.File[i], raw)
    	}
    	if t.Failed() {
    		return
    	}
    
    	// test simultaneous reads
    	n := 0
    	done := make(chan bool)
    	for i := 0; i < 5; i++ {
    		for j, ft := range zt.File {
    			go func(j int, ft ZipTestFile) {
    				readTestFile(t, zt, ft, z.File[j], raw)
    				done <- true
    			}(j, ft)
    			n++
    		}
    	}
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Mar 11 22:19:38 UTC 2025
    - 56.6K bytes
    - Viewed (0)
  7. src/bufio/bufio_test.go

    	}
    }
    
    type zeroReader struct{}
    
    func (zeroReader) Read(p []byte) (int, error) {
    	return 0, nil
    }
    
    func TestZeroReader(t *testing.T) {
    	var z zeroReader
    	r := NewReader(z)
    
    	c := make(chan error)
    	go func() {
    		_, err := r.ReadByte()
    		c <- err
    	}()
    
    	select {
    	case err := <-c:
    		if err == nil {
    			t.Error("error expected")
    		} else if err != io.ErrNoProgress {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.15.md

    - The Kubelet now properly requests protobuf objects where they are supported from the apiserver, reducing load in large clusters. ([#75602](https://github.com/kubernetes/kubernetes/pull/75602), [@smarterclayton](https://github.com/smarterclayton))
    
    ### OpenStack
    
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 278.9K bytes
    - Viewed (0)
  9. docs/vi/docs/tutorial/index.md

    Mỗi phần được xây dựng từ những phần trước đó, nhưng nó được cấu trúc thành các chủ đề riêng biệt, do đó bạn có thể xem trực tiếp từng phần cụ thể bất kì để giải quyết những API cụ thể mà bạn cần.
    
    Nó cũng được xây dựng để làm việc như một tham chiếu trong tương lai.
    
    Do đó bạn có thể quay lại và tìm chính xác những gì bạn cần.
    
    ## Chạy
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. cmd/iam-store.go

    	// were changes to the in-memory cache we should wait for the next
    	// cycle until we can safely update the in-memory cache.
    	//
    	// An in-memory cache must be replaced only if we know for sure that the
    	// values loaded from disk are not stale. They might be stale if the
    	// cached.updatedAt is more recent than the refresh cycle began.
    	if cache.updatedAt.Before(loadedAt) || firstTime {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 86.7K bytes
    - Viewed (0)
Back to top