3 files changed, 627 insertions, 25 deletions

diff --git a/OpenSim/Framework/IClientAPI.cs b/OpenSim/Framework/IClientAPI.cs
index 9fd043c..9aa3af1 100644
--- a/OpenSim/Framework/IClientAPI.cs
+++ b/OpenSim/Framework/IClientAPI.cs
@@ -517,6 +517,233 @@ namespace OpenSim.Framework
         public float dwell;
     }
 
+    public struct SendAvatarData
+    {
+        private ulong m_regionHandle;
+        private string m_firstName;
+        private string m_lastName;
+        private string m_grouptitle;
+        private UUID m_avatarID;
+        private uint m_avatarLocalID;
+        private Vector3 m_Pos;
+        private byte[] m_textureEntry;
+        private uint m_parentID;
+        private Quaternion m_rotation;
+
+        public SendAvatarData(ulong regionHandle, string firstName, string lastName, string grouptitle, UUID avatarID,
+                            uint avatarLocalID,
+                            Vector3 Pos, byte[] textureEntry, uint parentID, Quaternion rotation)
+        {
+            this.m_regionHandle = regionHandle;
+            this.m_firstName = firstName;
+            this.m_lastName = lastName;
+            this.m_grouptitle = grouptitle;
+            this.m_avatarID = avatarID;
+            this.m_avatarLocalID = avatarLocalID;
+            this.m_Pos = Pos;
+            this.m_textureEntry = textureEntry;
+            this.m_parentID = parentID;
+            this.m_rotation = rotation;
+        }
+
+        public ulong regionHandle { get { return this.m_regionHandle; } }
+        public string firstName { get { return this.m_firstName; } }
+        public string lastName { get { return this.m_lastName; } }
+        public string grouptitle { get { return this.m_grouptitle; } }
+        public UUID avatarID { get { return this.m_avatarID; } }
+        public uint avatarLocalID { get { return this.m_avatarLocalID; } }
+        public Vector3 Pos { get { return this.m_Pos; } }
+        public byte[] textureEntry { get { return this.m_textureEntry; } }
+        public uint parentID { get { return this.m_parentID; } }
+        public Quaternion rotation { get { return this.m_rotation; } }
+    }
+
+    public struct SendAvatarTerseData
+    {
+        private ulong m_regionHandle;
+        private ushort m_timeDilation;
+        private uint m_localID;
+        private Vector3 m_position;
+        private Vector3 m_velocity;
+        private Quaternion m_rotation;
+        private UUID m_agentid;
+        private double m_priority;
+
+        public SendAvatarTerseData(ulong regionHandle, ushort timeDilation, uint localID, Vector3 position,
+                                   Vector3 velocity, Quaternion rotation, UUID agentid, double priority)
+        {
+            this.m_regionHandle = regionHandle;
+            this.m_timeDilation = timeDilation;
+            this.m_localID = localID;
+            this.m_position = position;
+            this.m_velocity = velocity;
+            this.m_rotation = rotation;
+            this.m_agentid = agentid;
+            this.m_priority = priority;
+        }
+
+        public ulong regionHandle { get { return this.m_regionHandle; } }
+        public ushort timeDilation { get { return this.m_timeDilation; } }
+        public uint localID { get { return this.m_localID; } }
+        public Vector3 position { get { return this.m_position; } }
+        public Vector3 velocity { get { return this.m_velocity; } }
+        public Quaternion rotation { get { return this.m_rotation; } }
+        public UUID agentid { get { return this.m_agentid; } }
+        public double priority { get { return this.m_priority; } }
+    }
+
+    public struct SendPrimitiveTerseData
+    {
+        private ulong m_regionHandle;
+        private ushort m_timeDilation;
+        private uint m_localID;
+        private Vector3 m_position;
+        private Quaternion m_rotation;
+        private Vector3 m_velocity;
+        private Vector3 m_rotationalvelocity;
+        private byte m_state;
+        private UUID m_AssetId;
+        private UUID m_owner;
+        private int m_attachPoint;
+        private double m_priority;
+
+        public SendPrimitiveTerseData(ulong regionHandle, ushort timeDilation, uint localID, Vector3 position,
+                                 Quaternion rotation, Vector3 velocity, Vector3 rotationalvelocity, byte state,
+                                 UUID AssetId, UUID owner, int attachPoint, double priority)
+        {
+            this.m_regionHandle = regionHandle;
+            this.m_timeDilation = timeDilation;
+            this.m_localID = localID;
+            this.m_position = position;
+            this.m_rotation = rotation;
+            this.m_velocity = velocity;
+            this.m_rotationalvelocity = rotationalvelocity;
+            this.m_state = state;
+            this.m_AssetId = AssetId;
+            this.m_owner = owner;
+            this.m_attachPoint = attachPoint;
+            this.m_priority = priority;
+        }
+
+        public ulong regionHandle { get { return this.m_regionHandle; } }
+        public ushort timeDilation { get { return this.m_timeDilation; } }
+        public uint localID { get { return this.m_localID; } }
+        public Vector3 position { get { return this.m_position; } }
+        public Quaternion rotation { get { return this.m_rotation; } }
+        public Vector3 velocity { get { return this.m_velocity; } }
+        public Vector3 rotationalvelocity { get { return this.m_rotationalvelocity; } }
+        public byte state { get { return this.m_state; } }
+        public UUID AssetId { get { return this.m_AssetId; } }
+        public UUID owner { get { return this.m_owner; } }
+        public int attachPoint { get { return this.m_attachPoint; } }
+        public double priority { get { return this.m_priority; } }
+    }
+
+    public struct SendPrimitiveData
+    {
+        private ulong m_regionHandle;
+        private ushort m_timeDilation;
+        private uint m_localID;
+        private PrimitiveBaseShape m_primShape;
+        private Vector3 m_pos;
+        private Vector3 m_vel;
+        private Vector3 m_acc;
+        private Quaternion m_rotation;
+        private Vector3 m_rvel;
+        private uint m_flags;
+        private UUID m_objectID;
+        private UUID m_ownerID;
+        private string m_text;
+        private byte[] m_color;
+        private uint m_parentID;
+        private byte[] m_particleSystem;
+        private byte m_clickAction;
+        private byte m_material;
+        private byte[] m_textureanim;
+        private bool m_attachment;
+        private uint m_AttachPoint;
+        private UUID m_AssetId;
+        private UUID m_SoundId;
+        private double m_SoundVolume;
+        private byte m_SoundFlags;
+        private double m_SoundRadius;
+        private double m_priority;
+
+        public SendPrimitiveData(ulong regionHandle, ushort timeDilation, uint localID, PrimitiveBaseShape primShape,
+                                   Vector3 pos, Vector3 vel, Vector3 acc, Quaternion rotation, Vector3 rvel,
+                                   uint flags, UUID objectID, UUID ownerID, string text, byte[] color,
+                                   uint parentID, byte[] particleSystem, byte clickAction, byte material, double priority) :
+            this(regionHandle, timeDilation, localID, primShape, pos, vel, acc, rotation, rvel, flags, objectID,
+            ownerID, text, color, parentID, particleSystem, clickAction, material, new byte[0], false, 0, UUID.Zero,
+            UUID.Zero, 0, 0, 0, priority) { }
+
+        public SendPrimitiveData(ulong regionHandle, ushort timeDilation, uint localID, PrimitiveBaseShape primShape,
+                                   Vector3 pos, Vector3 vel, Vector3 acc, Quaternion rotation, Vector3 rvel,
+                                   uint flags,
+                                   UUID objectID, UUID ownerID, string text, byte[] color, uint parentID,
+                                   byte[] particleSystem,
+                                   byte clickAction, byte material, byte[] textureanim, bool attachment,
+                                   uint AttachPoint, UUID AssetId, UUID SoundId, double SoundVolume, byte SoundFlags,
+                                   double SoundRadius, double priority)
+        {
+            this.m_regionHandle = regionHandle;
+            this.m_timeDilation = timeDilation;
+            this.m_localID = localID;
+            this.m_primShape = primShape;
+            this.m_pos = pos;
+            this.m_vel = vel;
+            this.m_acc = acc;
+            this.m_rotation = rotation;
+            this.m_rvel = rvel;
+            this.m_flags = flags;
+            this.m_objectID = objectID;
+            this.m_ownerID = ownerID;
+            this.m_text = text;
+            this.m_color = color;
+            this.m_parentID = parentID;
+            this.m_particleSystem = particleSystem;
+            this.m_clickAction = clickAction;
+            this.m_material = material;
+            this.m_textureanim = textureanim;
+            this.m_attachment = attachment;
+            this.m_AttachPoint = AttachPoint;
+            this.m_AssetId = AssetId;
+            this.m_SoundId = SoundId;
+            this.m_SoundVolume = SoundVolume;
+            this.m_SoundFlags = SoundFlags;
+            this.m_SoundRadius = SoundRadius;
+            this.m_priority = priority;
+        }
+
+        public ulong regionHandle { get { return this.m_regionHandle; } }
+        public ushort timeDilation { get { return this.m_timeDilation; } }
+        public uint localID { get { return this.m_localID; } }
+        public PrimitiveBaseShape primShape { get { return this.m_primShape; } }
+        public Vector3 pos { get { return this.m_pos; } }
+        public Vector3 vel { get { return this.m_vel; } }
+        public Vector3 acc { get { return this.m_acc; } }
+        public Quaternion rotation { get { return this.m_rotation; } }
+        public Vector3 rvel { get { return this.m_rvel; } }
+        public uint flags { get { return this.m_flags; } }
+        public UUID objectID { get { return this.m_objectID; } }
+        public UUID ownerID { get { return this.m_ownerID; } }
+        public string text { get { return this.m_text; } }
+        public byte[] color { get { return this.m_color; } }
+        public uint parentID { get { return this.m_parentID; } }
+        public byte[] particleSystem { get { return this.m_particleSystem; } }
+        public byte clickAction { get { return this.m_clickAction; } }
+        public byte material { get { return this.m_material; } }
+        public byte[] textureanim { get { return this.m_textureanim; } }
+        public bool attachment { get { return this.m_attachment; } }
+        public uint AttachPoint { get { return this.m_AttachPoint; } }
+        public UUID AssetId { get { return this.m_AssetId; } }
+        public UUID SoundId { get { return this.m_SoundId; } }
+        public double SoundVolume { get { return this.m_SoundVolume; } }
+        public byte SoundFlags { get { return this.m_SoundFlags; } }
+        public double SoundRadius { get { return this.m_SoundRadius; } }
+        public double priority { get { return this.m_priority; } }
+    }
+
     public interface IClientAPI
     {
         Vector3 StartPos { get; set; }
@@ -878,37 +1105,18 @@ namespace OpenSim.Framework
         void SendMoneyBalance(UUID transaction, bool success, byte[] description, int balance);
         void SendPayPrice(UUID objectID, int[] payPrice);
 
-        void SendAvatarData(ulong regionHandle, string firstName, string lastName, string grouptitle, UUID avatarID,
-                            uint avatarLocalID,
-                            Vector3 Pos, byte[] textureEntry, uint parentID, Quaternion rotation);
+        void SendAvatarData(SendAvatarData data);
 
-        void SendAvatarTerseUpdate(ulong regionHandle, ushort timeDilation, uint localID, Vector3 position,
-                                   Vector3 velocity, Quaternion rotation, UUID agentid);
+        void SendAvatarTerseUpdate(SendAvatarTerseData data);
 
         void SendCoarseLocationUpdate(List<UUID> users, List<Vector3> CoarseLocations);
 
         void AttachObject(uint localID, Quaternion rotation, byte attachPoint, UUID ownerID);
         void SetChildAgentThrottle(byte[] throttle);
 
-        void SendPrimitiveToClient(ulong regionHandle, ushort timeDilation, uint localID, PrimitiveBaseShape primShape,
-                                   Vector3 pos, Vector3 vel, Vector3 acc, Quaternion rotation, Vector3 rvel,
-                                   uint flags,
-                                   UUID objectID, UUID ownerID, string text, byte[] color, uint parentID,
-                                   byte[] particleSystem,
-                                   byte clickAction, byte material, byte[] textureanim, bool attachment,
-                                   uint AttachPoint, UUID AssetId, UUID SoundId, double SoundVolume, byte SoundFlags,
-                                   double SoundRadius);
-
+        void SendPrimitiveToClient(SendPrimitiveData data);
 
-        void SendPrimitiveToClient(ulong regionHandle, ushort timeDilation, uint localID, PrimitiveBaseShape primShape,
-                                   Vector3 pos, Vector3 vel, Vector3 acc, Quaternion rotation, Vector3 rvel,
-                                   uint flags, UUID objectID, UUID ownerID, string text, byte[] color,
-                                   uint parentID, byte[] particleSystem, byte clickAction, byte material);
-
-
-        void SendPrimTerseUpdate(ulong regionHandle, ushort timeDilation, uint localID, Vector3 position,
-                                 Quaternion rotation, Vector3 velocity, Vector3 rotationalvelocity, byte state,
-                                 UUID AssetId, UUID owner, int attachPoint);
+        void SendPrimTerseUpdate(SendPrimitiveTerseData data);
 
         void SendInventoryFolderDetails(UUID ownerID, UUID folderID, List<InventoryItemBase> items,
                                         List<InventoryFolderBase> folders, bool fetchFolders,
diff --git a/OpenSim/Framework/MinHeap.cs b/OpenSim/Framework/MinHeap.cs
new file mode 100755
index 0000000..ad39bbc
--- /dev/null
+++ b/OpenSim/Framework/MinHeap.cs
@@ -0,0 +1,375 @@
+using System;
+using System.Threading;
+using System.Collections;
+using System.Collections.Generic;
+using System.Runtime.InteropServices;
+
+namespace OpenSim.Framework
+{
+    public interface IHandle { }
+
+    [Serializable, ComVisible(false)]
+    public class MinHeap<T> : ICollection<T>, ICollection
+    {
+        private class Handle : IHandle
+        {
+            internal int index = -1;
+            internal MinHeap<T> heap = null;
+
+            internal void Clear()
+            {
+                this.index = -1;
+                this.heap = null;
+            }
+        }
+
+        private struct HeapItem
+        {
+            internal T value;
+            internal Handle handle;
+
+            internal HeapItem(T value, Handle handle)
+            {
+                this.value = value;
+                this.handle = handle;
+            }
+
+            internal void Clear()
+            {
+                this.value = default(T);
+                if (this.handle != null)
+                {
+                    this.handle.Clear();
+                    this.handle = null;
+                }
+            }
+        }
+
+        public const int DEFAULT_CAPACITY = 4;
+
+        private HeapItem[] items;
+        private int size;
+        private object sync_root;
+        private int version;
+
+        private Comparison<T> comparison;
+
+        public MinHeap() : this(DEFAULT_CAPACITY, Comparer<T>.Default) { }
+        public MinHeap(int capacity) : this(capacity, Comparer<T>.Default) { }
+        public MinHeap(IComparer<T> comparer) : this(DEFAULT_CAPACITY, comparer) { }
+        public MinHeap(int capacity, IComparer<T> comparer) :
+            this(capacity, new Comparison<T>(comparer.Compare)) { }
+        public MinHeap(Comparison<T> comparison) : this(DEFAULT_CAPACITY, comparison) { }
+        public MinHeap(int capacity, Comparison<T> comparison)
+        {
+            this.items = new HeapItem[capacity];
+            this.comparison = comparison;
+            this.size = this.version = 0;
+        }
+
+        public int Count { get { return this.size; } }
+
+        public bool IsReadOnly { get { return false; } }
+
+        public bool IsSynchronized { get { return false; } }
+
+        public T this[IHandle key]
+        {
+            get
+            {
+                Handle handle = ValidateThisHandle(key);
+                return this.items[handle.index].value;
+            }
+
+            set
+            {
+                Handle handle = ValidateThisHandle(key);
+                this.items[handle.index].value = value;
+                if (!BubbleUp(handle.index))
+                    BubbleDown(handle.index);
+            }
+        }
+
+        public object SyncRoot
+        {
+            get
+            {
+                if (this.sync_root == null)
+                    Interlocked.CompareExchange<object>(ref this.sync_root, new object(), null);
+                return this.sync_root;
+            }
+        }
+
+        private Handle ValidateHandle(IHandle ihandle)
+        {
+            if (ihandle == null)
+                throw new ArgumentNullException("handle");
+            Handle handle = ihandle as Handle;
+            if (handle == null)
+                throw new InvalidOperationException("handle is not valid");
+            return handle;
+        }
+
+        private Handle ValidateThisHandle(IHandle ihandle)
+        {
+            Handle handle = ValidateHandle(ihandle);
+            if (!object.ReferenceEquals(handle.heap, this))
+                throw new InvalidOperationException("handle is not valid for this heap");
+            if (handle.index < 0)
+                throw new InvalidOperationException("handle is not associated to a value");
+            return handle;
+        }
+
+        private void Set(HeapItem item, int index)
+        {
+            this.items[index] = item;
+            if (item.handle != null)
+                item.handle.index = index;
+        }
+
+        private bool BubbleUp(int index)
+        {
+            HeapItem item = this.items[index];
+            int current, parent;
+
+            for (current = index, parent = (current - 1) / 2;
+                (current > 0) && (this.comparison(this.items[parent].value, item.value)) > 0;
+                current = parent, parent = (current - 1) / 2)
+            {
+                Set(this.items[parent], current);
+            }
+
+            if (current != index)
+            {
+                Set(item, current);
+                ++this.version;
+                return true;
+            }
+            return false;
+        }
+
+        private void BubbleDown(int index)
+        {
+            HeapItem item = this.items[index];
+            int current, child;
+
+            for (current = index, child = (2 * current) + 1;
+                current < this.size / 2;
+                current = child, child = (2 * current) + 1)
+            {
+                if ((child < this.size - 1) && this.comparison(this.items[child].value, this.items[child + 1].value) > 0)
+                    ++child;
+                if (this.comparison(this.items[child].value, item.value) >= 0)
+                    break;
+                Set(this.items[child], current);
+            }
+
+            if (current != index)
+            {
+                Set(item, current);
+                ++this.version;
+            }
+        }
+
+        public bool TryGetValue(IHandle key, out T value)
+        {
+            Handle handle = ValidateHandle(key);
+            if (handle.index > -1)
+            {
+                value = this.items[handle.index].value;
+                return true;
+            }
+            value = default(T);
+            return false;
+        }
+
+        public bool ContainsHandle(IHandle ihandle)
+        {
+            Handle handle = ValidateHandle(ihandle);
+            return object.ReferenceEquals(handle.heap, this) && handle.index > -1;
+        }
+
+        public void Add(T value, ref IHandle handle)
+        {
+            if (handle == null)
+                handle = new Handle();
+            Add(value, handle);
+        }
+
+        public void Add(T value, IHandle ihandle)
+        {
+            if (this.size == this.items.Length)
+            {
+                int capacity = (int)((this.items.Length * 200L) / 100L);
+                if (capacity < (this.items.Length + DEFAULT_CAPACITY))
+                    capacity = this.items.Length + DEFAULT_CAPACITY;
+                Array.Resize<HeapItem>(ref this.items, capacity);
+            }
+
+            Handle handle = null;
+            if (ihandle != null)
+            {
+                handle = ValidateHandle(ihandle);
+                handle.heap = this;
+            }
+
+            HeapItem item = new MinHeap<T>.HeapItem(value, handle);
+
+            Set(item, this.size);
+            BubbleUp(this.size++);
+        }
+
+        public void Add(T value)
+        {
+            Add(value, null);
+        }
+
+        public T Min()
+        {
+            if (this.size == 0)
+                throw new InvalidOperationException("Heap is empty");
+
+            return this.items[0].value;
+        }
+
+        public void Clear()
+        {
+            for (int index = 0; index < this.size; ++index)
+                this.items[index].Clear();
+            this.size = 0;
+            ++this.version;
+        }
+
+        public void TrimExcess()
+        {
+            int length = (int)(this.items.Length * 0.9);
+            if (this.size < length)
+                Array.Resize<HeapItem>(ref this.items, Math.Min(this.size, DEFAULT_CAPACITY));
+        }
+
+        private void RemoveAt(int index)
+        {
+            if (this.size == 0)
+                throw new InvalidOperationException("Heap is empty");
+            if (index >= this.size)
+                throw new ArgumentOutOfRangeException("index");
+
+            this.items[index].Clear();
+            if (--this.size > 0 && index != this.size)
+            {
+                Set(this.items[this.size], index);
+                if (!BubbleUp(index))
+                    BubbleDown(index);
+            }
+        }
+
+        public T RemoveMin()
+        {
+            if (this.size == 0)
+                throw new InvalidOperationException("Heap is empty");
+
+            HeapItem item = this.items[0];
+            RemoveAt(0);
+            return item.value;
+        }
+
+        public T Remove(IHandle ihandle)
+        {
+            Handle handle = ValidateThisHandle(ihandle);
+            HeapItem item = this.items[handle.index];
+            RemoveAt(handle.index);
+            return item.value;
+        }
+
+        private int GetIndex(T value)
+        {
+            EqualityComparer<T> comparer = EqualityComparer<T>.Default;
+            int index;
+
+            for (index = 0; index < this.size; ++index)
+            {
+                if (comparer.Equals(this.items[index].value, value))
+                    return index;
+            }
+            return -1;
+        }
+
+        public bool Contains(T value)
+        {
+            return GetIndex(value) != -1;
+        }
+
+        public bool Remove(T value)
+        {
+            int index = GetIndex(value);
+            if (index != -1)
+            {
+                RemoveAt(index);
+                return true;
+            }
+            return false;
+        }
+
+        public void CopyTo(T[] array, int index)
+        {
+            if (array == null)
+                throw new ArgumentNullException("array");
+            if (array.Rank != 1)
+                throw new ArgumentException("Multidimensional array not supported");
+            if (array.GetLowerBound(0) != 0)
+                throw new ArgumentException("Non-zero lower bound array not supported");
+
+            int length = array.Length;
+            if ((index < 0) || (index > length))
+                throw new ArgumentOutOfRangeException("index");
+            if ((length - index) < this.size)
+                throw new ArgumentException("Not enough space available in array starting at index");
+
+            for (int i = 0; i < this.size; ++i)
+                array[index + i] = this.items[i].value;
+        }
+
+        public void CopyTo(Array array, int index)
+        {
+            if (array == null)
+                throw new ArgumentNullException("array");
+            if (array.Rank != 1)
+                throw new ArgumentException("Multidimensional array not supported");
+            if (array.GetLowerBound(0) != 0)
+                throw new ArgumentException("Non-zero lower bound array not supported");
+
+            int length = array.Length;
+            if ((index < 0) || (index > length))
+                throw new ArgumentOutOfRangeException("index");
+            if ((length - index) < this.size)
+                throw new ArgumentException("Not enough space available in array starting at index");
+
+            try
+            {
+                for (int i = 0; i < this.size; ++i)
+                    array.SetValue(this.items[i].value, index + i);
+            }
+            catch (ArrayTypeMismatchException)
+            {
+                throw new ArgumentException("Invalid array type");
+            }
+        }
+
+        public IEnumerator<T> GetEnumerator()
+        {
+            int version = this.version;
+
+            for (int index = 0; index < this.size; ++index)
+            {
+                if (version != this.version)
+                    throw new InvalidOperationException("Heap was modified while enumerating");
+                yield return this.items[index].value;
+            }
+        }
+
+        IEnumerator IEnumerable.GetEnumerator()
+        {
+            return GetEnumerator();
+        }
+    }
+}
diff --git a/OpenSim/Framework/Util.cs b/OpenSim/Framework/Util.cs
index 38729c6..3203fc1 100644
--- a/OpenSim/Framework/Util.cs
+++ b/OpenSim/Framework/Util.cs
@@ -44,6 +44,7 @@ using System.Xml;
 using log4net;
 using Nini.Config;
 using Nwc.XmlRpc;
+using BclExtras;
 using OpenMetaverse;
 using OpenMetaverse.StructuredData;
 
@@ -1269,14 +1270,32 @@ namespace OpenSim.Framework
 
         #region FireAndForget Threading Pattern
 
+        /// <summary>
+        /// Created to work around a limitation in Mono with nested delegates
+        /// </summary>
+        private class FireAndForgetWrapper
+        {
+            public void FireAndForget(System.Threading.WaitCallback callback)
+            {
+                callback.BeginInvoke(null, EndFireAndForget, callback);
+            }
+
+            public void FireAndForget(System.Threading.WaitCallback callback, object obj)
+            {
+                callback.BeginInvoke(obj, EndFireAndForget, callback);
+            }
+        }
+
         public static void FireAndForget(System.Threading.WaitCallback callback)
         {
-            callback.BeginInvoke(null, EndFireAndForget, callback);
+            FireAndForgetWrapper wrapper = Singleton.GetInstance<FireAndForgetWrapper>();
+            wrapper.FireAndForget(callback);
         }
 
         public static void FireAndForget(System.Threading.WaitCallback callback, object obj)
         {
-            callback.BeginInvoke(obj, EndFireAndForget, callback);
+            FireAndForgetWrapper wrapper = Singleton.GetInstance<FireAndForgetWrapper>();
+            wrapper.FireAndForget(callback, obj);
         }
 
         private static void EndFireAndForget(IAsyncResult ar)