Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 42 for newLocker (0.08 sec)

  1. cmd/metacache-manager.go

    	// Start saver when object layer is ready.
    	go func() {
    		objAPI := newObjectLayerFn()
    		for objAPI == nil {
    			time.Sleep(time.Second)
    			objAPI = newObjectLayerFn()
    		}
    
    		t := time.NewTicker(time.Minute)
    		defer t.Stop()
    
    		var exit bool
    		for !exit {
    			select {
    			case <-t.C:
    			case <-GlobalContext.Done():
    				exit = true
    			}
    			m.mu.RLock()
    			for _, v := range m.buckets {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  2. cmd/metacache.go

    func (m metacache) keepAlive(ctx context.Context, rpc *peerRESTClient) {
    	// we intentionally operate on a copy of m, so we can update without locks.
    	t := time.NewTicker(metacacheMaxClientWait / 10)
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			// Request is done, stop updating.
    			return
    		case <-t.C:
    			m.lastHandout = time.Now()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. internal/grid/muxserver.go

    	handlerErr = handler.Handle(ctx, msg.Payload, handlerIn, send)
    	return handlerErr
    }
    
    // checkRemoteAlive will check if the remote is alive.
    func (m *muxServer) checkRemoteAlive() {
    	t := time.NewTicker(m.clientPingInterval)
    	defer t.Stop()
    	for {
    		select {
    		case <-m.ctx.Done():
    			return
    		case <-t.C:
    			last := time.Since(time.Unix(atomic.LoadInt64(&m.LastPing), 0))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  4. cni/pkg/install/install_test.go

    			if err := file.AtomicCopy(filepath.Join("testdata", c.validConfigFilename), tempDir, c.cniConfigFilename); err != nil {
    				t.Fatal(err)
    			}
    
    			// Listen for isReady to be set to true
    			ticker := time.NewTicker(500 * time.Millisecond)
    			defer ticker.Stop()
    			readyChan := make(chan bool)
    			go func(ctx context.Context, tick <-chan time.Time) {
    				for {
    					select {
    					case <-ctx.Done():
    						return
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. cmd/prepare-storage.go

    	if err == nil {
    		return storageDisks, format, nil
    	}
    
    	tries++ // tried already once
    
    	// Wait on each try for an update.
    	ticker := time.NewTicker(1 * time.Second)
    	defer ticker.Stop()
    
    	for {
    		// Only log once every 10 iterations, then reset the tries count.
    		verbose = tries >= 10
    		if verbose {
    			tries = 1
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  6. cmd/namespace-lock.go

    // NewNSLock - returns a lock instance for a given volume and
    // path. The returned lockInstance object encapsulates the nsLockMap,
    // volume, path and operation ID.
    func (n *nsLockMap) NewNSLock(lockers func() ([]dsync.NetLocker, string), volume string, paths ...string) RWLocker {
    	sort.Strings(paths)
    	opsID := mustGetUUID()
    	if n.isDistErasure {
    		drwmutex := dsync.NewDRWMutex(&dsync.Dsync{
    			GetLockers: lockers,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. istioctl/pkg/waypoint/waypoint.go

    					return fmt.Errorf("missing Kubernetes Gateway CRDs need to be installed before applying a waypoint: %s", err)
    				}
    				return err
    			}
    
    			if waitReady {
    				startTime := time.Now()
    				ticker := time.NewTicker(1 * time.Second)
    				defer ticker.Stop()
    				for range ticker.C {
    					programmed := false
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  8. cmd/site-replication-metrics.go

    	} else {
    		srs.XferRateSml.addSize(sz, duration)
    	}
    }
    
    func newSRStats() *SRStats {
    	s := SRStats{
    		M:               make(map[string]*SRStatus),
    		movingAvgTicker: time.NewTicker(time.Second * 2),
    	}
    	go s.trackEWMA()
    	return &s
    }
    
    func (sr *SRStats) trackEWMA() {
    	for {
    		select {
    		case <-sr.movingAvgTicker.C:
    			sr.updateMovingAvg()
    		case <-GlobalContext.Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  9. internal/config/identity/plugin/config.go

    	return true
    }
    
    var (
    	healthCheckInterval = 1 * time.Minute
    	healthCheckTimeout  = 5 * time.Second
    )
    
    func (o *AuthNPlugin) doPeriodicHealthCheck() {
    	ticker := time.NewTicker(healthCheckInterval)
    	defer ticker.Stop()
    
    	for {
    		select {
    		case <-ticker.C:
    			now := time.Now()
    			isConnected := o.checkConnectivity(o.shutdownCtx)
    			if isConnected {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. cmd/storage-rest-server.go

    			} else {
    				write([]byte{0})
    			}
    			xioutil.SafeClose(doneCh)
    			return
    		}
    		defer xioutil.SafeClose(doneCh)
    		// Initiate ticker after body has been read.
    		ticker := time.NewTicker(time.Second * 10)
    		defer ticker.Stop()
    
    		for {
    			select {
    			case <-ticker.C:
    				// The done() might have been called
    				// concurrently, check for it before we
    				// write the filler byte.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top