Search Options

Results per page
Sort
Preferred Languages
Advance

Results 641 - 650 of 1,781 for take (0.12 sec)

  1. src/buildall.bash

    # architectures.
    #
    # Originally the Go build system used it as a smoke test to quickly
    # flag portability issues in builders named "misc-compile" or "all-compile".
    # As of CL 464955, the build system uses make.bash -compile-only instead,
    # so this script no longer runs in any automated fashion.
    #
    # Options:
    #   -e: stop at first failure
    
    if [ ! -f run.bash ]; then
    	echo 'buildall.bash must be run from $GOROOT/src' 1>&2
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Apr 23 17:45:23 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  2. src/archive/zip/reader.go

    		// to an index into the r.fileList entry that we are
    		// building. They are used to mark duplicate entries.
    		files := make(map[string]int)
    		knownDirs := make(map[string]int)
    
    		// dirs[name] is true if name is known to be a directory,
    		// because it appears as a prefix in a path.
    		dirs := make(map[string]bool)
    
    		for _, file := range r.File {
    			isDir := len(file.Name) > 0 && file.Name[len(file.Name)-1] == '/'
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Sat Aug 03 01:05:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  3. internal/bucket/bandwidth/monitor.go

    	NodeCount             uint64
    }
    
    // NewMonitor returns a monitor with defaults.
    func NewMonitor(ctx context.Context, numNodes uint64) *Monitor {
    	m := &Monitor{
    		bucketsMeasurement:    make(map[BucketOptions]*bucketMeasurement),
    		bucketsThrottle:       make(map[BucketOptions]*bucketThrottle),
    		bucketMovingAvgTicker: time.NewTicker(2 * time.Second),
    		ctx:                   ctx,
    		NodeCount:             numNodes,
    	}
    	go m.trackEWMA()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. internal/s3select/simdj/reader.go

    func NewReader(readCloser io.ReadCloser, args *json.ReaderArgs) *Reader {
    	r := Reader{
    		args:       args,
    		readCloser: &safeCloser{r: io.Reader(readCloser)},
    		decoded:    make(chan simdjson.Object, 1000),
    		input:      make(chan simdjson.Stream, 2),
    		exitReader: make(chan struct{}),
    	}
    	r.onReaderExit = func() {
    		close(r.decoded)
    		readCloser.Close()
    		for range r.input {
    			// Read until EOF trickles through.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  5. istioctl/pkg/tag/util.go

    	namespaces, err := client.CoreV1().Namespaces().List(ctx, metav1.ListOptions{
    		LabelSelector: fmt.Sprintf("%s=%s", label.IoIstioRev.Name, tag),
    	})
    	if err != nil {
    		return nil, err
    	}
    
    	nsNames := make([]string, len(namespaces.Items))
    	for i, ns := range namespaces.Items {
    		nsNames[i] = ns.Name
    	}
    	return nsNames, nil
    }
    
    // GetWebhookTagName extracts tag name from webhook object.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. docs/en/docs/tutorial/dependencies/dependencies-with-yield.md

    In the same way, you can use `finally` to make sure the exit steps are executed, no matter if there was an exception or not.
    
    ```Python hl_lines="3  5"
    {!../../docs_src/dependencies/tutorial007.py!}
    ```
    
    ## Sub-dependencies with `yield`
    
    You can have sub-dependencies and "trees" of sub-dependencies of any size and shape, and any or all of them can use `yield`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 14K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  8. docs/bucket/replication/test_del_marker_proxying.sh

    	echo -n "Cleaning up instances of MinIO ..."
    	pkill -9 minio || sudo pkill -9 minio
    	rm -rf /tmp/sitea
    	rm -rf /tmp/siteb
    	echo "done"
    }
    
    cleanup
    
    export MINIO_CI_CD=1
    export MINIO_BROWSER=off
    
    make install-race
    
    # Start MinIO instances
    echo -n "Starting MinIO instances ..."
    minio server --address 127.0.0.1:9001 --console-address ":10000" "http://127.0.0.1:9001/tmp/sitea/data/disterasure/xl{1...4}" \
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  9. internal/etag/etag_test.go

    	Plaintext ETag
    }{
    	{ // 0
    		Key:       make([]byte, 32),
    		ETag:      must("3b83ef96387f14655fc854ddc3c6bd57"),
    		Plaintext: must("3b83ef96387f14655fc854ddc3c6bd57"),
    	},
    	{ // 1
    		Key:       make([]byte, 32),
    		ETag:      must("7b976cc68452e003eec7cb0eb631a19a-1"),
    		Plaintext: must("7b976cc68452e003eec7cb0eb631a19a-1"),
    	},
    	{ // 2
    		Key:       make([]byte, 32),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  10. internal/s3select/jstream/scanner.go

    	fillReq   chan struct{}
    	fillReady chan int64
    	readerErr error // underlying reader error, if any
    }
    
    func newScanner(r io.Reader) *scanner {
    	sr := &scanner{
    		end:       maxInt,
    		fillReq:   make(chan struct{}),
    		fillReady: make(chan int64),
    	}
    
    	go func() {
    		var rpos int64 // total bytes read into buffer
    
    		defer func() {
    			atomic.StoreInt64(&sr.end, rpos)
    			close(sr.fillReady)
    		}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top