mirror of https://github.com/grpc/grpc-go.git
cd89eaf40e
Before this fix, stream is removed from activeStreams in finishStream, which happens when the service handler returns status, without waiting for the status to be sent by loopyWriter. If GracefulStop() is called in between, it will close the connection (because activeStreams is empty), which causes the RPC to fail with "transport is closing". This change moves the activeStreams cleanup into loopyWriter, after sending status on wire. |
||
|---|---|---|
| .. | ||
| backoff | ||
| balancerload | ||
| binarylog | ||
| channelz | ||
| envconfig | ||
| grpcrand | ||
| grpcsync | ||
| grpctest | ||
| leakcheck | ||
| syscall | ||
| testutils | ||
| transport | ||
| internal.go | ||