Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,713 for Make (0.1 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. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. common/scripts/lint_go.sh

    #
    # The original version of this file is located in the https://github.com/istio/common-files repo.
    # If you're looking at this file in a different repo and want to make a change, please go to the
    # common-files repo, make the change there and check it in. Then come back to this repo and run
    # "make update-common".
    
    # Copyright Istio Authors
    #
    # Licensed under the Apache License, Version 2.0 (the "License");
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 26 21:57:53 UTC 2022
    - 1.2K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    	endpointStrings := make([]string, len(endpoints.Endpoints))
    	for i, endpoint := range endpoints.Endpoints {
    		endpointStrings[i] = endpoint.String()
    	}
    
    	// Initialize the erasure sets instance.
    	s := &erasureSets{
    		sets:               make([]*erasureObjects, setCount),
    		erasureDisks:       make([][]StorageAPI, setCount),
    		erasureLockers:     make([][]dsync.NetLocker, setCount),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  10. 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)
Back to top