- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 900 for makeAs (0.11 sec)
-
docs/debugging/reorder-disks/main.go
} format, err := getFormatJSON(localDisks[0].path) if err != nil { log.Fatal(err) } setSize := len(format.XL.Sets[0]) expectedDisksName := make(map[string]string) actualDisksName := make(map[string]string) // Calculate the set/disk index for _, disk := range localDisks { expectedDisksName[fmt.Sprintf("%d-%d", disk.index/setSize, disk.index%setSize)] = disk.path
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0) -
internal/s3select/sql/analysis.go
if e.Count.StarArg { return qProp{isAggregation: true} } exprA = e.Count.ExprArg.analyze(s) } else { if len(e.SFunc.ArgsList) != 1 { return qProp{err: fmt.Errorf("%s takes exactly one argument", funcName)} } exprA = e.SFunc.ArgsList[0].analyze(s) } if exprA.err != nil { return exprA } if exprA.isAggregation { return qProp{err: errNestedAggregation}
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Dec 23 07:19:11 UTC 2023 - 8.5K bytes - Viewed (0) -
cmd/callhome.go
if duration < time.Second { // Make sure to sleep at least a second to avoid high CPU ticks. duration = time.Second } time.Sleep(duration) } }() } func runCallhome(ctx context.Context, objAPI ObjectLayer) bool { // Make sure only 1 callhome is running on the cluster. locker := objAPI.NewNSLock(minioMetaBucket, "callhome/runCallhome.lock")
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 17 16:53:34 UTC 2024 - 5.3K bytes - Viewed (0) -
internal/grid/types.go
*m = nil return bts, nil } var zb0002 uint32 zb0002, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err, "Values") return } dst := *m if dst == nil { dst = make(map[string]string, zb0002) } else if len(dst) > 0 { for key := range dst { delete(dst, key) } } for zb0002 > 0 { var za0001 string var za0002 string zb0002--
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 15.5K bytes - Viewed (0) -
docs/en/docs/tutorial/body-updates.md
* Convert the copied model to something that can be stored in your DB (for example, using the `jsonable_encoder`). * This is comparable to using the model's `.model_dump()` method again, but it makes sure (and converts) the values to data types that can be converted to JSON, for example, `datetime` to `str`. * Save the data to your DB. * Return the updated model. //// tab | Python 3.10+
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 5.6K bytes - Viewed (0) -
cmd/perf-tests.go
var retError string var totalBytesWritten uint64 var totalBytesRead uint64 objCountPerThread := make([]uint64, opts.concurrency) uploadsCtx, uploadsCancel := context.WithTimeout(ctx, opts.duration) defer uploadsCancel() objNamePrefix := pathJoin(speedTest, mustGetUUID()) userMetadata := make(map[string]string) userMetadata[globalObjectPerfUserMetadata] = "true" // Bypass S3 API freeze
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
src/bufio/export_test.go
) var IsSpace = isSpace const DefaultBufSize = defaultBufSize func (s *Scanner) MaxTokenSize(n int) { if n < utf8.UTFMax || n > 1e9 { panic("bad max token size") } if n < len(s.buf) { s.buf = make([]byte, n) } s.maxTokenSize = n } // ErrOrEOF is like Err, but returns EOF. Used to test a corner case. func (s *Scanner) ErrOrEOF() error { return s.err
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Thu Nov 02 17:17:44 UTC 2017 - 597 bytes - Viewed (0) -
src/cmd/asm/internal/asm/parse.go
if p.errorCount > 10 && !*flags.AllErrors { log.Fatal("too many errors") } } func (p *Parser) pos() src.XPos { return p.ctxt.PosTable.XPos(src.MakePos(p.lex.Base(), uint(p.lineNum), 0)) } func (p *Parser) Parse() (*obj.Prog, bool) { scratch := make([][]lex.Token, 0, 3) for { word, cond, operands, ok := p.line(scratch) if !ok { break } scratch = operands
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Wed Sep 04 18:16:59 UTC 2024 - 36.9K bytes - Viewed (0) -
internal/config/crypto.go
if err != nil { return nil, err } stream, err := algorithm.Stream(key.Plaintext) if err != nil { return nil, err } nonce := make([]byte, stream.NonceSize()) if _, err := rand.Read(nonce); err != nil { return nil, err } const ( MaxMetadataSize = 1 << 20 // max. size of the metadata Version = 1 ) var (
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 5K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
} // Borrowed from rwmutex_test.go func doTestParallelReaders(numReaders, gomaxprocs int) { runtime.GOMAXPROCS(gomaxprocs) m := NewDRWMutex(ds, "test-parallel") clocked := make(chan bool) cunlock := make(chan bool) cdone := make(chan bool) for i := 0; i < numReaders; i++ { go parallelReader(context.Background(), m, clocked, cunlock, cdone) } // Wait for all parallel RLock()s to succeed.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0)