- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for updaterotate (0.53 sec)
-
internal/grid/connection.go
} err = conn.SetWriteDeadline(time.Now().Add(connWriteTimeout)) if err != nil { return err } return wsutil.WriteMessage(conn, c.side, ws.OpBinary, dst) } func (c *Connection) connect() { c.updateState(StateConnecting) rng := rand.New(rand.NewSource(time.Now().UnixNano())) // Runs until the server is shut down. for { if c.State() == StateShutdown { return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
cmd/site-replication-utils.go
wg.Wait() sm.Unlock() } sTimer.Reset(siteResyncSaveInterval) case <-ctx.Done(): return } } } // update overall site resync state func (sm *siteResyncMetrics) updateState(s SiteResyncStatus) error { if !globalSiteReplicationSys.isEnabled() { return nil } sm.Lock() defer sm.Unlock() switch s.Status { case ResyncStarted:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.9K bytes - Viewed (1) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
// Actually fetch origState, err = getCurrentState() if err != nil { return err } origStateIsCurrent = true // Retry continue } ret, ttl, err := s.updateState(origState, tryUpdate) if err != nil { // If our data is already up to date, return the error if origStateIsCurrent { return err } // It's possible we were working with stale data
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
// event through a channel. type testClientConn struct { resolver.ClientConn stateCh chan resolver.State errorCh chan error } func (t *testClientConn) UpdateState(s resolver.State) error { t.stateCh <- s return nil } func (t *testClientConn) ReportError(err error) { t.errorCh <- err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
cmd/site-replication.go
defer func() { if err != nil { rs.Status = ResyncFailed saveSiteResyncMetadata(ctx, rs, objAPI) globalSiteResyncMetrics.updateState(rs) } }() if err := globalSiteResyncMetrics.updateState(rs); err != nil { return res, err } for _, bi := range buckets { bucket := bi.Name
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0)