- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 128 for cap (0.16 sec)
-
internal/config/errors.go
"Please ensure no other program uses the same address/port", "", ) ErrPortAccess = newErrFn( "Unable to use specified port", "Please ensure MinIO binary has 'cap_net_bind_service=+ep' permissions", `Use 'sudo setcap cap_net_bind_service=+ep /path/to/minio' to provide sufficient permissions`, ) ErrTLSReadError = newErrFn( "Cannot read the TLS certificate",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 18 22:25:32 GMT 2024 - 9.1K bytes - Viewed (0) -
istioctl/pkg/kubeinject/testdata/mesh-config.yaml
# The "TPROXY" mode preserves both the source and destination IP # addresses and ports, so that they can be used for advanced filtering # and manipulation. # The "TPROXY" mode also configures the sidecar to run with the # CAP_NET_ADMIN capability, which is required to use TPROXY. #interceptionMode: REDIRECT # # Port where Envoy listens (on local host) for admin commands # You can exec into the istio-proxy container in a pod and
Others - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 2.2K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_gen.go
return } case "bkts": var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "QueuedBuckets") return } if cap(z.QueuedBuckets) >= int(zb0002) { z.QueuedBuckets = (z.QueuedBuckets)[:zb0002] } else { z.QueuedBuckets = make([]string, zb0002) } for za0001 := range z.QueuedBuckets {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jul 04 21:02:54 GMT 2022 - 26.7K bytes - Viewed (0) -
internal/handlers/forwarder.go
if f.RoundTripper == nil { f.RoundTripper = http.DefaultTransport } return f } type bufPool struct { sz int pool sync.Pool } func (b *bufPool) Put(buf []byte) { if cap(buf) < b.sz || cap(buf) > b.sz*2 { // Buffer too small or will likely leak memory after being expanded. // Drop it. return } b.pool.Put(&buf) } func (b *bufPool) Get() []byte { bufp := b.pool.Get().(*[]byte)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 07 05:42:10 GMT 2023 - 5.6K bytes - Viewed (0) -
src/bytes/example_test.go
b = append(b, ' ') buf.Write(b) } os.Stdout.Write(buf.Bytes()) // Output: 0 1 2 3 } func ExampleBuffer_Cap() { buf1 := bytes.NewBuffer(make([]byte, 10)) buf2 := bytes.NewBuffer(make([]byte, 0, 10)) fmt.Println(buf1.Cap()) fmt.Println(buf2.Cap()) // Output: // 10 // 10 } func ExampleBuffer_Grow() { var b bytes.Buffer b.Grow(64) bb := b.Bytes()
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Mar 04 15:54:40 GMT 2024 - 15K bytes - Viewed (1) -
cni/README.md
- CAP_SYS_ADMIN - CAP_NET_ADMIN - CAP_NET_RAW ## Ambient mode details Fundamentally, this component is responsible for the following:
Plain Text - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Feb 28 17:29:38 GMT 2024 - 12.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/ProjectModelResolver.java
* declared in the POM. * */ public class ProjectModelResolver implements ModelResolver { private static final int MAX_CAP = 0x7fff; private final RepositorySystemSession session; private final RequestTrace trace; private final String context = "project"; private List<RemoteRepository> repositories;
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/storage-datatypes_gen.go
return } z.Metadata[za0001] = za0002 } var zb0003 uint32 zb0003, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "Parts") return } if cap(z.Parts) >= int(zb0003) { z.Parts = (z.Parts)[:zb0003] } else { z.Parts = make([]ObjectPartInfo, zb0003) } for za0003 := range z.Parts { err = z.Parts[za0003].DecodeMsg(dc) if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 127.5K bytes - Viewed (0) -
internal/grid/connection.go
} continue } if int64(cap(dst)) < hdr.Length+1 { dst = make([]byte, 0, hdr.Length+hdr.Length>>3) } return readAllInto(dst[:0], &wsReader) } } // Keep reusing the same buffer. var msg []byte for { if atomic.LoadUint32((*uint32)(&c.state)) != StateConnected { cancel(ErrDisconnected) return } if cap(msg) > readBufferSize*4 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
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 Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0)