Skip to content

Commit

Permalink
Monitor test hangs during interrupt handling
Browse files Browse the repository at this point in the history
  • Loading branch information
xueqzhan committed Feb 7, 2024
1 parent f7e4413 commit 729aab4
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/monitortestframework/impl.go
Expand Up @@ -79,7 +79,7 @@ func (r *monitorTestRegistry) ListMonitorTests() sets.String {

func (r *monitorTestRegistry) StartCollection(ctx context.Context, adminRESTConfig *rest.Config, recorder monitorapi.RecorderWriter) ([]*junitapi.JUnitTestCase, error) {
wg := sync.WaitGroup{}
junitCh := make(chan *junitapi.JUnitTestCase, len(r.monitorTests))
junitCh := make(chan *junitapi.JUnitTestCase, 2*len(r.monitorTests))
errCh := make(chan error, len(r.monitorTests))

for i := range r.monitorTests {
Expand Down Expand Up @@ -148,7 +148,7 @@ func (r *monitorTestRegistry) StartCollection(ctx context.Context, adminRESTConf
func (r *monitorTestRegistry) CollectData(ctx context.Context, storageDir string, beginning, end time.Time) (monitorapi.Intervals, []*junitapi.JUnitTestCase, error) {
wg := sync.WaitGroup{}
intervalsCh := make(chan monitorapi.Intervals, len(r.monitorTests))
junitCh := make(chan []*junitapi.JUnitTestCase, 2*len(r.monitorTests))
junitCh := make(chan []*junitapi.JUnitTestCase, 3*len(r.monitorTests))
errCh := make(chan error, len(r.monitorTests))

for i := range r.monitorTests {
Expand Down

0 comments on commit 729aab4

Please sign in to comment.