Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 181 for We (0.15 sec)

  1. cmd/metacache-set.go

    	if askDisks == -1 {
    		newDisks := getQuorumDisks(disks, infos, (len(disks)+1)/2)
    		if newDisks != nil {
    			// If we found disks signature in quorum, we proceed to list
    			// from a single drive, shuffling of the drives is subsequently.
    			disks = newDisks
    			askDisks = 1
    		} else {
    			// If we did not find suitable disks, perform strict quorum listing
    			// as no disk agrees on quorum anymore.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  2. internal/dsync/drwmutex.go

    				locksFailed++
    				if locksFailed > tolerance {
    					// We know that we are not going to get the lock anymore,
    					// so exit out and release any locks that did get acquired
    					done = true
    				}
    			}
    		case <-ctx.Done():
    			// Capture timedout locks as failed or took too long
    			locksFailed++
    			if locksFailed > tolerance {
    				// We know that we are not going to get the lock anymore,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  3. cmd/sts-handlers.go

    	// RoleARN parameter processing: If a role ARN is given in the request, we
    	// use that and validate the authentication request. If not, we assume this
    	// is an STS request for a claim based IDP (if one is present) and set
    	// roleArn = openid.DummyRoleARN.
    	//
    	// Currently, we do not support multiple claim based IDPs, as there is no
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 18:36:18 GMT 2024
    - 34.7K bytes
    - Viewed (2)
  4. cmd/metacache-walk.go

    				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.
    					err := scanDir(pop)
    					if err != nil && !IsErrIgnored(err, context.Canceled) {
    						internalLogIf(ctx, err)
    					}
    				}
    				dirStack = dirStack[:len(dirStack)-1]
    			}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  5. cmd/erasure-multipart.go

    			if time.Since(vi.Created) > expiry {
    				pathUUID := mustGetUUID()
    				targetPath := pathJoin(drivePath, minioMetaTmpDeletedBucket, pathUUID)
    
    				// We are not deleting shaDir recursively here, if shaDir is empty
    				// and its older then we can happily delete it.
    				Rename(pathJoin(drivePath, minioMetaMultipartBucket, shaDir), targetPath)
    			}
    			wait()
    			return nil
    		})
    	})
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  6. cmd/admin-handlers-idp-config.go

    		return
    	}
    
    	if err = validateConfig(ctx, cfg, subSys); err != nil {
    
    		var validationErr ldap.Validation
    		if errors.As(err, &validationErr) {
    			// If we got an LDAP validation error, we need to send appropriate
    			// error message back to client (likely mc).
    			writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminConfigLDAPValidation),
    				validationErr.FormatError(), r.URL)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  7. cmd/data-usage-cache.go

    	})
    	for remove > 0 && len(leaves) > 0 {
    		// Remove top entry.
    		e := leaves[0]
    		candidate := e.path
    		if candidate == path && !compactSelf {
    			// We should be the biggest,
    			// if we cannot compact ourself, we are done.
    			break
    		}
    		removing := d.totalChildrenRec(candidate.Key())
    		flat := d.sizeRecursive(candidate.Key())
    		if flat == nil {
    			leaves = leaves[1:]
    			continue
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  8. cmd/batch-handlers.go

    	}
    	if srcObjInfo.DeleteMarker {
    		_, err := api.DeleteObject(ctx, tgtBucket, tgtObject, ObjectOptions{
    			VersionID: versionID,
    			// Since we are preserving a delete marker, we have to make sure this is always true.
    			// regardless of the current configuration of the bucket we must preserve all versions
    			// on the pool being batch replicated from source.
    			Versioned:          true,
    			MTime:              srcObjInfo.ModTime,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 14:11:38 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  9. .github/workflows/multipart/migrate.sh

    failed_count_site2=$(s3-check-md5 -versions -access-key minioadmin -secret-key minioadmin -endpoint http://site2-nginx:9002 -bucket testbucket 2>&1 | grep FAILED | wc -l)
    
    ## we do not need to fail here, since we are going to test
    ## upgrading to master, healing and being able to recover
    ## the last version.
    if [ $failed_count_site1 -ne 0 ]; then
    	echo "failed with multipart on site1 uploads ${failed_count_site1}"
    fi
    Shell Script
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 15:54:24 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  10. cmd/object-handlers-common.go

    // to activate delete only headers set delete as true
    func setPutObjHeaders(w http.ResponseWriter, objInfo ObjectInfo, delete bool) {
    	// We must not use the http.Header().Set method here because some (broken)
    	// clients expect the ETag header key to be literally "ETag" - not "Etag" (case-sensitive).
    	// Therefore, we have to set the ETag directly as map entry.
    	if objInfo.ETag != "" && !delete {
    		w.Header()[xhttp.ETag] = []string{`"` + objInfo.ETag + `"`}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 09 08:17:49 GMT 2024
    - 14.6K bytes
    - Viewed (0)
Back to top