Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 1,340 for makeCT (0.06 sec)

  1. cmd/xl-storage-format_test.go

    	// Number of checksum info == total parts.
    	xlMeta.Erasure.Checksums = make([]ChecksumInfo, totalParts)
    	// total number of parts.
    	xlMeta.Parts = make([]ObjectPartInfo, totalParts)
    	for i := 0; i < totalParts; i++ {
    		// hard coding hash and algo value for the checksum, Since we are benchmarking the parsing of xl.meta the magnitude doesn't affect the test,
    		// The magnitude doesn't make a difference, only the size does.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  2. src/bytes/bytes_js_wasm_test.go

    // license that can be found in the LICENSE file.
    
    //go:build js && wasm
    
    package bytes_test
    
    import (
    	"bytes"
    	"testing"
    )
    
    func TestIssue65571(t *testing.T) {
    	b := make([]byte, 1<<31+1)
    	b[1<<31] = 1
    	i := bytes.IndexByte(b, 1)
    	if i != 1<<31 {
    		t.Errorf("IndexByte(b, 1) = %d; want %d", i, 1<<31)
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jul 17 07:00:20 UTC 2024
    - 417 bytes
    - Viewed (0)
  3. internal/http/dial_dnscache.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"context"
    	"net"
    	"time"
    )
    
    // LookupHost is a function to make custom lookupHost for optional cached DNS requests
    type LookupHost func(ctx context.Context, host string) (addrs []string, err error)
    
    // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v1_gen_test.go

    	v := ChecksumInfo{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgChecksumInfo(b *testing.B) {
    	v := ChecksumInfo{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		bts, _ = v.MarshalMsg(bts[0:0])
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 13.2K bytes
    - Viewed (0)
  5. .junit.run/Not Slow.run.xml

        <option name="TEST_SEARCH_SCOPE">
          <value defaultName="wholeProject" />
        </option>
        <tag value="!Slow &amp; !Slowish &amp; !Remote &amp; !Android" />
        <method v="2">
          <option name="Make" enabled="true" />
        </method>
      </configuration>
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Nov 21 13:28:45 UTC 2020
    - 730 bytes
    - Viewed (0)
  6. cmd/tier_gen.go

    		case "Tiers":
    			var zb0002 uint32
    			zb0002, err = dc.ReadMapHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "Tiers")
    				return
    			}
    			if z.Tiers == nil {
    				z.Tiers = make(map[string]madmin.TierConfig, zb0002)
    			} else if len(z.Tiers) > 0 {
    				for key := range z.Tiers {
    					delete(z.Tiers, key)
    				}
    			}
    			for zb0002 > 0 {
    				zb0002--
    				var za0001 string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 4K bytes
    - Viewed (0)
  7. internal/logger/audit.go

    		entry.ParentUser = reqInfo.Cred.ParentUser
    
    		entry.API.Name = reqInfo.API
    		entry.API.Bucket = reqInfo.BucketName
    		entry.API.Object = reqInfo.ObjectName
    		entry.API.Objects = make([]audit.ObjectVersion, 0, len(reqInfo.Objects))
    		for _, ov := range reqInfo.Objects {
    			entry.API.Objects = append(entry.API.Objects, audit.ObjectVersion{
    				ObjectName: ov.ObjectName,
    				VersionID:  ov.VersionID,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. internal/logger/logonce.go

    func (l *logOnceType) cleanupRoutine() {
    	for {
    		time.Sleep(time.Hour)
    
    		l.Lock()
    		l.IDMap = make(map[string]onceErr)
    		l.Unlock()
    	}
    }
    
    // Returns logOnceType
    func newLogOnceType() *logOnceType {
    	l := &logOnceType{IDMap: make(map[string]onceErr)}
    	go l.cleanupRoutine()
    	return l
    }
    
    var logOnce = newLogOnceType()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  9. internal/logger/reqinfo.go

    	if r == nil {
    		return nil
    	}
    	r.RLock()
    	defer r.RUnlock()
    	return append(make([]KeyVal, 0, len(r.tags)), r.tags...)
    }
    
    // GetTagsMap - returns the user defined tags in a map structure
    func (r *ReqInfo) GetTagsMap() map[string]string {
    	if r == nil {
    		return nil
    	}
    	r.RLock()
    	defer r.RUnlock()
    	m := make(map[string]string, len(r.tags))
    	for _, t := range r.tags {
    		m[t.Key] = t.Val
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. internal/s3select/jstream/decoder.go

    func NewDecoder(r io.Reader, emitDepth int) *Decoder {
    	d := &Decoder{
    		scanner:   newScanner(r),
    		emitDepth: emitDepth,
    		scratch:   &scratch{data: make([]byte, 1024)},
    		metaCh:    make(chan *MetaValue, 128),
    	}
    	if emitDepth < 0 {
    		d.emitDepth = 0
    		d.emitRecursive = true
    	}
    	return d
    }
    
    // ObjectAsKVS - by default JSON returns map[string]interface{} this
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
Back to top