diff options
author | Carl Mastrangelo <notcarl@google.com> | 2017-09-15 11:49:31 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-09-15 11:49:31 -0700 |
commit | 2924e30e45d308b2b432a22b793898e7434c8de2 (patch) | |
tree | ec67648dd4736e65a15ae4cefa966707b6787794 /android-interop-testing | |
parent | 8ee9fb51837a96b18664241a6875ff155843152b (diff) | |
download | grpc-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.gradle | 1 | ||||
-rw-r--r-- | android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/InteropTester.java | 42 |
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]; |