File tree Expand file tree Collapse file tree 1 file changed +5
-6
lines changed Expand file tree Collapse file tree 1 file changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -247,6 +247,11 @@ void SendRpcResponse(int64_t correlation_id,
247247 // Send rpc response over stream even if server side failed to create
248248 // stream for some reason.
249249 if (cntl->has_remote_stream ()){
250+ if (stream_ptr) {
251+ // Now it's ok the mark this server-side stream as connectted as all the
252+ // written user data would follower the RPC response.
253+ ((Stream*)stream_ptr->conn ())->SetConnected ();
254+ }
250255 // Send the response over stream to notify that this stream connection
251256 // is successfully built.
252257 // Response_stream can be INVALID_STREAM_ID when error occurs.
@@ -262,12 +267,6 @@ void SendRpcResponse(int64_t correlation_id,
262267 }
263268 return ;
264269 }
265-
266- if (stream_ptr) {
267- // Now it's ok the mark this server-side stream as connected as all the
268- // written user data would follower the RPC response.
269- ((Stream*)stream_ptr->conn ())->SetConnected ();
270- }
271270 } else {
272271 // Have the risk of unlimited pending responses, in which case, tell
273272 // users to set max_concurrency.
You can’t perform that action at this time.
0 commit comments