Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 126 for cap1 (0.03 sec)

  1. internal/rest/client.go

    		panic("unit cannot exceed one hour")
    	}
    	return func(attempt uint) time.Duration {
    		if attempt > 16 {
    			// Protect against integer overflow
    			attempt = 16
    		}
    		// sleep = random_between(unit, min(cap, base * 2 ** attempt))
    		sleep := min(unit*time.Duration(1<<attempt), maxSleep)
    		sleep -= time.Duration(r.Float64() * float64(sleep-unit))
    		return sleep
    	}
    }
    
    func (c *Client) runHealthCheck() bool {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  2. internal/ringbuffer/ring_buffer.go

    // otherwise a new buffer will be allocated.
    func (r *RingBuffer) Bytes(dst []byte) []byte {
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	getDst := func(n int) []byte {
    		if cap(dst) < n {
    			return make([]byte, n)
    		}
    		return dst[:n]
    	}
    
    	if r.w == r.r {
    		if r.isFull {
    			buf := getDst(r.size)
    			copy(buf, r.buf[r.r:])
    			copy(buf[r.size-r.r:], r.buf[:r.w])
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  3. api/go1.12.txt

    pkg runtime/debug, type Module struct, Sum string
    pkg runtime/debug, type Module struct, Version string
    pkg strings, func ReplaceAll(string, string, string) string
    pkg strings, method (*Builder) Cap() int
    pkg syscall (freebsd-386), const S_IRWXG = 56
    pkg syscall (freebsd-386), const S_IRWXG ideal-int
    pkg syscall (freebsd-386), const S_IRWXO = 7
    pkg syscall (freebsd-386), const S_IRWXO ideal-int
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Jan 02 21:21:53 UTC 2019
    - 13.5K bytes
    - Viewed (0)
  4. cmd/storage-datatypes.go

    }
    
    // Recycle will reuse the memory allocated for the FileInfo data.
    func (r *RenameDataInlineHandlerParams) Recycle() {
    	if r == nil {
    		return
    	}
    	if cap(r.FI.Data) >= xioutil.SmallBlock {
    		grid.PutByteBuffer(r.FI.Data)
    		r.FI.Data = nil
    	}
    }
    
    // RenameFileHandlerParams are parameters for RenameFileHandler.
    type RenameFileHandlerParams struct {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  5. doc/go_spec.html

    </p>
    
    <pre>
    s := make([]int, 10, 100)       // slice with len(s) == 10, cap(s) == 100
    s := make([]int, 1e3)           // slice with len(s) == cap(s) == 1000
    s := make([]int, 1&lt;&lt;63)         // illegal: len(s) is not representable by a value of type int
    s := make([]int, 10, 0)         // illegal: len(s) > cap(s)
    c := make(chan int, 10)         // channel with a buffer size of 10
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Tue Dec 02 23:07:19 UTC 2025
    - 286.5K bytes
    - Viewed (1)
  6. internal/s3select/select.go

    						break
    					}
    					if err = writer.Finish(s3Select.getProgress()); err != nil {
    						// FIXME: log this error.
    						err = nil
    					}
    					return
    				}
    
    				if len(outputQueue) < cap(outputQueue) {
    					continue
    				}
    
    				if !sendRecord() {
    					break OuterLoop
    				}
    			}
    		}
    	}
    
    	if err != nil {
    		_ = writer.FinishWithError("InternalError", err.Error())
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  7. docs/es/docs/deployment/concepts.md

        * Un administrador de procesos de Uvicorn **escucharía** en la **IP** y **puerto**, y iniciaría **múltiples worker processes de Uvicorn**.
    * **Kubernetes** y otros sistemas de **contenedor distribuidos**
        * Algo en la capa de **Kubernetes** escucharía en la **IP** y **puerto**. La replicación sería al tener **múltiples contenedores**, cada uno con **un proceso de Uvicorn** ejecutándose.
    * **Servicios en la Nube** que manejan esto por ti
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 16 16:33:45 UTC 2025
    - 20.1K bytes
    - Viewed (0)
  8. cmd/streaming-signature-v4.go

    	if err == io.EOF {
    		err = io.ErrUnexpectedEOF
    	}
    	if err != nil {
    		cr.err = err
    		return n, cr.err
    	}
    	if b != '\n' {
    		cr.err = errMalformedEncoding
    		return n, cr.err
    	}
    
    	if cap(cr.buffer) < size {
    		cr.buffer = make([]byte, size)
    	} else {
    		cr.buffer = cr.buffer[:size]
    	}
    
    	// Now, we read the payload and compute its SHA-256 hash.
    	_, err = io.ReadFull(cr.reader, cr.buffer)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/asm/parse.go

    	nesting := 0
    	colon := -1
    	for tok != '\n' && tok != ';' {
    		// Process one operand.
    		var items []lex.Token
    		if cap(operands) > len(operands) {
    			// Reuse scratch items slice.
    			items = operands[:cap(operands)][len(operands)][:0]
    		} else {
    			items = make([]lex.Token, 0, 3)
    		}
    		for {
    			tok = p.nextToken()
    			if len(operands) == 0 && len(items) == 0 {
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Nov 12 03:59:40 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  10. docs/pt/docs/async.md

    ## Detalhes muito técnicos { #very-technical-details }
    
    /// warning | Atenção
    
    Você pode provavelmente pular isso.
    
    Esses são detalhes muito técnicos de como **FastAPI** funciona por baixo do capô.
    
    Se você tem certo conhecimento técnico (corrotinas, threads, blocking etc) e está curioso sobre como o FastAPI controla o `async def` vs normal `def`, vá em frente.
    
    ///
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Nov 12 16:23:57 UTC 2025
    - 25.8K bytes
    - Viewed (0)
Back to top