Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for getBucket (0.33 sec)

  1. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 31 14:48:50 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  2. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 04 15:12:32 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  3. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 01:12:23 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  4. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  5. cmd/peer-rest-server.go

    	}
    
    	return
    }
    
    func (s *peerRESTServer) GetMetacacheListingHandler(opts *listPathOptions) (*metacache, *grid.RemoteErr) {
    	resp := localMetacacheMgr.getBucket(context.Background(), opts.Bucket).findCache(*opts)
    	return &resp, nil
    }
    
    func (s *peerRESTServer) UpdateMetacacheListingHandler(req *metacache) (*metacache, *grid.RemoteErr) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 52.1K bytes
    - Viewed (0)
  6. src/crypto/tls/handshake_client_test.go

    		}
    		return k
    	}
    
    	testResumeState("Handshake", false)
    	ticket := getTicket()
    	testResumeState("Resume", true)
    	if bytes.Equal(ticket, getTicket()) {
    		t.Fatal("ticket didn't change after resumption")
    	}
    
    	// An old session ticket is replaced with a ticket encrypted with a fresh key.
    	ticket = getTicket()
    	serverConfig.Time = func() time.Time { return time.Now().Add(24*time.Hour + time.Minute) }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 88.7K bytes
    - Viewed (0)
Back to top