Undo

Virtualbags · Mar 21, 2024 · af16c2a · af16c2a
1 parent ea4445d
commit af16c2a
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/cmd/netsync/main.go b/cmd/netsync/main.go
@@ -447,6 +447,9 @@ func (s *NetsyncState) worker(id int) error {
 				return nil
 			}
 
+			// Wait for rate limiter
+			s.limiter.Wait(ctx)
+
 			// Clone repo
 			cloneState, err := s.cloneRepo(ctx, repo)
 			if err != nil {
@@ -495,8 +498,6 @@ func (s *NetsyncState) cloneRepo(ctx context.Context, did string) (cloneState st
 		req.Header.Set(s.magicHeaderKey, s.magicHeaderVal)
 	}
 
-	s.limiter.Wait(ctx)
-
 	resp, err := s.client.Do(req)
 	if err != nil {
 		cloneState = "failed (client.do)"