Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 2,660 for Errorf (0.42 sec)

  1. cmd/xl-storage_windows_test.go

    	}
    
    	// Try to create a file that includes a file in its path components.
    	// In *nix, this returns syscall.ENOTDIR while in windows we receive the following error.
    	err = fs.AppendFile(context.Background(), "voldir", "/file/obj1", []byte("hello"))
    	if err != errFileAccessDenied {
    		t.Errorf("expected: %s, got: %s", errFileAccessDenied, err)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Nov 29 06:35:16 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  2. internal/s3select/jstream/scanner_test.go

    	failAfter int
    }
    
    func newMockReader(failAfter int, data byte) *mockReader {
    	return &mockReader{0, data, failAfter}
    }
    
    func (r *mockReader) Read(p []byte) (n int, err error) {
    	if r.pos >= r.failAfter {
    		return 0, fmt.Errorf("intentionally unexpected reader error")
    	}
    	r.pos++
    	p[0] = r.mockData
    	return 1, nil
    }
    
    func TestScannerFailure(t *testing.T) {
    	var (
    		i         int
    		failAfter = 900
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  3. internal/config/subnet/subnet.go

    	if resp.StatusCode == http.StatusOK {
    		return respStr, nil
    	}
    
    	return respStr, fmt.Errorf("SUBNET request failed with code %d and error: %s", resp.StatusCode, respStr)
    }
    
    // Post submit 'payload' to specified URL
    func (c Config) Post(reqURL string, payload any) (string, error) {
    	if !c.Registered() {
    		return "", errors.New("Deployment is not registered with SUBNET. Please register the deployment via 'mc license register ALIAS'")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  4. internal/s3select/message.go

    	207, 151, 211, 146, // message crc.
    }
    
    // newErrorMessage - creates new Request Level Error Message. S3 sends this message if the request failed for any reason.
    // It contains the error code and error message for the failure. If S3 sends a RequestLevelError message,
    // it doesn't send an End message.
    //
    // Header specification:
    // Request-level error messages contain three headers, as follows:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  5. internal/disk/stat_windows.go

    	info.Ffree = uint64(lpNumberOfFreeClusters)
    
    	return info, nil
    }
    
    // GetDriveStats returns IO stats of the drive by its major:minor
    func GetDriveStats(major, minor uint32) (iostats IOStats, err error) {
    	return IOStats{}, errors.New("operation unsupported")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. cmd/sftp-server-driver.go

    }
    
    // TransferError will catch network errors during transfer.
    // When TransferError() is called Close() will also
    // be called, so we do not need to Wait() here.
    func (w *writerAt) TransferError(err error) {
    	_ = w.w.CloseWithError(err)
    	_ = w.r.CloseWithError(err)
    	w.err = err
    }
    
    func (w *writerAt) Close() (err error) {
    	switch {
    	case len(w.buffer) > 0:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 10 16:35:49 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  7. internal/config/certs_test.go

    			t.Setenv(EnvCertPassword, testCase.password)
    		}
    		_, err = LoadX509KeyPair(certificate, privateKey)
    		if err != nil && !testCase.shouldFail {
    			t.Errorf("Test %d: test should succeed but it failed: %v", i, err)
    		}
    		if err == nil && testCase.shouldFail {
    			t.Errorf("Test %d: test should fail but it succeed", i)
    		}
    		os.Remove(privateKey)
    		os.Remove(certificate)
    	}
    }
    
    var loadX509KeyPairTests = []struct {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  8. internal/config/bool-flag.go

    		return true, nil
    	}
    	if strings.EqualFold(str, "disabled") {
    		return false, nil
    	}
    	return false, fmt.Errorf("ParseBool: parsing '%s': %w", str, strconv.ErrSyntax)
    }
    
    // ParseBoolFlag - parses string into BoolFlag.
    func ParseBoolFlag(s string) (bf BoolFlag, err error) {
    	b, err := ParseBool(s)
    	return BoolFlag(b), err
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Apr 07 15:10:40 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  9. docs/debugging/reorder-disks/main.go

    	}
    
    	if err := scanner.Err(); err != nil {
    		return nil, err
    	}
    
    	return result, nil
    }
    
    func getDiskUUIDMap() (map[string]string, error) {
    	result := make(map[string]string)
    	err := filepath.Walk("/dev/disk/by-uuid/",
    		func(path string, info os.FileInfo, err error) error {
    			if err != nil {
    				return err
    			}
    			realPath, err := filepath.EvalSymlinks(path)
    			if err != nil {
    				return err
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  10. internal/s3select/progress.go

    	default:
    		return nil, errInvalidCompressionFormat(fmt.Errorf("unknown compression type '%v'", compType))
    	}
    	pr.processedReader = newCountUpReader(r)
    
    	return &pr, nil
    }
    
    type nopReadCloser struct {
    	fn func()
    }
    
    func (n2 *nopReadCloser) Read(p []byte) (n int, err error) {
    	panic("should not be called")
    }
    
    func (n2 *nopReadCloser) Close() error {
    	if n2.fn != nil {
    		n2.fn()
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top