Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for kuwait (0.15 sec)

  1. cmd/format-erasure.go

    			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) {
    	var wg sync.WaitGroup
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  2. cmd/config-current.go

    			Description: "manage namespace scanning for usage calculation, lifecycle, healing and more",
    		},
    		config.HelpKV{
    			Key:         config.BatchSubSys,
    			Description: "manage batch job workers and wait times",
    		},
    		config.HelpKV{
    			Key:         config.CompressionSubSys,
    			Description: "enable server side compression of objects",
    		},
    		config.HelpKV{
    			Key:             config.IdentityOpenIDSubSys,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    						// proceed to heal nonetheless, since
    						// this object might be dangling.
    						entry, _ = entries.firstFound()
    					}
    					wait := noWait
    					if f.weSleep() {
    						// wait timer per object.
    						wait = scannerSleeper.Timer(ctx)
    					}
    					defer wait()
    					f.updateCurrentPath(entry.name)
    					stopFn := globalScannerMetrics.log(scannerMetricHealAbandonedObject, f.root, entry.name)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    	for index := range s.sets {
    		index := index
    		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
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  5. cmd/handler-api.go

    			if val := globalServiceFreeze.Load(); val != nil {
    				if unlock, ok := val.(chan struct{}); ok && unlock != nil {
    					// Wait until unfrozen.
    					select {
    					case <-unlock:
    					case <-r.Context().Done():
    						// if client canceled we don't need to wait here forever.
    						return
    					}
    				}
    			}
    		}
    
    		pool, deadline := globalAPIConfig.getRequestsPool()
    		if pool == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 10K bytes
    - Viewed (0)
  6. cmd/server-main.go

    		EnvVar: "MINIO_SHUTDOWN_TIMEOUT",
    		Hidden: true,
    	},
    	cli.DurationFlag{
    		Name:   "idle-timeout",
    		Value:  xhttp.DefaultIdleTimeout,
    		Usage:  "idle timeout is the maximum amount of time to wait for the next request when keep-alive are enabled",
    		EnvVar: "MINIO_IDLE_TIMEOUT",
    		Hidden: true,
    	},
    	cli.DurationFlag{
    		Name:   "read-header-timeout",
    		Value:  xhttp.DefaultReadHeaderTimeout,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (2)
Back to top