@@ -78,7 +78,7 @@ public ServerEndPoint(ConnectionMultiplexer multiplexer, EndPoint endpoint, Text
78
78
public bool IsConnected => interactive ? . IsConnected == true ;
79
79
80
80
public bool IsConnecting => interactive ? . IsConnecting == true ;
81
-
81
+
82
82
internal Exception LastException
83
83
{
84
84
get
@@ -321,7 +321,7 @@ internal void AutoConfigure(PhysicalConnection connection)
321
321
322
322
private int _nextReplicaOffset ;
323
323
internal uint NextReplicaOffset ( ) // used to round-robin between multiple replicas
324
- => ( uint ) System . Threading . Interlocked . Increment ( ref _nextReplicaOffset ) ;
324
+ => ( uint ) System . Threading . Interlocked . Increment ( ref _nextReplicaOffset ) ;
325
325
326
326
internal Task Close ( )
327
327
{
@@ -393,11 +393,11 @@ internal string GetProfile()
393
393
internal byte [ ] GetScriptHash ( string script , RedisCommand command )
394
394
{
395
395
var found = ( byte [ ] ) knownScripts [ script ] ;
396
- if ( found == null && command == RedisCommand . EVALSHA )
396
+ if ( found == null && command == RedisCommand . EVALSHA )
397
397
{
398
398
// the script provided is a hex sha; store and re-use the ascii for that
399
399
found = Encoding . ASCII . GetBytes ( script ) ;
400
- lock ( knownScripts )
400
+ lock ( knownScripts )
401
401
{
402
402
knownScripts [ script ] = found ;
403
403
}
@@ -581,14 +581,15 @@ internal string Summary()
581
581
var tmp = interactive ;
582
582
sb . Append ( "; int: " ) . Append ( tmp ? . ConnectionState . ToString ( ) ?? "n/a" ) ;
583
583
tmp = subscription ;
584
- if ( tmp == null )
584
+ if ( tmp == null )
585
585
{
586
586
sb . Append ( "; sub: n/a" ) ;
587
- } else
587
+ }
588
+ else
588
589
{
589
590
var state = tmp . ConnectionState ;
590
591
sb . Append ( "; sub: " ) . Append ( state ) ;
591
- if ( state == PhysicalBridge . State . ConnectedEstablished )
592
+ if ( state == PhysicalBridge . State . ConnectedEstablished )
592
593
{
593
594
sb . Append ( ", " ) . Append ( tmp . SubscriptionCount ) . Append ( " active" ) ;
594
595
}
@@ -678,7 +679,7 @@ private void Handshake(PhysicalConnection connection, TextWriter log)
678
679
if ( connType == ConnectionType . Subscription )
679
680
{
680
681
var configChannel = multiplexer . ConfigurationChangedChannel ;
681
- if ( configChannel != null )
682
+ if ( configChannel != null )
682
683
{
683
684
msg = Message . Create ( - 1 , CommandFlags . FireAndForget , RedisCommand . SUBSCRIBE , ( RedisChannel ) configChannel ) ;
684
685
WriteDirectOrQueueFireAndForget ( connection , msg , ResultProcessor . TrackSubscriptions ) ;
@@ -690,7 +691,7 @@ private void Handshake(PhysicalConnection connection, TextWriter log)
690
691
691
692
private void SetConfig < T > ( ref T field , T value , [ CallerMemberName ] string caller = null )
692
693
{
693
- if ( ! EqualityComparer < T > . Default . Equals ( field , value ) )
694
+ if ( ! EqualityComparer < T > . Default . Equals ( field , value ) )
694
695
{
695
696
multiplexer . Trace ( caller + " changed from " + field + " to " + value , "Configuration" ) ;
696
697
field = value ;
0 commit comments