Add async nonblocking ssl support in java client

Author: HTHou

.github/workflows/build.yml

@@ -274,6 +274,7 @@ jobs:
           if-no-files-found: error
           path: |
             lib/java/build/functionalTestJar/
+            lib/java/build/runnonblockingclient
             lib/java/build/runclient
             lib/java/build/runnonblockingserver
             lib/java/build/runserver
@@ -320,21 +321,21 @@ jobs:
       - name: Set up .NET SDK (via install script)
         run: |
           # remove any existing install
-          sudo apt remove dotnet*    
+          sudo apt remove dotnet*
           # install key
           sudo apt install gpg
           wget https://dot.net/v1/dotnet-install.asc
-          gpg --import dotnet-install.asc          
+          gpg --import dotnet-install.asc
           # download and verify
           wget https://dot.net/v1/dotnet-install.sh
           wget https://dot.net/v1/dotnet-install.sig
-          gpg --verify dotnet-install.sig dotnet-install.sh          
+          gpg --verify dotnet-install.sig dotnet-install.sh
           # run install script
           chmod +x dotnet-install.sh
-          ./dotnet-install.sh --channel 10.0          
+          ./dotnet-install.sh --channel 10.0
           # export env vars
           export DOTNET_ROOT=$HOME/.dotnet
-          export PATH=$PATH:$DOTNET_ROOT:$DOTNET_ROOT/tools          
+          export PATH=$PATH:$DOTNET_ROOT:$DOTNET_ROOT/tools
           dotnet --list-sdks
 
 #      the sdk is installed by default, but keep this step for reference

lib/java/gradle/functionalTests.gradle

@@ -64,7 +64,7 @@ dependencies {
 shadowJar {
     description = 'Assemble a test JAR file for cross-check execution'
     // make sure the runners are created when this runs
-    dependsOn 'generateRunnerScriptForClient', 'generateRunnerScriptForServer', 'generateRunnerScriptForNonblockingServer', 'generateRunnerScriptForTServletServer'
+    dependsOn 'generateRunnerScriptForClient', 'generateRunnerScriptForNonblockingClient', 'generateRunnerScriptForServer', 'generateRunnerScriptForNonblockingServer', 'generateRunnerScriptForTServletServer'
     archiveBaseName.set('functionalTest')
     destinationDirectory = file("$buildDir/functionalTestJar")
     // We do not need a version number for this internal jar
@@ -119,6 +119,26 @@ ${scriptHead}
     }
 }
 
+task generateRunnerScriptForNonblockingClient(group: 'Build') {
+    description = 'Generate a runner script for cross-check tests with TestNonblockingClient'
+
+    def clientFile = file("$buildDir/runnonblockingclient${scriptExt}")
+
+    def runClientText = """\
+${scriptHead}
+
+"${javaExe}" -cp "$jarPath" "-Djavax.net.ssl.keyStore=$clientKeyStore" -Djavax.net.ssl.keyStorePassword=thrift "-Djavax.net.ssl.trustStore=$trustStore" -Djavax.net.ssl.trustStorePassword=thrift org.apache.thrift.test.TestNonblockingClient $args
+"""
+    inputs.property 'runClientText', runClientText
+    outputs.file clientFile
+
+    doLast {
+        clientFile.parentFile.mkdirs()
+        clientFile.text = runClientText
+        clientFile.setExecutable(true, false)
+    }
+}
+
 task generateRunnerScriptForServer(group: 'Build') {
     description = 'Generate a runner script for cross-check tests with TestServer'
 

lib/java/src/crossTest/java/org/apache/thrift/test/TestClient.java

@@ -62,12 +62,12 @@
  */
 public class TestClient {
 
-  private static int ERR_BASETYPES = 1;
-  private static int ERR_STRUCTS = 2;
-  private static int ERR_CONTAINERS = 4;
-  private static int ERR_EXCEPTIONS = 8;
-  private static int ERR_PROTOCOLS = 16;
-  private static int ERR_UNKNOWN = 64;
+  static int ERR_BASETYPES = 1;
+  static int ERR_STRUCTS = 2;
+  static int ERR_CONTAINERS = 4;
+  static int ERR_EXCEPTIONS = 8;
+  static int ERR_PROTOCOLS = 16;
+  static int ERR_UNKNOWN = 64;
 
   public static void main(String[] args) {
     String host = "localhost";
@@ -819,7 +819,7 @@ public static void main(String[] args) {
     System.exit(returnCode);
   }
 
-  private static byte[] getBytesData() {
+  static byte[] getBytesData() {
     ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(256);
     IntStream.range(-128, 128).forEach(byteArrayOutputStream::write);
     return byteArrayOutputStream.toByteArray();