CommandInModel增加StartTime，指定命令开始执行的未来时间

NewLifeX · Sep 23, 2024 · 2c59777 · 2c59777
1 parent a280c81
commit 2c59777
Show file tree

Hide file tree

Showing 14 changed files with 21 additions and 16 deletions.
diff --git a/NewLife.Remoting.Extensions/WebHelper.cs b/NewLife.Remoting.Extensions/WebHelper.cs
@@ -49,7 +49,7 @@ private static Uri GetRawUrl(Uri uri, Func<String, String> headers)
         if (port > 0 && port != 80 && port != 443)
         {
             uriInfo.Port = port;
-            uri = new Uri(uriInfo.ToString());
+            uri = new Uri(uriInfo.ToString()!);
         }
 
         return uri;

diff --git a/NewLife.Remoting/ApiClient.cs b/NewLife.Remoting/ApiClient.cs
@@ -189,7 +189,7 @@ protected virtual ICluster<String, ISocketClient> InitCluster()
         }
         finally
         {
-            Cluster.Put(client);
+            Cluster.Return(client);
         }
     }
 

diff --git a/NewLife.Remoting/ClientPoolCluster.cs b/NewLife.Remoting/ClientPoolCluster.cs
@@ -35,11 +35,11 @@ public class ClientPoolCluster<T> : ICluster<String, T> where T : class
 
     /// <summary>归还</summary>
     /// <param name="value"></param>
-    public virtual Boolean Put(T value)
+    public virtual Boolean Return(T value)
     {
         if (value == null) return false;
 
-        return Pool.Put(value);
+        return Pool.Return(value);
     }
 
     /// <summary>Round-Robin 负载均衡</summary>
@@ -101,7 +101,7 @@ public MyPool(ClientPoolCluster<T> cluster)
 
         /// <summary>释放时，返回是否有效。无效对象将会被抛弃</summary>
         /// <param name="value"></param>
-        protected override Boolean OnPut(T value) => value != null && (value is not IDisposable2 ds || !ds.Disposed);
+        protected override Boolean OnReturn(T value) => value != null && (value is not IDisposable2 ds || !ds.Disposed);
     }
 
     #region 日志

diff --git a/NewLife.Remoting/ClientSingleCluster.cs b/NewLife.Remoting/ClientSingleCluster.cs
@@ -53,7 +53,7 @@ public virtual T Get()
 
     /// <summary>归还</summary>
     /// <param name="value"></param>
-    public virtual Boolean Put(T value) => true;
+    public virtual Boolean Return(T value) => true;
 
     /// <summary>Round-Robin 负载均衡</summary>
     private Int32 _index = -1;

diff --git a/NewLife.Remoting/ICluster.cs b/NewLife.Remoting/ICluster.cs
@@ -25,7 +25,7 @@ public interface ICluster<TKey, TValue>
 
     /// <summary>归还</summary>
     /// <param name="value"></param>
-    Boolean Put(TValue value);
+    Boolean Return(TValue value);
 }
 
 /// <summary>集群助手</summary>
@@ -47,7 +47,7 @@ public static TResult Invoke<TKey, TValue, TResult>(this ICluster<TKey, TValue>
         }
         finally
         {
-            cluster.Put(item);
+            cluster.Return(item);
         }
     }
 
@@ -67,7 +67,7 @@ public static async Task<TResult> InvokeAsync<TKey, TValue, TResult>(this IClust
         }
         finally
         {
-            cluster.Put(item);
+            cluster.Return(item);
         }
     }
 }
diff --git a/NewLife.Remoting/Models/CommandInModel.cs b/NewLife.Remoting/Models/CommandInModel.cs
@@ -12,6 +12,9 @@ public class CommandInModel
     /// <summary>参数</summary>
     public String? Argument { get; set; }
 
+    /// <summary>开始时间。多久之后开始执行，单位秒</summary>
+    public Int32 StartTime { get; set; }
+
     /// <summary>有效期。多久之后指令过期，单位秒，未指定时表示不限制</summary>
     public Int32 Expire { get; set; }
 

