@@ -1023,7 +1023,7 @@ private async Task<bool> OpenNamedPipeAsync(ConnectionSettings cs, int startTick
1023
1023
#else
1024
1024
if ( Log . IsInfoEnabled ( ) )
1025
1025
Log . Info ( "Session{0} connecting to NamedPipe '{1}' on Server '{2}'" , m_logArguments [ 0 ] , cs . PipeName , cs . HostNames ! [ 0 ] ) ;
1026
- var namedPipeStream = new NamedPipeClientStream ( cs . HostNames ! [ 0 ] , cs . PipeName , PipeDirection . InOut , PipeOptions . Asynchronous ) ;
1026
+ var namedPipeStream = new NamedPipeClientStream ( cs . HostNames ! [ 0 ] , cs . PipeName ! , PipeDirection . InOut , PipeOptions . Asynchronous ) ;
1027
1027
var timeout = Math . Max ( 1 , cs . ConnectionTimeoutMilliseconds - unchecked ( Environment . TickCount - startTickCount ) ) ;
1028
1028
try
1029
1029
{
@@ -1274,14 +1274,14 @@ private async Task InitSslAsync(ProtocolCapabilities serverCapabilities, Connect
1274
1274
}
1275
1275
}
1276
1276
1277
- X509Certificate ValidateLocalCertificate ( object lcbSender , string lcbTargetHost , X509CertificateCollection lcbLocalCertificates , X509Certificate lcbRemoteCertificate , string [ ] lcbAcceptableIssuers ) => lcbLocalCertificates [ 0 ] ;
1277
+ X509Certificate ValidateLocalCertificate ( object lcbSender , string lcbTargetHost , X509CertificateCollection lcbLocalCertificates , X509Certificate ? lcbRemoteCertificate , string [ ] lcbAcceptableIssuers ) => lcbLocalCertificates [ 0 ] ;
1278
1278
1279
- bool ValidateRemoteCertificate ( object rcbSender , X509Certificate rcbCertificate , X509Chain rcbChain , SslPolicyErrors rcbPolicyErrors )
1279
+ bool ValidateRemoteCertificate ( object rcbSender , X509Certificate ? rcbCertificate , X509Chain ? rcbChain , SslPolicyErrors rcbPolicyErrors )
1280
1280
{
1281
1281
if ( cs . SslMode == MySqlSslMode . Preferred || cs . SslMode == MySqlSslMode . Required )
1282
1282
return true ;
1283
1283
1284
- if ( ( rcbPolicyErrors & SslPolicyErrors . RemoteCertificateChainErrors ) != 0 && caCertificateChain is not null )
1284
+ if ( ( rcbPolicyErrors & SslPolicyErrors . RemoteCertificateChainErrors ) != 0 && caCertificateChain is not null && rcbCertificate is not null )
1285
1285
{
1286
1286
if ( caCertificateChain . Build ( ( X509Certificate2 ) rcbCertificate ) && caCertificateChain . ChainStatus . Length > 0 )
1287
1287
{
@@ -1297,8 +1297,8 @@ bool ValidateRemoteCertificate(object rcbSender, X509Certificate rcbCertificate,
1297
1297
return rcbPolicyErrors == SslPolicyErrors . None ;
1298
1298
}
1299
1299
1300
- var sslStream = clientCertificates is null ? new SslStream ( m_stream , false , ValidateRemoteCertificate ) :
1301
- new SslStream ( m_stream , false , ValidateRemoteCertificate , ValidateLocalCertificate ) ;
1300
+ var sslStream = clientCertificates is null ? new SslStream ( m_stream ! , false , ValidateRemoteCertificate ) :
1301
+ new SslStream ( m_stream ! , false , ValidateRemoteCertificate , ValidateLocalCertificate ) ;
1302
1302
1303
1303
var checkCertificateRevocation = cs . SslMode == MySqlSslMode . VerifyFull ;
1304
1304
0 commit comments