fix(storage): Handle redirect on takeover. (#13354)

cjc25 · web-flow · commit b0f136268be1 · 2025-11-13T22:33:35.000-05:00
The initial takeover response wasn't being checked for a redirect. PR #13239 addressed successful responses. This addresses error responses. See #12785, b/459905219
diff --git a/storage/grpc_writer.go b/storage/grpc_writer.go
@@ -1229,7 +1229,8 @@ func (s *gRPCAppendTakeoverBidiWriteBufferSender) connect(ctx context.Context, c
 
 		resp, err := stream.Recv()
 		if err != nil {
-			s.streamErr = err
+			// A Recv() error may be a redirect.
+			s.streamErr = s.maybeHandleRedirectionError(err)
 			close(cs.completions)
 			return
 		}

Original file line number	Diff line number	Diff line change
`@@ -1229,7 +1229,8 @@ func (s *gRPCAppendTakeoverBidiWriteBufferSender) connect(ctx context.Context, c`
`1229`	`1229`
`1230`	`1230`	`resp, err := stream.Recv()`
`1231`	`1231`	`if err != nil {`
`1232`		`- s.streamErr = err`
	`1232`	`+ // A Recv() error may be a redirect.`
	`1233`	`+ s.streamErr = s.maybeHandleRedirectionError(err)`
`1233`	`1234`	`close(cs.completions)`
`1234`	`1235`	`return`
`1235`	`1236`	`}`