Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for LastConn (0.12 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  2. cmd/naughty-disk_test.go

    }
    
    func (d *naughtyDisk) IsOnline() bool {
    	if err := d.calcError(); err != nil {
    		return err == errDiskNotFound
    	}
    	return d.disk.IsOnline()
    }
    
    func (d *naughtyDisk) LastConn() time.Time {
    	return d.disk.LastConn()
    }
    
    func (d *naughtyDisk) IsLocal() bool {
    	return d.disk.IsLocal()
    }
    
    func (d *naughtyDisk) Endpoint() Endpoint {
    	return d.disk.Endpoint()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. cmd/storage-interface.go

    	// of this function is to know if the "drive" has "format.json" or not
    	// if it has a "format.json" then is it correct "format.json" or not.
    	IsOnline() bool
    
    	// Returns the last time this disk (re)-connected
    	LastConn() time.Time
    
    	// Indicates if disk is local or not.
    	IsLocal() bool
    
    	// Returns hostname if disk is remote.
    	Hostname() string
    
    	// Returns the entire endpoint.
    	Endpoint() Endpoint
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    	storedDiskID, err := p.storage.GetDiskID()
    	if err != nil {
    		return false
    	}
    	return storedDiskID == *p.diskID.Load()
    }
    
    func (p *xlStorageDiskIDCheck) LastConn() time.Time {
    	return p.storage.LastConn()
    }
    
    func (p *xlStorageDiskIDCheck) IsLocal() bool {
    	return p.storage.IsLocal()
    }
    
    func (p *xlStorageDiskIDCheck) Endpoint() Endpoint {
    	return p.storage.Endpoint()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top