Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 187 for reader_r (0.26 sec)

  1. cmd/http-tracer.go

    		// http stats requests and audit if enabled.
    		respRecorder := xhttp.NewResponseRecorder(w)
    
    		// Setup a http request body recorder
    		reqRecorder := &xhttp.RequestRecorder{Reader: r.Body}
    		r.Body = reqRecorder
    
    		// Create tracing data structure and associate it to the request context
    		tc := mcontext.TraceCtxt{
    			AmzReqID:         w.Header().Get(xhttp.AmzRequestID),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. cmd/warm-backend-azure.go

    	destObj := object
    	if az.Prefix != "" {
    		destObj = fmt.Sprintf("%s/%s", az.Prefix, object)
    	}
    	return destObj
    }
    
    func (az *warmBackendAzure) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    	resp, err := az.clnt.UploadStream(ctx, az.Bucket, az.getDest(object), io.LimitReader(r, length), &azblob.UploadStreamOptions{
    		Concurrency: 4,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. cmd/object-handlers_test.go

    		}
    
    		readers := []io.Reader{}
    		cumulativeSum := int64(0)
    		for _, p := range oi.partLengths {
    			readers = append(readers, NewDummyDataGen(p, cumulativeSum))
    			cumulativeSum += p
    		}
    
    		refReader := io.LimitReader(ioutilx.NewSkipReader(io.MultiReader(readers...), off), length)
    		if ok, msg := cmpReaders(refReader, rec.Body); !ok {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  4. api/go1.22.txt

    pkg go/version, func IsValid(string) bool #62039
    pkg go/version, func Lang(string) string #62039
    pkg html/template, const ErrJSTemplate //deprecated #61619
    pkg io, method (*SectionReader) Outer() (ReaderAt, int64, int64) #61870
    pkg log/slog, func SetLogLoggerLevel(Level) Level #62418
    pkg math/big, method (*Rat) FloatPrec() (int, bool) #50489
    pkg math/rand/v2, func ExpFloat64() float64 #61716
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Jan 24 20:54:27 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  5. cmd/mrf_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *PartialOperation) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  6. internal/logger/logrotate.go

    	if w.f != nil {
    		if err := w.closeCurrentFile(); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    var stdErrEnc = json.NewEncoder(os.Stderr)
    
    func (w *Writer) listen() {
    	for {
    		var r io.Reader = w.pr
    		if w.opts.MaximumFileSize > 0 {
    			r = io.LimitReader(w.pr, w.opts.MaximumFileSize)
    		}
    		if _, err := io.Copy(w.f, r); err != nil {
    			msg := fmt.Sprintf("unable to write to log file %v: %v", w.f.Name(), err)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. internal/grid/connection.go

    	// This will ensure that is something asks to disconnect and we are blocked on reads/writes
    	// the connection will be closed and readers/writers will unblock.
    	go c.monitorState(conn, cancel)
    
    	c.handleMsgWg.Add(2)
    	c.reconnectMu.Unlock()
    
    	// Start reader and writer
    	go c.readStream(ctx, conn, cancel)
    	c.writeStream(ctx, conn, cancel)
    }
    
    // readStream handles the read side of the connection.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  8. cmd/site-replication-utils_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *SiteResyncStatus) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 7.2K bytes
    - Viewed (0)
  9. cmd/bucket-replication-handlers.go

    			return
    		}
    		if sameTarget && bucket == clnt.Bucket {
    			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrBucketRemoteIdenticalToSource), r.URL)
    			return
    		}
    
    		reader := bytes.NewReader(buf)
    		// fake a PutObject and RemoveObject call to validate permissions
    		c := &minio.Core{Client: clnt.Client}
    		putOpts := minio.PutObjectOptions{
    			Internal: minio.AdvancedPutOptions{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  10. internal/mountinfo/mountinfo_linux_test.go

    	{
    		if _, err = readProcMounts(filepath.Join(dir, "non-existent")); err != nil && !os.IsNotExist(err) {
    			t.Fatal(err)
    		}
    	}
    }
    
    // Tests read proc mounts reader.
    func TestReadProcMountFrom(t *testing.T) {
    	successCase := `/dev/0 /path/to/0 type0 flags 0 0
    		/dev/1    /path/to/1   type1	flags 1 1
    		/dev/2 /path/to/2 type2 flags,1,2=3 2 2
    		`
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top