aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorzpencer <spencerfang@google.com>2017-12-14 14:20:30 -0800
committerGitHub <noreply@github.com>2017-12-14 14:20:30 -0800
commit02f56b0218515f7c614098e889e24410d8387f7c (patch)
tree9cbb3a547fffa62bb625d671ec200a08fe622772
parentf1151f91b9cd901e44f5c6038cd4bf53c67c992e (diff)
downloadgrpc-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.java2
-rw-r--r--core/src/main/java/io/grpc/internal/ServerCallImpl.java2
-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;