Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 123 for readAll (0.05 seconds)

  1. src/archive/tar/writer_test.go

    			origtarget := string(fsys[name].Data)
    			if hdr.Linkname != origtarget {
    				t.Fatalf("test fs has link content %s; archive header %v", origtarget, hdr.Linkname)
    			}
    		default:
    			data, err := io.ReadAll(tr)
    			if err != nil {
    				t.Fatal(err)
    			}
    			origdata := fsys[name].Data
    			if string(data) != string(origdata) {
    				t.Fatalf("test fs has file content %v; archive header has %v", origdata, data)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 15 16:34:13 GMT 2025
    - 40.2K bytes
    - Click Count (0)
  2. internal/s3select/csv/reader_contrib_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	for _, f := range z.File {
    		if f.Name == file {
    			rc, err := f.Open()
    			if err != nil {
    				t.Fatal(err)
    			}
    			defer rc.Close()
    			b, err := io.ReadAll(rc)
    			if err != nil {
    				t.Fatal(err)
    			}
    			return b
    		}
    	}
    	t.Fatal(file, "not found in testdata/testdata.zip")
    	return nil
    }
    
    func TestReadExtended(t *testing.T) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.4K bytes
    - Click Count (0)
  3. 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 != "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  4. 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
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 103.4K bytes
    - Click Count (1)
  5. cmd/batch-job-common-types_gen.go

    				if err != nil {
    					err = msgp.WrapError(err, "SmallerThan")
    					return
    				}
    				z.SmallerThan = nil
    			} else {
    				if z.SmallerThan == nil {
    					z.SmallerThan = new(string)
    				}
    				*z.SmallerThan, err = dc.ReadString()
    				if err != nil {
    					err = msgp.WrapError(err, "SmallerThan")
    					return
    				}
    			}
    		case "SkipErrs":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.9K bytes
    - Click Count (0)
  6. cmd/streaming-v4-unsigned.go

    			return n, cr.err
    		}
    	}
    
    	if cap(cr.buffer) < size {
    		cr.buffer = make([]byte, size)
    	} else {
    		cr.buffer = cr.buffer[:size]
    	}
    
    	// Now, we read the payload.
    	_, err = io.ReadFull(cr.reader, cr.buffer)
    	if err == io.EOF && size != 0 {
    		err = io.ErrUnexpectedEOF
    	}
    	if err != nil && err != io.EOF {
    		cr.err = err
    		return n, cr.err
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 03 14:55:52 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  7. cmd/storage-rest-common_gen.go

    				return
    			}
    		case "m":
    			z.ScanMode, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "ScanMode")
    				return
    			}
    		case "c":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "Cache")
    					return
    				}
    				z.Cache = nil
    			} else {
    				if z.Cache == nil {
    					z.Cache = new(dataUsageCache)
    				}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  8. internal/s3select/json/preader.go

    	if cap(dst) < skip {
    		dst = make([]byte, 0, skip+1024)
    	}
    	dst = dst[:skip]
    	if skip > 0 {
    		n, err := io.ReadFull(r.buf, dst)
    		if err != nil && err != io.ErrUnexpectedEOF {
    			// If an EOF happens after reading some but not all the bytes,
    			// ReadFull returns ErrUnexpectedEOF.
    			return dst[:n], err
    		}
    		dst = dst[:n]
    		if err == io.ErrUnexpectedEOF {
    			return dst, io.EOF
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  9. cmd/bitrot-streaming.go

    		}
    	}
    	if offset != b.currOffset {
    		// Can never happen unless there are programmer bugs
    		return 0, errUnexpected
    	}
    	b.h.Reset()
    	_, err = io.ReadFull(b.rc, b.hashBytes)
    	if err != nil {
    		return 0, err
    	}
    	_, err = io.ReadFull(b.rc, buf)
    	if err != nil {
    		return 0, err
    	}
    	b.h.Write(buf)
    	if !bytes.Equal(b.h.Sum(nil), b.hashBytes) {
    		return 0, errFileCorrupt
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jan 17 19:19:30 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  10. internal/crypto/key.go

    	if random == nil {
    		random = rand.Reader
    	}
    	if len(extKey) != 32 { // safety check
    		logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length"))
    	}
    	var nonce [32]byte
    	if _, err := io.ReadFull(random, nonce[:]); err != nil {
    		logger.CriticalIf(context.Background(), errOutOfEntropy)
    	}
    
    	const Context = "object-encryption-key generation"
    	mac := hmac.New(sha256.New, extKey)
    	mac.Write([]byte(Context))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 6.2K bytes
    - Click Count (0)
Back to Top