Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/xl-storage-disk-id-check.go

    		}
    	}
    }
    
    const (
    	diskHealthOK int32 = iota
    	diskHealthFaulty
    )
    
    type diskHealthTracker struct {
    	// atomic time of last success
    	lastSuccess int64
    
    	// atomic time of last time a token was grabbed.
    	lastStarted int64
    
    	// Atomic status of disk.
    	status atomic.Int32
    
    	// Atomic number indicates if a disk is hung
    	waiting atomic.Int32
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    	name              string
    	parent            *dataUsageHash
    	objectHealProbDiv uint32
    }
    
    type folderScanner struct {
    	root        string
    	getSize     getSizeFn
    	oldCache    dataUsageCache
    	newCache    dataUsageCache
    	updateCache dataUsageCache
    
    	dataUsageScannerDebug bool
    	healObjectSelect      uint32 // Do a heal check on an object once every n cycles. Must divide into healFolderInclude
    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)
  3. cmd/object-api-interface.go

    	// Locking operations on object.
    	NewNSLock(bucket string, objects ...string) RWLocker
    
    	// Storage operations.
    	Shutdown(context.Context) error
    	NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, scanMode madmin.HealScanMode) error
    	BackendInfo() madmin.BackendInfo
    	Legacy() bool // Only returns true for deployments which use CRCMOD as its object distribution algorithm.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  4. cmd/storage-rest-server.go

    				} else {
    					write([]byte{0})
    				}
    				xioutil.SafeClose(doneCh)
    				return
    			case block := <-blockCh:
    				var tmp [5]byte
    				tmp[0] = 2
    				binary.LittleEndian.PutUint32(tmp[1:], uint32(len(block)))
    				write(tmp[:])
    				write(block)
    				if canWrite {
    					w.(http.Flusher).Flush()
    				}
    			}
    		}
    	}()
    	return &h
    }
    
    var poolBuf8k = sync.Pool{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  5. cmd/erasure-sets.go

    }
    
    func crcHashMod(key string, cardinality int) int {
    	if cardinality <= 0 {
    		return -1
    	}
    	keyCrc := crc32.Checksum([]byte(key), crc32.IEEETable)
    	return int(keyCrc % uint32(cardinality))
    }
    
    func hashKey(algo string, key string, cardinality int, id [16]byte) int {
    	switch algo {
    	case formatErasureVersionV2DistributionAlgoV1:
    		return crcHashMod(key, cardinality)
    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)
  6. internal/rest/client.go

    // Unwrap returns the error wrapped in NetworkError.
    func (n *NetworkError) Unwrap() error {
    	return n.Err
    }
    
    // Client - http based RPC client.
    type Client struct {
    	connected int32 // ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG
    	_         int32 // For 64 bits alignment
    	lastConn  int64
    
    	// HealthCheckFn is the function set to test for health.
    	// If not set the client will not keep track of health.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 14.4K bytes
    - Viewed (0)
Back to top