Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for read_all (0.27 sec)

  1. cmd/sts-handlers_test.go

    		}
    	}
    
    	contentReader, err := s.adm.ExportIAM(ctx)
    	if err != nil {
    		c.Fatalf("export %d: Unable to export IAM: %v", caseNum, err)
    	}
    	defer contentReader.Close()
    
    	expContent, err := io.ReadAll(contentReader)
    	if err != nil {
    		c.Fatalf("export %d: Unable to read exported content: %v", caseNum, err)
    	}
    
    	return expContent
    }
    
    type dummyCloser struct {
    	io.Reader
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  2. 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) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  3. internal/s3select/select_test.go

    				ContentLength: int64(len(w.response)),
    			}
    			res, err := minio.NewSelectResults(&resp, "testbucket")
    			if err != nil {
    				t.Error(err)
    				return
    			}
    			got, err := io.ReadAll(res)
    			if err != nil {
    				t.Error(err)
    				return
    			}
    			gotS := strings.TrimSpace(string(got))
    			if !reflect.DeepEqual(gotS, testCase.wantResult) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 76.2K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    	if err != nil {
    		return nil, err
    	}
    
    	newChunkHdr := []byte(fmt.Sprintf("%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(""))),
    	)
    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)
  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(context.Background(), testCase.volume, testCase.path)
    		if err != testCase.err {
    			t.Errorf("TestXLStorage %d: Expected err \"%v\", got err \"%v\"", i+1, testCase.err, err)
    			continue
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
  6. cmd/batch-handlers.go

    	ctx := r.Context()
    
    	objectAPI, creds := validateAdminReq(ctx, w, r, policy.StartBatchJobAction)
    	if objectAPI == nil {
    		return
    	}
    
    	buf, err := io.ReadAll(ioutil.HardLimitReader(r.Body, humanize.MiByte*4))
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	user := creds.AccessKey
    	if creds.ParentUser != "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  7. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  8. 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 {
    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