Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for serialize (0.18 sec)

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

    		if err != nil {
    			return keys, err
    		}
    	}
    	return keys, nil
    }
    
    // serialize will serialize the provided keys and values.
    // The function will panic if keys/value slices aren't of equal length.
    // Payload size can give an indication of expected payload size.
    // If plSize is <= 0 it will be calculated.
    func (x *xlMetaInlineData) serialize(plSize int, keys [][]byte, vals [][]byte) {
    	if len(keys) != len(vals) {
    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. cmd/erasure-object.go

    		//   inconsequential to the overall read operation.
    		// - xl.meta metadata is still verified for quorum under lock()
    		//   however writing the response doesn't need to serialize
    		//   concurrent writers
    		unlockOnDefer = true
    		nsUnlocker = func() { lock.RUnlock(lkctx) }
    	}
    
    	fi, metaArr, onlineDisks, err := er.getObjectFileInfo(ctx, bucket, object, opts, true)
    	if err != nil {
    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)
  3. cmd/data-usage_test.go

    				PendingCount:   6,
    			},
    		},
    	}
    	want.replace("abucket/dir2", "", *e)
    	var buf bytes.Buffer
    	err = want.serializeTo(&buf)
    	if err != nil {
    		t.Fatal(err)
    	}
    	t.Log("serialized size:", buf.Len(), "bytes")
    	var got dataUsageCache
    	err = got.deserialize(&buf)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if got.Info.LastUpdate.IsZero() {
    		t.Error("lastupdate not set")
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  4. cmd/metrics-v2_gen.go

    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z *MetricDescription) Msgsize() (s int) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 19.2K bytes
    - Viewed (0)
  5. internal/grid/types.go

    // call Recycle() when the object is no longer needed.
    // The recycler should handle nil pointers.
    type Recycler interface {
    	Recycle()
    }
    
    // MSS is a map[string]string that can be serialized.
    // It is not very efficient, but it is only used for easy parameter passing.
    type MSS map[string]string
    
    // Get returns the value for the given key.
    func (m *MSS) Get(key string) string {
    	if m == nil {
    		return ""
    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)
  6. cmd/data-usage-cache_gen.go

    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z *allTierStats) Msgsize() (s int) {
    	s = 1 + 3 + msgp.MapHeaderSize
    	if z.Tiers != nil {
    		for za0001, za0002 := range z.Tiers {
    			_ = za0002
    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)
  7. cmd/xl-storage-format-v2_gen.go

    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = ChecksumAlgo(zb0001)
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z ChecksumAlgo) Msgsize() (s int) {
    	s = msgp.Uint8Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *ErasureAlgo) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 53.8K bytes
    - Viewed (0)
  8. cmd/metacache-set_gen.go

    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z *listPathOptions) Msgsize() (s int) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 20:23:12 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  9. cmd/metrics-v2.go

    	wg.Add(2)
    	go publish(ReportMetrics(GlobalContext, c.metricsGroups))
    	go publish(globalNotificationSys.GetClusterMetrics(GlobalContext))
    	wg.Wait()
    }
    
    // ReportMetrics reports serialized metrics to the channel passed for the metrics generated.
    func ReportMetrics(ctx context.Context, metricsGroups []*MetricsGroupV2) <-chan MetricV2 {
    	ch := make(chan MetricV2)
    	go func() {
    		defer xioutil.SafeClose(ch)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    			if target == "" {
    				continue
    			}
    			select {
    			case s.immediatePurge <- target:
    			default:
    				// Too much back pressure, we will perform the delete
    				// blocking at this point we need to serialize operations.
    				removeAll(target)
    			}
    		}
    	}
    
    	return nil
    }
    
    // DeleteVersion - deletes FileInfo metadata for path at `xl.meta`. forceDelMarker
    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