pull/1/head
unknown 5 years ago
parent ccfbe6eca6
commit 9f1bcfa923

@ -19,7 +19,7 @@ namespace TestApp
{ {
Log.Info("Started"); Log.Info("Started");
ReadServiceInfo(); ReadServiceInfo();
var host = UseHost(8800); var host = UseHost();
AutoregisterInboxes(host); AutoregisterInboxes(host);
host.OnConnect += Host_OnConnect; host.OnConnect += Host_OnConnect;
host.OnDisconnect += Host_OnDisconnect; host.OnDisconnect += Host_OnDisconnect;
@ -31,7 +31,7 @@ namespace TestApp
Interlocked.Exchange(ref counter, 0); Interlocked.Exchange(ref counter, 0);
}); });
Exchange.RoutesStorage.Set("test.app", new IPEndPoint(IPAddress.Loopback, 8800)); //Exchange.RoutesStorage.Set("test.app", new IPEndPoint(IPAddress.Loopback, 8800));
while (true) while (true)
{ {

@ -9,7 +9,7 @@ namespace TestApp
Bootstrap.Startup<MyService>(args, Bootstrap.Startup<MyService>(args,
() => Configuration.ReadSetFromIniFile("config.ini")) () => Configuration.ReadSetFromIniFile("config.ini"))
.EnableConsoleLog(ZeroLevel.Services.Logging.LogLevel.System | ZeroLevel.Services.Logging.LogLevel.FullDebug) .EnableConsoleLog(ZeroLevel.Services.Logging.LogLevel.System | ZeroLevel.Services.Logging.LogLevel.FullDebug)
//.UseDiscovery() .UseDiscovery()
.Run() .Run()
.WaitWhileStatus(ZeroServiceStatus.Running) .WaitWhileStatus(ZeroServiceStatus.Running)
.Stop(); .Stop();

@ -8,11 +8,6 @@ namespace ZeroLevel.Network
internal sealed class ExClientServerCachee internal sealed class ExClientServerCachee
: IDisposable : IDisposable
{ {
static ExClientServerCachee()
{
Sheduller.RemindEvery(TimeSpan.FromSeconds(30), () => { Log.Info(string.Join("\r\n", _clientInstances.Keys)); });
}
private static readonly ConcurrentDictionary<string, ExClient> _clientInstances = new ConcurrentDictionary<string, ExClient>(); private static readonly ConcurrentDictionary<string, ExClient> _clientInstances = new ConcurrentDictionary<string, ExClient>();
private static readonly ConcurrentDictionary<string, object> _clientLocks = new ConcurrentDictionary<string, object>(); private static readonly ConcurrentDictionary<string, object> _clientLocks = new ConcurrentDictionary<string, object>();

@ -11,8 +11,8 @@ namespace ZeroLevel.Network
internal sealed class Router internal sealed class Router
: IRouter : IRouter
{ {
public event Action<ISocketClient> OnDisconnect = _ => { }; public event Action<ISocketClient> OnDisconnect = _ => { }; // must be never rised
public event Action<ExClient> OnConnect = _ => { }; public event Action<ExClient> OnConnect = _ => { }; // must be never rised
#region Routing #region Routing

@ -5,7 +5,7 @@
<Description>Infrastructure layer library</Description> <Description>Infrastructure layer library</Description>
<Authors>ogoun</Authors> <Authors>ogoun</Authors>
<Company>ogoun</Company> <Company>ogoun</Company>
<AssemblyVersion>3.0.0.2</AssemblyVersion> <AssemblyVersion>3.0.0.3</AssemblyVersion>
<PackageReleaseNotes>Fix file transfer <PackageReleaseNotes>Fix file transfer
Expand serialization types</PackageReleaseNotes> Expand serialization types</PackageReleaseNotes>
<PackageProjectUrl>https://github.com/ogoun/Zero/wiki</PackageProjectUrl> <PackageProjectUrl>https://github.com/ogoun/Zero/wiki</PackageProjectUrl>
@ -14,8 +14,8 @@ Expand serialization types</PackageReleaseNotes>
<PackageIconUrl>https://raw.githubusercontent.com/ogoun/Zero/master/zero.png</PackageIconUrl> <PackageIconUrl>https://raw.githubusercontent.com/ogoun/Zero/master/zero.png</PackageIconUrl>
<RepositoryUrl>https://github.com/ogoun/Zero</RepositoryUrl> <RepositoryUrl>https://github.com/ogoun/Zero</RepositoryUrl>
<RepositoryType>GitHub</RepositoryType> <RepositoryType>GitHub</RepositoryType>
<Version>3.0.2</Version> <Version>3.0.3</Version>
<FileVersion>3.0.0.2</FileVersion> <FileVersion>3.0.0.3</FileVersion>
</PropertyGroup> </PropertyGroup>
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'"> <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">

Loading…
Cancel
Save

Powered by TurnKey Linux.