- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for refresh (0.25 sec)
-
internal/dsync/drwmutex.go
log("dsync: Unable to call Refresh failed with %s for %#v at %s\n", err, args, c) } else { ch <- refreshResult{refreshed: refreshed} log("dsync: Refresh returned false for %#v at %s\n", args, c) } }(index, c) } // Wait until we have either // // a) received all refresh responses // b) received too many refreshed for quorum to be still possible // c) timed out //
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
docs/sts/client_grants/__init__.py
""" if self.cid is not None: fetcher = self._create_credentials_fetcher() return RefreshableCredentials.create_from_metadata( metadata=fetcher(), refresh_using=fetcher, method=self.METHOD, ) else: return None def _create_credentials_fetcher(self): method = self.METHOD def fetch_credentials():
Python - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 4.6K bytes - Viewed (1) -
cmd/lock-rest-server.go
type lockRESTServer struct { ll *localLocker } // RefreshHandler - refresh the current lock func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { resp := lockRPCRefresh.NewResponse() refreshed, err := l.ll.Refresh(context.Background(), *args) if err != nil { return l.makeResp(resp, err) } if !refreshed { return l.makeResp(resp, errLockNotFound) } return l.makeResp(resp, err)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/tier-handlers.go
switch cfg.Name { case storageclass.STANDARD, storageclass.RRS: writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errTierReservedName), r.URL) return } // Refresh from the disk in case we had missed notifications about edits from peers. if err := globalTierConfigMgr.Reload(ctx, objAPI); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 15 19:52:44 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/warm-backend-azure.go
if err != nil { return nil, err } // Refresh obtains a fresh token err = spt.Refresh() if err != nil { return nil, err } tc := azblob.NewTokenCredential(spt.Token().AccessToken, func(tc azblob.TokenCredential) time.Duration { err := spt.Refresh() if err != nil { return 0 } // set the new token value
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1) -
internal/dsync/locker.go
// Canceling the context will abort the remote call. // In that case, the resource may or may not be unlocked. Unlock(ctx context.Context, args LockArgs) (bool, error) // Refresh the given lock to prevent it from becoming stale Refresh(ctx context.Context, args LockArgs) (bool, error) // Unlock (read/write) forcefully for given LockArgs. It should return // * a boolean to indicate success/failure of the operation
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0) -
cmd/lock-rest-client.go
// RUnlock calls read unlock REST API. func (c *lockRESTClient) RUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRUnlock, &args) } // Refresh calls Refresh REST API. func (c *lockRESTClient) Refresh(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRefresh, &args) } // Unlock calls write unlock RPC.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Nov 24 17:07:14 GMT 2023 - 3.3K bytes - Viewed (0) -
internal/kms/kes.go
if err != nil { logger.LogOnceIf(ctx, fmt.Errorf("%s, using default of 10s", err.Error()), "refresh-kms-master-key") cacheDuration = defaultCacheDuration } if cacheDuration < time.Second { logger.LogOnceIf(ctx, errors.New("cache duration is less than 1s, using default of 10s"), "refresh-kms-master-key") cacheDuration = defaultCacheDuration } timer := time.NewTimer(cacheDuration) defer timer.Stop()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/node/minio-node.json
Json - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Mar 28 15:14:26 GMT 2024 - 23.1K bytes - Viewed (0) -
internal/dsync/dsync_test.go
dm2 := NewDRWMutex(ds, "noot") dm1.Lock(id, source) dm2.Lock(id, source) dm1.Unlock(context.Background()) dm2.Unlock(context.Background()) } // Test refreshing lock - refresh should always return true func TestSuccessfulLockRefresh(t *testing.T) { if testing.Short() { t.Skip("skipping test in short mode.") } dm := NewDRWMutex(ds, "aap")
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0)