- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 173 for Lannon (0.17 sec)
-
cmd/admin-handlers-config-kv.go
if objectAPI == nil { return } cfg := globalServerConfig.Clone() var s strings.Builder hkvs := config.HelpSubSysMap[""] for _, hkv := range hkvs { // We ignore the error below, as we cannot get one. cfgSubsysItems, _ := cfg.GetSubsysInfo(hkv.Key, "", false) for _, item := range cfgSubsysItems { off := item.Config.Get(config.Enable) == config.EnableOff switch hkv.Key {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.7K bytes - Viewed (0) -
internal/grid/muxclient.go
ctx: ctx, cancelFn: cancelFn, parent: parent, LastPong: time.Now().Unix(), BaseFlags: parent.baseFlags, } } // roundtrip performs a roundtrip, returning the first response. // This cannot be used concurrently. func (m *muxClient) roundtrip(h HandlerID, req []byte) ([]byte, error) { if m.init { return nil, errors.New("mux client already used") } m.init = true m.singleResp = true msg := message{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/rest/client.go
// https://www.awsarchitectureblog.com/2015/03/backoff.html func exponentialBackoffWait(r *rand.Rand, unit, cap time.Duration) func(uint) time.Duration { if unit > time.Hour { // Protect against integer overflow 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))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/encryption-v1.go
// but has an invalid size. func (o ObjectInfo) DecryptedSize() (int64, error) { if _, ok := crypto.IsEncrypted(o.UserDefined); !ok { return 0, errors.New("Cannot compute decrypted size of an unencrypted object") } if !o.isMultipart() { size, err := sio.DecryptedSize(uint64(o.Size)) if err != nil { err = errObjectTampered // assign correct error type }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
cmd/format-erasure.go
} if len(formatErasure.Erasure.Sets[0]) != setDriveCount { return fmt.Errorf("%s drive is already formatted with %d drives per erasure set. This cannot be changed to %d", disks[i], len(formatErasure.Erasure.Sets[0]), setDriveCount) } } return nil } // Get backend Erasure format in quorum `format.json`.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// // All this is necessary because quite often apps use the same port for healthchecks as they do for reg. traffic, and // we cannot make assumptions there. // -A OUTPUT -m owner --socket-exists -p tcp -m set --match-set istio-inpod-probes dst,dst -j SNAT --to-source 169.254.7.127 iptablesBuilder.AppendRuleV4(
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
if r.Type == SelectRestoreRequest && r.OutputLocation.IsEmpty() { return fmt.Errorf("OutputLocation required for SELECT requests") } if r.Days != 0 && r.Type == SelectRestoreRequest { return fmt.Errorf("Days cannot be specified with SELECT restore request") } if r.Days == 0 && r.Type != SelectRestoreRequest { return fmt.Errorf("restoration days should be at least 1") } // Check if bucket exists.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
src/cmd/asm/internal/asm/asm.go
targetAddr.Type = obj.TYPE_REG } case target.Type == obj.TYPE_CONST: // JMP $4 *targetAddr = a[0] case target.Type == obj.TYPE_NONE: // JMP default: p.errorf("cannot assemble jump %+v", target) return } p.append(prog, cond, true) } func (p *Parser) patch() { for _, patch := range p.toPatch { targetProg := p.labels[patch.label]
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 25.3K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
globalNotificationSys.ReloadPoolMeta(ctx) } z.poolMetaMutex.Unlock() } wk.Take() go func(setIdx int) { defer wk.Give() // We will perpetually retry listing if it fails, since we cannot // possibly give up in this matter for { if contextCanceled(ctx) { break } err := set.listObjectsToDecommission(ctx, bi, func(entry metaCacheEntry) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/xl-storage.go
if err = mkdirAll(pathutil.Dir(filePath), 0o777, skipParent); err != nil { return nil, osErrToFileErr(err) } w, err := OpenFile(filePath, mode, 0o666) if err != nil { // File path cannot be verified since one of the parents is a file. switch { case isSysErrIsDir(err): return nil, errIsNotRegular case osIsPermission(err): return nil, errFileAccessDenied case isSysErrNotDir(err):
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)