github
/
consul
mirror of https://github.com/hashicorp/consul
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

agent/cache: change uint8 to uint

pull/4275/head
Mitchell Hashimoto 2018-05-09 11:54:15 -07:00
parent fc5508f8a3
commit 4f3b5647e5
No known key found for this signature in database
GPG Key ID: 744E147AA52F5B0A
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
agent/cache/cache.go vendored
View File

@ -287,7 +287,7 @@ func (c *Cache) entryKey(r *RequestInfo) string {
// If allowNew is true then the fetch should create the cache entry // If allowNew is true then the fetch should create the cache entry
// if it doesn't exist. If this is false, then fetch will do nothing // if it doesn't exist. If this is false, then fetch will do nothing
// if the entry doesn't exist. This latter case is to support refreshing. // if the entry doesn't exist. This latter case is to support refreshing.
func (c *Cache) fetch(t, key string, r Request, allowNew bool, attempt uint8) (<-chan struct{}, error) { func (c *Cache) fetch(t, key string, r Request, allowNew bool, attempt uint) (<-chan struct{}, error) {
// Get the type that we're fetching // Get the type that we're fetching
c.typesLock.RLock() c.typesLock.RLock()
tEntry, ok := c.types[t] tEntry, ok := c.types[t]
@ -432,7 +432,7 @@ func (c *Cache) fetchDirect(t string, r Request) (interface{}, error) {
// refresh triggers a fetch for a specific Request according to the // refresh triggers a fetch for a specific Request according to the
// registration options. // registration options.
func (c *Cache) refresh(opts *RegisterOptions, attempt uint8, t string, key string, r Request) { func (c *Cache) refresh(opts *RegisterOptions, attempt uint, t string, key string, r Request) {
// Sanity-check, we should not schedule anything that has refresh disabled // Sanity-check, we should not schedule anything that has refresh disabled
if !opts.Refresh { if !opts.Refresh {
return return