v1.1.4 -debug: Connect timeout

2881099 · Jun 30, 2023 · 1a7482f · 1a7482f
1 parent 1b455b3
commit 1a7482f
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 4 deletions.
diff --git a/src/FreeRedis/FreeRedis.csproj b/src/FreeRedis/FreeRedis.csproj
@@ -5,7 +5,7 @@
 		<AssemblyName>FreeRedis</AssemblyName>
 		<PackageId>FreeRedis</PackageId>
 		<RootNamespace>FreeRedis</RootNamespace>
-		<Version>1.1.3</Version>
+		<Version>1.1.4</Version>
 		<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
 		<PackageProjectUrl>https://github.com/2881099/FreeRedis</PackageProjectUrl>
 		<Description>FreeRedis is .NET redis client, supports cluster, sentinel, master-slave, pipeline, transaction and connection pool.</Description>

diff --git a/src/FreeRedis/Internal/DefaultRedisSocket.cs b/src/FreeRedis/Internal/DefaultRedisSocket.cs
@@ -249,7 +249,10 @@ public void Connect()
                 {
                     var endpointString = endpoint.ToString();
                     if (endpointString != $"{_ip}:{_port}") endpointString = $"{_ip}:{_port} -> {endpointString}";
-                    throw new TimeoutException($"Connect to redis-server({endpointString}) timeout");
+                    var debugString = "";
+                    try { debugString = $", DEBUG: Dns.GetHostEntry({_ip})={Dns.GetHostEntry(_ip)}"; }
+                    catch (Exception ex) { debugString = $", DEBUG: {ex.Message}"; }
+                    throw new TimeoutException($"Connect to redis-server({endpointString}) timeout{debugString}");
                 }
                 localSocket.EndConnect(asyncResult);
                 _socket = localSocket;

diff --git a/src/FreeRedis/Internal/ObjectPool/ObjectPool.cs b/src/FreeRedis/Internal/ObjectPool/ObjectPool.cs
@@ -125,7 +125,7 @@ private void CheckAvailable(int interval)
                             {
                                 conn.ResetValue();
                             }
-                            if (Policy.OnCheckAvailable(conn) == false) throw new Exception("【{Policy.Name}】An exception needs to be thrown");
+                            if (Policy.OnCheckAvailable(conn) == false) throw new Exception($"【{Policy.Name}】An exception needs to be thrown");
                             break;
                         }
                         finally
@@ -373,7 +373,7 @@ async public Task<Object<T>> GetAsync()
             if (obj == null)
             {
                 if (Policy.AsyncGetCapacity > 0 && _getAsyncQueue.Count >= Policy.AsyncGetCapacity - 1)
-                    throw new OutOfMemoryException($"【{Policy.Name}】ObjectPool.GetAsync() The queue is too long. Policy. AsyncGetCapacity = {Policy.AsyncGetCapacity}");
+                    throw new OutOfMemoryException($"【{Policy.Name}】ObjectPool.GetAsync() The queue is too long. Policy.AsyncGetCapacity = {Policy.AsyncGetCapacity}");
 
                 var tcs = new TaskCompletionSource<Object<T>>();