Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for reserialize (0.23 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  2. cmd/data-usage-cache.go

    	}
    	err = mEnc.Flush()
    	if err != nil {
    		return err
    	}
    	err = enc.Close()
    	if err != nil {
    		return err
    	}
    	return nil
    }
    
    // deserialize the supplied byte slice into the cache.
    func (d *dataUsageCache) deserialize(r io.Reader) error {
    	var b [1]byte
    	n, _ := r.Read(b[:])
    	if n != 1 {
    		return io.ErrUnexpectedEOF
    	}
    	ver := int(b[0])
    	switch ver {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 41.3K bytes
    - Viewed (1)
  3. cmd/s3-zip-handlers.go

    	files, srcInfo, err := getFilesListFromZIPObject(ctx, objectAPI, bucket, object, opts)
    	if err != nil {
    		return nil, err
    	}
    	files.OptimizeSize()
    	zipInfo, err := files.Serialize()
    	if err != nil {
    		return nil, err
    	}
    	at := archiveType
    	zipInfoStr := string(zipInfo)
    	if opts.EncryptFn != nil {
    		at = archiveTypeEnc
    		zipInfoStr = string(opts.EncryptFn(archiveTypeEnc, zipInfo))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  4. docs/bucket/replication/DESIGN.md

    ### Existing object replication
    
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 14.7K bytes
    - Viewed (0)
  5. cmd/streaming-v4-unsigned.go

    			return n, cr.err
    		}
    		if b == '\r' { // \r\n denotes end of size.
    			err := mustRead('\n')
    			if err != nil {
    				cr.err = err
    				return n, cr.err
    			}
    			break
    		}
    
    		// Manually deserialize the size since AWS specified
    		// the chunk size to be of variable width. In particular,
    		// a size of 16 is encoded as `10` while a size of 64 KB
    		// is `10000`.
    		switch {
    		case b >= '0' && b <= '9':
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat May 06 02:53:12 GMT 2023
    - 6.1K bytes
    - Viewed (1)
  6. cmd/admin-handlers-pools.go

    	if objectAPI == nil {
    		return
    	}
    
    	// NB rebalance-start admin API is always coordinated from first pool's
    	// first node. The following is required to serialize (the effects of)
    	// concurrent rebalance-start commands.
    	if ep := globalEndpoints[0].Endpoints[0]; !ep.IsLocal {
    		for nodeIdx, proxyEp := range globalProxyEndpoints {
    			if proxyEp.Endpoint.Host == ep.Host {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  7. cmd/streaming-signature-v4.go

    		if err == io.EOF {
    			err = io.ErrUnexpectedEOF
    		}
    		if err != nil {
    			cr.err = err
    			return n, cr.err
    		}
    		if b == ';' { // separating character
    			break
    		}
    
    		// Manually deserialize the size since AWS specified
    		// the chunk size to be of variable width. In particular,
    		// a size of 16 is encoded as `10` while a size of 64 KB
    		// is `10000`.
    		switch {
    		case b >= '0' && b <= '9':
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  8. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 82.4K bytes
    - Viewed (0)
  9. cmd/metacache-entries.go

    	}
    	selected.cached.versions = mergeXLV2Versions(r.objQuorum, r.strict, r.requestedVersions, r.candidates...)
    	if len(selected.cached.versions) == 0 {
    		return nil, false
    	}
    
    	// Reserialize
    	var err error
    	selected.metadata, err = selected.cached.AppendTo(metaDataPoolGet())
    	if err != nil {
    		bugLogIf(context.Background(), err)
    		return nil, false
    	}
    	return selected, true
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  10. cmd/data-usage_test.go

    	var got dataUsageCache
    	err = got.deserialize(&buf)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if got.Info.LastUpdate.IsZero() {
    		t.Error("lastupdate not set")
    	}
    
    	if !want.Info.LastUpdate.Equal(got.Info.LastUpdate) {
    		t.Fatalf("deserialize LastUpdate mismatch\nwant: %+v\ngot:  %+v", want, got)
    	}
    	if len(want.Cache) != len(got.Cache) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
Back to top