Say a registry came back only when the call worked, and retry from toRetry's set (issue 457 review)

The streaming blob PUT is left unwaited, with why, since its body cannot be
read twice and the POST before it already waited.

internal/builder/mirror.go

@@ -429,6 +429,11 @@ func (r Registry) copyBlob(ctx context.Context, src *source, where upstream, dig
 	if response.ContentLength > 0 {
 		put.ContentLength = response.ContentLength
 	}
+	// **Not waited for if refused** (novox/hq issue 457): the body streams from upstream and cannot be
+	// read twice, so a registry held still between the POST above and this PUT fails the copy with
+	// "its body cannot be read twice" rather than waiting. Accepted: the POST a moment before already
+	// waited the registry out, so the window is the length of one upstream fetch, and the build fails
+	// loudly, to be asked again, rather than buffering every base blob in memory.
 	done, err := r.client().Do(put)
 	if err != nil {
 		return fmt.Errorf("cannot upload blob %s: %w", digest, err)

internal/builder/registry_wait.go

@@ -74,8 +74,14 @@ func waitForRegistry(ctx context.Context, address, what string, try func() error
 		}
 		pause = min(pause*2, registryMostPause)
 		if err = try(); !refused(err) {
-			tell("registry", "%s: the registry at %s answers again after %s; the build goes on", what, address,
-				time.Since(started).Round(time.Millisecond))
+			// Said as it is: the registry answering is only the build going on when the call worked.
+			if err == nil {
+				tell("registry", "%s: the registry at %s answers again after %s; the build goes on", what, address,
+					time.Since(started).Round(time.Millisecond))
+			} else {
+				tell("registry", "%s: the registry at %s no longer refuses after %s, and answered with: %v", what,
+					address, time.Since(started).Round(time.Millisecond), err)
+			}
 			return err
 		}
 	}