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

core,services: move BinaryLog class to grpc-services (#3867)

This commit is contained in:
zpencer 2017-12-14 14:20:30 -08:00 committed by GitHub
parent f1151f91b9
commit 02f56b0218
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/java/io/grpc/internal/ClientCallImpl.java
View File

@ -83,7 +83,6 @@ final class ClientCallImpl<ReqT, RespT> extends ClientCall<ReqT, RespT> {
private boolean fullStreamDecompression; private boolean fullStreamDecompression;
private DecompressorRegistry decompressorRegistry = DecompressorRegistry.getDefaultInstance(); private DecompressorRegistry decompressorRegistry = DecompressorRegistry.getDefaultInstance();
private CompressorRegistry compressorRegistry = CompressorRegistry.getDefaultInstance(); private CompressorRegistry compressorRegistry = CompressorRegistry.getDefaultInstance();
private final BinaryLog binlog;
ClientCallImpl( ClientCallImpl(
MethodDescriptor<ReqT, RespT> method, Executor executor, CallOptions callOptions, 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.callOptions = callOptions;
this.clientTransportProvider = clientTransportProvider; this.clientTransportProvider = clientTransportProvider;
this.deadlineCancellationExecutor = deadlineCancellationExecutor; this.deadlineCancellationExecutor = deadlineCancellationExecutor;
this.binlog = BinaryLog.getLog(method.getFullMethodName());
} }
private final class ContextCancellationListener implements CancellationListener { private final class ContextCancellationListener implements CancellationListener {

2
core/src/main/java/io/grpc/internal/ServerCallImpl.java
View File

@ -54,7 +54,6 @@ final class ServerCallImpl<ReqT, RespT> extends ServerCall<ReqT, RespT> {
private final byte[] messageAcceptEncoding; private final byte[] messageAcceptEncoding;
private final DecompressorRegistry decompressorRegistry; private final DecompressorRegistry decompressorRegistry;
private final CompressorRegistry compressorRegistry; private final CompressorRegistry compressorRegistry;
private final BinaryLog binlog;
// state // state
private volatile boolean cancelled; 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.messageAcceptEncoding = inboundHeaders.get(MESSAGE_ACCEPT_ENCODING_KEY);
this.decompressorRegistry = decompressorRegistry; this.decompressorRegistry = decompressorRegistry;
this.compressorRegistry = compressorRegistry; this.compressorRegistry = compressorRegistry;
binlog = BinaryLog.getLog(method.getFullMethodName());
} }
@Override @Override

2
core/src/main/java/io/grpc/internal/BinaryLog.java → services/src/main/java/io/grpc/services/BinaryLog.java
View File

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package io.grpc.internal; package io.grpc.services;
import com.google.common.annotations.VisibleForTesting; import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Objects; import com.google.common.base.Objects;

4
core/src/test/java/io/grpc/internal/BinaryLogTest.java → services/src/test/java/io/grpc/services/BinaryLogTest.java
View File

@ -14,12 +14,12 @@
* limitations under the License. * limitations under the License.
*/ */
package io.grpc.internal; package io.grpc.services;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull; 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.Test;
import org.junit.runner.RunWith; import org.junit.runner.RunWith;
import org.junit.runners.JUnit4; import org.junit.runners.JUnit4;