Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for Towers (0.16 sec)

  1. cmd/iam-store.go

    	for member, groups := range c.iamUserGroupMemberships {
    		if !groups.Contains(group) {
    			continue
    		}
    		groups.Remove(group)
    		c.iamUserGroupMemberships[member] = groups
    	}
    }
    
    // policyDBGet - lower-level helper; does not take locks.
    //
    // If a group is passed, it returns policies associated with the group.
    //
    // If a user is passed, it returns policies of the user along with any groups
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  2. cmd/xl-storage.go

    	// Small file threshold below which data accompanies metadata from storage layer.
    	smallFileThreshold = 128 * humanize.KiByte // Optimized for NVMe/SSDs
    
    	// For hardrives it is possible to set this to a lower value to avoid any
    	// spike in latency. But currently we are simply keeping it optimal for SSDs.
    
    	// bigFileThreshold is the point where we add readahead to put operations.
    	bigFileThreshold = 128 * humanize.MiByte
    
    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)
  3. cmd/erasure-server-pool.go

    		nsUnlocker = func() { lock.RUnlock(lkctx) }
    		unlockOnDefer = true
    	}
    
    	checkPrecondFn := opts.CheckPrecondFn
    	opts.CheckPrecondFn = nil // do not need to apply pre-conditions at lower layer.
    	opts.NoLock = true        // no locks needed at lower levels for getObjectInfo()
    	objInfo, zIdx, err := z.getLatestObjectInfoWithIdx(ctx, bucket, object, opts)
    	if err != nil {
    		if objInfo.DeleteMarker {
    			if opts.VersionID == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  4. src/archive/zip/zip_test.go

    			rp = &r.buf[len(r.buf)-1]
    		} else {
    			rp.n++
    		}
    	}
    	return len(p), nil
    }
    
    func memset(a []byte, b byte) {
    	if len(a) == 0 {
    		return
    	}
    	// Double, until we reach power of 2 >= len(a), same as bytes.Repeat,
    	// but without allocation.
    	a[0] = b
    	for i, l := 1, len(a); i < l; i *= 2 {
    		copy(a[i:], a[:i])
    	}
    }
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Mar 27 18:23:49 GMT 2024
    - 19.5K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    			markDelete = false
    		}
    		if opts.VersionPurgeStatus() == Complete {
    			markDelete = false
    		}
    		// now, since VersionPurgeStatus() is already set, we can let the
    		// lower layers decide this. This fixes a regression that was introduced
    		// in PR #14555 where !VersionPurgeStatus.Empty() is automatically
    		// considered as Delete marker true to avoid listing such objects by
    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)
  6. cmd/object-handlers.go

    		return
    	}
    
    	if r.ContentLength <= 0 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrEmptyRequestBody), r.URL)
    		return
    	}
    
    	// Take read lock on object, here so subsequent lower-level
    	// calls do not need to.
    	lock := objectAPI.NewNSLock(bucket, object)
    	lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  7. cni/pkg/util/podutil.go

    		Patch(
    			context.Background(),
    			pod.Name,
    			types.MergePatchType,
    			annotationPatch,
    			metav1.PatchOptions{},
    			// Both "pods" and "pods/status" can mutate the metadata. However, pods/status is lower privilege, so we use that instead.
    			"status",
    		)
    	return err
    }
    
    func AnnotateUnenrollPod(client kubernetes.Interface, pod *metav1.ObjectMeta) error {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v1.go

    	crc := hashDeterministicString(c.Meta)
    	c.Meta = nil
    
    	if bts, err := c.MarshalMsg(metaDataPoolGet()); err == nil {
    		crc ^= xxhash.Sum64(bts)
    		metaDataPoolPut(bts)
    	}
    
    	// Combine upper and lower part
    	var tmp [4]byte
    	binary.LittleEndian.PutUint32(tmp[:], uint32(crc^(crc>>32)))
    	return tmp
    }
    
    // XL metadata constants.
    const (
    	// XL meta version.
    	xlMetaVersion101 = "1.0.1"
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  9. cmd/object-api-interface.go

    	PreserveETag                        string    // preserves this etag during a PUT call.
    	NoLock                              bool      // indicates to lower layers if the caller is expecting to hold locks.
    	ProxyRequest                        bool      // only set for GET/HEAD in active-active replication scenario
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  10. cmd/postpolicyform.go

    			if !condPassed {
    				return fmt.Errorf("Invalid according to Policy: Policy Condition failed")
    			}
    		} else if strings.HasPrefix(policy.Key, "$x-amz-meta-") || strings.HasPrefix(policy.Key, "$x-amz-") {
    			// This covers all conditions X-Amz-Meta-* and X-Amz-*
    			// Check if policy condition is satisfied
    			condPassed = checkPolicyCond(op, formValues.Get(formCanonicalName), policy.Value)
    			if !condPassed {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 12.2K bytes
    - Viewed (0)
Back to top