Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 1,586 for makeCT (0.04 sec)

  1. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java

    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import static java.util.Objects.requireNonNull;
    
    /**
     * A {@link TransferListener} implementation that wraps another delegate {@link TransferListener} but makes it run
     * on single thread, keeping the listener logic simple. This listener also blocks on last transfer event to allow
     * output to perform possible cleanup. It spawns a daemon thread to consume queued events that may fall in even
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. schema/utils.go

    	queryValues := make([]interface{}, len(foreignValues))
    	if len(foreignKeys) == 1 {
    		for idx, r := range foreignValues {
    			queryValues[idx] = r[0]
    		}
    
    		return clause.Column{Table: table, Name: foreignKeys[0]}, queryValues
    	}
    
    	columns := make([]clause.Column, len(foreignKeys))
    	for idx, key := range foreignKeys {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Aug 19 13:35:14 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  3. cmd/peer-rest-client.go

    	if !globalIsDistErasure {
    		// Only useful in distributed setups
    		return nil, nil
    	}
    
    	hosts := endpoints.hostsSorted()
    	remote = make([]*peerRESTClient, 0, len(hosts))
    	all = make([]*peerRESTClient, len(hosts))
    	for i, host := range hosts {
    		if host == nil {
    			continue
    		}
    		all[i] = newPeerRESTClient(host, endpoints.FindGridHostsFromPeer(host))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. istioctl/pkg/multixds/gather.go

    	MessageWriter:     os.Stdout,
    	XdsViaAgents:      false,
    	XdsViaAgentsLimit: 0,
    }
    
    // RequestAndProcessXds merges XDS responses from 1 central or 1..N K8s cluster-based XDS servers
    // Deprecated This method makes multiple responses appear to come from a single control plane;
    // consider using AllRequestAndProcessXds or FirstRequestAndProcessXds
    // nolint: lll
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. bin/build_ztunnel.sh

    # limitations under the License.
    
    set -o errexit
    set -o nounset
    set -o pipefail
    
    if [[ "${TARGET_OUT_LINUX:-}" == "" ]]; then
      echo "Environment variables not set. Make sure you run through the makefile (\`make init\`) rather than directly."
      exit 1
    fi
    
    # Gets the download command supported by the system (currently either curl or wget)
    DOWNLOAD_COMMAND=""
    function set_download_command () {
      # Try curl.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Apr 02 21:46:06 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. cmd/erasure-multipart.go

    	var buffer []byte
    	switch size := data.Size(); {
    	case size == 0:
    		buffer = make([]byte, 1) // Allocate at least a byte to reach EOF
    	case size == -1:
    		if size := data.ActualSize(); size > 0 && size < fi.Erasure.BlockSize {
    			// Account for padding and forced compression overhead and encryption.
    			buffer = make([]byte, data.ActualSize()+256+32+32, data.ActualSize()*2+512)
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  7. cmd/storage-rest-server.go

    	}
    
    	globalLocalDrivesMap = make(map[string]StorageAPI)
    	globalLocalSetDrives = make([][][]StorageAPI, len(endpointServerPools))
    	for pool := range globalLocalSetDrives {
    		globalLocalSetDrives[pool] = make([][]StorageAPI, endpointServerPools[pool].SetCount)
    		for set := range globalLocalSetDrives[pool] {
    			globalLocalSetDrives[pool][set] = make([]StorageAPI, endpointServerPools[pool].DrivesPerSet)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  8. cmd/global-heal.go

    			HealSettings: hs,
    		},
    		cancelCtx:          cancelCtx,
    		ctx:                ctx,
    		reportProgress:     false,
    		scannedItemsMap:    make(map[madmin.HealItemType]int64),
    		healedItemsMap:     make(map[madmin.HealItemType]int64),
    		healFailedItemsMap: make(map[madmin.HealItemType]int64),
    	}
    }
    
    // getLocalBackgroundHealStatus will return the heal status of the local node
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  9. cmd/metrics-realtime.go

    		dm.NDisks = 1
    		if d.Healing {
    			dm.Healing++
    		}
    		if d.Metrics != nil {
    			dm.LifeTimeOps = make(map[string]uint64, len(d.Metrics.APICalls))
    			for k, v := range d.Metrics.APICalls {
    				if v != 0 {
    					dm.LifeTimeOps[k] = v
    				}
    			}
    			dm.LastMinute.Operations = make(map[string]madmin.TimedAction, len(d.Metrics.APICalls))
    			for k, v := range d.Metrics.LastMinute {
    				if v.Count != 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  10. internal/store/batch.go

    }
    
    // NewBatch creates a new batch
    func NewBatch[I any](config BatchConfig[I]) *Batch[I] {
    	if config.CommitTimeout == 0 {
    		config.CommitTimeout = defaultCommitTimeout
    	}
    	quitCh := make(chan struct{})
    	batch := &Batch[I]{
    		items:  make([]I, 0, config.Limit),
    		limit:  config.Limit,
    		store:  config.Store,
    		quitCh: quitCh,
    	}
    	if batch.store != nil {
    		go func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top