Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,686 for make (0.05 sec)

  1. src/cmd/asm/internal/arch/arch.go

    	return false
    }
    
    func jumpWasm(word string) bool {
    	return word == "JMP" || word == "CALL" || word == "Call" || word == "Br" || word == "BrIf"
    }
    
    func archX86(linkArch *obj.LinkArch) *Arch {
    	register := make(map[string]int16)
    	// Create maps for easy lookup of instruction names etc.
    	for i, s := range x86.Register {
    		register[s] = int16(i + x86.REG_AL)
    	}
    	// Pseudo-registers.
    	register["SB"] = RSB
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 24 12:32:56 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  2. cmd/notification.go

    }
    
    // GetLastDayTierStats fetches per-tier stats of the last 24hrs from all peers
    func (sys *NotificationSys) GetLastDayTierStats(ctx context.Context) DailyAllTierStats {
    	errs := make([]error, len(sys.allPeerClients))
    	lastDayStats := make([]DailyAllTierStats, len(sys.allPeerClients))
    	var wg sync.WaitGroup
    	for index := range sys.peerClients {
    		if sys.peerClients[index] == nil {
    			continue
    		}
    		wg.Add(1)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  3. internal/s3select/csv/reader.go

    	}
    
    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.input = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.readerWg.Add(1)
    
    	// Start splitter
    	go func() {
    		defer close(r.input)
    		defer close(r.queue)
    		defer r.readerWg.Done()
    		for {
    			q := queueItem{
    				input: next,
    				dst:   make(chan [][]string, 1),
    				err:   nextErr,
    			}
    			select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. cmd/peer-s3-server.go

    	globalLocalDrivesMu.RUnlock()
    
    	// Initialize sync waitgroup.
    	g := errgroup.WithNErrs(len(localDrives))
    
    	// Disk states slices
    	beforeState := make([]string, len(localDrives))
    	afterState := make([]string, len(localDrives))
    
    	// Make a volume entry on all underlying storage disks.
    	for index := range localDrives {
    		index := index
    		g.Go(func() (serr error) {
    			if localDrives[index] == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  5. clause/set.go

    func (set Set) MergeClause(clause *Clause) {
    	copiedAssignments := make([]Assignment, len(set))
    	copy(copiedAssignments, set)
    	clause.Expression = Set(copiedAssignments)
    }
    
    func Assignments(values map[string]interface{}) Set {
    	keys := make([]string, 0, len(values))
    	for key := range values {
    		keys = append(keys, key)
    	}
    	sort.Strings(keys)
    
    	assignments := make([]Assignment, len(keys))
    	for idx, key := range keys {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Nov 29 03:02:44 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  6. cmd/metacache-bucket.go

    	b.mu.RLock()
    	defer b.mu.RUnlock()
    	dst := make(map[string]metacache, len(b.caches))
    	for k, v := range b.caches {
    		dst[k] = v
    	}
    	// Copy indexes
    	dst2 := make(map[string][]string, len(b.cachesRoot))
    	for k, v := range b.cachesRoot {
    		tmp := make([]string, len(v))
    		copy(tmp, v)
    		dst2[k] = tmp
    	}
    
    	return dst, dst2
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  7. docs/hotfixes.md

    Unit tests
    
    ```
    λ make test
    ```
    
    Verify different type of MinIO deployments work
    
    ```
    λ make verify
    ```
    
    Verify if healing and replacing a drive works
    
    ```
    λ make verify-healing
    ```
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 14 21:36:02 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. .gitignore

    /pip_test
    /_python_build
    *.pyc
    __pycache__
    *.swp
    .vscode/
    cmake_build/
    tensorflow/contrib/cmake/_build/
    .idea/**
    /build/
    [Bb]uild/
    /build_output/
    /tensorflow/core/util/version_info.cc
    /tensorflow/python/framework/fast_tensor_util.cpp
    /tensorflow/lite/gen/**
    /tensorflow/lite/tools/make/downloads/**
    /tensorflow/lite/tools/make/gen/**
    /api_init_files_list.txt
    /estimator_api_init_files_list.txt
    *.whl
    dist
    
    # Android
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Sep 20 17:43:17 UTC 2024
    - 939 bytes
    - Viewed (0)
  9. docs/debugging/xl-meta/main.go

    			return errors.New("cannot combine --data and --combine")
    		}
    		// file / version / file
    		filemap := make(map[string]map[string]string)
    		foundData := make(map[string][]byte)
    		partDataToVerID := make(map[string][2]string)
    		var baseName string
    		// versionID ->
    		combineFiles := make(map[string][]string)
    		decode := func(r io.Reader, file string) ([]byte, error) {
    			file = strings.ReplaceAll(file, ":", "_")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  10. internal/s3select/json/preader.go

    func (r *PReader) startReaders() {
    	r.bufferPool.New = func() interface{} {
    		return make([]byte, jsonSplitSize+1024)
    	}
    
    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.input = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.readerWg.Add(1)
    
    	// Start splitter
    	go func() {
    		defer close(r.input)
    		defer close(r.queue)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
Back to top