Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for UpdateMetacacheListing (0.13 sec)

  1. cmd/metacache-set.go

    		o.debugln("First ", tmp.First, "<", search, " search", i)
    		i++
    	}
    }
    
    // updateMetacacheListing will update the metacache listing.
    func (o *listPathOptions) updateMetacacheListing(m metacache, rpc *peerRESTClient) (metacache, error) {
    	if rpc == nil {
    		return localMetacacheMgr.updateCacheEntry(m)
    	}
    	return rpc.UpdateMetacacheListing(context.Background(), m)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  2. cmd/metacache.go

    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			// Request is done, stop updating.
    			return
    		case <-t.C:
    			m.lastHandout = time.Now()
    
    			if m2, err := rpc.UpdateMetacacheListing(ctx, m); err == nil {
    				if m2.status != scanStateStarted {
    					if serverDebugLog {
    						console.Debugln("returning", m.id, "due to scan state", m2.status, time.Now().Format(time.RFC3339))
    					}
    					return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/peer-rest-client.go

    		return &resp, nil
    	}
    	return getMetacacheListingRPC.Call(ctx, client.gridConn(), &o)
    }
    
    // UpdateMetacacheListing - update an existing metacache it will unconditionally be updated to the new state.
    func (client *peerRESTClient) UpdateMetacacheListing(ctx context.Context, m metacache) (metacache, error) {
    	if client == nil {
    		return localMetacacheMgr.updateCacheEntry(m)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. cmd/metacache-server-pool.go

    				defer cancel()
    				c, err := rpc.GetMetacacheListing(ctx, *o)
    				if err == nil {
    					c.error = "no longer used"
    					c.status = scanStateError
    					rpc.UpdateMetacacheListing(ctx, *c)
    				}
    			}
    		}()
    		o.ID = ""
    	}
    
    	if contextCanceled(ctx) {
    		return entries, ctx.Err()
    	}
    	// Do listing in-place.
    	// Create output for our results.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top