- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for rosulate (0.32 sec)
-
internal/bpool/bpool.go
} return &BytePoolCap{ c: make(chan []byte, maxSize), w: width, wcap: capwidth, } } // Populate - populates and pre-warms the byte pool, this function is non-blocking. func (bp *BytePoolCap) Populate() { for _, buf := range reedsolomon.AllocAligned(cap(bp.c), bp.wcap) { bp.Put(buf[:bp.w]) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 2.6K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
func (s *NetServer) buildZtunnelSnapshot(ambientPodUIDs map[types.UID]*corev1.Pod) error { // first add all the pods as empty: for uid := range ambientPodUIDs { s.currentPodSnapshot.Ensure(string(uid)) } // populate full pod snapshot from cgroups return s.scanProcForPodsAndCache(ambientPodUIDs) } func (s *NetServer) scanProcForPodsAndCache(pods map[types.UID]*corev1.Pod) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cmd/metacache-entries.go
case <-ctxDone: return ctx.Err() case entry, ok := <-in[idx]: if !ok { top[idx] = nil nDone++ } else { top[idx] = &entry } } return nil } // Populate all... for i := range in { if err := selectFrom(i); err != nil { return err } } last := "" var toMerge []int // Choose the best to return. for { if nDone == len(in) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/update-notifier.go
// color characters, the result is incorrect. line1Length := len(fmt.Sprintf(msgLine1Fmt, newerThan)) line2Length := len(fmt.Sprintf(msgLine2Fmt, updateString)) // Populate lines with color coding. line1InColor := fmt.Sprintf(msgLine1Fmt, color.YellowBold(newerThan)) line2InColor := fmt.Sprintf(msgLine2Fmt, color.CyanBold(updateString)) // calculate the rectangular box size.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 3.6K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
} cr.err = errMalformedEncoding return n, cr.err } cr.offset = copy(buf, cr.buffer) n += cr.offset return n, err } // readTrailers will read all trailers and populate cr.trailers with actual values. func (cr *s3ChunkedReader) readTrailers() error { if cr.debug { fmt.Printf("pre trailer sig: %s\n", cr.seedSignature) } var valueBuffer bytes.Buffer // Read value for {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
cmd/xl-storage.go
// Do the same for inline data dirs, err := xl.data.list() if err != nil { return err } // Clear and repopulate for k := range foundDirs { delete(foundDirs, k) } // Populate into map for _, k := range dirs { foundDirs[k] = struct{}{} } // Delete all directories we expect to be there. for _, dir := range wantDirs { delete(foundDirs, dir) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/auth-handler.go
if err != nil { authZLogIf(ctx, err, logger.ErrorKind) return ErrMalformedXML } // Populate payload to extract location constraint. r.Body = io.NopCloser(bytes.NewReader(payload)) region, s3Err = parseLocationConstraint(r) if s3Err != ErrNone { return s3Err } // Populate payload again to handle it in HTTP handler. r.Body = io.NopCloser(bytes.NewReader(payload)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26K bytes - Viewed (0) -
cmd/erasure-server-pool.go
} // Initialize byte pool once for all sets, bpool size is set to // setCount * setDriveCount with each memory upto blockSizeV2. buffers := bpool.NewBytePoolCap(n, blockSizeV2, blockSizeV2*2) buffers.Populate() globalBytePoolCap.Store(buffers) var localDrives []StorageAPI local := endpointServerPools.FirstLocal() for i, ep := range endpointServerPools {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/metrics-v2.go
dependGlobalIsDistErasure bool dependGlobalBackgroundHealState bool dependBucketTargetSys bool } // RegisterRead register the metrics populator function to be used // to populate new values upon cache invalidation. func (g *MetricsGroupV2) RegisterRead(read func(context.Context) []MetricV2) { g.metricsCache = cachevalue.NewFromFunc(g.cacheInterval, cachevalue.Opts{ReturnLastGood: true},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
pods = append(pods, pod) } } return pods } // EnqueueNamespace takes a Namespace and enqueues all Pod objects that make need an update // TODO it is sort of pointless/confusing/implicit to populate Old and New with the same reference here func (s *InformerHandlers) enqueueNamespace(o controllers.Object) { namespace := o.GetName() labels := o.GetLabels()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0)