- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 169 for _refresh (0.26 sec)
-
guava-tests/test/com/google/common/cache/CacheRefreshTest.java
assertEquals(Integer.valueOf(2), cache.getUnchecked(2)); assertEquals(expectedLoads, loader.getLoadCount()); assertEquals(expectedReloads, loader.getReloadCount()); // refresh 0 ticker.advance(1, MILLISECONDS); assertEquals(Integer.valueOf(1), cache.getUnchecked(0)); expectedReloads++; assertEquals(Integer.valueOf(1), cache.getUnchecked(1));
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 3.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
assertEquals(2, stats.missCount()); assertEquals(2, stats.loadSuccessCount()); assertEquals(0, stats.loadExceptionCount()); assertEquals(0, stats.hitCount()); key = new Object(); cache.refresh(key); checkNothingLogged(); stats = cache.stats(); assertEquals(2, stats.missCount()); assertEquals(3, stats.loadSuccessCount()); assertEquals(0, stats.loadExceptionCount());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 86.2K bytes - Viewed (0) -
docs_src/sql_databases/sql_app_py39/crud.py
db.add(db_user) db.commit() db.refresh(db_user) return db_user def get_items(db: Session, skip: int = 0, limit: int = 100): return db.query(models.Item).offset(skip).limit(limit).all() def create_user_item(db: Session, item: schemas.ItemCreate, user_id: int): db_item = models.Item(**item.dict(), owner_id=user_id) db.add(db_item) db.commit() db.refresh(db_item)
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Fri Jan 07 14:11:31 GMT 2022 - 1K 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 28 19:28:10 GMT 2024 - Last Modified: Fri Nov 24 17:07:14 GMT 2023 - 3.3K bytes - Viewed (0) -
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 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0) -
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 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheBuilderFactory.java
} if (expireAfterAccess != null) { builder.expireAfterAccess(expireAfterAccess.duration, expireAfterAccess.unit); } if (refresh != null) { builder.refreshAfterWrite(refresh.duration, refresh.unit); } if (keyStrength != null) { builder.setKeyStrength(keyStrength); } if (valueStrength != null) { builder.setValueStrength(valueStrength);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 8.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/LabelTypeService.java
op.setRefreshPolicy(Constants.TRUE); }); final LabelTypeHelper labelTypeHelper = ComponentUtil.getLabelTypeHelper(); if (labelTypeHelper != null) { labelTypeHelper.refresh(getLabelTypeList()); } } protected void setupListCondition(final LabelTypeCB cb, final LabelTypePager labelTypePager) { if (StringUtil.isNotBlank(labelTypePager.name)) {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.8K bytes - Viewed (0) -
guava/src/com/google/common/cache/ForwardingLoadingCache.java
return delegate().getAll(keys); } @Override public V apply(K key) { return delegate().apply(key); } @Override public void refresh(K key) { delegate().refresh(key); } /** * A simplified version of {@link ForwardingLoadingCache} where subclasses can pass in an already * constructed {@link LoadingCache} as the delegate. * * @since 10.0
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sat Aug 06 17:12:03 GMT 2022 - 2.9K bytes - Viewed (1) -
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 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1)