Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 325 for ctx (0.02 seconds)

  1. cmd/bucket-handlers.go

    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrObjectLockConfigurationNotAllowed), r.URL)
    		} else {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		}
    		return
    	}
    
    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, objectLockConfig, configData)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (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
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  3. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  4. 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
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  5. cmd/erasure-server-pool.go

    			return ListObjectsInfo{}, err
    		}
    		if contextCanceled(ctx) {
    			return ListObjectsInfo{}, ctx.Err()
    		}
    	}
    	return listFn(ctx, opts, maxKeys)
    }
    
    func (z *erasureServerPools) ListMultipartUploads(ctx context.Context, bucket, prefix, keyMarker, uploadIDMarker, delimiter string, maxUploads int) (ListMultipartsInfo, error) {
    	if err := checkListMultipartArgs(ctx, bucket, prefix, keyMarker, uploadIDMarker, delimiter); err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  6. cmd/iam.go

    	case <-ctx.Done():
    		return nil, ctx.Err()
    	}
    }
    
    // ListUsers - list all users.
    func (sys *IAMSys) ListUsers(ctx context.Context) (map[string]madmin.UserInfo, error) {
    	if !sys.Initialized() {
    		return nil, errServerNotInitialized
    	}
    	select {
    	case <-sys.configLoaded:
    		return sys.store.GetUsers(), nil
    	case <-ctx.Done():
    		return nil, ctx.Err()
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
  7. cmd/metacache-walk.go

    				return nil
    			}
    			if contextCanceled(ctx) {
    				return ctx.Err()
    			}
    			pop := dirStack[len(dirStack)-1]
    			select {
    			case <-ctx.Done():
    				return ctx.Err()
    			case out <- metaCacheEntry{name: pop}:
    			}
    			if opts.Recursive {
    				// Scan folder we found. Should be in correct sort order where we are.
    				internalLogIf(ctx, scanDir(pop))
    			}
    			dirStack = dirStack[:len(dirStack)-1]
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon May 26 07:06:43 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  8. logger/slog.go

    }
    
    func (l *slogLogger) Info(ctx context.Context, msg string, data ...interface{}) {
    	if l.LogLevel >= Info {
    		l.log(ctx, slog.LevelInfo, msg, slog.Any("data", data))
    	}
    }
    
    func (l *slogLogger) Warn(ctx context.Context, msg string, data ...interface{}) {
    	if l.LogLevel >= Warn {
    		l.log(ctx, slog.LevelWarn, msg, slog.Any("data", data))
    	}
    }
    
    func (l *slogLogger) Error(ctx context.Context, msg string, data ...interface{}) {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Oct 30 10:56:26 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  9. cmd/site-replication.go

    		if err != nil {
    			return err
    		}
    
    		c.healBucket(ctx, objAPI, bucket, info)
    
    		if bi.Deleted.IsZero() || (!bi.Created.IsZero() && bi.Deleted.Before(bi.Created)) {
    			c.healVersioningMetadata(ctx, objAPI, bucket, info)
    			c.healOLockConfigMetadata(ctx, objAPI, bucket, info)
    			c.healSSEMetadata(ctx, objAPI, bucket, info)
    			c.healBucketReplicationConfig(ctx, objAPI, bucket, info, &opts)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  10. cmd/erasure-object.go

    	}
    	return false
    }
    
    func readAllXL(ctx context.Context, disks []StorageAPI, bucket, object string, readData, inclFreeVers bool) ([]FileInfo, []error) {
    	rawFileInfos, errs := readAllRawFileInfo(ctx, disks, bucket, object, readData)
    	return pickLatestQuorumFilesInfo(ctx, rawFileInfos, errs, bucket, object, readData, inclFreeVers)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
Back to Top