Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 231 - 240 of 896 for context_a (0.07 seconds)

  1. cmd/warm-backend-azure.go

    		vid = *resp.VersionID
    	}
    	return remoteVersionID(vid), nil
    }
    
    func (az *warmBackendAzure) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    	return az.PutWithMeta(ctx, object, r, length, map[string]string{})
    }
    
    func (az *warmBackendAzure) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (r io.ReadCloser, err error) {
    	if opts.startOffset < 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 31 22:10:24 GMT 2024
    - 7K bytes
    - Click Count (0)
  2. cmd/xl-storage_windows_test.go

    		t.Fatal(err)
    	}
    
    	// Create volume to use in conjunction with other StorageAPI's file API(s)
    	err = fs.MakeVol(context.Background(), "voldir")
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	for i, test := range testCases {
    		t.Run(fmt.Sprint(i), func(t *testing.T) {
    			err = fs.AppendFile(context.Background(), "voldir", test.objName, []byte("hello"))
    			if err != nil && test.pass {
    				t.Error(err)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Nov 29 06:35:16 GMT 2023
    - 2.8K bytes
    - Click Count (0)
  3. cmd/erasure-metadata-utils.go

    	errorCounts := make(map[error]int)
    	for _, err := range errs {
    		if IsErrIgnored(err, ignoredErrs...) {
    			continue
    		}
    		// Errors due to context cancellation may be wrapped - group them by context.Canceled.
    		if errors.Is(err, context.Canceled) {
    			errorCounts[context.Canceled]++
    			continue
    		}
    		errorCounts[err]++
    	}
    
    	maxCnt := 0
    	for err, count := range errorCounts {
    		switch {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  4. cmd/bucket-object-lock.go

    }
    
    // enforceRetentionForDeletion checks if it is appropriate to remove an
    // object according to locking configuration when this is lifecycle/ bucket quota asking.
    func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) {
    	if objInfo.DeleteMarker {
    		return false
    	}
    
    	lhold := objectlock.GetObjectLegalHoldMeta(objInfo.UserDefined)
    	if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 02:38:25 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  5. internal/crypto/key.go

    	}
    	if len(extKey) != 32 { // safety check
    		logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length"))
    	}
    	var nonce [32]byte
    	if _, err := io.ReadFull(random, nonce[:]); err != nil {
    		logger.CriticalIf(context.Background(), errOutOfEntropy)
    	}
    
    	const Context = "object-encryption-key generation"
    	mac := hmac.New(sha256.New, extKey)
    	mac.Write([]byte(Context))
    	mac.Write(nonce[:])
    	mac.Sum(key[:0])
    	return key
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  6. cmd/background-heal-ops.go

    }
    
    func waitForLowHTTPReq() {
    	maxIO, maxWait, _ := globalHealConfig.Clone()
    	waitForLowIO(maxIO, maxWait, currentHTTPIO)
    }
    
    func initBackgroundHealing(ctx context.Context, objAPI ObjectLayer) {
    	bgSeq := newBgHealSequence()
    	// Run the background healer
    	for range globalBackgroundHealRoutine.workers {
    		go globalBackgroundHealRoutine.AddWorker(ctx, objAPI, bgSeq)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  7. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/AcceptedRegressionsRulePostProcess.java

        @Override
        @SuppressWarnings("unchecked")
        public void execute(ViolationCheckContextWithViolations context) {
            Set<ApiChange> acceptedApiChanges = (Set<ApiChange>) context.getUserData().get("acceptedApiChanges");
            Set<ApiChange> seenApiChanges = (Set<ApiChange>) context.getUserData().get("seenApiChanges");
            Set<ApiChange> left = new HashSet<>(acceptedApiChanges);
            left.removeAll(seenApiChanges);
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Jun 09 08:16:49 GMT 2021
    - 1.7K bytes
    - Click Count (0)
  8. .github/ISSUE_TEMPLATE/20_contributor_feature_request.yml

        validations:
          required: false
      - type: textarea
        id: context
        attributes:
          label: Context
          description: |
            How has this issue affected you? What are you trying to accomplish? What other alternatives have you considered?
            Providing context helps us come up with a solution that is most useful in the real world
        validations:
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Nov 27 15:48:22 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  9. .github/ISSUE_TEMPLATE/40_contributor_documentation.yml

            Please describe the problem as concisely as possible.
        validations:
          required: true
      - type: textarea
        id: context
        attributes:
          label: Context (optional)
          description: |
            How has this issue affected you? What are you trying to accomplish?
            Providing context helps us come up with a solution that is most useful in the real world
        validations:
          required: false
      - type: input
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Mon Jan 15 10:01:01 GMT 2024
    - 1.6K bytes
    - Click Count (0)
  10. tests/association_generics_test.go

    package tests_test
    
    import (
    	"context"
    	"testing"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/clause"
    	. "gorm.io/gorm/utils/tests"
    )
    
    // BelongsToCompany and BelongsToUser models for belongs to tests - using existing User and Company models
    
    // Test Set + Create with Association OpCreate operation using real database
    func TestClauseAssociationSetCreateWithOpCreate(t *testing.T) {
    	ctx := context.Background()
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Sep 12 05:42:26 GMT 2025
    - 37.9K bytes
    - Click Count (0)
Back to Top