Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 654 for appear (0.05 seconds)

  1. internal/config/lambda/event/targetlist.go

    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := make([]Target, 0, len(list.targets))
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // Empty returns true if targetList is empty.
    func (list *TargetList) Empty() bool {
    	list.RLock()
    	defer list.RUnlock()
    
    	return len(list.targets) == 0
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  2. cmd/local-locker_test.go

    		}
    		if !ok {
    			t.Fatal("did not get write lock")
    		}
    		rUIDs = append(rUIDs, uid)
    
    		// RLock twice, different uid
    		uid = mustGetUUID()
    		arg.UID = uid
    		ok, err = l.RLock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    			t.Fatal("did not get write lock")
    		}
    		rResources[i] = name
    		rUIDs = append(rUIDs, uid)
    	}
    	// Each Lock has m entries
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  3. cmd/dynamic-timeouts.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"math"
    	"sync"
    	"sync/atomic"
    	"time"
    )
    
    const (
    	dynamicTimeoutIncreaseThresholdPct = 0.33 // Upper threshold for failures in order to increase timeout
    	dynamicTimeoutDecreaseThresholdPct = 0.10 // Lower threshold for failures in order to decrease timeout
    	dynamicTimeoutLogSize              = 16
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  4. cmd/object-handlers_test.go

    		}
    		if testCase.expectedRespStatus != http.StatusOK {
    			b, err := io.ReadAll(rec.Body)
    			if err != nil {
    				t.Fatal(err)
    			}
    			var apiErr APIErrorResponse
    			err = xml.Unmarshal(b, &apiErr)
    			if err != nil {
    				t.Fatal(err)
    			}
    			gotErr := apiErr.Code
    			wantErr := testCase.wantAPICode
    			if gotErr != wantErr {
    				t.Errorf("test %d: want api error %q, got %q", i, wantErr, gotErr)
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
  5. cmd/metrics-v2_test.go

    	capitalPutObjects := make([]MetricV2, 0, len(histBuckets)+1)
    	for _, metric := range metrics {
    		if value := metric.VariableLabels["api"]; value == "PutObject" {
    			capitalPutObjects = append(capitalPutObjects, metric)
    		}
    	}
    	if expMetricsPerAPI := len(histBuckets) + 1; expMetricsPerAPI != len(capitalPutObjects) {
    		t.Fatalf("Expected %d api=PutObject metrics but got %d", expMetricsPerAPI, len(capitalPutObjects))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  6. cmd/erasure-healing_test.go

    	err = objLayer.MakeBucket(ctx, bucket, MakeBucketOptions{})
    	if err != nil {
    		t.Fatalf("Failed to make a bucket - %v", err)
    	}
    
    	disks := objLayer.(*erasureServerPools).serverPools[0].erasureDisks[0]
    	orgDisks := append([]StorageAPI{}, disks...)
    
    	// Enable versioning.
    	globalBucketMetadataSys.Update(ctx, bucket, bucketVersioningConfig, []byte(`<VersioningConfiguration><Status>Enabled</Status></VersioningConfiguration>`))
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 48.5K bytes
    - Click Count (0)
  7. clause/set.go

    func (set Set) Assignments() []Assignment { return []Assignment(set) }
    
    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 {
    		assignments[idx] = Assignment{Column: Column{Name: key}, Value: values[key]}
    	}
    	return assignments
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Tue Sep 09 01:34:33 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  8. ci/official/requirements_updater/nvidia-requirements.txt

    nvidia-cublas-cu12>=12.5.3.2,<13.0
    nvidia-cuda-cupti-cu12>=12.5.82,<13.0
    nvidia-cuda-nvcc-cu12>=12.5.82,<13.0
    nvidia-cuda-nvrtc-cu12>=12.5.82,<13.0
    nvidia-cuda-runtime-cu12>=12.5.82,<13.0
    # The upper bound is set for the CUDNN API compatibility.
    # See
    # https://docs.nvidia.com/deeplearning/cudnn/backend/latest/developer/forward-compatibility.html#cudnn-api-compatibility
    nvidia-cudnn-cu12>=9.3.0.75,<10.0
    nvidia-cufft-cu12>=11.2.3.61,<12.0
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Wed Sep 03 23:57:17 GMT 2025
    - 646 bytes
    - Click Count (0)
  9. internal/config/dns/dns_path.go

    func msgPath(s, prefix string) string {
    	l := dns.SplitDomainName(s)
    	for i, j := 0, len(l)-1; i < j; i, j = i+1, j-1 {
    		l[i], l[j] = l[j], l[i]
    	}
    	return path.Join(append([]string{etcdPathSeparator + prefix + etcdPathSeparator}, l...)...)
    }
    
    // dnsJoin joins labels to form a fully qualified domain name. If the last label is
    // the root label it is ignored. Not other syntax checks are performed.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 28 17:31:12 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  10. cmd/erasure-server-pool-decom.go

    func (pd *PoolDecommissionInfo) bucketPop(bucket string) bool {
    	pd.DecommissionedBuckets = append(pd.DecommissionedBuckets, bucket)
    	for i, b := range pd.QueuedBuckets {
    		if b == bucket {
    			// Bucket is done.
    			pd.QueuedBuckets = append(pd.QueuedBuckets[:i], pd.QueuedBuckets[i+1:]...)
    			// Clear tracker info.
    			if pd.Bucket == bucket {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
Back to Top