Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for LastConn (0.06 sec)

  1. internal/rest/client.go

    func (c *Client) IsOnline() bool {
    	return atomic.LoadInt32(&c.connected) == online
    }
    
    // LastConn returns when the disk was (re-)connected
    func (c *Client) LastConn() time.Time {
    	return time.Unix(0, atomic.LoadInt64(&c.lastConn))
    }
    
    // LastError returns previous error
    func (c *Client) LastError() error {
    	c.RLock()
    	defer c.RUnlock()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    func (client *storageRESTClient) IsOnlineWS() bool {
    	return client.gridConn.State() == grid.StateConnected
    }
    
    // LastConn - returns when the disk is seen to be connected the last time
    func (client *storageRESTClient) LastConn() time.Time {
    	return client.restClient.LastConn()
    }
    
    func (client *storageRESTClient) IsLocal() bool {
    	return false
    }
    
    func (client *storageRESTClient) Hostname() string {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    }
    
    // Stats returns the current connection stats.
    func (c *Connection) Stats() madmin.RPCMetrics {
    	conn := 0
    	if c.State() == StateConnected {
    		conn++
    	}
    	var lastConn time.Time
    	if t := c.lastConnect.Load(); t != nil {
    		lastConn = *t
    	}
    	pingMS := float64(c.lastPingDur.Load()) / float64(time.Millisecond)
    	m := madmin.RPCMetrics{
    		CollectedAt:      time.Now(),
    		Connected:        conn,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 46.9K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    		if cdisk != nil && cdisk.IsOnline() {
    			if s.lastConnectDisksOpTime.IsZero() {
    				continue
    			}
    
    			// An online-disk means its a valid disk but it may be a re-connected disk
    			// we verify that here based on LastConn(), however we make sure to avoid
    			// putting it back into the s.erasureDisks by re-placing the disk again.
    			_, setIndex, _ := cdisk.GetDiskLoc()
    			if setIndex != -1 {
    				continue
    			}
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  5. cmd/xl-storage.go

    	return s.endpoint
    }
    
    func (s *xlStorage) Close() error {
    	s.immediatePurgeCancel()
    	return nil
    }
    
    func (s *xlStorage) IsOnline() bool {
    	return true
    }
    
    func (s *xlStorage) LastConn() time.Time {
    	return time.Time{}
    }
    
    func (s *xlStorage) IsLocal() bool {
    	return true
    }
    
    // Retrieve location indexes.
    func (s *xlStorage) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 91.7K bytes
    - Viewed (0)
Back to top