Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for readAll (0.04 sec)

  1. cmd/test-utils_test.go

    	if err != nil {
    		return nil, err
    	}
    
    	newChunkHdr := fmt.Appendf(nil, "%s"+s3ChunkSignatureStr+"%s\r\n",
    		hexChunkSize, chunkSignature)
    	newChunk, err := io.ReadAll(bufReader)
    	if err != nil {
    		return nil, err
    	}
    	newReq := req
    	newReq.Body = io.NopCloser(
    		bytes.NewReader(bytes.Join([][]byte{newChunkHdr, newChunk[:len(newChunk)/2]},
    			[]byte(""))),
    	)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  2. cmd/admin-handlers-users.go

    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.AddUserToGroupAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    	data, err := io.ReadAll(r.Body)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    
    	var updReq madmin.GroupAddRemove
    	err = json.Unmarshal(data, &updReq)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    		buf = buf[:sz]
    	} else {
    		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) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  4. 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 Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Mar 11 22:19:38 UTC 2025
    - 56.6K bytes
    - Viewed (0)
  5. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
  6. 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 Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    	ctx := r.Context()
    
    	objectAPI, creds := validateAdminReq(ctx, w, r, policy.StartBatchJobAction)
    	if objectAPI == nil {
    		return
    	}
    
    	buf, err := io.ReadAll(xioutil.HardLimitReader(r.Body, humanize.MiByte*4))
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	user := creds.AccessKey
    	if creds.ParentUser != "" {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2_gen.go

    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "V2Obj":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "ObjectV2")
    					return
    				}
    				z.ObjectV2 = nil
    			} else {
    				if z.ObjectV2 == nil {
    					z.ObjectV2 = new(struct {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Dec 15 22:50:12 UTC 2024
    - 56K bytes
    - Viewed (0)
  9. cmd/bucket-stats_gen.go

    			z.CurrentBandwidthInBytesPerSecond, err = dc.ReadFloat64()
    			if err != nil {
    				err = msgp.WrapError(err, "CurrentBandwidthInBytesPerSecond")
    				return
    			}
    		case "lt":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "XferRateLrg")
    					return
    				}
    				z.XferRateLrg = nil
    			} else {
    				if z.XferRateLrg == nil {
    					z.XferRateLrg = new(XferStats)
    				}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 57.5K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v2.go

    	hasFull := true
    	if initial > metaDataReadDefault {
    		initial = metaDataReadDefault
    		hasFull = false
    	}
    
    	buf := metaDataPoolGet()[:initial]
    	_, err := io.ReadFull(r, buf)
    	if err != nil {
    		return nil, fmt.Errorf("readXLMetaNoData(io.ReadFull): %w", err)
    	}
    	readMore := func(n int64) error {
    		has := int64(len(buf))
    		if has >= n {
    			return nil
    		}
    		if hasFull || n > size {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 65.6K bytes
    - Viewed (1)
Back to top