Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 78 for mbuf (0.01 seconds)

  1. internal/config/identity/openid/jwks.go

    			return nil, errMalformedJWKRSAKey
    		}
    
    		// decode exponent
    		ebuf, err := base64.RawURLEncoding.DecodeString(key.E)
    		if err != nil {
    			return nil, errMalformedJWKRSAKey
    		}
    
    		nbuf, err := base64.RawURLEncoding.DecodeString(key.N)
    		if err != nil {
    			return nil, errMalformedJWKRSAKey
    		}
    
    		var n, e big.Int
    		n.SetBytes(nbuf)
    		e.SetBytes(ebuf)
    
    		return &rsa.PublicKey{
    			E: int(e.Int64()),
    			N: &n,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 02 23:02:35 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  2. cmd/os_unix.go

    	}
    	defer syscall.Close(fd)
    
    	bufp := direntPool.Get()
    	defer direntPool.Put(bufp)
    	buf := *bufp
    
    	boff := 0 // starting read position in buf
    	nbuf := 0 // end valid data in buf
    
    	for {
    		if boff >= nbuf {
    			boff = 0
    			stop := globalOSMetrics.time(osMetricReadDirent)
    			nbuf, err = syscall.ReadDirent(fd, buf)
    			stop()
    			if err != nil {
    				if isSysErrNotDir(err) {
    					return nil
    				}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.3K bytes
    - Click Count (0)
  3. internal/s3select/jstream/scanner.go

    func (s *scanner) cur() byte { return s.buf[s.ipos] }
    
    // read next byte
    func (s *scanner) next() byte {
    	if s.pos >= atomic.LoadInt64(&s.end) {
    		return nullByte
    	}
    	s.ipos++
    
    	if s.ipos > s.ifill { // internal buffer is exhausted
    		s.ifill = <-s.fillReady
    
    		s.buf[0] = s.buf[len(s.buf)-1] // copy current last item to guarantee lookback
    		copy(s.buf[1:], s.nbuf[:])     // copy contents of pre-filled next buffer
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  4. docs/debugging/inspect/export.go

    	hdrVer, buf, e := msgp.ReadUintBytes(buf)
    	if e != nil {
    		return 0, buf, e
    	}
    	metaVer, buf, e := msgp.ReadUintBytes(buf)
    	if e != nil {
    		return 0, buf, e
    	}
    	if hdrVer > xlHeaderVersion {
    		return 0, buf, fmt.Errorf("decodeXLHeaders: Unknown xl header version %d", metaVer)
    	}
    	if metaVer > xlMetaVersion {
    		return 0, buf, fmt.Errorf("decodeXLHeaders: Unknown xl meta version %d", metaVer)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.2K bytes
    - Click Count (1)
  5. cmd/local-locker_gen_test.go

    	v := localLockMap{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodelocalLockMap Msgsize() is inaccurate")
    	}
    
    	vn := localLockMap{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  6. cmd/batch-handlers_gen_test.go

    	v := BatchJobPrefix{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeBatchJobPrefix Msgsize() is inaccurate")
    	}
    
    	vn := BatchJobPrefix{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  7. cmd/storage-rest-common_gen_test.go

    	v := nsScannerOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodensScannerOptions Msgsize() is inaccurate")
    	}
    
    	vn := nsScannerOptions{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  8. cmd/metacache_gen_test.go

    	v := metacache{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodemetacache Msgsize() is inaccurate")
    	}
    
    	vn := metacache{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  9. cmd/tier-last-day-stats_gen_test.go

    	v := DailyAllTierStats{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeDailyAllTierStats Msgsize() is inaccurate")
    	}
    
    	vn := DailyAllTierStats{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  10. internal/bucket/bandwidth/monitor_gen_test.go

    	v := BucketBandwidthReport{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeBucketBandwidthReport Msgsize() is inaccurate")
    	}
    
    	vn := BucketBandwidthReport{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.5K bytes
    - Click Count (0)
Back to Top