esiur/esiur-dotnet
2
0
Fork 0
mirror of https://github.com/esiur/esiur-dotnet.git synced 2025-09-13 20:43:19 +00:00
Code Issues Projects Releases Wiki Activity

a

Browse Source
This commit is contained in:
ahmed
2025-08-13 11:42:34 +03:00
parent 24a2eadec5
commit c475f403ce
6 changed files with 145 additions and 88 deletions
Download Patch File Download Diff File Expand all files Collapse all files

68
Esiur/Core/AsyncBag.cs
View File

@@ -38,8 +38,8 @@ interface IAsyncBag
public class AsyncBag<T> : AsyncReply, IAsyncBag public class AsyncBag<T> : AsyncReply, IAsyncBag
{ {
protected List<AsyncReply> replies = new List<AsyncReply>(); protected List<object> replies = new List<object>();
List<T> results = new(); //List<T> results = new();
int count = 0; int count = 0;
bool sealedBag = false; bool sealedBag = false;
@@ -75,62 +75,54 @@ public class AsyncBag<T> : AsyncReply, IAsyncBag
sealedBag = true; sealedBag = true;
if (results.Count == 0) var results = ArrayType == null ? new T[replies.Count]
: Array.CreateInstance(ArrayType, replies.Count);
if (replies.Count == 0)
{ {
if (ArrayType != null) Trigger(results);
{ return;
var ar = Array.CreateInstance(ArrayType, 0);
Trigger(ar);
}
else
{
Trigger(new object[0]);
}
} }
for (var i = 0; i < results.Count; i++) for (var i = 0; i < replies.Count; i++)
//foreach(var reply in results.Keys)
{ {
var k = replies[i];// results.Keys.ElementAt(i); var k = replies[i];
var index = i; var index = i;
k.Then((r) => if (k is AsyncReply)
{ {
results[index] = (T)r; (k as AsyncReply).Then((r) =>
{
results.SetValue(r, i);
count++; count++;
if (count == results.Count) if (count == replies.Count)
{ Trigger(results);
if (ArrayType != null) });
{
try
{
// @TODO: Safe casting check
var ar = Array.CreateInstance(ArrayType, count);
for (var i = 0; i < count; i++)
ar.SetValue(results[i], i);
Trigger(ar);
}
catch
{
Trigger(results.ToArray());
}
} }
else else
Trigger(results.ToArray()); {
results.SetValue(replies[i], i);
count++;
if (count == replies.Count)
Trigger(results);
} }
});
} }
} }
public void Add(AsyncReply reply)
public void Add(object valueOrReply)
{ {
if (!sealedBag) if (!sealedBag)
{ {
results.Add(default(T)); //if (valueOrReply is AsyncReply)
replies.Add(reply); //{
// results.Add(default(T));
replies.Add(valueOrReply);
//}
} }
} }
public void AddBag(AsyncBag<T> bag) public void AddBag(AsyncBag<T> bag)
{ {
foreach (var r in bag.replies) foreach (var r in bag.replies)

34
Esiur/Data/Codec.cs
View File

@@ -39,42 +39,46 @@ namespace Esiur.Data;
public static class Codec public static class Codec
{ {
delegate AsyncReply AsyncParser(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence); //delegate AsyncReply AsyncParser(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence);
delegate object SyncParser(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence); delegate object SyncParser(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence);
static AsyncParser[][] FixedParsers = new AsyncParser[][] static SyncParser[][] FixedParsers = new SyncParser[][]
{ {
new AsyncParser[]{ new SyncParser[]{
DataDeserializer.NullParser, DataDeserializer.NullParser,
DataDeserializer.BooleanFalseParser, DataDeserializer.BooleanFalseParser,
DataDeserializer.BooleanTrueParser, DataDeserializer.BooleanTrueParser,
DataDeserializer.NotModifiedParser, DataDeserializer.NotModifiedParser,
}, },
new AsyncParser[]{ new SyncParser[]{
DataDeserializer.ByteParser, DataDeserializer.ByteParser,
DataDeserializer.SByteParser, DataDeserializer.SByteParser,
DataDeserializer.Char8Parser, DataDeserializer.Char8Parser,
DataDeserializer.LocalResourceParser8,
DataDeserializer.ResourceParser8,
}, },
new AsyncParser[]{ new SyncParser[]{
DataDeserializer.Int16Parser, DataDeserializer.Int16Parser,
DataDeserializer.UInt16Parser, DataDeserializer.UInt16Parser,
DataDeserializer.Char16Parser, DataDeserializer.Char16Parser,
DataDeserializer.LocalResourceParser16,
DataDeserializer.ResourceParser16,
}, },
new AsyncParser[]{ new SyncParser[]{
DataDeserializer.Int32Parser, DataDeserializer.Int32Parser,
DataDeserializer.UInt32Parser, DataDeserializer.UInt32Parser,
DataDeserializer.Float32Parser, DataDeserializer.Float32Parser,
DataDeserializer.ResourceParser, DataDeserializer.LocalResourceParser32,
DataDeserializer.LocalResourceParser, DataDeserializer.ResourceParser32,
}, },
new AsyncParser[]{ new SyncParser[]{
DataDeserializer.Int64Parser, DataDeserializer.Int64Parser,
DataDeserializer.UInt64Parser, DataDeserializer.UInt64Parser,
DataDeserializer.Float64Parser, DataDeserializer.Float64Parser,
DataDeserializer.DateTimeParser, DataDeserializer.DateTimeParser,
}, },
new AsyncParser[] new SyncParser[]
{ {
DataDeserializer.Int128Parser, // int 128 DataDeserializer.Int128Parser, // int 128
DataDeserializer.UInt128Parser, // uint 128 DataDeserializer.UInt128Parser, // uint 128
@@ -82,7 +86,7 @@ public static class Codec
} }
}; };
static AsyncParser[] DynamicParsers = new AsyncParser[] static SyncParser[] DynamicParsers = new SyncParser[]
{ {
DataDeserializer.RawDataParser, DataDeserializer.RawDataParser,
DataDeserializer.StringParser, DataDeserializer.StringParser,
@@ -91,7 +95,7 @@ public static class Codec
DataDeserializer.RecordListParser, DataDeserializer.RecordListParser,
}; };
static AsyncParser[] TypedParsers = new AsyncParser[] static SyncParser[] TypedParsers = new SyncParser[]
{ {
DataDeserializer.RecordParser, DataDeserializer.RecordParser,
DataDeserializer.TypedListParser, DataDeserializer.TypedListParser,
@@ -111,7 +115,7 @@ public static class Codec
/// <param name="connection">DistributedConnection is required in case a structure in the array holds items at the other end.</param> /// <param name="connection">DistributedConnection is required in case a structure in the array holds items at the other end.</param>
/// <param name="dataType">DataType, in case the data is not prepended with DataType</param> /// <param name="dataType">DataType, in case the data is not prepended with DataType</param>
/// <returns>Value</returns> /// <returns>Value</returns>
public static (uint, AsyncReply) ParseAsync(byte[] data, uint offset, DistributedConnection connection, uint[] requestSequence, TransmissionType? dataType = null) public static (uint, object) ParseAsync(byte[] data, uint offset, DistributedConnection connection, uint[] requestSequence, TransmissionType? dataType = null)
{ {
uint len = 0; uint len = 0;
@@ -144,10 +148,6 @@ public static class Codec
} }
} }
public static uint ParseSync(byte[] data, uint offset, TransmissionType? dataType = null)
{
}
/// <summary> /// <summary>
/// Check if a resource is local to a given connection. /// Check if a resource is local to a given connection.

45
Esiur/Data/DataDeserializer.cs
View File

@@ -72,7 +72,7 @@ public static class DataDeserializer
return *(int*)ptr; return *(int*)ptr;
} }
public static unsafe uint UInt32Parser(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence) public static unsafe object UInt32Parser(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence)
{ {
fixed (byte* ptr = &data[offset]) fixed (byte* ptr = &data[offset])
return *(uint*)ptr; return *(uint*)ptr;
@@ -129,16 +129,55 @@ public static class DataDeserializer
} }
public static unsafe object ResourceParser8(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence)
{
if (connection == null)
return new ResourceId(false, data[offset]);
else
return connection.Fetch(data[offset], requestSequence);
}
public static unsafe object ResourceParser(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence) public static unsafe object LocalResourceParser8(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence)
{
if (connection == null)
return new ResourceId(true, data[offset]);
else
return Warehouse.GetById(data[offset]);
}
public static unsafe object ResourceParser16(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence)
{ {
fixed (byte* ptr = &data[offset]) fixed (byte* ptr = &data[offset])
if (connection == null)
return new ResourceId(false, *(ushort*)ptr);
else
return connection.Fetch(*(ushort*)ptr, requestSequence);
}
public static unsafe object LocalResourceParser16(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence)
{
fixed (byte* ptr = &data[offset])
if (connection == null)
return new ResourceId(true, *(ushort*)ptr);
else
return Warehouse.GetById(*(ushort*)ptr);
}
public static unsafe object ResourceParser32(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence)
{
fixed (byte* ptr = &data[offset])
if (connection == null)
return new ResourceId(false, *(uint*)ptr);
else
return connection.Fetch(*(uint*)ptr, requestSequence); return connection.Fetch(*(uint*)ptr, requestSequence);
} }
public static unsafe object LocalResourceParser(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence) public static unsafe object LocalResourceParser32(byte[] data, uint offset, uint length, DistributedConnection connection, uint[] requestSequence)
{ {
fixed (byte* ptr = &data[offset]) fixed (byte* ptr = &data[offset])
if (connection == null)
return new ResourceId(true, *(uint*)ptr);
else
return Warehouse.GetById(*(uint*)ptr); return Warehouse.GetById(*(uint*)ptr);
} }

18
Esiur/Data/ResourceId.cs Normal file
View File

@@ -0,0 +1,18 @@
using System;
using System.Collections.Generic;
using System.Text;
namespace Esiur.Data
{
public struct ResourceId
{
public bool Local;
public uint Id;
public ResourceId(bool local, uint id)
{
this.Id = id;
this.Local = local;
}
}
}

42
Esiur/Data/TransmissionType.cs
View File

@@ -14,21 +14,31 @@ public enum TransmissionTypeIdentifier : byte
UInt8 = 0x8, UInt8 = 0x8,
Int8 = 0x9, Int8 = 0x9,
Char8 = 0xA, Char8 = 0xA,
Int16 = 0x10, LocalResource8 = 0xB,
UInt16 = 0x11, RemoteResource8 = 0xC,
LocalProcedure8 = 0xD,
RemoteProcedure8 = 0xE,
UInt16 = 0x10,
Int16 = 0x11,
Char16 = 0x12, Char16 = 0x12,
Int32 = 0x18, LocalResource16 = 0x13,
UInt32 = 0x19, RemoteResource16 = 0x14,
LocalProcedure16 = 0x15,
RemoteProcedure16 = 0x16,
UInt32 = 0x18,
Int32 = 0x19,
Float32 = 0x1A, Float32 = 0x1A,
Resource = 0x1B, LocalResource32 = 0x1B,
ResourceLocal = 0x1C, RemoteResource32 = 0x1C,
Int64 = 0x20, LocalProcedure32 = 0x1D,
UInt64 = 0x21, RemoteProcedure32 = 0x1E,
UInt64 = 0x20,
Int64 = 0x21,
Float64 = 0x22, Float64 = 0x22,
DateTime = 0x23, DateTime = 0x23,
Int128 = 0x28, UInt128 = 0x28,
UInt128 = 0x29, Int128 = 0x29,
Float128 = 0x2A, Decimal128 = 0x2A,
RawData = 0x40, RawData = 0x40,
String = 0x41, String = 0x41,
@@ -37,17 +47,15 @@ public enum TransmissionTypeIdentifier : byte
RecordList = 0x44, RecordList = 0x44,
Map = 0x45, Map = 0x45,
MapList = 0x46, MapList = 0x46,
//Tuple = 0x47,
Record = 0x80, Record = 0x80,
TypedList = 0x81, TypedList = 0x81,
TypedMap = 0x82, TypedMap = 0x82,
Tuple = 0x83, TypedTuple = 0x83,
Enum = 0x84, TypedEnum = 0x84,
Constant = 0x85 TypedConstant = 0x85,
//TypedResourceList = 0x81,
//TypedRecordList = 0x82,
ResourceLink = 0xC0
} }
public enum TransmissionTypeClass public enum TransmissionTypeClass

2
Esiur/Net/IIP/DistributedConnectionProtocol.cs
View File

@@ -2152,7 +2152,7 @@ partial class DistributedConnection
var dataType = (TransmissionType)ar[0]; var dataType = (TransmissionType)ar[0];
var data = (byte[])ar[1]; var data = (byte[])ar[1];
var (_, parsed) = Codec.Parse(data, dataType.Offset, this, null, dataType); var (_, parsed) = Codec.ParseAsync(data, dataType.Offset, this, null, dataType);
parsed.Then(resources => rt.Trigger(resources)) parsed.Then(resources => rt.Trigger(resources))
.Error(ex => rt.TriggerError(ex)); .Error(ex => rt.TriggerError(ex));