Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for send (0.15 sec)

  1. cmd/erasure-server-pool.go

    					recursive:      true,
    					forwardTo:      opts.Marker,
    					minDisks:       listingQuorum,
    					reportNotFound: false,
    					agreed:         send,
    					partial: func(entries metaCacheEntries, _ []error) {
    						entry, ok := entries.resolve(&resolver)
    						if ok {
    							send(*entry)
    						}
    					},
    					finished: nil,
    				}
    
    				if err := listPathRaw(ctx, lopts); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    		// the content implicitly for all versions, we can
    		// avoid triggering another MRF heal for offline drives.
    		if len(versions) == 0 {
    			// Whether a disk was initially or becomes offline
    			// during this upload, send it to the MRF list.
    			for i := 0; i < len(onlineDisks); i++ {
    				if onlineDisks[i] != nil && onlineDisks[i].IsOnline() {
    					continue
    				}
    
    				er.addPartial(bucket, object, fi.VersionID)
    				break
    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)
  3. cmd/api-errors.go

    		case *googleapi.Error:
    			apiErr = APIError{
    				Code:           "XGCSInternalError",
    				Description:    e.Message,
    				HTTPStatusCode: e.Code,
    			}
    			// GCS may send multiple errors, just pick the first one
    			// since S3 only sends one Error XML response.
    			if len(e.Errors) >= 1 {
    				apiErr.Code = e.Errors[0].Reason
    			}
    		case azblob.StorageError:
    			apiErr = APIError{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  4. cmd/object-api-listobjects_test.go

    		// Marker being set to a value which is greater than and all object names when sorted (36).
    		// Expected to send an empty response in this case.
    		{"test-bucket-list-object", "", "zen", "", 10, ListObjectsInfo{}, nil, true},
    		// Marker being set to a value which is lesser than and all object names when sorted (37).
    		// Expected to send all the objects in the bucket in this case.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  5. cmd/test-utils_test.go

    func getRandomRange(min, max int, seed int64) int {
    	// special value -1 means no explicit seeding.
    	if seed != -1 {
    		rand.Seed(seed)
    	}
    	return rand.Intn(max-min) + min
    }
    
    // Randomizes the order of bytes in the byte array
    // using Knuth Fisher-Yates shuffle algorithm.
    func randomizeBytes(s []byte, seed int64) []byte {
    	// special value -1 means no explicit seeding.
    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)
  6. cmd/admin-handlers-users.go

    	if hasSpaceBE(createReq.AccessKey) {
    		return ctx, auth.Credentials{}, newServiceAccountOpts{}, madmin.AddServiceAccountReq{}, "", errorCodes.ToAPIErr(ErrAdminResourceInvalidArgument)
    	}
    
    	if err := createReq.Validate(); err != nil {
    		// Since this validation would happen client side as well, we only send
    		// a generic error message here.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 77.5K bytes
    - Viewed (0)
Back to top