Changeset 13358 for branches/PersistenceOverhaul/HeuristicLab.Persistence/4.0/Core/Mapper.cs

Timestamp:

11/24/15 15:22:21 (9 years ago)

Author:

swagner

Message:

#2520: Worked on new persistence implementation

File:

• branches/PersistenceOverhaul/HeuristicLab.Persistence/4.0/Core/Mapper.cs (modified) (8 diffs)

branches/PersistenceOverhaul/HeuristicLab.Persistence/4.0/Core/Mapper.cs

@@ -29 +29 @@
 namespace HeuristicLab.Persistence {
   public sealed class Mapper {
+    private static StaticCache staticCache = null;
+    private static object locker = new object();
+    public static StaticCache StaticCache {
+      get {
+        lock (locker) {
+          if (staticCache == null) staticCache = new StaticCache();
+          return staticCache;
+        }
+      }
+    }
+
     private Index<ITransformer> transformers;
-    private Dictionary<Type, TypeInfo> typeInfos;
     private Index<Type> types;
     private Index<string> strings;
     private Index<Box> boxes;
-    private Dictionary<object, uint> boxCache;
-    private Dictionary<uint, object> objectCache;
+    private Dictionary<object, uint> object2BoxId;
+    private Dictionary<uint, object> boxId2object;
 
     public long BoxCount { get; private set; }
@@ -41 +51 @@
     public Mapper() {
       transformers = new Index<ITransformer>();
-      typeInfos = new Dictionary<Type, TypeInfo>();
       types = new Index<Type>();
       strings = new Index<string>();
       boxes = new Index<Box>();
-      boxCache = new Dictionary<object, uint>(new ReferenceEqualityComparer<object>());
-      objectCache = new Dictionary<uint, object>();
+      object2BoxId = new Dictionary<object, uint>(new ReferenceEqualityComparer<object>());
+      boxId2object = new Dictionary<uint, object>();
 
       BoxCount = 0;
-
-      foreach (var transformer in ApplicationManager.Manager.GetInstances<ITransformer>().OrderBy(x => x.Order)) {
-        transformer.Initialize(transformers.GetIndex(transformer));
-      }
     }
 
-    public TypeInfo GetTypeInfo(Type type) {
-      TypeInfo typeInfo;
-      if (!typeInfos.TryGetValue(type, out typeInfo)) {
-        var transformer = transformers.GetValues().Where(x => x.CanTransformType(type)).FirstOrDefault();
-        typeInfo = new TypeInfo(type, transformer);
-        typeInfos.Add(type, typeInfo);
-      }
-      return typeInfo;
+    public uint GetTransformerId(ITransformer transformer) {
+      return transformers.GetIndex(transformer);
     }
-    public IEnumerable<TypeInfo> GetTypeInfos() {
-      return typeInfos.Values;
-    }
-    public IEnumerable<Type> GetTypes() {
-      return typeInfos.Values.Select(x => x.Type);
+    public ITransformer GetTransformer(uint transformerId) {
+      return transformers.GetValue(transformerId);
     }
 
@@ -87 +83 @@
     public uint GetBoxId(object o) {
       uint boxId;
-      if (boxCache.TryGetValue(o, out boxId)) return boxId;
+      if (object2BoxId.TryGetValue(o, out boxId)) return boxId;
 
       if (o == null)
@@ -93 +89 @@
       else {
         var type = o.GetType();
-        var typeInfo = GetTypeInfo(type);
+        var typeInfo = StaticCache.GetTypeInfo(type);
         if (typeInfo.Transformer == null) throw new ArgumentException("Cannot serialize object of type " + o.GetType());
         BoxCount++;
@@ -99 +95 @@
         boxId = boxes.GetIndex(typeInfo.Transformer.ToBox(o, this));
       }
-      boxCache.Add(o, boxId);
+      object2BoxId.Add(o, boxId);
       return boxId;
     }
     public object GetObject(uint boxId) {
       object o;
-      if (objectCache.TryGetValue(boxId, out o)) return o;
+      if (boxId2object.TryGetValue(boxId, out o)) return o;
 
       var box = this.boxes.GetValue(boxId);
@@ -113 +109 @@
         o = transformer.ToObject(box, this);
       }
-      objectCache.Add(boxId, o);
+      boxId2object.Add(boxId, o);
       return o;
     }
 
     public object CreateInstance(Type type) {
-      return GetTypeInfo(type).GetConstructor()();
+      return StaticCache.GetTypeInfo(type).GetConstructor()();
     }
 
@@ -126 +122 @@
       bundle.RootBoxId = mapper.GetBoxId(o);
       bundle.AddRangeTransformerGuids(mapper.transformers.GetValues().Select(x => x.Guid).Select(x => ByteString.CopyFrom(x.ToByteArray())));
-      bundle.AddRangeTypeGuids(mapper.types.GetValues().Select(x => mapper.typeInfos[x].StorableClassAttribute.Guid).Select(x => ByteString.CopyFrom(x.ToByteArray())));
+      bundle.AddRangeTypeGuids(mapper.types.GetValues().Select(x => StaticCache.GetGuid(x)).Select(x => ByteString.CopyFrom(x.ToByteArray())));
       bundle.AddRangeStrings(mapper.strings.GetValues());
       bundle.AddRangeBoxes(mapper.boxes.GetValues());
@@ -132 +128 @@
     }
     public static object ToObject(Bundle bundle) {
-      var types = new Dictionary<Guid, Type>();
-      foreach (var asm in AppDomain.CurrentDomain.GetAssemblies()) {
-        foreach (var t in asm.GetTypes().Where(x => StorableClassAttribute.IsStorableClass(x)))
-          types.Add(StorableClassAttribute.GetStorableClassAttribute(t).Guid, t);
-      }
-
       var mapper = new Mapper();
-      mapper.types = new Index<Type>(bundle.TypeGuidsList.Select(x => new Guid(x.ToByteArray())).Select(x => types[x]));
+      mapper.types = new Index<Type>(bundle.TypeGuidsList.Select(x => new Guid(x.ToByteArray())).Select(x => StaticCache.GetType(x)));
       mapper.strings = new Index<string>(bundle.StringsList);
       mapper.boxes = new Index<Box>(bundle.BoxesList);
-      mapper.transformers = new Index<ITransformer>(bundle.TransformerGuidsList.Select(x => new Guid(x.ToByteArray())).Select(x => mapper.transformers.GetValues().First(y => y.Guid == x)));
-      foreach (var type in mapper.types.GetValues())
-        mapper.typeInfos.Add(type, new TypeInfo(type));
-
+      mapper.transformers = new Index<ITransformer>(bundle.TransformerGuidsList.Select(x => new Guid(x.ToByteArray())).Select(x => StaticCache.GetTransformer(x)));
       return mapper.GetObject(bundle.RootBoxId);
     }