Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 127 for goroutines (0.06 seconds)

  1. cmd/erasure-sets.go

    	g := errgroup.WithNErrs(len(s.sets))
    	for index := range s.sets {
    		g.Go(func() error {
    			storageInfos[index] = s.sets[index].StorageInfo(ctx)
    			return nil
    		}, index)
    	}
    
    	// Wait for the go routines.
    	g.Wait()
    
    	for _, lstorageInfo := range storageInfos {
    		storageInfo.Disks = append(storageInfo.Disks, lstorageInfo.Disks...)
    	}
    
    	return storageInfo
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  2. docs/pt/docs/async.md

    Nas versões anteriores do NodeJS / Navegador JavaScript, você utilizaria "callbacks". O que leva ao "inferno do callback".
    
    ## Corrotinas { #coroutines }
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Nov 12 16:23:57 GMT 2025
    - 25.8K bytes
    - Click Count (0)
  3. cmd/testdata/decryptObjectInfo.json.zst

    Sealed-Key":"IAAfAO9a/NaH0+0MKscdm+NL+AbVJkA78wAeP/+yJutEhk6EpDuvTRUpbzl==","X-Minio-Internal-Server-Side-Encryption-Seal-Algorithm":"DAREv2-HMAC-SHA256","content-type":"application/octet-stream"}},{"Bucket":"buck1","Name":"go_113/src/cmd/trace/goroutines.go","UserDef":{"X-Minio-Internal-Server-Side-Encryption-Iv":"X3+eO4vJp/nKeywGLAy+kjPz6MYWHUc1Qc+Aw5bf6ng=","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Key-Id":"my-minio-key","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Sealed-Key":"IAAfA...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 29 16:34:20 GMT 2020
    - 164K bytes
    - Click Count (0)
  4. CHANGELOG/CHANGELOG-1.19.md

    - Add delays between goroutines for vm instance update ([#88094](https://github.com/kubernetes/kubernetes/pull/88094), [@aramase](https://github.com/aramase)) [SIG Cloud Provider]
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Wed Jan 05 05:42:32 GMT 2022
    - 489.7K bytes
    - Click Count (0)
  5. cmd/erasure-metadata.go

    			fi.Erasure.Index = index + 1
    			if fi.IsValid() {
    				return disks[index].WriteMetadata(ctx, origbucket, bucket, prefix, fi)
    			}
    			return errFileCorrupt
    		}, index)
    	}
    
    	// Wait for all the routines.
    	mErrs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, quorum)
    	if err != nil && revert {
    		ng := errgroup.WithNErrs(len(disks))
    		for index := range disks {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.3K bytes
    - Click Count (0)
  6. cmd/admin-heal-ops.go

    	}
    
    	if h.clientToken == bgHealingUUID {
    		// For background heal do nothing, do not spawn an unnecessary goroutine.
    	} else {
    		// Launch top-level background heal go-routine
    		go h.healSequenceStart(objAPI)
    	}
    
    	b, err := json.Marshal(madmin.HealStartSuccess{
    		ClientToken:   clientToken,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  7. cmd/format-erasure.go

    		g.Go(func() error {
    			if formats[index] == nil {
    				return errDiskNotFound
    			}
    			return saveFormatErasure(storageDisks[index], formats[index], "")
    		}, index)
    	}
    
    	// Wait for the routines to finish.
    	return reduceWriteQuorumErrs(ctx, g.Wait(), nil, len(storageDisks))
    }
    
    // relinquishes the underlying connection for all storage disks.
    func closeStorageDisks(storageDisks ...StorageAPI) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  8. docs/metrics/prometheus/list.md

    | `minio_node_file_descriptor_open_total`    | Total number of open file descriptors by the MinIO Server process.                                              |
    | `minio_node_go_routine_total`              | Total number of go routines running.                                                                            |
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 43.4K bytes
    - Click Count (0)
  9. internal/ringbuffer/ring_buffer_test.go

    	go func() {
    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    			fmt.Printf("=== Timeout, assuming deadlock ===\n*** goroutine dump...\n%s\n*** end\n", string(buf[:stacklen]))
    			os.Exit(2)
    		}
    	}()
    	return func() {
    		close(cc)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  10. internal/grid/grid_test.go

    	go func() {
    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    			fmt.Printf("=== Timeout, assuming deadlock ===\n*** goroutine dump...\n%s\n*** end\n", string(buf[:stacklen]))
    			os.Exit(2)
    		}
    	}()
    	return func() {
    		close(cc)
    	}
    }
    
    func assertNoActive(t *testing.T, c *Connection) {
    	t.Helper()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
Back to Top