Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 451 - 460 of 1,039 for take (0.02 seconds)

  1. cmd/bootstrap-peer-server_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "CmdLines")
    				return
    			}
    			if cap(z.CmdLines) >= int(zb0002) {
    				z.CmdLines = (z.CmdLines)[:zb0002]
    			} else {
    				z.CmdLines = make([]string, zb0002)
    			}
    			for za0001 := range z.CmdLines {
    				z.CmdLines[za0001], err = dc.ReadString()
    				if err != nil {
    					err = msgp.WrapError(err, "CmdLines", za0001)
    					return
    				}
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  2. internal/s3select/jstream/scanner.go

    	fillReq   chan struct{}
    	fillReady chan int64
    	readerErr error // underlying reader error, if any
    }
    
    func newScanner(r io.Reader) *scanner {
    	sr := &scanner{
    		end:       maxInt,
    		fillReq:   make(chan struct{}),
    		fillReady: make(chan int64),
    	}
    
    	go func() {
    		var rpos int64 // total bytes read into buffer
    
    		defer func() {
    			atomic.StoreInt64(&sr.end, rpos)
    			close(sr.fillReady)
    		}()
    
    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)
  3. internal/ringbuffer/README.md

    	"github.com/smallnest/ringbuffer"
    )
    
    func main() {
    	rb := ringbuffer.New(1024)
    
    	// write
    	rb.Write([]byte("abcd"))
    	fmt.Println(rb.Length())
    	fmt.Println(rb.Free())
    
    	// read
    	buf := make([]byte, 4)
    	rb.Read(buf)
    	fmt.Println(string(buf))
    }
    ```
    
    It is possible to use an existing buffer with by replacing `New` with `NewBuffer`.
    
    
    # Blocking vs Non-blocking
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 15 00:11:04 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  4. src/buildall.bash

    # architectures.
    #
    # Originally the Go build system used it as a smoke test to quickly
    # flag portability issues in builders named "misc-compile" or "all-compile".
    # As of CL 464955, the build system uses make.bash -compile-only instead,
    # so this script no longer runs in any automated fashion.
    #
    # Options:
    #   -e: stop at first failure
    
    if [ ! -f run.bash ]; then
    	echo 'buildall.bash must be run from $GOROOT/src' 1>&2
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Apr 23 17:45:23 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  5. cmd/metrics-v2.go

    		Description:          m.Description,
    		Value:                m.Value,
    		HistogramBucketLabel: m.HistogramBucketLabel,
    		StaticLabels:         make(map[string]string, len(m.StaticLabels)),
    		VariableLabels:       make(map[string]string, len(m.VariableLabels)),
    		Histogram:            make(map[string]uint64, len(m.Histogram)),
    	}
    	maps.Copy(metric.StaticLabels, m.StaticLabels)
    	maps.Copy(metric.VariableLabels, m.VariableLabels)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  6. cmd/data-usage-cache_gen_test.go

    	v := allTierStats{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgallTierStats(b *testing.B) {
    	v := allTierStats{}
    	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])
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19K bytes
    - Click Count (0)
  7. cmd/erasure-server-pool-rebalance_gen_test.go

    	v := rebalanceInfo{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgrebalanceInfo(b *testing.B) {
    	v := rebalanceInfo{}
    	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])
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11K bytes
    - Click Count (0)
  8. internal/etag/etag_test.go

    	Plaintext ETag
    }{
    	{ // 0
    		Key:       make([]byte, 32),
    		ETag:      must("3b83ef96387f14655fc854ddc3c6bd57"),
    		Plaintext: must("3b83ef96387f14655fc854ddc3c6bd57"),
    	},
    	{ // 1
    		Key:       make([]byte, 32),
    		ETag:      must("7b976cc68452e003eec7cb0eb631a19a-1"),
    		Plaintext: must("7b976cc68452e003eec7cb0eb631a19a-1"),
    	},
    	{ // 2
    		Key:       make([]byte, 32),
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  9. docs/en/docs/reference/request.md

    You can import it directly from `fastapi`:
    
    ```python
    from fastapi import Request
    ```
    
    /// tip
    
    When you want to define dependencies that should be compatible with both HTTP and WebSockets, you can define a parameter that takes an `HTTPConnection` instead of a `Request` or a `WebSocket`.
    
    ///
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Aug 06 04:48:30 GMT 2024
    - 518 bytes
    - Click Count (0)
  10. docs/en/docs/how-to/conditional-openapi.md

    If you want to secure your API, there are several better things you can do, for example:
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 2.4K bytes
    - Click Count (0)
Back to Top