Parsing

Esiur/Data/Codec.cs

@@ -197,6 +197,8 @@ public static class Codec
 
         var tt = dataType.Value;
 
+        Console.WriteLine("Parsing " + tt.Class + " " + tt.Identifier);
+
         if (tt.Class == TransmissionTypeClass.Fixed)
         {
             return (len, FixedAsyncParsers[tt.Exponent][tt.Index](data, dataType.Value.Offset, (uint)tt.ContentLength, connection, requestSequence));

Esiur/Net/IIP/DistributedConnectionProtocol.cs

@@ -1692,23 +1692,30 @@ partial class DistributedConnection
 
         var rt = new AsyncReply<IResource>();
 
-        Query(path).Then(ar =>
+        SendRequest(IIPPacketRequest.GetResourceIdByLink, path)
-        {
+            .Then(result =>
+            {
+                rt.Trigger(result);
+            }).Error(ex => rt.TriggerError(ex));
 
-            //if (filter != null)
+        //Query(path).Then(ar =>
-            //  ar = ar?.Where(filter).ToArray();
+        //{
 
-            // MISSING: should dispatch the unused resources. 
+        //    //if (filter != null)
-            if (ar?.Length > 0)
+        //    //  ar = ar?.Where(filter).ToArray();
-                rt.Trigger(ar[0]);
+
-            else
+        //    // MISSING: should dispatch the unused resources. 
-                rt.Trigger(null);
+        //    if (ar?.Length > 0)
-        }).Error(ex => rt.TriggerError(ex));
+        //        rt.Trigger(ar[0]);
+        //    else
+        //        rt.Trigger(null);
+        //}).Error(ex => rt.TriggerError(ex));
 
 
         return rt;
     }
 
+
     public AsyncReply<TypeTemplate[]> GetLinkTemplates(string link)
     {
         var reply = new AsyncReply<TypeTemplate[]>();
@@ -1743,6 +1750,7 @@ partial class DistributedConnection
     /// <returns>DistributedResource</returns>
     public AsyncReply<DistributedResource> Fetch(uint id, uint[] requestSequence)
     {
+
         DistributedResource resource = null;
 
         attachedResources[id]?.TryGetTarget(out resource);
@@ -1758,22 +1766,30 @@ partial class DistributedConnection
         {
             if (resource != null && (requestSequence?.Contains(id) ?? false))
             {
+                Console.WriteLine("Fetching DL " + id);
+
                 // dead lock avoidance for loop reference.
                 return new AsyncReply<DistributedResource>(resource);
             }
             else if (resource != null && requestInfo.RequestSequence.Contains(id))
             {
+                Console.WriteLine("Fetching DL2 " + id);
+
                 // dead lock avoidance for dependent reference.
                 return new AsyncReply<DistributedResource>(resource);
             }
             else
             {
+                Console.WriteLine("Fetching DL3 " + id);
+
                 return requestInfo.Reply;
             }
         }
         else if (resource != null && !resource.DistributedResourceSuspended)
         {
             // @REVIEW: this should never happen
+            Console.WriteLine("Fetching DLWWW " + id);
+
             Global.Log("DCON", LogType.Error, "Resource not moved to attached.");
             return new AsyncReply<DistributedResource>(resource);
 
@@ -1783,6 +1799,7 @@ partial class DistributedConnection
 
         var reply = new AsyncReply<DistributedResource>();
         resourceRequests.Add(id, new DistributedResourceAttachRequestInfo(reply, newSequence));
+        Console.WriteLine("Fetching " + id);
 
         SendRequest(IIPPacketRequest.AttachResource, id)
                     .Then((result) =>
@@ -1802,6 +1819,8 @@ partial class DistributedConnection
                         var hops = (byte)args[3];
                         var pvData = (byte[])args[4];
 
+                        Console.WriteLine("Fetching CL " + id);
+
                         DistributedResource dr;
                         TypeTemplate template = null;
 

Esiur/Net/IIP/DistributedResource.cs

@@ -169,7 +169,7 @@ public class DistributedResource : DynamicObject, IResource, INotifyPropertyChan
     }
 
     /// <summary>
-    /// Export all properties with ResourceProperty attributed as bytes array.
+    /// Export properties as byte array.
     /// </summary>
     /// <returns></returns>
     internal PropertyValue[] _Serialize()

Test/Program.cs

@@ -190,7 +190,7 @@ namespace Test
             var format = x.RequiredFormat;
 
             if (format == IIPAuthPacketIAuthFormat.Number)
-                return new AsyncReply<object>(Convert.ToInt32(Console.ReadLine()));
+                return new AsyncReply<object>(Convert.ToInt32(10));
             else if (format == IIPAuthPacketIAuthFormat.Text)
                 return new AsyncReply<object>(Console.ReadLine().Trim());