diff options
author | zpencer <spencerfang@google.com> | 2017-12-14 14:20:30 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-12-14 14:20:30 -0800 |
commit | 02f56b0218515f7c614098e889e24410d8387f7c (patch) | |
tree | 9cbb3a547fffa62bb625d671ec200a08fe622772 | |
parent | f1151f91b9cd901e44f5c6038cd4bf53c67c992e (diff) | |
download | grpc-grpc-java-02f56b0218515f7c614098e889e24410d8387f7c.tar.gz |
core,services: move BinaryLog class to grpc-services (#3867)
-rw-r--r-- | core/src/main/java/io/grpc/internal/ClientCallImpl.java | 2 | ||||
-rw-r--r-- | core/src/main/java/io/grpc/internal/ServerCallImpl.java | 2 | ||||
-rw-r--r-- | services/src/main/java/io/grpc/services/BinaryLog.java (renamed from core/src/main/java/io/grpc/internal/BinaryLog.java) | 2 | ||||
-rw-r--r-- | services/src/test/java/io/grpc/services/BinaryLogTest.java (renamed from core/src/test/java/io/grpc/internal/BinaryLogTest.java) | 4 |
4 files changed, 3 insertions, 7 deletions
diff --git a/core/src/main/java/io/grpc/internal/ClientCallImpl.java b/core/src/main/java/io/grpc/internal/ClientCallImpl.java index 9e22e6405..5c03f2a7a 100644 --- a/core/src/main/java/io/grpc/internal/ClientCallImpl.java +++ b/core/src/main/java/io/grpc/internal/ClientCallImpl.java @@ -83,7 +83,6 @@ final class ClientCallImpl<ReqT, RespT> extends ClientCall<ReqT, RespT> { private boolean fullStreamDecompression; private DecompressorRegistry decompressorRegistry = DecompressorRegistry.getDefaultInstance(); private CompressorRegistry compressorRegistry = CompressorRegistry.getDefaultInstance(); - private final BinaryLog binlog; ClientCallImpl( MethodDescriptor<ReqT, RespT> method, Executor executor, CallOptions callOptions, @@ -105,7 +104,6 @@ final class ClientCallImpl<ReqT, RespT> extends ClientCall<ReqT, RespT> { this.callOptions = callOptions; this.clientTransportProvider = clientTransportProvider; this.deadlineCancellationExecutor = deadlineCancellationExecutor; - this.binlog = BinaryLog.getLog(method.getFullMethodName()); } private final class ContextCancellationListener implements CancellationListener { diff --git a/core/src/main/java/io/grpc/internal/ServerCallImpl.java b/core/src/main/java/io/grpc/internal/ServerCallImpl.java index 8e75742eb..a0ffba891 100644 --- a/core/src/main/java/io/grpc/internal/ServerCallImpl.java +++ b/core/src/main/java/io/grpc/internal/ServerCallImpl.java @@ -54,7 +54,6 @@ final class ServerCallImpl<ReqT, RespT> extends ServerCall<ReqT, RespT> { private final byte[] messageAcceptEncoding; private final DecompressorRegistry decompressorRegistry; private final CompressorRegistry compressorRegistry; - private final BinaryLog binlog; // state private volatile boolean cancelled; @@ -72,7 +71,6 @@ final class ServerCallImpl<ReqT, RespT> extends ServerCall<ReqT, RespT> { this.messageAcceptEncoding = inboundHeaders.get(MESSAGE_ACCEPT_ENCODING_KEY); this.decompressorRegistry = decompressorRegistry; this.compressorRegistry = compressorRegistry; - binlog = BinaryLog.getLog(method.getFullMethodName()); } @Override diff --git a/core/src/main/java/io/grpc/internal/BinaryLog.java b/services/src/main/java/io/grpc/services/BinaryLog.java index 5f3db9508..ef1c61095 100644 --- a/core/src/main/java/io/grpc/internal/BinaryLog.java +++ b/services/src/main/java/io/grpc/services/BinaryLog.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package io.grpc.internal; +package io.grpc.services; import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Objects; diff --git a/core/src/test/java/io/grpc/internal/BinaryLogTest.java b/services/src/test/java/io/grpc/services/BinaryLogTest.java index 8b6cdbd02..6be9cf6b3 100644 --- a/core/src/test/java/io/grpc/internal/BinaryLogTest.java +++ b/services/src/test/java/io/grpc/services/BinaryLogTest.java @@ -14,12 +14,12 @@ * limitations under the License. */ -package io.grpc.internal; +package io.grpc.services; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertNull; -import io.grpc.internal.BinaryLog.FactoryImpl; +import io.grpc.services.BinaryLog.FactoryImpl; import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.JUnit4; |