Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 59 for ReadAll (0.22 sec)

  1. 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)
  2. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatalf("Failed to getLatestFileInfo - %v", err)
    	}
    
    	part1Disk1Origin, err := firstDisk.ReadAll(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"))
    	if err != nil {
    		t.Fatalf("Failed to read a file - %v", err)
    	}
    
    	part1Disk2Origin, err := secondDisk.ReadAll(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"))
    	if err != nil {
    		t.Fatalf("Failed to read a file - %v", err)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  3. docs/debugging/inspect/main.go

    	// Parse parameters
    	switch {
    	case *stdin:
    		// Parse 'mc support inspect --json' output
    		input := struct {
    			File string `json:"file"`
    			Key  string `json:"key"`
    		}{}
    		got, err := io.ReadAll(os.Stdin)
    		if err != nil {
    			fatalErr(err)
    		}
    		fatalErr(json.Unmarshal(got, &input))
    		inputs = []string{input.File}
    		*keyHex = input.Key
    	case len(flag.Args()) == 1:
    		var err error
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 17 17:09:42 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  4. cmd/storage-interface.go

    	// Write all data, syncs the data to disk.
    	// Should be used for smaller payloads.
    	WriteAll(ctx context.Context, volume string, path string, b []byte) (err error)
    
    	// Read all.
    	ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error)
    	GetDiskLoc() (poolIdx, setIdx, diskIdx int) // Retrieve location indexes.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  5. cmd/object-handlers_test.go

    		if rec.Code != testCase.expectedRespStatus {
    			b, _ := io.ReadAll(rec.Body)
    			t.Fatalf("Test %d: Expected the response status to be `%d`, but instead found `%d`: %s", i, testCase.expectedRespStatus, rec.Code, string(b))
    		}
    		if testCase.expectedRespStatus != http.StatusOK {
    			b, err := io.ReadAll(rec.Body)
    			if err != nil {
    				t.Fatal(err)
    			}
    			var apiErr APIErrorResponse
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  6. cmd/storage-rest-client.go

    	}
    	defer xhttp.DrainBody(respBody)
    
    	dec := msgpNewReader(respBody)
    	defer readMsgpReaderPoolPut(dec)
    
    	err = rf.DecodeMsg(dec)
    	return rf, err
    }
    
    // ReadAll - reads all contents of a file.
    func (client *storageRESTClient) ReadAll(ctx context.Context, volume string, path string) ([]byte, error) {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  7. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  8. cmd/xl-storage-format-v2_test.go

    	f, err := os.Open("testdata/xl.meta-corrupt.gz")
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer f.Close()
    
    	gz, err := gzip.NewReader(bufio.NewReader(f))
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	buf, err := io.ReadAll(gz)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	_, err = readXLMetaNoData(bytes.NewReader(buf), int64(len(buf)))
    	if err == nil {
    		t.Fatal("expected error but returned success")
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  9. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  10. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Nov 25 17:10:22 UTC 2024
    - 9.1K bytes
    - Viewed (0)
Back to top