Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Gully (0.12 sec)

  1. cmd/bucket-replication.go

    		}
    	}
    	return
    }
    
    // replicateAll replicates metadata for specified version of the object to destination bucket
    // if the destination version is missing it automatically does fully copy as well.
    // The source object is then updated to reflect the replication status.
    func (ri ReplicateObjectInfo) replicateAll(ctx context.Context, objectAPI ObjectLayer, tgt *TargetClient) (rinfo replicatedTargetInfo) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  2. internal/rest/client.go

    		// the client offline in such situations.
    		// generally all implementations should simply return
    		// 403, but in situations where there is a dependency
    		// with the caller to take the client offline purpose
    		// fully it should make sure to respond with '412'
    		// instead, see cmd/storage-rest-server.go for ideas.
    		if c.HealthCheckFn != nil && resp.StatusCode == http.StatusPreconditionFailed {
    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)
  3. cmd/xl-storage.go

    		return err
    	}
    
    	srcFilePath := pathJoin(filePath, xlStorageFormatFileV1)
    	dstFilePath := pathJoin(filePath, xlStorageFormatFile)
    
    	// Renaming xl.json to xl.meta should be fully synced to disk.
    	defer func() {
    		if err == nil && s.globalSync {
    			// Sync to disk only upon success.
    			globalSync()
    		}
    	}()
    
    	if err = Rename(srcFilePath, dstFilePath); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    	case size >= fi.Erasure.BlockSize:
    		buffer = globalBytePoolCap.Load().Get()
    		defer globalBytePoolCap.Load().Put(buffer)
    	case size < fi.Erasure.BlockSize:
    		// No need to allocate fully blockSizeV1 buffer if the incoming data is smaller.
    		buffer = make([]byte, size, 2*size+int64(fi.Erasure.ParityBlocks+fi.Erasure.DataBlocks-1))
    	}
    
    	if len(buffer) > int(fi.Erasure.BlockSize) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  5. cmd/erasure-multipart.go

    		}
    	case size >= fi.Erasure.BlockSize:
    		buffer = globalBytePoolCap.Load().Get()
    		defer globalBytePoolCap.Load().Put(buffer)
    	case size < fi.Erasure.BlockSize:
    		// No need to allocate fully fi.Erasure.BlockSize buffer if the incoming data is smaller.
    		buffer = make([]byte, size, 2*size+int64(fi.Erasure.ParityBlocks+fi.Erasure.DataBlocks-1))
    	}
    
    	if len(buffer) > int(fi.Erasure.BlockSize) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  6. cmd/metrics-v3-types.go

    func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() {
    	mg.bucketsLock.Lock()
    	mg.buckets = buckets
    	return func() {
    		mg.bucketsLock.Unlock()
    	}
    }
    
    // MetricFQN - returns the fully qualified name for the given metric name.
    func (mg *MetricsGroup) MetricFQN(name MetricName) string {
    	v, ok := mg.descriptorMap[name]
    	if !ok {
    		// This should never happen.
    		return ""
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:05:22 GMT 2024
    - 14.7K bytes
    - Viewed (0)
Back to top