- Sort Score
- Result 10 results
- Languages All
Results 611 - 620 of 1,423 for Func (0.04 sec)
-
internal/grid/debugmsg_string.go
// Code generated by "stringer -type=debugMsg debug.go"; DO NOT EDIT. package grid import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[debugShutdown-0] _ = x[debugKillInbound-1] _ = x[debugKillOutbound-2] _ = x[debugWaitForExit-3] _ = x[debugSetConnPingDuration-4]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 1K bytes - Viewed (0) -
cmd/os_other.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "io" "os" "syscall" ) func access(name string) error { _, err := os.Lstat(name) return err } func osMkdirAll(dirPath string, perm os.FileMode, _ string) error { // baseDir is not honored in plan9 and solaris platforms. return os.MkdirAll(dirPath, perm) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 13 15:14:36 UTC 2023 - 4K bytes - Viewed (0) -
cmd/batch-replicate.go
// Validate validates if the replicate resource type is recognized and supported func (t BatchJobReplicateResourceType) Validate() error { switch t { case BatchJobReplicateResourceMinIO: case BatchJobReplicateResourceS3: default: return errInvalidArgument } return nil } func (t BatchJobReplicateResourceType) isMinio() bool { return t == BatchJobReplicateResourceMinIO }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 01 12:53:30 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/xl-storage-format-v2_gen.go
func (z ErasureAlgo) Msgsize() (s int) { s = msgp.Uint8Size return } // DecodeMsg implements msgp.Decodable func (z *VersionType) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint8 zb0001, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err) return } (*z) = VersionType(zb0001) } return } // EncodeMsg implements msgp.Encodable
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 55.5K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
errDecommissionRebalanceAlreadyRunning = errors.New("Decommission cannot be started, rebalance is already in progress") ) func (a adminAPIHandlers) StartDecommission(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, _ := validateAdminReq(ctx, w, r, policy.DecommissionAdminAction) if objectAPI == nil { return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 00:22:30 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen_test.go
t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgrebalanceInfo(b *testing.B) { v := rebalanceInfo{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgrebalanceInfo(b *testing.B) { v := rebalanceInfo{} bts := make([]byte, 0, v.Msgsize())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 25 19:36:57 UTC 2022 - 11K bytes - Viewed (0) -
cmd/erasure-decode.go
stashBuffer: b, } } // Done will release any resources used by the parallelReader. func (p *parallelReader) Done() { if p.stashBuffer != nil { globalBytePoolCap.Load().Put(p.stashBuffer) p.stashBuffer = nil } } // preferReaders can mark readers as preferred. // These will be chosen before others. func (p *parallelReader) preferReaders(prefer []bool) { if len(prefer) != len(p.orgReaders) { return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0) -
cmd/bootstrap-messages.go
mu sync.RWMutex info []madmin.TraceInfo } var globalBootstrapTracer = &bootstrapTracer{} func (bs *bootstrapTracer) Record(info madmin.TraceInfo) { bs.mu.Lock() defer bs.mu.Unlock() if len(bs.info) > bootstrapTraceLimit { return } bs.info = append(bs.info, info) } func (bs *bootstrapTracer) Events() []madmin.TraceInfo { traceInfo := make([]madmin.TraceInfo, 0, bootstrapTraceLimit)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 23 10:07:06 UTC 2023 - 1.7K bytes - Viewed (0) -
cmd/http-stats.go
} // Increase internode total input bytes func (s *connStats) incInternodeInputBytes(n int64) { atomic.AddUint64(&s.internodeInputBytes, uint64(n)) } // Increase internode total output bytes func (s *connStats) incInternodeOutputBytes(n int64) { atomic.AddUint64(&s.internodeOutputBytes, uint64(n)) } // Return internode total input bytes func (s *connStats) getInternodeInputBytes() uint64 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 11.4K bytes - Viewed (0) -
src/cmd/asm/internal/asm/asm.go
return false } return true } // evalInteger evaluates an integer constant for a pseudo-op. func (p *Parser) evalInteger(pseudo string, operands []lex.Token) int64 { addr := p.address(operands) return p.getConstantPseudo(pseudo, &addr) } // validImmediate checks that addr represents an immediate constant. func (p *Parser) validImmediate(pseudo string, addr *obj.Addr) bool {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Oct 21 14:11:44 UTC 2024 - 25.5K bytes - Viewed (0)