Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 74 for ReadAll (0.04 sec)

  1. cmd/admin-handlers_test.go

    	if err != nil {
    		t.Fatalf("Failed to build service status request %v", err)
    	}
    
    	rec := httptest.NewRecorder()
    	adminTestBed.router.ServeHTTP(rec, req)
    
    	resp, _ := io.ReadAll(rec.Body)
    	if rec.Code != http.StatusOK {
    		t.Errorf("Expected to receive %d status code but received %d. Body (%s)",
    			http.StatusOK, rec.Code, string(resp))
    	}
    
    	result := &serviceResult{}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  2. cmd/storage-rest-server.go

    	if !s.checkID(p.DiskID) {
    		return nil, grid.NewRemoteErr(errDiskNotFound)
    	}
    
    	volume := p.Volume
    	filePath := p.FilePath
    
    	buf, err := s.getStorage().ReadAll(context.Background(), volume, filePath)
    	return grid.NewBytesWith(buf), grid.NewRemoteErr(err)
    }
    
    // ReadXLHandler - read xl.meta for an object at path.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  3. cmd/signature-v4-utils.go

    	}
    	return false
    }
    
    // Returns SHA256 for calculating canonical-request.
    func getContentSha256Cksum(r *http.Request, stype serviceType) string {
    	if stype == serviceSTS {
    		payload, err := io.ReadAll(io.LimitReader(r.Body, stsRequestBodyLimit))
    		if err != nil {
    			logger.CriticalIf(GlobalContext, err)
    		}
    		sum256 := sha256.Sum256(payload)
    		r.Body = io.NopCloser(bytes.NewReader(payload))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Nov 25 17:10:22 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. docs/debugging/inspect/export.go

    	"github.com/klauspost/compress/zip"
    	"github.com/tinylib/msgp/msgp"
    )
    
    func inspectToExportType(downloadPath string, datajson bool) error {
    	decode := func(r io.Reader, file string) ([]byte, error) {
    		b, e := io.ReadAll(r)
    		if e != nil {
    			return nil, e
    		}
    		b, _, minor, e := checkXL2V1(b)
    		if e != nil {
    			return nil, e
    		}
    
    		buf := bytes.NewBuffer(nil)
    		var data xlMetaInlineData
    		switch minor {
    		case 0:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.2K bytes
    - Viewed (1)
  5. src/bufio/bufio_test.go

    		})
    	}
    }
    
    func TestReaderReset(t *testing.T) {
    	checkAll := func(r *Reader, want string) {
    		t.Helper()
    		all, err := io.ReadAll(r)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if string(all) != want {
    			t.Errorf("ReadAll returned %q, want %q", all, want)
    		}
    	}
    
    	r := NewReader(strings.NewReader("foo foo"))
    	buf := make([]byte, 3)
    	r.Read(buf)
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  6. cmd/bucket-policy-handlers_test.go

    			t.Fatalf("Case %d: Expected the response status to be `%d`, but instead found `%d`", i+1, testCase.expectedRespStatus, recV4.Code)
    		}
    		// read the response body.
    		bucketPolicyReadBuf, err := io.ReadAll(recV4.Body)
    		if err != nil {
    			t.Fatalf("Test %d: %s: Failed parsing response body: <ERROR> %v", i+1, instanceType, err)
    		}
    
    		if recV4.Code != testCase.expectedRespStatus {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    		buf = make([]byte, sz)
    	}
    
    	// Read file...
    	_, err = io.ReadFull(f, buf)
    
    	return buf, stat.ModTime().UTC(), osErrToFileErr(err)
    }
    
    // ReadAll is a raw call, reads content at any path and returns the buffer.
    func (s *xlStorage) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) {
    	// Specific optimization to avoid re-read from the drives for `format.json`
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  8. cmd/xl-storage_test.go

    		{
    			volume: "ab",
    			path:   "as-file",
    			err:    errVolumeNotFound,
    		},
    	}
    
    	var dataRead []byte
    	// Run through all the test cases and validate for ReadAll.
    	for i, testCase := range testCases {
    		dataRead, err = xlStorage.ReadAll(t.Context(), testCase.volume, testCase.path)
    		if err != testCase.err {
    			t.Errorf("TestXLStorage %d: Expected err \"%v\", got err \"%v\"", i+1, testCase.err, err)
    			continue
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
  9. src/archive/tar/reader.go

    		n += nn
    	}
    	if len(b) == n && err == io.EOF {
    		err = nil
    	}
    	return n, err
    }
    
    // readSpecialFile is like io.ReadAll except it returns
    // ErrFieldTooLong if more than maxSpecialFileSize is read.
    func readSpecialFile(r io.Reader) ([]byte, error) {
    	buf, err := io.ReadAll(io.LimitReader(r, maxSpecialFileSize+1))
    	if len(buf) > maxSpecialFileSize {
    		return nil, ErrFieldTooLong
    	}
    	return buf, err
    }
    
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Tue Oct 07 19:46:36 UTC 2025
    - 26.9K bytes
    - Viewed (0)
  10. src/archive/zip/reader_test.go

    		return
    	}
    	start, err := f.DataOffset()
    	if err != nil {
    		t.Errorf("%v: DataOffset error=%v", f.Name, err)
    		return
    	}
    	got, err := io.ReadAll(rw)
    	if err != nil {
    		t.Errorf("%v: OpenRaw ReadAll error=%v", f.Name, err)
    		return
    	}
    	end := uint64(start) + f.CompressedSize64
    	want := raw[start:end]
    	if !bytes.Equal(got, want) {
    		t.Logf("got %q", got)
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Oct 17 20:10:27 UTC 2025
    - 56.5K bytes
    - Viewed (0)
Back to top