Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for SplitN (0.17 sec)

  1. cmd/erasure-object.go

    	}
    	// return errors if any during deletion
    	return reduceWriteQuorumErrs(ctx, g.Wait(), objectOpIgnoredErrs, writeQuorum)
    }
    
    // DeleteObjects deletes objects/versions in bulk, this function will still automatically split objects list
    // into smaller bulks if some object names are found to be duplicated in the delete list, splitting
    // into smaller bulks will avoid holding twice the write lock of the duplicated object names.
    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)
  2. cmd/test-utils_test.go

    	encodedResource := req.URL.RawPath
    	encodedQuery := req.URL.RawQuery
    	if encodedResource == "" {
    		splits := strings.SplitN(req.URL.Path, "?", 2)
    		encodedResource = splits[0]
    		if len(splits) == 2 {
    			encodedQuery = splits[1]
    		}
    	}
    
    	unescapedQueries, err := unescapeQueries(encodedQuery)
    	if err != nil {
    		return err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  3. cmd/iam-store.go

    		return true
    	})
    	return policies
    }
    
    // converts a mapped policy into a slice of distinct policies
    func (mp MappedPolicy) toSlice() []string {
    	var policies []string
    	for _, policy := range strings.Split(mp.Policies, ",") {
    		if strings.TrimSpace(policy) == "" {
    			continue
    		}
    		policies = append(policies, policy)
    	}
    	return policies
    }
    
    func (mp MappedPolicy) policySet() set.StringSet {
    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)
  4. cmd/xl-storage.go

    			}
    		}
    	}
    
    	// Set skipParent to skip mkdirAll() calls for deeply nested objects
    	// - if its an overwrite
    	// - if its a versioned object
    	//
    	// This can potentiall reduce syscalls by strings.Split(path, "/")
    	// times relative to the object name.
    	skipParent := dstVolumeDir
    	if len(dstBuf) > 0 {
    		skipParent = pathutil.Dir(dstFilePath)
    	}
    
    	var reqVID string
    	if fi.VersionID == "" {
    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)
  5. cmd/peer-rest-server.go

    	if !s.IsValid(w, r) {
    		s.writeErrorResponse(w, errors.New("Invalid request"))
    		return
    	}
    
    	vars := mux.Vars(r)
    	profiles := strings.Split(vars[peerRESTProfiler], ",")
    	if len(profiles) == 0 {
    		s.writeErrorResponse(w, errors.New("profiler name is missing"))
    		return
    	}
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  6. cmd/batch-handlers.go

    		opts.VersionID = ""
    	}
    	if crypto.S3.IsEncrypted(srcObjInfo.UserDefined) {
    		opts.ServerSideEncryption = encrypt.NewSSE()
    	}
    	slc := strings.Split(srcObjInfo.ETag, "-")
    	if len(slc) == 2 {
    		partsCount, err := strconv.Atoi(slc[1])
    		if err != nil {
    			return err
    		}
    		return r.copyWithMultipartfromSource(ctx, api, core, srcObjInfo, opts, partsCount)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
Back to top