Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for reserialize (0.3 sec)

  1. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  2. internal/grid/types.go

    	}
    	return (*m)[key]
    }
    
    // Set a key, value pair.
    func (m *MSS) Set(key, value string) {
    	if m == nil {
    		*m = mssPool.Get().(map[string]string)
    	}
    	(*m)[key] = value
    }
    
    // UnmarshalMsg deserializes m from the provided byte slice and returns the
    // remainder of bytes.
    func (m *MSS) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	if m == nil {
    		return bts, errors.New("MSS: UnmarshalMsg on nil pointer")
    	}
    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. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  4. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  5. cmd/data-usage-cache.go

    						return true, nil
    					}
    					return false, err
    				}
    				err = d.deserialize(r)
    				r.Close()
    				return err != nil, nil
    			case InsufficientReadQuorum, StorageErr:
    				return true, nil
    			}
    			return false, err
    		}
    		err = d.deserialize(r)
    		r.Close()
    		return err != nil, nil
    	}
    
    	// Caches are read+written without locks,
    	retries := 0
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  6. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  7. docs/bucket/replication/DESIGN.md

    ### Existing object replication
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 14.7K bytes
    - Viewed (0)
  8. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 10.9K bytes
    - Viewed (0)
Back to top