Lines Matching refs:callCtx
43 callCtx := perCallContext(parentCtx, callOpts, attempt)
44 lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
96 callCtx := perCallContext(parentCtx, callOpts, 0)
99 newStreamer, lastErr = streamer(callCtx, desc, cc, method, grpcOpts...)
191 callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
192 newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
240 callCtx context.Context,
245 newStream, err := s.streamerCall(callCtx)
247 logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
252 logTrace(callCtx, "grpc_retry failed resending message: %v", err)
257 logTrace(callCtx, "grpc_retry failed CloseSend on new stream %v", err)