Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 47 for wg (0.02 sec)

  1. cmd/erasure.go

    	var wg sync.WaitGroup
    	disks := er.getDisks()
    	infos := make([]DiskInfo, len(disks))
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	for _, i := range r.Perm(len(disks)) {
    		i := i
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    
    			disk := disks[i]
    			if disk == nil {
    				infos[i].Error = errDiskNotFound.Error()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  2. cmd/perf-tests.go

    		connectionsPerPeer = 1
    	}
    
    	errStr := ""
    	var wg sync.WaitGroup
    	for index := range globalNotificationSys.peerClients {
    		if globalNotificationSys.peerClients[index] == nil {
    			continue
    		}
    		go func(index int) {
    			for i := 0; i < connectionsPerPeer; i++ {
    				wg.Add(1)
    				go func() {
    					defer wg.Done()
    					err := globalNotificationSys.peerClients[index].DevNull(ctx, r)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. internal/dsync/dsync_test.go

    	dm.refreshInterval = 500 * time.Millisecond
    	var wg sync.WaitGroup
    	wg.Add(1)
    
    	ctx, cl := context.WithCancel(context.Background())
    	cancel := func() {
    		cl()
    		wg.Done()
    	}
    
    	if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) {
    		t.Fatal("GetLock() should be successful")
    	}
    
    	// Wait until context is canceled
    	wg.Wait()
    	if ctx.Err() == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  4. internal/pubsub/pubsub.go

    	combined := Mask(atomic.LoadUint64(&ps.types))
    	combined.Merge(Mask(mask.Mask()))
    	atomic.StoreUint64(&ps.types, uint64(combined))
    	if wg != nil {
    		wg.Add(1)
    	}
    	go func() {
    		defer func() {
    			if wg != nil {
    				wg.Done()
    			}
    			// Clean up and de-register the subscriber
    			ps.Lock()
    			defer ps.Unlock()
    			var remainTypes Mask
    			for i, s := range ps.subs {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  5. internal/grid/muxserver.go

    		LastPing:           time.Now().Unix(),
    		BaseFlags:          c.baseFlags,
    		clientPingInterval: c.clientPingInterval,
    	}
    	// Acknowledge Mux created.
    	// Send async.
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		defer wg.Done()
    		var ack message
    		ack.Op = OpAckMux
    		ack.Flags = m.BaseFlags
    		ack.MuxID = m.ID
    		m.send(ack)
    		if debugPrint {
    			fmt.Println("connected stream mux:", ack.MuxID)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  6. cmd/untar.go

    		}
    
    		header, err := tarReader.Next()
    		switch {
    
    		// if no more files are found return
    		case err == io.EOF:
    			wg.Wait()
    			return asyncErr
    
    		// return any other error
    		case err != nil:
    			wg.Wait()
    			extra := ""
    			if n > 0 {
    				extra = fmt.Sprintf(" after %d successful object(s)", n)
    			}
    			return fmt.Errorf("tar file error: %w%s", err, extra)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. tests/prepared_stmt_test.go

    	sqlDB.SetMaxOpenConns(1)
    
    	tx = tx.Session(&gorm.Session{PrepareStmt: true})
    
    	wg := sync.WaitGroup{}
    	for i := 0; i < 100; i++ {
    		wg.Add(1)
    		go func() {
    			user := User{Name: "jinzhu"}
    			tx.Create(&user)
    
    			var result User
    			tx.First(&result)
    			wg.Done()
    		}()
    	}
    	wg.Wait()
    
    	conn, ok := tx.ConnPool.(*gorm.PreparedStmtDB)
    	AssertEqual(t, ok, true)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. cmd/notification.go

    		}(client)
    	}
    
    	wg.Add(1)
    	go func() {
    		defer wg.Done()
    		select {
    		case <-ctx.Done():
    		case ch <- driveSpeedTest(ctx, opts):
    		}
    	}()
    
    	go func(wg *sync.WaitGroup, ch chan madmin.DriveSpeedTestResult) {
    		wg.Wait()
    		xioutil.SafeClose(ch)
    	}(&wg, ch)
    
    	return ch
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  9. internal/store/batch_test.go

    			t.Log(err)
    		},
    	})
    	defer batch.Close()
    
    	var wg sync.WaitGroup
    	for i := 0; i < int(limit); i++ {
    		wg.Add(1)
    		go func(key int) {
    			defer wg.Done()
    			if err := batch.Add(testItem); err != nil {
    				t.Errorf("failed to add item %v; %v", key, err)
    				return
    			}
    		}(i)
    	}
    	wg.Wait()
    
    	batchLen := batch.Len()
    	if batchLen != int(limit) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-timer.C:
    			var wg sync.WaitGroup
    			for _, set := range s.sets {
    				wg.Add(1)
    				go func(set *erasureObjects) {
    					defer wg.Done()
    					if set == nil {
    						return
    					}
    					set.cleanupDeletedObjects(ctx)
    				}(set)
    			}
    			wg.Wait()
    
    			// Reset for the next interval
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
Back to top