aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorzpencer <spencerfang@google.com>2018-02-22 10:08:12 -0800
committerGitHub <noreply@github.com>2018-02-22 10:08:12 -0800
commit887217e57b5860bd9a062b4e0bf075b9801b8b4e (patch)
treebfd29b8b7c027e9a0bb7e49a4f29413092b3a7b8
parent46c1133a1ee49c14c7d0bc715cab9d1cf57db69c (diff)
downloadgrpc-grpc-java-887217e57b5860bd9a062b4e0bf075b9801b8b4e.tar.gz
core,services: fix binarylog unit tests (#4109)
- The unsafe operation was reverted in code, so the test should not use it either - The variable naming is tripping internal linters
-rw-r--r--core/src/test/java/io/grpc/internal/BinaryLogProviderTest.java32
-rw-r--r--services/src/test/java/io/grpc/services/BinaryLogTest.java3
2 files changed, 17 insertions, 18 deletions
diff --git a/core/src/test/java/io/grpc/internal/BinaryLogProviderTest.java b/core/src/test/java/io/grpc/internal/BinaryLogProviderTest.java
index 87b0b6f24..3b753330f 100644
--- a/core/src/test/java/io/grpc/internal/BinaryLogProviderTest.java
+++ b/core/src/test/java/io/grpc/internal/BinaryLogProviderTest.java
@@ -183,37 +183,37 @@ public class BinaryLogProviderTest {
},
new Metadata());
- String actualRequest = "hello world";
+ String expectedRequest = "hello world";
assertThat(binlogReq).isEmpty();
assertThat(serializedReq).isEmpty();
assertEquals(0, reqMarshaller.streamInvocations);
- clientCall.sendMessage(actualRequest);
+ clientCall.sendMessage(expectedRequest);
// it is unacceptably expensive for the binlog to double parse every logged message
assertEquals(1, reqMarshaller.streamInvocations);
assertEquals(0, reqMarshaller.parseInvocations);
assertThat(binlogReq).hasSize(1);
assertThat(serializedReq).hasSize(1);
assertEquals(
- actualRequest,
+ expectedRequest,
StringMarshaller.INSTANCE.parse(new ByteArrayInputStream(binlogReq.get(0))));
assertEquals(
- actualRequest,
+ expectedRequest,
StringMarshaller.INSTANCE.parse(serializedReq.get(0)));
- int actualResponse = 12345;
+ int expectedResponse = 12345;
assertThat(binlogResp).isEmpty();
assertThat(observedResponse).isEmpty();
assertEquals(0, respMarshaller.parseInvocations);
- onClientMessageHelper(listener.get(), IntegerMarshaller.INSTANCE.stream(actualResponse));
+ onClientMessageHelper(listener.get(), IntegerMarshaller.INSTANCE.stream(expectedResponse));
// it is unacceptably expensive for the binlog to double parse every logged message
assertEquals(1, respMarshaller.parseInvocations);
assertEquals(0, respMarshaller.streamInvocations);
assertThat(binlogResp).hasSize(1);
assertThat(observedResponse).hasSize(1);
assertEquals(
- actualResponse,
+ expectedResponse,
(int) IntegerMarshaller.INSTANCE.parse(new ByteArrayInputStream(binlogResp.get(0))));
- assertEquals(actualResponse, (int) observedResponse.get(0));
+ assertEquals(expectedResponse, (int) observedResponse.get(0));
}
@SuppressWarnings({"rawtypes", "unchecked"})
@@ -274,35 +274,35 @@ public class BinaryLogProviderTest {
List<Object> serializedResp = new ArrayList<Object>();
ServerCall.Listener<?> wListener = startServerCallHelper(wDef, serializedResp);
- String actualRequest = "hello world";
+ String expectedRequest = "hello world";
assertThat(binlogReq).isEmpty();
assertThat(observedRequest).isEmpty();
assertEquals(0, reqMarshaller.parseInvocations);
- onServerMessageHelper(wListener, StringMarshaller.INSTANCE.stream(actualRequest));
+ onServerMessageHelper(wListener, StringMarshaller.INSTANCE.stream(expectedRequest));
// it is unacceptably expensive for the binlog to double parse every logged message
assertEquals(1, reqMarshaller.parseInvocations);
assertEquals(0, reqMarshaller.streamInvocations);
assertThat(binlogReq).hasSize(1);
assertThat(observedRequest).hasSize(1);
assertEquals(
- actualRequest,
+ expectedRequest,
StringMarshaller.INSTANCE.parse(new ByteArrayInputStream(binlogReq.get(0))));
- assertEquals(actualRequest, observedRequest.get(0));
+ assertEquals(expectedRequest, observedRequest.get(0));
- int actualResponse = 12345;
+ int expectedResponse = 12345;
assertThat(binlogResp).isEmpty();
assertThat(serializedResp).isEmpty();
assertEquals(0, respMarshaller.streamInvocations);
- serverCall.get().sendMessage(actualResponse);
+ serverCall.get().sendMessage(expectedResponse);
// it is unacceptably expensive for the binlog to double parse every logged message
assertEquals(0, respMarshaller.parseInvocations);
assertEquals(1, respMarshaller.streamInvocations);
assertThat(binlogResp).hasSize(1);
assertThat(serializedResp).hasSize(1);
assertEquals(
- actualResponse,
+ expectedResponse,
(int) IntegerMarshaller.INSTANCE.parse(new ByteArrayInputStream(binlogResp.get(0))));
- assertEquals(actualResponse, (int) method.parseResponse((InputStream) serializedResp.get(0)));
+ assertEquals(expectedResponse, (int) method.parseResponse((InputStream) serializedResp.get(0)));
}
@SuppressWarnings({"rawtypes", "unchecked"})
diff --git a/services/src/test/java/io/grpc/services/BinaryLogTest.java b/services/src/test/java/io/grpc/services/BinaryLogTest.java
index 287a94f74..0f5f6f74e 100644
--- a/services/src/test/java/io/grpc/services/BinaryLogTest.java
+++ b/services/src/test/java/io/grpc/services/BinaryLogTest.java
@@ -26,7 +26,6 @@ import static org.mockito.Mockito.verifyNoMoreInteractions;
import com.google.common.primitives.Bytes;
import com.google.protobuf.ByteString;
-import com.google.protobuf.UnsafeByteOperations;
import io.grpc.Metadata;
import io.grpc.binarylog.GrpcLogEntry;
import io.grpc.binarylog.Message;
@@ -487,7 +486,7 @@ public final class BinaryLogTest {
assertEquals(
Message
.newBuilder()
- .setData(UnsafeByteOperations.unsafeWrap(truncatedMessage.getBytes(US_ASCII)))
+ .setData(ByteString.copyFrom(truncatedMessage.getBytes(US_ASCII)))
.setFlags(0)
.setLength(bytes.remaining())
.build(),