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

core: disable MigratingThreadDeframer (#7177)

This commit is contained in:
Jihun Cho 2020-07-01 15:39:13 -07:00 committed by GitHub
parent b8822e56af
commit c6bd97245c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
core/src/main/java/io/grpc/internal/AbstractStream.java
View File

@ -157,7 +157,8 @@ public abstract class AbstractStream implements Stream {
maxMessageSize, maxMessageSize,
statsTraceCtx, statsTraceCtx,
transportTracer); transportTracer);
deframer = new MigratingThreadDeframer(this, this, rawDeframer); // TODO(#7168): use MigratingThreadDeframer when enabling retry doesn't break.
deframer = rawDeframer;
} }
final void optimizeForDirectExecutor() { final void optimizeForDirectExecutor() {

4
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java
View File

@ -101,10 +101,6 @@ class OkHttpClientStream extends AbstractClientStream {
transport, transport,
initialWindowSize, initialWindowSize,
method.getFullMethodName()); method.getFullMethodName());
// TODO(#7168): fix a potential data race using MigratingThreadDeframer in OkHttp.
// disabling MigratingThreadDeframer in OkHttp due to the race
optimizeForDirectExecutor();
} }
@Override @Override