Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 208 for newReader (0.15 sec)

  1. cmd/metacache-set.go

    		if len(b.data) == 0 && b.n == 0 && o.Transient {
    			return nil
    		}
    		o.debugln(color.Green("saveMetaCacheStream:")+" saving block", b.n, "to", o.objectPath(b.n))
    		r, err := hash.NewReader(ctx, bytes.NewReader(b.data), int64(len(b.data)), "", "", int64(len(b.data)))
    		bugLogIf(ctx, err)
    		custom := b.headerKV()
    		_, err = er.putMetacacheObject(ctx, o.objectPath(b.n), NewPutObjReader(r), ObjectOptions{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  2. src/archive/tar/reader.go

    	// ensure that this error is sticky.
    	err error
    }
    
    type fileReader interface {
    	io.Reader
    	fileState
    
    	WriteTo(io.Writer) (int64, error)
    }
    
    // NewReader creates a new [Reader] reading from r.
    func NewReader(r io.Reader) *Reader {
    	return &Reader{r: r, curr: &regFileReader{r, 0}}
    }
    
    // Next advances to the next entry in the tar archive.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  3. internal/logger/target/http/http.go

    			h.status.Store(statusOnline)
    		}
    	}()
    
    	ctx, cancel := context.WithTimeout(ctx, timeout)
    	defer cancel()
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost,
    		h.Endpoint(), bytes.NewReader(payload))
    	if err != nil {
    		return fmt.Errorf("invalid configuration for '%s'; %v", h.Endpoint(), err)
    	}
    	if payloadType != "" {
    		req.Header.Set(xhttp.ContentType, payloadType)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  4. cmd/s3-zip-handlers.go

    			return
    		}
    		defer gr.Close()
    		rc, err = file.Open(gr)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	} else {
    		rc = io.NopCloser(bytes.NewReader([]byte{}))
    	}
    
    	defer rc.Close()
    
    	if err = setObjectHeaders(ctx, w, fileObjInfo, nil, opts); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    					CurrentVersion: Version,
    					UpdatedVersion: lrTime.Format(MinioReleaseTagTimeLayout),
    				}
    			}
    		}
    	}
    
    	if err = verifyBinary(u, sha256Sum, releaseInfo, mode, bytes.NewReader(bin)); err != nil {
    		peerResults[local] = madmin.ServerPeerUpdateStatus{
    			Host:           local,
    			Err:            err.Error(),
    			CurrentVersion: Version,
    		}
    	} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  6. internal/rest/client.go

    	if body != nil {
    		switch v := body.(type) {
    		case *bytes.Buffer:
    			req.ContentLength = int64(v.Len())
    			buf := v.Bytes()
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := bytes.NewReader(buf)
    				return io.NopCloser(r), nil
    			}
    		case *bytes.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := snapshot
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. cmd/metacache-stream_test.go

    func loadMetacacheSample(t testing.TB) *metacacheReader {
    	b, err := os.ReadFile("testdata/metacache.s2")
    	if err != nil {
    		t.Fatal(err)
    	}
    	return newMetacacheReader(bytes.NewReader(b))
    }
    
    func loadMetacacheSampleEntries(t testing.TB) metaCacheEntriesSorted {
    	r := loadMetacacheSample(t)
    	defer r.Close()
    	entries, err := r.readN(-1, false, true, false, "")
    	if err != io.EOF {
    		t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 15K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    	)
    
    	var objectSize int64
    	for _, partInfo := range objInfo.Parts {
    		if isSSEC {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.Size), partInfo.Size, "", "", partInfo.ActualSize)
    		} else {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.ActualSize), partInfo.ActualSize, "", "", partInfo.ActualSize)
    		}
    		if err != nil {
    			return err
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  9. cmd/object-api-utils.go

    			var dopts []s2.ReaderOption
    			if off > 0 || decOff > 0 {
    				// We are not starting at the beginning, so ignore stream identifiers.
    				dopts = append(dopts, s2.ReaderIgnoreStreamIdentifier())
    			}
    			s2Reader := s2.NewReader(inputReader, dopts...)
    			// Apply the skipLen and limit on the decompressed stream.
    			if decOff > 0 {
    				if err = s2Reader.Skip(decOff); err != nil {
    					// Call the cleanup funcs
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  10. doc/godebug.md

    ### Go 1.20
    
    Go 1.20 introduced support for rejecting insecure paths in tar and zip archives,
    controlled by the [`tarinsecurepath` setting](/pkg/archive/tar/#Reader.Next)
    and the [`zipinsecurepath` setting](/pkg/archive/zip/#NewReader).
    These default to `tarinsecurepath=1` and `zipinsecurepath=1`,
    preserving the behavior of earlier versions of Go.
    A future version of Go may change the defaults to
    `tarinsecurepath=0` and `zipinsecurepath=0`.
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 28 14:46:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
Back to top