ci: Add concurrent channel tests

.github/workflows/test.yml

@@ -2,6 +2,9 @@ name: Tests
 
 on:
   pull_request:
+  push:
+    branches:
+      - main
 
 concurrency:
   group: test-${{ github.ref }}

packages/csharp/ArmoniK.Api.Client.Test/ConnectivityTest.cs

@@ -21,8 +21,12 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+using System.Linq;
+using System.Threading.Tasks;
+
 using ArmoniK.Api.gRPC.V1;
 using ArmoniK.Api.gRPC.V1.Results;
+using ArmoniK.Utils;
 
 using NUnit.Framework;
 
@@ -40,4 +44,28 @@ public void ResultsGetServiceConfiguration([Values] ConnectivityKind connectivit
     Assert.That(() => resultClient.GetServiceConfiguration(new Empty()),
                 Throws.Nothing);
   }
+
+  [Test]
+  public async Task MultipleChannels([Values] ConnectivityKind connectivityKind,
+                                     [Values(1,
+                                             2,
+                                             10,
+                                             100)]
+                                     int concurrency)
+  {
+    var channels = await Enumerable.Range(0,
+                                          concurrency)
+                                   .ParallelSelect(new ParallelTaskOptions(-1),
+                                                   i => Task.FromResult(connectivityKind.GetChannel()))
+                                   .ToListAsync()
+                                   .ConfigureAwait(false);
+
+    await channels.ParallelForEach(async channel =>
+                                   {
+                                     var resultClient = new Results.ResultsClient(channel);
+                                     await resultClient.GetServiceConfigurationAsync(new Empty())
+                                                       .ConfigureAwait(false);
+                                   })
+                  .ConfigureAwait(false);
+  }
 }

packages/csharp/ArmoniK.Api.Client/Submitter/GrpcChannelFactory.cs

@@ -31,7 +31,6 @@
 using System.Security.Authentication;
 using System.Security.Cryptography;
 using System.Security.Cryptography.X509Certificates;
-using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 
@@ -280,7 +279,8 @@ private static GrpcChannel CreateChannelInternal(GrpcClient  optionsGrpcClient,
         var parser = new X509CertificateParser();
         using var stream = File.Open(optionsGrpcClient.CaCert,
                                      FileMode.Open,
-                                     FileAccess.Read);
+                                     FileAccess.Read,
+                                     FileShare.Read);
         caCert = parser.ReadCertificate(stream);
       }
 
@@ -449,16 +449,20 @@ public static X509Certificate2 GetCertificate(GrpcClient optionsGrpcClient)
       X509Certificate cert;
       using (var reader = new FileStream(optionsGrpcClient.CertPem,
                                          FileMode.Open,
-                                         FileAccess.Read))
+                                         FileAccess.Read,
+                                         FileShare.Read))
       {
         cert = new X509CertificateParser().ReadCertificate(reader);
       }
 
       var store = new Pkcs12StoreBuilder().Build();
-      using (var reader = new StreamReader(optionsGrpcClient.KeyPem,
-                                           Encoding.UTF8))
+      using (var reader = new FileStream(optionsGrpcClient.KeyPem,
+                                         FileMode.Open,
+                                         FileAccess.Read,
+                                         FileShare.Read))
+      using (var textReader = new StreamReader(reader))
       {
-        var                     pemReader = new PemReader(reader);
+        var                     pemReader = new PemReader(textReader);
         AsymmetricKeyParameter? key;
 
         do