name the socket manager in BookSleeveTestBase; fix bug in...

name the socket manager in BookSleeveTestBase; fix bug in AbandonPendingBacklog; compensate for Me() changes in AsyncTasksReportFailureIfServerUnavailable

StackExchange.Redis.Tests/AsyncTests.cs

@@ -36,7 +36,7 @@ public void AsyncTasksReportFailureIfServerUnavailable()
                 Assert.True(c.IsFaulted, "faulted");
                 var ex = c.Exception.InnerExceptions.Single();
                 Assert.IsType<RedisConnectionException>(ex);
-                Assert.StartsWith("No connection is available to service this operation: SADD AsyncTasksReportFailureIfServerUnavailable", ex.Message);
+                Assert.StartsWith("No connection is available to service this operation: SADD " + key.ToString(), ex.Message);
             }
         }
 #endif

StackExchange.Redis.Tests/Booksleeve/BookSleeveTestBase.cs

@@ -27,7 +27,7 @@ static BookSleeveTestBase()
 
         public static string CreateUniqueName() => Guid.NewGuid().ToString("N");
         internal static IServer GetServer(ConnectionMultiplexer conn) => conn.GetServer(conn.GetEndPoints()[0]);
-        private static readonly SocketManager socketManager = new SocketManager();
+        private static readonly SocketManager socketManager = new SocketManager(nameof(BookSleeveTestBase));
 
         internal static ConnectionMultiplexer GetRemoteConnection(bool open = true, bool allowAdmin = false, bool waitForOpen = false, int syncTimeout = 5000, int ioTimeout = 5000)
         {

StackExchange.Redis.Tests/TestBase.cs

@@ -199,7 +199,8 @@ protected IServer GetAnyMaster(ConnectionMultiplexer muxer)
             int? connectTimeout = null, string password = null, string tieBreaker = null, TextWriter log = null,
             bool fail = true, string[] disabledCommands = null, string[] enabledCommands = null,
             bool checkConnect = true, bool pause = true, string failMessage = null,
-            string channelPrefix = null, bool useSharedSocketManager = true, Proxy? proxy = null)
+            string channelPrefix = null, bool useSharedSocketManager = true, Proxy? proxy = null,
+            [CallerMemberName] string caller = null)
         {
             if (pause) Thread.Sleep(250); // get a lot of glitches when hammering new socket creations etc; pace it out a bit
             string configuration = GetConfiguration();
@@ -223,6 +224,7 @@ protected IServer GetAnyMaster(ConnectionMultiplexer muxer)
             if (tieBreaker != null) config.TieBreaker = tieBreaker;
             if (password != null) config.Password = string.IsNullOrEmpty(password) ? null : password;
             if (clientName != null) config.ClientName = clientName;
+            else if (caller != null) config.ClientName = caller;
             if (syncTimeout != null) config.SyncTimeout = syncTimeout.Value;
             if (allowAdmin != null) config.AllowAdmin = allowAdmin.Value;
             if (keepAlive != null) config.KeepAlive = keepAlive.Value;

StackExchange.Redis/StackExchange/Redis/PhysicalBridge.cs

@@ -328,7 +328,7 @@ void WritePendingBacklog(PhysicalConnection connection)
                 do
                 {
                     next = DequeueNextPendingBacklog();
-                    WriteMessageDirect(connection, next);
+                    if(next != null) WriteMessageDirect(connection, next);
                 } while (next != null);
             }
         }
@@ -338,7 +338,7 @@ void AbandonPendingBacklog(Exception ex)
             do
             {
                 next = DequeueNextPendingBacklog();
-                next.Cancel(ex);
+                next?.Cancel(ex);
             } while (next != null);
         }
         internal void OnFullyEstablished(PhysicalConnection connection)