Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 453 for ctx_ (0.05 sec)

  1. cmd/acl-handlers.go

    			writeErrorResponse(ctx, w, toAPIError(ctx, NotImplemented{}), r.URL)
    			return
    		}
    
    		if acl.AccessControlList.Grants[0].Permission != "FULL_CONTROL" {
    			writeErrorResponse(ctx, w, toAPIError(ctx, NotImplemented{}), r.URL)
    			return
    		}
    	}
    
    	if aclHeader != "" && aclHeader != "private" {
    		writeErrorResponse(ctx, w, toAPIError(ctx, NotImplemented{}), r.URL)
    		return
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. cmd/bucket-listobjects-handlers.go

    	listObjectVersionsInfo, err := listObjectVersions(ctx, bucket, prefix, marker, versionIDMarker, delimiter, maxkeys)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	if err = DecryptETags(ctx, GlobalKMS, listObjectVersionsInfo.Objects); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricStatVol, volume)
    	if err != nil {
    		return vol, err
    	}
    	defer done(0, &err)
    
    	return xioutil.WithDeadline[VolInfo](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (result VolInfo, err error) {
    		return p.storage.StatVol(ctx, volume)
    	})
    }
    
    func (p *xlStorageDiskIDCheck) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  4. cmd/notification.go

    			// Errors are logged but not returned.
    			ctx, cancel := context.WithTimeout(ctx, 15*time.Second)
    			defer cancel()
    			data, err := client.DownloadProfileData(ctx)
    			if err != nil {
    				reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", client.host.String())
    				ctx := logger.SetReqInfo(ctx, reqInfo)
    				peersLogOnceIf(ctx, err, client.host.String())
    				return nil
    			}
    
    			for typ, data := range data {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  5. cmd/namespace-lock.go

    	}) {
    		timeout.LogFailure()
    		defer cancel()
    		if err := newCtx.Err(); err == context.Canceled {
    			return LockContext{ctx: ctx, cancel: func() {}}, err
    		}
    		return LockContext{ctx: ctx, cancel: func() {}}, OperationTimedOut{}
    	}
    	timeout.LogSuccess(UTCNow().Sub(start))
    	return LockContext{ctx: newCtx, cancel: cancel}, nil
    }
    
    // Unlock - block until write lock is released.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  6. cmd/s3-zip-handlers.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	zipInfo := zipObjInfo.ArchiveInfo(r.Header)
    	if len(zipInfo) == 0 {
    		opts.EncryptFn, err = zipObjInfo.metadataEncryptFn(r.Header)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  7. cmd/erasure-object_test.go

    	defer removeRoots(disks)
    
    	err = objLayer.MakeBucket(ctx, "bucket1", MakeBucketOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	res, err := objLayer.NewMultipartUpload(ctx, "bucket1", "mpartObj1", opts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	fiveMBBytes := bytes.Repeat([]byte("a"), 5*humanize.MiByte)
    	md5Hex := getMD5Hash(fiveMBBytes)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  8. cmd/admin-handlers-users_test.go

    	err = s.adm.RemoveUser(ctx, accessKey)
    	if err != nil {
    		c.Fatalf("user could not be deleted: %v", err)
    	}
    
    	err = s.adm.RemoveCannedPolicy(ctx, policy1)
    	if err != nil {
    		c.Fatalf("policy del err: %v", err)
    	}
    
    	err = s.adm.RemoveCannedPolicy(ctx, policy2)
    	if err != nil {
    		c.Fatalf("policy del err: %v", err)
    	}
    }
    
    func (s *TestSuiteIAM) TestPolicyCreate(c *check) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  9. cmd/sts-handlers_test.go

    	dillonClient := makeSTSClient("******@****.***", "dillon")
    	// Validate client's permissions
    	c.mustListBuckets(ctx, dillonClient)
    	c.mustListObjects(ctx, dillonClient, "projecta")
    	c.mustListObjects(ctx, dillonClient, "projectb")
    	c.mustListObjects(ctx, dillonClient, "projectaorb")
    	c.mustNotListObjects(ctx, dillonClient, "other")
    
    	// this user's groups attribute is ["projectb"]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 97.1K bytes
    - Viewed (0)
  10. cmd/bucket-notification-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	_, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{})
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	config, err := globalBucketMetadataSys.GetNotificationConfig(bucketName)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.1K bytes
    - Viewed (0)
Back to top