Increase stat channel buffer sizes and bump test timeout value

jhiemstrawisc · Oct 22, 2024 · 707d5d0 · 707d5d0
1 parent b761a7e
commit 707d5d0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/director/stat.go b/director/stat.go
@@ -328,9 +328,9 @@ func (stat *ObjectStat) queryServersForObject(ctx context.Context, objectName st
 	timeout := param.Director_StatTimeout.GetDuration()
 	// Note there is a small buffer in each channel; in the case of a cache hit, we write
 	// to the channel from within this goroutine.
-	positiveReqChan := make(chan *objectMetadata, 1)
-	negativeReqChan := make(chan error, 1)
-	deniedReqChan := make(chan *headReqForbiddenErr, 1) // Requests with 403 response
+	positiveReqChan := make(chan *objectMetadata, 5)
+	negativeReqChan := make(chan error, 5)
+	deniedReqChan := make(chan *headReqForbiddenErr, 5) // Requests with 403 response
 	// Cancel the rest of the requests when requests received >= max required
 	maxCancelCtx, maxCancel := context.WithCancel(ctx)
 	numTotalReq := 0

diff --git a/local_cache/cache_test.go b/local_cache/cache_test.go
@@ -417,7 +417,7 @@ func TestOriginUnresponsive(t *testing.T) {
 	tmpDir := t.TempDir()
 
 	server_utils.ResetTestState()
-	viper.Set("Transport.ResponseHeaderTimeout", "3s")
+	viper.Set("Transport.ResponseHeaderTimeout", "5s")
 	viper.Set("Logging.Level", "debug")
 	ft := fed_test_utils.NewFedTest(t, pubOriginCfg)