Skip to content

Commit

Permalink
consider failed stream as skip
Browse files Browse the repository at this point in the history
  • Loading branch information
sonroyaalmerol committed Dec 20, 2024
1 parent d08d5ae commit 2cbafcc
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions proxy/load_balancer.go
Original file line number Diff line number Diff line change
Expand Up @@ -80,10 +80,9 @@ func (instance *StreamInstance) LoadBalancer(ctx context.Context, session *store
continue
}

allSkipped = false // At least one URL is not skipped

resp, err := utils.CustomHttpRequest(method, url)
if err == nil {
allSkipped = false // At least one URL is not skipped

Check failure on line 85 in proxy/load_balancer.go

View workflow job for this annotation

GitHub Actions / lint

ineffectual assignment to allSkipped (ineffassign)

Check failure on line 85 in proxy/load_balancer.go

View workflow job for this annotation

GitHub Actions / lint

ineffectual assignment to allSkipped (ineffassign)
if debug {
utils.SafeLogf("[DEBUG] Successfully fetched stream from %s\n", url)
}
Expand All @@ -93,6 +92,7 @@ func (instance *StreamInstance) LoadBalancer(ctx context.Context, session *store
if debug {
utils.SafeLogf("[DEBUG] Error fetching stream from %s: %s\n", url, err.Error())
}
session.SetTestedIndexes(append(session.TestedIndexes, index))
}

if allSkipped {
Expand Down

0 comments on commit 2cbafcc

Please sign in to comment.