Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 900 for makeAs (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top