- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 42 for Cap (0.12 sec)
-
internal/logger/target/http/http.go
// from this main worker routine will exit // once the channel drops below half capacity // and when it's been at least 30 seconds since // we launched a new worker. if mainWorker && len(h.logCh) > cap(h.logCh)/2 { nWorkers := atomic.LoadInt64(&h.workers) if nWorkers < h.maxWorkers { if time.Since(h.lastStarted).Milliseconds() > 10 { h.lastStarted = time.Now() go h.startQueueProcessor(ctx, false)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/handler-api.go
apiRequestsMaxPerNode /= n } } if globalIsDistErasure { logger.Info("Configured max API requests per node based on available memory: %d", apiRequestsMaxPerNode) } if cap(t.requestsPool) != apiRequestsMaxPerNode { // Only replace if needed. // Existing requests will use the previous limit, // but new requests will use the new limit. // There will be a short overlap window,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 10K bytes - Viewed (0) -
cmd/untar.go
name = pathJoin(o.prefixAll, name) } // Do small files async n++ if header.Size <= smallFileThreshold { asyncWriters <- struct{}{} b := poolBuf128k.Get().([]byte) if cap(b) < int(header.Size) { b = make([]byte, smallFileThreshold) } b = b[:header.Size] if _, err := io.ReadFull(tarReader, b); err != nil { return err } wg.Add(1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/xl-storage-format-v1_gen.go
return } case "Distribution": var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "Distribution") return } if cap(z.Distribution) >= int(zb0002) { z.Distribution = (z.Distribution)[:zb0002] } else { z.Distribution = make([]int, zb0002) } for za0001 := range z.Distribution {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 40.2K bytes - Viewed (0) -
cmd/metacache-stream.go
err = io.ErrUnexpectedEOF } r.err = err return m, err } m.metadata, err = r.mr.ReadBytes(metaDataPoolGet()) if err == io.EOF { err = io.ErrUnexpectedEOF } if len(m.metadata) == 0 && cap(m.metadata) >= metaDataReadDefault { metaDataPoolPut(m.metadata) m.metadata = nil } r.err = err return m, err } // next will read one entry from the stream.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
manifests/charts/istio-cni/values.yaml
# Note the pod will be crashlooping, so this may take a few minutes to become fully functional based on when the retry occurs. # This requires no RBAC privilege, but does require `securityContext.privileged/CAP_SYS_ADMIN`. repairPods: true initContainerName: "istio-validation" brokenPodLabelKey: "cni.istio.io/uninitialized" brokenPodLabelValue: "true"
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 5.2K bytes - Viewed (1) -
cmd/xl-storage-format-v2.go
func metaDataPoolGet() []byte { return metaDataPool.Get().([]byte)[:0] } // metaDataPoolPut will put an unused small buffer back into the pool. func metaDataPoolPut(buf []byte) { if cap(buf) >= metaDataReadDefault && cap(buf) < metaDataReadDefault*4 { //nolint:staticcheck // SA6002 we are fine with the tiny alloc metaDataPool.Put(buf) } } // readXLMetaNoData will load the metadata, but skip data segments.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 05:07:37 GMT 2024 - 63.6K bytes - Viewed (1) -
internal/grid/muxserver.go
} func (m *muxServer) message(msg message) { if debugPrint { fmt.Printf("muxServer: received message %d, length %d\n", msg.Seq, len(msg.Payload)) } m.recvMu.Lock() defer m.recvMu.Unlock() if cap(m.inbound) == 0 { m.disconnect("did not expect inbound message") return } if !m.checkSeq(msg.Seq) { return } // Note, on EOF no value can be sent. if msg.Flags&FlagEOF != 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/erasure-decode.go
r2b := make([]int, len(readers)) for i := range r2b { r2b[i] = i } bufs := make([][]byte, len(readers)) // Fill buffers b := globalBytePoolCap.Load().Get() shardSize := int(e.ShardSize()) if cap(b) < len(readers)*shardSize { // We should always have enough capacity, but older objects may be bigger. globalBytePoolCap.Load().Put(b) b = nil } else { // Seed the buffers. for i := range bufs {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0)