Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for sz (0.12 sec)

  1. cmd/xl-storage-meta-inline.go

    	if len(x) == 0 || !x.versionOK() {
    		return 0
    	}
    	sz, _, _ := msgp.ReadMapHeaderBytes(x.afterVersion())
    	return int(sz)
    }
    
    // replace will add or replace a key/value pair.
    func (x *xlMetaInlineData) replace(key string, value []byte) {
    	in := x.afterVersion()
    	sz, buf, _ := msgp.ReadMapHeaderBytes(in)
    	keys := make([][]byte, 0, sz+1)
    	vals := make([][]byte, 0, sz+1)
    
    	// Version plus header...
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  2. internal/grid/types.go

    }
    
    // NewJSONPool returns a new JSONPool.
    func NewJSONPool[T any]() *JSONPool[T] {
    	var t T
    	sz := 128
    	if b, err := json.Marshal(t); err != nil {
    		sz = len(b)
    	}
    	return &JSONPool[T]{
    		pool: sync.Pool{
    			New: func() interface{} {
    				var t T
    				return &t
    			},
    		},
    		emptySz: sz,
    	}
    }
    
    func (p *JSONPool[T]) new() *T {
    	var zero T
    	t := p.pool.Get().(*T)
    	*t = zero
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  3. docs/debugging/xl-meta/main.go

    		}
    
    		toPrint := make([]string, 0, 16)
    		for _, file := range files {
    			var r io.Reader
    			var sz int64
    			switch file {
    			case "-":
    				r = os.Stdin
    			default:
    				f, err := os.Open(file)
    				if err != nil {
    					return err
    				}
    				if st, err := f.Stat(); err == nil {
    					sz = st.Size()
    				}
    				defer f.Close()
    				r = f
    			}
    			if strings.HasSuffix(file, ".zip") {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  4. internal/bucket/lifecycle/filter.go

    				f.Tag = tag
    				f.tagSet = true
    			case "ObjectSizeLessThan":
    				var sz int64
    				if err = d.DecodeElement(&sz, &se); err != nil {
    					return err
    				}
    				f.ObjectSizeLessThan = sz
    			case "ObjectSizeGreaterThan":
    				var sz int64
    				if err = d.DecodeElement(&sz, &se); err != nil {
    					return err
    				}
    				f.ObjectSizeGreaterThan = sz
    			default:
    				return errUnknownXMLTag
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 27 00:01:20 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  5. cmd/admin-bucket-handlers.go

    	// of bucket metadata
    	zipWriter := zip.NewWriter(w)
    	defer zipWriter.Close()
    
    	rawDataFn := func(r io.Reader, filename string, sz int) {
    		header, zerr := zip.FileInfoHeader(dummyFileInfo{
    			name:    filename,
    			size:    int64(sz),
    			mode:    0o600,
    			modTime: time.Now(),
    			isDir:   false,
    			sys:     nil,
    		})
    		if zerr == nil {
    			header.Method = zip.Deflate
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    }
    
    func (e *lockedLastMinuteLatency) add(value time.Duration) {
    	e.addSize(value, 0)
    }
    
    // addSize will add a duration and size.
    func (e *lockedLastMinuteLatency) addSize(value time.Duration, sz int64) {
    	// alloc on every call, so we have a clean entry to swap in.
    	t := time.Now().Unix()
    	e.init.Do(func() {
    		e.cached.Store(&AccElem{})
    		atomic.StoreInt64(&e.cachedSec, t)
    	})
    	acc := e.cached.Load()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  7. cmd/data-usage-cache_gen.go

    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "ch":
    			err = z.Children.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Children")
    				return
    			}
    		case "sz":
    			z.Size, err = dc.ReadInt64()
    			if err != nil {
    				err = msgp.WrapError(err, "Size")
    				return
    			}
    		case "os":
    			z.Objects, err = dc.ReadUint64()
    			if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 100.8K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    			inlineBuffers = make([]*bytes.Buffer, len(onlineDisks))
    		}
    	} else {
    		// If compressed, use actual size to determine.
    		if sz := erasure.ShardFileSize(data.ActualSize()); sz > 0 {
    			if !opts.Versioned && sz < inlineBlock {
    				inlineBuffers = make([]*bytes.Buffer, len(onlineDisks))
    			} else if sz < inlineBlock/8 {
    				inlineBuffers = make([]*bytes.Buffer, len(onlineDisks))
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  9. internal/grid/connection.go

    	// Add baseflags.
    	msg.Flags.Set(c.baseFlags)
    	// This cannot encode subroute.
    	msg.Flags.Clear(FlagSubroute)
    	if payload != nil {
    		if sz := payload.Msgsize(); cap(msg.Payload) < sz {
    			PutByteBuffer(msg.Payload)
    			msg.Payload = GetByteBufferCap(sz)
    		}
    		var err error
    		msg.Payload, err = payload.MarshalMsg(msg.Payload[:0])
    		msg.Op = payload.Op()
    		if err != nil {
    			return err
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    	}
    	if stat.IsDir() {
    		return nil, dmTime, errFileNotFound
    	}
    
    	// Read into appropriate buffer.
    	sz := stat.Size()
    	if sz <= metaDataReadDefault {
    		buf = metaDataPoolGet()
    		buf = buf[:sz]
    	} else {
    		buf = make([]byte, sz)
    	}
    
    	// Read file...
    	_, err = io.ReadFull(f, buf)
    
    	return buf, stat.ModTime().UTC(), osErrToFileErr(err)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
Back to top