Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for LimitReader (0.06 sec)

  1. cmd/admin-handlers-users.go

    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminConfigTooLarge), r.URL)
    		return
    	}
    
    	password := cred.SecretKey
    	configBytes, err := madmin.DecryptData(password, io.LimitReader(r.Body, r.ContentLength))
    	if err != nil {
    		adminLogIf(ctx, err)
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminConfigBadJSON), r.URL)
    		return
    	}
    
    	var ureq madmin.AddOrUpdateUserReq
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  2. cmd/batch-handlers.go

    		if err != nil {
    			return ErrorRespToObjectError(err, srcBucket, srcObject, srcObjInfo.VersionID)
    		}
    		defer rd.Close()
    
    		hr, err = hash.NewReader(ctx, io.LimitReader(rd, objInfo.Size), objInfo.Size, "", "", objInfo.Size)
    		if err != nil {
    			return err
    		}
    		pReader := NewPutObjReader(hr)
    		opts.PreserveETag = ""
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    		return 0, errIsNotRegular
    	}
    
    	if verifier == nil {
    		n, err = file.ReadAt(buffer, offset)
    		return int64(n), err
    	}
    
    	h := verifier.algorithm.New()
    	if _, err = io.Copy(h, io.LimitReader(file, offset)); err != nil {
    		return 0, err
    	}
    
    	if n, err = io.ReadFull(file, buffer); err != nil {
    		return int64(n), err
    	}
    
    	if _, err = h.Write(buffer); err != nil {
    		return 0, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	tags, err := tags.ParseBucketXML(io.LimitReader(r.Body, r.ContentLength))
    	if err != nil {
    		apiErr := errorCodes.ToAPIErr(ErrMalformedXML)
    		apiErr.Description = err.Error()
    		writeErrorResponse(ctx, w, apiErr, r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    	}
    	defer gr.Close()
    
    	// rehydrate the parts back on disk as per the original xl.meta prior to transition
    	for _, partInfo := range oi.Parts {
    		hr, err := hash.NewReader(ctx, io.LimitReader(gr, partInfo.Size), partInfo.Size, "", "", partInfo.Size)
    		if err != nil {
    			return setRestoreHeaderFn(oi, err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  6. src/archive/zip/reader_test.go

    //		"os"
    //	)
    //
    //	type zeros struct{}
    //
    //	func (zeros) Read(b []byte) (int, error) {
    //		clear(b)
    //		return len(b), nil
    //	}
    //
    //	func main() {
    //		bigZip := makeZip("big.file", io.LimitReader(zeros{}, 1<<32-1))
    //		if err := os.WriteFile("/tmp/big.zip", bigZip, 0666); err != nil {
    //			log.Fatal(err)
    //		}
    //
    //		biggerZip := makeZip("big.zip", bytes.NewReader(bigZip))
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 55.6K bytes
    - Viewed (0)
Back to top