Max concurrent stream check should happen after authority verification failure if any

Author: kannanjgithub

okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java

@@ -521,9 +521,6 @@ void streamReadyToStart(OkHttpClientStream clientStream, String authority) {
     if (goAwayStatus != null) {
       clientStream.transportState().transportReportStatus(
           goAwayStatus, RpcProgress.MISCARRIED, true, new Metadata());
-    } else if (streams.size() >= maxConcurrentStreams) {
-      pendingStreams.add(clientStream);
-      setInUse(clientStream);
     } else {
       if (socket instanceof SSLSocket && !authority.equals(defaultAuthority)) {
         Status authorityVerificationResult;
@@ -541,7 +538,12 @@ void streamReadyToStart(OkHttpClientStream clientStream, String authority) {
           }
         }
       }
-      startStream(clientStream);
+      if (streams.size() >= maxConcurrentStreams) {
+        pendingStreams.add(clientStream);
+        setInUse(clientStream);
+      } else {
+        startStream(clientStream);
+      }
     }
   }