Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 391 for ctx_ (0.02 sec)

  1. cmd/bucket-metadata-sys.go

    	}
    
    	return updatedAt, sys.save(ctx, meta)
    }
    
    func (sys *BucketMetadataSys) save(ctx context.Context, meta BucketMetadata) error {
    	objAPI := newObjectLayerFn()
    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    
    	if isMinioMetaBucketName(meta.Name) {
    		return errInvalidArgument
    	}
    
    	if err := meta.Save(ctx, objAPI); err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. cmd/admin-handlers-config-kv.go

    		if err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    		for _, chEntry := range chEntries {
    			if err = delServerConfigHistory(ctx, objectAPI, chEntry.RestoreID); err != nil {
    				writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    				return
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	bucketLifecycle, err := lifecycle.ParseLifecycleConfigWithID(io.LimitReader(r.Body, r.ContentLength))
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Validate the received bucket policy document
    	if err = bucketLifecycle.Validate(rcfg); 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
    - 7K bytes
    - Viewed (0)
  4. cmd/ftp-server-driver.go

    func (driver *ftpDriver) Rename(ctx *ftp.Context, fromObjPath string, toObjPath string) (err error) {
    	stopFn := globalFtpMetrics.log(ctx, fromObjPath, toObjPath)
    	defer stopFn(0, err)
    
    	return NotImplemented{}
    }
    
    // MakeDir implements ftpDriver
    func (driver *ftpDriver) MakeDir(ctx *ftp.Context, objPath string) (err error) {
    	stopFn := globalFtpMetrics.log(ctx, objPath)
    	defer stopFn(0, err)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  5. cmd/admin-handlers-pools.go

    		// We didn't find any matching pools, invalid input
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL)
    		return
    	}
    
    	if !proxyDecommissionRequest(ctx, globalEndpoints[idx].Endpoints[0], w, r) {
    		if err := pools.DecommissionCancel(ctx, idx); err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  6. cmd/admin-bucket-handlers.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    
    	quotaConfig, err := parseBucketQuota(bucket, data)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketQuotaConfigFile, data)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  7. cmd/bucket-policy-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketPolicyConfig, configData)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Call site replication hook.
    	replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{
    		Type:      madmin.SRBucketMetaTypePolicy,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. 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)
  9. cmd/peer-rest-client.go

    func (client *peerRESTClient) GetCPUs(ctx context.Context) (info madmin.CPUs, err error) {
    	resp, err := getCPUsHandler.Call(ctx, client.gridConn(), grid.NewMSS())
    	return resp.ValueOrZero(), err
    }
    
    // GetNetInfo - fetch network information for a remote node.
    func (client *peerRESTClient) GetNetInfo(ctx context.Context) (info madmin.NetInfo, err error) {
    	resp, err := getNetInfoRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  10. 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)
Back to top