diff --git a/NewLife.Remoting/NewLife.Remoting.csproj b/NewLife.Remoting/NewLife.Remoting.csproj
@@ -52,7 +52,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="NewLife.Core" Version="11.0.2024.913-beta0901" />
+    <PackageReference Include="NewLife.Core" Version="11.0.2024.923-beta0014" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/NewLife.Remoting/WsClient.cs b/NewLife.Remoting/WsClient.cs
@@ -175,7 +175,7 @@ protected virtual ICluster<String, WebSocket> InitCluster()
         }
         finally
         {
-            Cluster.Put(client);
+            Cluster.Return(client);
         }
     }
 

diff --git a/Samples/IoTZero/IoTZero.csproj b/Samples/IoTZero/IoTZero.csproj
@@ -24,6 +24,7 @@
     <PackageReference Include="NewLife.MQTT" Version="2.0.2024.708" />
     <PackageReference Include="NewLife.Redis" Version="5.7.2024.801" />
     <PackageReference Include="NewLife.Stardust.Extensions" Version="3.0.2024.902" />
+    <PackageReference Include="NewLife.XCode" Version="11.16.2024.917-beta0218" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/Samples/Zero.RpcServer/Zero.RpcServer.csproj b/Samples/Zero.RpcServer/Zero.RpcServer.csproj
@@ -22,7 +22,7 @@
   <ItemGroup>
     <PackageReference Include="NewLife.Redis" Version="5.7.2024.801" />
     <PackageReference Include="NewLife.Stardust" Version="3.0.2024.902" />
-    <PackageReference Include="NewLife.XCode" Version="11.15.2024.902" />
+    <PackageReference Include="NewLife.XCode" Version="11.16.2024.917-beta0218" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/Samples/ZeroServer/ZeroServer.csproj b/Samples/ZeroServer/ZeroServer.csproj
@@ -22,6 +22,7 @@
     <PackageReference Include="NewLife.Cube.Core" Version="6.1.2024.902" />
     <PackageReference Include="NewLife.Redis" Version="5.7.2024.801" />
     <PackageReference Include="NewLife.Stardust.Extensions" Version="3.0.2024.902" />
+    <PackageReference Include="NewLife.XCode" Version="11.16.2024.917-beta0218" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/Test/Test.csproj b/Test/Test.csproj
@@ -10,7 +10,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="NewLife.Core" Version="11.0.2024.913-beta0901" />
+    <PackageReference Include="NewLife.Core" Version="11.0.2024.923-beta0014" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/XUnitTest/JsonEncoderTests.cs b/XUnitTest/JsonEncoderTests.cs
@@ -67,7 +67,7 @@ public void EncodeRequest()
             var len = reader.ReadInt32();
             Assert.Equal(value.Total, len);
             var buf = reader.ReadBytes(len);
-            Assert.Equal(value.ToHex(64), buf.ToHex(64));
+            Assert.Equal(value.ToHex(64), buf.ToHex(null, 0, 64));
         }
     }
 
@@ -129,7 +129,7 @@ public void EncodeResponse()
             Assert.Equal(value.ToArray(), span);
 
             var hex1 = value.ToHex(64);
-            var hex2 = span.ToHex(64);
+            var hex2 = span.ToHex();
             Assert.Equal(hex1, hex2);
             //Assert.Equal(value.Count, (Int32)pk.Slice(1 + name.Length, 4).ReadUInt32());
             //Assert.Equal(value.ToHex(), pk.Slice(1 + name.Length + 4, value.Count).ToHex());

diff --git a/XUnitTest/XUnitTest.csproj b/XUnitTest/XUnitTest.csproj
@@ -12,7 +12,7 @@
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="8.0.0" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.11.1" />
     <PackageReference Include="Moq" Version="4.20.72" />
-    <PackageReference Include="NewLife.Core" Version="11.0.2024.913-beta0901" />
+    <PackageReference Include="NewLife.Core" Version="11.0.2024.923-beta0014" />
     <PackageReference Include="NewLife.UnitTest" Version="1.0.2023.1204" />
     <PackageReference Include="xunit" Version="2.9.0" />
     <PackageReference Include="xunit.runner.visualstudio" Version="2.8.2">