Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 208 for newReader (0.22 sec)

  1. cmd/erasure-server-pool-rebalance.go

    		parts := make([]CompletePart, len(oi.Parts))
    		for i, part := range oi.Parts {
    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    				return fmt.Errorf("rebalanceObject: hash.NewReader() %w", err)
    			}
    			pi, err := z.PutObjectPart(ctx, bucket, oi.Name, res.UploadID,
    				part.Number,
    				NewPutObjReader(hr),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  2. src/cmd/asm/internal/lex/lex.go

    	tokens []Token  // Body of macro.
    }
    
    // Tokenize turns a string into a list of Tokens; used to parse the -D flag and in tests.
    func Tokenize(str string) []Token {
    	t := NewTokenizer("command line", strings.NewReader(str), nil)
    	var tokens []Token
    	for {
    		tok := t.Next()
    		if tok == scanner.EOF {
    			break
    		}
    		tokens = append(tokens, Make(tok, t.Text()))
    	}
    	return tokens
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  3. src/bufio/bufio.go

    	b, ok := rd.(*Reader)
    	if ok && len(b.buf) >= size {
    		return b
    	}
    	r := new(Reader)
    	r.reset(make([]byte, max(size, minReadBufferSize)), rd)
    	return r
    }
    
    // NewReader returns a new [Reader] whose buffer has the default size.
    func NewReader(rd io.Reader) *Reader {
    	return NewReaderSize(rd, defaultBufSize)
    }
    
    // Size returns the size of the underlying buffer in bytes.
    func (b *Reader) Size() int { return len(b.buf) }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  4. cmd/bucket-lifecycle_test.go

    			expectedErr: nil,
    		},
    	}
    	for i, tc := range testCases {
    		lc, err := lifecycle.ParseLifecycleConfig(bytes.NewReader(tc.xml))
    		if err != nil {
    			t.Fatalf("Test %d: Failed to parse lifecycle config %v", i+1, err)
    		}
    
    		err = validateTransitionTier(lc)
    		if err != tc.expectedErr {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 31 09:57:57 UTC 2022
    - 7K bytes
    - Viewed (0)
  5. internal/disk/stat_linux.go

    	}
    	return
    }
    
    func readStat(fileName string) (stats []uint64, err error) {
    	file, err := os.Open(fileName)
    	if err != nil {
    		return nil, err
    	}
    	defer file.Close()
    
    	s, err := bufio.NewReader(file).ReadString('\n')
    	if err != nil && !errors.Is(err, io.EOF) {
    		return nil, err
    	}
    	statLine := strings.TrimSpace(s)
    	for _, token := range strings.Fields(statLine) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  6. cmd/erasure-healing-common_test.go

    		t.Fatal(err)
    	}
    
    	for i, test := range testCases {
    		test := test
    		t.Run(fmt.Sprintf("case-%d", i), func(t *testing.T) {
    			_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", ""), ObjectOptions{})
    			if err != nil {
    				t.Fatalf("Failed to putObject %v", err)
    			}
    
    			partsMetadata, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  7. cmd/post-policy_test.go

    			t.Fatalf("Test %d: %s: Failed to create HTTP request for PostPolicyHandler: <ERROR> %v", i+1, instanceType, perr)
    		}
    		if testCase.malformedBody {
    			// Change the request body.
    			req.Body = io.NopCloser(bytes.NewReader([]byte("Hello,")))
    		}
    		// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    		// Call the ServeHTTP to execute the handler.
    		apiRouter.ServeHTTP(rec, req)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  8. internal/s3select/jstream/decoder_test.go

    package jstream
    
    import (
    	"bytes"
    	"testing"
    )
    
    func mkReader(s string) *bytes.Reader { return bytes.NewReader([]byte(s)) }
    
    func TestDecoderSimple(t *testing.T) {
    	var (
    		counter int
    		mv      *MetaValue
    		body    = `[{"bio":"bada bing bada boom","id":1,"name":"Charles","falseVal":false}]`
    	)
    
    	decoder := NewDecoder(mkReader(body), 1)
    
    	for mv = range decoder.Stream() {
    		counter++
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  9. docs/debugging/inspect/main.go

    			privateKey = b
    			fmt.Println("Using private key from", *privKeyPath)
    		}
    
    		// Prompt for decryption key if no --key or --private-key are provided
    		if len(privateKey) == 0 && !*stdin {
    			reader := bufio.NewReader(os.Stdin)
    			fmt.Print("Enter Decryption Key: ")
    
    			text, _ := reader.ReadString('\n')
    			// convert CRLF to LF
    			*keyHex = strings.ReplaceAll(text, "\n", "")
    			*keyHex = strings.TrimSpace(*keyHex)
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 31 14:49:23 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  10. cmd/auth-handler.go

    		}
    
    		// Populate payload to extract location constraint.
    		r.Body = io.NopCloser(bytes.NewReader(payload))
    		region, s3Err = parseLocationConstraint(r)
    		if s3Err != ErrNone {
    			return s3Err
    		}
    
    		// Populate payload again to handle it in HTTP handler.
    		r.Body = io.NopCloser(bytes.NewReader(payload))
    	}
    
    	logger.GetReqInfo(ctx).Region = region
    
    	return s3Err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top