Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 333 for found (0.12 sec)

  1. cmd/erasure-object.go

    }
    
    // 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/bucket-policy.go

    		}
    		cloneHeader.Del(objLock)
    	}
    
    	for key, values := range cloneHeader {
    		if strings.EqualFold(key, xhttp.AmzObjectTagging) {
    			continue
    		}
    		if existingValues, found := args[key]; found {
    			args[key] = append(existingValues, values...)
    		} else {
    			args[key] = values
    		}
    	}
    
    	cloneURLValues := make(url.Values, len(r.Form))
    	for k, v := range r.Form {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 8K bytes
    - Viewed (0)
  3. cmd/endpoint-ellipses.go

    	if setDriveCount > 0 {
    		msg := fmt.Sprintf("Invalid set drive count. Acceptable values for %d number drives are %d", commonSize, setCounts)
    		var found bool
    		for _, ss := range setCounts {
    			if ss == setDriveCount {
    				found = true
    			}
    		}
    		if !found {
    			return nil, config.ErrInvalidErasureSetSize(nil).Msg(msg)
    		}
    
    		// No automatic symmetry calculation expected, user is on their own
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  4. cmd/post-policy_test.go

    		// Call the ServeHTTP to execute the handler.
    		apiRouter.ServeHTTP(rec, req)
    		if rec.Code != test.expectedStatus {
    			t.Fatalf("Test %d: %s: Expected the response status to be `%d`, but instead found `%d`", i+1, instanceType, test.expectedStatus, rec.Code)
    		}
    	}
    
    	// Test cases for signature-V4.
    	testCasesV4 := []struct {
    		objectName         string
    		data               []byte
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 29.6K bytes
    - Viewed (0)
  5. cmd/namespace-lock.go

    	resource := pathJoin(volume, path)
    
    	n.lockMapMutex.Lock()
    	nsLk, found := n.lockMap[resource]
    	if !found {
    		nsLk = &nsLock{
    			LRWMutex: lsync.NewLRWMutex(),
    		}
    		// Add a count to indicate that a parallel unlock doesn't clear this entry.
    	}
    	nsLk.ref++
    	n.lockMap[resource] = nsLk
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jun 05 23:56:35 GMT 2023
    - 9.2K bytes
    - Viewed (0)
  6. cmd/erasure-metadata.go

    	// Find the successor mod time in quorum, otherwise leave the
    	// candidate's successor modTime as found
    	succModTimeMap := make(map[time.Time]int)
    	var candidate FileInfo
    	var found bool
    	for i, hash := range metaHashes {
    		if hash == maxHash {
    			if metaArr[i].IsValid() {
    				if !found {
    					candidate = metaArr[i]
    					found = true
    				}
    				succModTimeMap[metaArr[i].SuccessorModTime]++
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  7. internal/config/help.go

    			Optional:    true,
    		},
    	}
    )
    
    // DefaultHelpPostfix - Helper function to add (default: $value) messages in config help
    func DefaultHelpPostfix(subsystem KVS, key string) string {
    	val, found := subsystem.Lookup(key)
    	if !found || val == "" {
    		return ""
    	}
    	return " (default: '" + val + "')"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Jun 23 14:45:27 GMT 2023
    - 2.8K bytes
    - Viewed (0)
  8. cmd/signature-v4-utils_test.go

    		t.Fatalf("Unexpected failure with %v", errorCodes.ToAPIErr(s3Err))
    	}
    
    	if !owner {
    		t.Fatalf("Expected owner to be 'true', found %t", owner)
    	}
    
    	_, _, s3Err = checkKeyValid(req, "does-not-exist")
    	if s3Err != ErrInvalidAccessKeyID {
    		t.Fatalf("Expected error 'ErrInvalidAccessKeyID', found %v", s3Err)
    	}
    
    	ucreds, err := auth.CreateCredentials("myuser1", "mypassword1")
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 05 21:26:41 GMT 2024
    - 14.3K bytes
    - Viewed (0)
  9. docs/debugging/inspect/export.go

    				// Read metadata CRC (added in v2, ignore if not found)
    				b = nbuf
    			}
    
    			_, e = msgp.CopyToJSON(buf, bytes.NewReader(v))
    			if e != nil {
    				return nil, e
    			}
    			data = b
    		case 3:
    			v, b, e := msgp.ReadBytesZC(b)
    			if e != nil {
    				return nil, e
    			}
    			if _, nbuf, e := msgp.ReadUint32Bytes(b); e == nil {
    				// Read metadata CRC (added in v2, ignore if not found)
    				b = nbuf
    			}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 08 15:58:02 GMT 2022
    - 9.1K bytes
    - Viewed (0)
  10. internal/event/targetlist.go

    	}
    
    	return nil
    }
    
    // Exists - checks whether target by target ID exists or not.
    func (list *TargetList) Exists(id TargetID) bool {
    	list.RLock()
    	defer list.RUnlock()
    
    	_, found := list.targets[id]
    	return found
    }
    
    // TargetIDResult returns result of Remove/Send operation, sets err if
    // any for the associated TargetID
    type TargetIDResult struct {
    	// ID where the remove or send were initiated.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
Back to top