grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix unsynchronized access in InProcessTransport

This commit is contained in:
Carl Mastrangelo 2016-01-12 12:24:40 -08:00
parent 9cb79292aa
commit 5205d9cc43
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
core/src/main/java/io/grpc/inprocess/InProcessTransport.java
View File

@ -120,10 +120,11 @@ class InProcessTransport implements ServerTransport, ClientTransport {
public synchronized ClientStream newStream( public synchronized ClientStream newStream(
final MethodDescriptor<?, ?> method, final Metadata headers) { final MethodDescriptor<?, ?> method, final Metadata headers) {
if (shutdownStatus != null) { if (shutdownStatus != null) {
final Status capturedStatus = shutdownStatus;
return new NoopClientStream() { return new NoopClientStream() {
@Override @Override
public void start(ClientStreamListener listener) { public void start(ClientStreamListener listener) {
listener.closed(shutdownStatus, new Metadata()); listener.closed(capturedStatus, new Metadata());
} }
}; };
} }