aboutsummaryrefslogtreecommitdiff
path: root/android-interop-testing
diff options
context:
space:
mode:
authorCarl Mastrangelo <notcarl@google.com>2017-09-15 11:49:31 -0700
committerGitHub <noreply@github.com>2017-09-15 11:49:31 -0700
commit2924e30e45d308b2b432a22b793898e7434c8de2 (patch)
treeec67648dd4736e65a15ae4cefa966707b6787794 /android-interop-testing
parent8ee9fb51837a96b18664241a6875ff155843152b (diff)
downloadgrpc-grpc-java-2924e30e45d308b2b432a22b793898e7434c8de2.tar.gz
android-interop-testing: use Java Style enums
This makes it easier to convert over to Proto lite, which will be replacing nano in the near future. This CL is a port originally from @arielbackenroth
Diffstat (limited to 'android-interop-testing')
-rw-r--r--android-interop-testing/app/build.gradle1
-rw-r--r--android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/InteropTester.java42
2 files changed, 22 insertions, 21 deletions
diff --git a/android-interop-testing/app/build.gradle b/android-interop-testing/app/build.gradle
index 08dc50b8d..8555eb6b2 100644
--- a/android-interop-testing/app/build.gradle
+++ b/android-interop-testing/app/build.gradle
@@ -42,6 +42,7 @@ protobuf {
javanano {
// Options added to --javanano_out
option 'ignore_services=true'
+ option 'enum_style=java'
}
}
diff --git a/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/InteropTester.java b/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/InteropTester.java
index 6362671a6..62c0b91d9 100644
--- a/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/InteropTester.java
+++ b/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/InteropTester.java
@@ -216,7 +216,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
}
final Messages.SimpleRequest request = new Messages.SimpleRequest();
request.responseSize = 314159;
- request.responseType = Messages.COMPRESSABLE;
+ request.responseType = Messages.PayloadType.COMPRESSABLE;
request.payload = new Payload();
request.payload.body = new byte[271828];
@@ -229,7 +229,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
public void serverStreaming() throws Exception {
final Messages.StreamingOutputCallRequest request = new Messages.StreamingOutputCallRequest();
- request.responseType = Messages.COMPRESSABLE;
+ request.responseType = Messages.PayloadType.COMPRESSABLE;
request.responseParameters = new Messages.ResponseParameters[4];
for (int i = 0; i < 4; i++) {
request.responseParameters[i] = new Messages.ResponseParameters();
@@ -244,7 +244,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
for (int i = 0; i < 4; i++) {
goldenResponses[i] = new Messages.StreamingOutputCallResponse();
goldenResponses[i].payload = new Payload();
- goldenResponses[i].payload.type = Messages.COMPRESSABLE;
+ goldenResponses[i].payload.type = Messages.PayloadType.COMPRESSABLE;
}
goldenResponses[0].payload.body = new byte[31415];
goldenResponses[1].payload.body = new byte[9];
@@ -307,7 +307,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
for (int i = 0; i < 4; i++) {
goldenResponses[i] = new Messages.StreamingOutputCallResponse();
goldenResponses[i].payload = new Payload();
- goldenResponses[i].payload.type = Messages.COMPRESSABLE;
+ goldenResponses[i].payload.type = Messages.PayloadType.COMPRESSABLE;
}
goldenResponses[0].payload.body = new byte[31415];
goldenResponses[1].payload.body = new byte[9];
@@ -361,7 +361,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
request.payload.body = new byte[27182];
final StreamingOutputCallResponse goldenResponse = new StreamingOutputCallResponse();
goldenResponse.payload = new Payload();
- goldenResponse.payload.type = Messages.COMPRESSABLE;
+ goldenResponse.payload.type = Messages.PayloadType.COMPRESSABLE;
goldenResponse.payload.body = new byte[31415];
ResponseObserver responseObserver = new ResponseObserver();
@@ -387,7 +387,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
Integer[] responseSizes = {50, 100, 150, 200};
final StreamingOutputCallRequest request = new StreamingOutputCallRequest();
request.responseParameters = new ResponseParameters[responseSizes.length];
- request.responseType = Messages.COMPRESSABLE;
+ request.responseType = Messages.PayloadType.COMPRESSABLE;
for (int i = 0; i < responseSizes.length; ++i) {
request.responseParameters[i] = new ResponseParameters();
request.responseParameters[i].size = responseSizes[i];
@@ -408,7 +408,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
assertEquals(responseSizes.length * numRequests, recorder.getValues().size());
for (int ix = 0; ix < recorder.getValues().size(); ++ix) {
StreamingOutputCallResponse response = recorder.getValues().get(ix);
- assertEquals(Messages.COMPRESSABLE, response.payload.type);
+ assertEquals(Messages.PayloadType.COMPRESSABLE, response.payload.type);
int length = response.payload.body.length;
int expectedSize = responseSizes[ix % responseSizes.length];
assertEquals("comparison failed at index " + ix, expectedSize, length);
@@ -420,7 +420,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
Integer[] responseSizes = {50, 100, 150, 200};
final StreamingOutputCallRequest request = new StreamingOutputCallRequest();
request.responseParameters = new ResponseParameters[responseSizes.length];
- request.responseType = Messages.COMPRESSABLE;
+ request.responseType = Messages.PayloadType.COMPRESSABLE;
for (int i = 0; i < responseSizes.length; ++i) {
request.responseParameters[i] = new ResponseParameters();
request.responseParameters[i].size = responseSizes[i];
@@ -440,7 +440,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
assertEquals(responseSizes.length * numRequests, recorder.getValues().size());
for (int ix = 0; ix < recorder.getValues().size(); ++ix) {
StreamingOutputCallResponse response = recorder.getValues().get(ix);
- assertEquals(Messages.COMPRESSABLE, response.payload.type);
+ assertEquals(Messages.PayloadType.COMPRESSABLE, response.payload.type);
int length = response.payload.body.length;
int expectedSize = responseSizes[ix % responseSizes.length];
assertEquals("comparison failed at index " + ix, expectedSize, length);
@@ -449,7 +449,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
public void serverStreamingShouldBeFlowControlled() throws Exception {
final StreamingOutputCallRequest request = new StreamingOutputCallRequest();
- request.responseType = Messages.COMPRESSABLE;
+ request.responseType = Messages.PayloadType.COMPRESSABLE;
request.responseParameters = new ResponseParameters[2];
request.responseParameters[0] = new ResponseParameters();
request.responseParameters[0].size = 100000;
@@ -458,11 +458,11 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
final StreamingOutputCallResponse[] goldenResponses = new StreamingOutputCallResponse[2];
goldenResponses[0] = new StreamingOutputCallResponse();
goldenResponses[0].payload = new Payload();
- goldenResponses[0].payload.type = Messages.COMPRESSABLE;
+ goldenResponses[0].payload.type = Messages.PayloadType.COMPRESSABLE;
goldenResponses[0].payload.body = new byte[100000];
goldenResponses[1] = new StreamingOutputCallResponse();
goldenResponses[1].payload = new Payload();
- goldenResponses[1].payload.type = Messages.COMPRESSABLE;
+ goldenResponses[1].payload.type = Messages.PayloadType.COMPRESSABLE;
goldenResponses[1].payload.body = new byte[100001];
long start = System.nanoTime();
@@ -514,13 +514,13 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
}
final SimpleRequest request = new SimpleRequest();
request.payload = new Payload();
- request.payload.type = Messages.COMPRESSABLE;
+ request.payload.type = Messages.PayloadType.COMPRESSABLE;
request.payload.body = new byte[unaryPayloadLength()];
request.responseSize = 10;
- request.responseType = Messages.COMPRESSABLE;
+ request.responseType = Messages.PayloadType.COMPRESSABLE;
final SimpleResponse goldenResponse = new SimpleResponse();
goldenResponse.payload = new Payload();
- goldenResponse.payload.type = Messages.COMPRESSABLE;
+ goldenResponse.payload.type = Messages.PayloadType.COMPRESSABLE;
goldenResponse.payload.body = new byte[10];
assertMessageEquals(goldenResponse, blockingStub.unaryCall(request));
@@ -532,12 +532,12 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
}
final SimpleRequest request = new SimpleRequest();
request.responseSize = unaryPayloadLength();
- request.responseType = Messages.COMPRESSABLE;
+ request.responseType = Messages.PayloadType.COMPRESSABLE;
SimpleResponse resp = blockingStub.unaryCall(request);
final SimpleResponse goldenResponse = new SimpleResponse();
goldenResponse.payload = new Payload();
- goldenResponse.payload.type = Messages.COMPRESSABLE;
+ goldenResponse.payload.type = Messages.PayloadType.COMPRESSABLE;
goldenResponse.payload.body = new byte[unaryPayloadLength()];
assertMessageSizeEquals(goldenResponse, resp);
@@ -579,7 +579,7 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
responseParameters.size = 1;
responseParameters.intervalUs = 10000;
StreamingOutputCallRequest request = new StreamingOutputCallRequest();
- request.responseType = Messages.COMPRESSABLE;
+ request.responseType = Messages.PayloadType.COMPRESSABLE;
request.responseParameters = new ResponseParameters[4];
request.responseParameters[0] = responseParameters;
request.responseParameters[1] = responseParameters;
@@ -623,15 +623,15 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
StreamingOutputCallResponse[] goldenResponses = new StreamingOutputCallResponse[3];
goldenResponses[0] = new StreamingOutputCallResponse();
goldenResponses[0].payload = new Payload();
- goldenResponses[0].payload.type = Messages.COMPRESSABLE;
+ goldenResponses[0].payload.type = Messages.PayloadType.COMPRESSABLE;
goldenResponses[0].payload.body = new byte[3];
goldenResponses[1] = new StreamingOutputCallResponse();
goldenResponses[1].payload = new Payload();
- goldenResponses[1].payload.type = Messages.COMPRESSABLE;
+ goldenResponses[1].payload.type = Messages.PayloadType.COMPRESSABLE;
goldenResponses[1].payload.body = new byte[1];
goldenResponses[2] = new StreamingOutputCallResponse();
goldenResponses[2].payload = new Payload();
- goldenResponses[2].payload.type = Messages.COMPRESSABLE;
+ goldenResponses[2].payload.type = Messages.PayloadType.COMPRESSABLE;
goldenResponses[2].payload.body = new byte[4];