- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for lastPong (0.22 sec)
-
internal/grid/muxclient.go
xioutil "github.com/minio/minio/internal/ioutil" "github.com/zeebo/xxh3" ) // muxClient is a stateful connection to a remote. type muxClient struct { MuxID uint64 SendSeq, RecvSeq uint32 LastPong int64 BaseFlags Flags ctx context.Context cancelFn context.CancelCauseFunc parent *Connection respWait chan<- Response respMu sync.Mutex
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
internal/grid/connection.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
internal/grid/muxserver.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0) -
tools/docker-builder/builder/crane.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 26 01:07:39 UTC 2023 - 9K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 9.4K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 5K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.4K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller.go
controllers.WithMaxAttempts(math.MaxInt), // Retry with backoff. Failures could be from conflicts of other instances (quick retry helps), or // longer lasting concerns which will eventually be retried on 1min interval. // Unlike the mutating webhook controller, we do not use NewItemFastSlowRateLimiter. This is because
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0) -
ci/official/containers/linux_arm64/builder.devtoolset/stringop_trunc.patch
+#define UT_LINESIZE 32 +#define UT_NAMESIZE 32 +#define UT_HOSTSIZE 256 +/* The structure describing an entry in the database of + previous logins. */ struct lastlog { time_t ll_time; @@ -36,12 +38,16 @@ struct lastlog char ll_host[UT_HOSTSIZE]; }; +/* The structure describing an entry in the user accounting database. */ struct utmp { - char ut_line[UT_LINESIZE];
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Sep 18 14:52:45 UTC 2023 - 42.9K bytes - Viewed (0)