Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 601 - 610 of 824 for done (0.04 seconds)

  1. tests/preload_test.go

    	}
    }
    
    func TestPreloadGoroutine(t *testing.T) {
    	var wg sync.WaitGroup
    
    	wg.Add(10)
    	for i := 0; i < 10; i++ {
    		go func() {
    			defer wg.Done()
    			var user2 []User
    			tx := DB.Where("id = ?", 1).Session(&gorm.Session{})
    
    			if err := tx.Preload("Team").Find(&user2).Error; err != nil {
    				t.Error(err)
    			}
    		}()
    	}
    	wg.Wait()
    }
    
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Wed Jun 12 10:00:47 GMT 2024
    - 15.9K bytes
    - Click Count (0)
  2. tests/lru_test.go

    	lc := lru.NewLRU[string, string](0, nil, 0)
    	wg := sync.WaitGroup{}
    	wg.Add(1000)
    	for i := 0; i < 1000; i++ {
    		go func(i int) {
    			lc.Add(fmt.Sprintf("key-%d", i/10), fmt.Sprintf("val-%d", i/10))
    			wg.Done()
    		}(i)
    	}
    	wg.Wait()
    	if lc.Len() != 100 {
    		t.Fatalf("length differs from expected")
    	}
    }
    
    func TestLRUInvalidateAndEvict(t *testing.T) {
    	var evicted int
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Mon Sep 08 09:19:22 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  3. tests/associations_many2many_test.go

    	var wg sync.WaitGroup
    	for i := 0; i < count; i++ {
    		wg.Add(1)
    		go func(user User, language Language) {
    			err := db.Model(&user).Association("Languages").Append(&language)
    			AssertEqual(t, err, nil)
    
    			wg.Done()
    		}(user, languages[i])
    	}
    	wg.Wait()
    
    	var find User
    	err = db.Preload(clause.Associations).Where("id = ?", user.ID).First(&find).Error
    	AssertEqual(t, err, nil)
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Jun 10 13:05:19 GMT 2023
    - 13.2K bytes
    - Click Count (0)
  4. internal/ioutil/ioutil.go

    	if pb != nil && len(*pb) == p.size {
    		p.p.Put(pb)
    	}
    }
    
    // WriteOnCloser implements io.WriteCloser and always
    // executes at least one write operation if it is closed.
    //
    // This can be useful within the context of HTTP. At least
    // one write operation must happen to send the HTTP headers
    // to the peer.
    type WriteOnCloser struct {
    	io.Writer
    	hasWritten bool
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  5. cmd/erasure-healing.go

    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    	var wg sync.WaitGroup
    	for _, disk := range er.getDisks() {
    		if disk != nil {
    			wg.Add(1)
    			go func(disk StorageAPI) {
    				defer wg.Done()
    				_ = disk.CleanAbandonedData(ctx, bucket, object)
    			}(disk)
    		}
    	}
    	wg.Wait()
    	return nil
    }
    
    // healObjectDir - heals object directory specifically, this special call
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  6. CHANGELOG/CHANGELOG-1.27.md

    ### Bug or Regression
    
    - Fix component status calling etcd health endpoint over http which exposed kubernetes to the risk of complete watch starvation and is inconsistent with other etcd probing done by kube-apiserver. ([#118683](https://github.com/kubernetes/kubernetes/pull/118683), [@serathius](https://github.com/serathius)) [SIG API Machinery]
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Wed Jul 17 07:48:22 GMT 2024
    - 466.3K bytes
    - Click Count (2)
  7. cmd/object-api-multipart_test.go

    		// `KeyMarker` is set. It contains part of the objectname as `KeyPrefix`.
    		// `MaxUploads` is set equal to the number of meta data entries in the result, the result contains only one entry.
    		// Expecting the result to contain one MultipartInfo entry and IsTruncated to be false.
    		{
    			MaxUploads:  1,
    			KeyMarker:   "min",
    			IsTruncated: false,
    			Uploads: []MultipartInfo{
    				{
    					Object:   objectNames[0],
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 89.4K bytes
    - Click Count (0)
  8. docs/es/docs/_llm-test.md

    //// tab | Prueba
    
    AquĆ­ algunas cosas envueltas en elementos HTML "abbr" (algunas son inventadas):
    
    ### El abbr da una frase completa { #the-abbr-gives-a-full-phrase }
    
    * <abbr title="Getting Things Done - Hacer las cosas">GTD</abbr>
    * <abbr title="less than - menor que"><code>lt</code></abbr>
    * <abbr title="XML Web Token - Token web XML">XWT</abbr>
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 12.2K bytes
    - Click Count (0)
  9. cmd/tier.go

    	}
    
    	// To avoid all MinIO nodes reading the tier config object at the same
    	// time.
    	t := time.NewTimer(tierCfgRefresh + randInterval())
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-t.C:
    			err := config.Reload(ctx, objAPI)
    			if err != nil {
    				tierLogIf(ctx, err)
    			}
    		}
    		t.Reset(tierCfgRefresh + randInterval())
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  10. cmd/admin-bucket-handlers.go

    			}
    		case <-keepAliveTicker.C:
    			if len(diffCh) > 0 {
    				continue
    			}
    			if _, err := w.Write([]byte(" ")); err != nil {
    				return
    			}
    			xhttp.Flush(w)
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    // ReplicationMRFHandler - POST returns info on entries in the MRF backlog for a node or all nodes
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 33.3K bytes
    - Click Count (0)
Back to Top