- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for getBucket (0.2 sec)
-
cmd/global-heal.go
var forwardTo string // If we resume to the same bucket, forward to last known item. b := tracker.getBucket() if b == bucket { forwardTo = tracker.getObject() } if b != "" { // Reset to where last bucket ended if resuming. tracker.resume() } tracker.setObject("") tracker.setBucket(bucket) // Heal current bucket again in case if it is failed // in the beginning of erasure set healing
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
func (h *healingTracker) getLastUpdate() time.Time { h.mu.RLock() defer h.mu.RUnlock() return h.LastUpdate } func (h *healingTracker) getBucket() string { h.mu.RLock() defer h.mu.RUnlock() return h.Bucket } func (h *healingTracker) setBucket(bucket string) { h.mu.Lock() defer h.mu.Unlock() h.Bucket = bucket } func (h *healingTracker) getObject() string { h.mu.RLock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/metacache-server-pool.go
if o.ID != "" && !o.Transient { // Create or ping with handout... rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix)) var c *metacache if rpc == nil { resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(*o) c = &resp } else { rctx, cancel := context.WithTimeout(ctx, 5*time.Second) c, err = rpc.GetMetacacheListing(rctx, *o) cancel() } if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/peer-rest-client.go
} // GetMetacacheListing - get a new or existing metacache. func (client *peerRESTClient) GetMetacacheListing(ctx context.Context, o listPathOptions) (*metacache, error) { if client == nil { resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(o) return &resp, nil } return getMetacacheListingRPC.Call(ctx, client.gridConn(), &o) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 26.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/SearchLogService.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 28.4K bytes - Viewed (0) -
src/test/resources/plugin/repo2/index.html
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Tue Aug 13 07:34:14 UTC 2019 - 10.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java
searchResponse.ifPresent(response -> { final Terms terms = response.getAggregations().get(fessConfig.getIndexFieldSegment()); for (final Bucket bucket : terms.getBuckets()) { final Map<String, String> map = new HashMap<>(2); map.put(fessConfig.getIndexFieldSegment(), bucket.getKey().toString());
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 10.6K bytes - Viewed (0) -
src/test/java/jcifs/tests/PACTest.java
KerberosToken tok = new KerberosToken(krbToken, keys); KerberosEncData ed = tok.getTicket().getEncData(); Assert.assertEquals(1, ed.getUserAuthorizations().size()); KerberosPacAuthData pacData = (KerberosPacAuthData) ed.getUserAuthorizations().get(0);
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Oct 01 12:01:17 UTC 2023 - 22.3K bytes - Viewed (0)