- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 114 for defer (0.14 sec)
-
cmd/erasure-object.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cni/pkg/plugin/sidecar_iptables_linux.go
} netNs, err := getNs(netns) if err != nil { err = fmt.Errorf("failed to open netns %q: %s", netns, err) return err } defer netNs.Close() return netNs.Do(func(_ ns.NetNS) error { log.Infof("============= Start iptables configuration for %v =============", podName) defer log.Infof("============= End iptables configuration for %v =============", podName) return cmd.ProgramIptables(cfg) })
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 17:36:41 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/xl-storage.go
atomic.AddInt32(&s.scanning, 1) defer atomic.AddInt32(&s.scanning, -1) var err error stopFn := globalScannerMetrics.log(scannerMetricScanBucketDrive, s.drivePath, cache.Info.Name) defer func() { res := make(map[string]string) if err != nil { res["err"] = err.Error() } stopFn(res) }() // Updates must be closed before we return. defer xioutil.SafeClose(updates)
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/erasure.go
go func() { // Add jitter to the update time so multiple sets don't sync up. updateTime := 30*time.Second + time.Duration(float64(10*time.Second)*rand.Float64()) t := time.NewTicker(updateTime) defer t.Stop() defer saverWg.Done() var lastSave time.Time for { select { case <-t.C: if cache.Info.LastUpdate.Equal(lastSave) { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
cmd/site-replication.go
time.Sleep(duration) } c.RLock() defer c.RUnlock() if c.enabled { logger.Info("Cluster replication initialized") } return nil } func (c *SiteReplicationSys) loadFromDisk(ctx context.Context, objAPI ObjectLayer) error { buf, err := readConfig(ctx, objAPI, getSRStateFilePath()) if err != nil { if errors.Is(err, errConfigNotFound) { c.Lock() defer c.Unlock() c.state = srState{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/metacache-set.go
rpc := mc.rpc cancel := mc.cancel defer func() { o.debugln(color.Green("saveMetaCacheStream:")+"err:", err) if err != nil && !errors.Is(err, io.EOF) { go mc.setErr(err.Error()) cancel() } }() defer cancel() // Save continuous updates go func() { var err error ticker := time.NewTicker(10 * time.Second) defer ticker.Stop() var exit bool for !exit {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/object-handlers.go
} var buf *bytebufferpool.ByteBuffer if update { if globalCacheConfig.MatchesSize(objInfo.Size) { buf = bytebufferpool.Get() defer bytebufferpool.Put(buf) } defer func() { var data []byte if buf != nil { data = buf.Bytes() } asize, err := objInfo.GetActualSize() if err != nil { asize = objInfo.Size }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/erasure-sets.go
timer := time.NewTimer(globalAPIConfig.getDeleteCleanupInterval()) defer timer.Stop() for { select { case <-ctx.Done(): return case <-timer.C: var wg sync.WaitGroup for _, set := range s.sets { wg.Add(1) go func(set *erasureObjects) { defer wg.Done() if set == nil { return } set.cleanupDeletedObjects(ctx)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
cmd/update.go
if err != nil { return nil, nil, err } } else { return nil, nil, fmt.Errorf("unsupported protocol scheme: %s", u.Scheme) } defer xhttp.DrainBody(reader) b := bytebufferpool.Get() bc := bytebufferpool.Get() defer func() { b.Reset() bc.Reset() bytebufferpool.Put(b) bytebufferpool.Put(bc) }() w, err := zstd.NewWriter(bc) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/data-usage-cache.go
// Abandon if more than a minute, so we don't hold up scanner. ctx, cancel := context.WithTimeout(ctx, timeout) defer cancel() return saveConfig(ctx, store, pathJoin(bucketMetaPrefix, name), buf.Bytes()) } defer save(name+".bkp", 5*time.Second) // Keep a backup as well // drive timeout by default is 2 minutes, we do not need to wait longer. return save(name, time.Minute) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1)