1 files changed, 21 insertions, 216 deletions

diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs b/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs
index e9e1fa3..8de31d7 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs
@@ -3687,12 +3687,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP
                     avgTimeDilation += update.TimeDilation;
                     avgTimeDilation *= 0.5f;
 
-// <MIC>
-// DEBUGGING CODE... REMOVE
-//                    if (update.Entity is ScenePresence)
-//                        LogAvatarUpdateEvent(this.m_agentId,update.Entity.UUID,timeinqueue);
-// </MIC>
-
                     if (update.Entity is SceneObjectPart)
                     {
                         SceneObjectPart part = (SceneObjectPart)update.Entity;
@@ -5017,7 +5011,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
             AddLocalPacketHandler(PacketType.TeleportLocationRequest, HandleTeleportLocationRequest);
             AddLocalPacketHandler(PacketType.UUIDNameRequest, HandleUUIDNameRequest, false);
             AddLocalPacketHandler(PacketType.RegionHandleRequest, HandleRegionHandleRequest);
-            AddLocalPacketHandler(PacketType.ParcelInfoRequest, HandleParcelInfoRequest, false);
+            AddLocalPacketHandler(PacketType.ParcelInfoRequest, HandleParcelInfoRequest);
             AddLocalPacketHandler(PacketType.ParcelAccessListRequest, HandleParcelAccessListRequest, false);
             AddLocalPacketHandler(PacketType.ParcelAccessListUpdate, HandleParcelAccessListUpdate, false);
             AddLocalPacketHandler(PacketType.ParcelPropertiesRequest, HandleParcelPropertiesRequest, false);
@@ -8888,13 +8882,29 @@ namespace OpenSim.Region.ClientStack.LindenUDP
                 case "instantmessage":
                     if (((Scene)m_scene).Permissions.CanIssueEstateCommand(AgentId, false))
                     {
-                        if (messagePacket.ParamList.Length < 5)
+                        if (messagePacket.ParamList.Length < 2)
                             return true;
+
                         UUID invoice = messagePacket.MethodData.Invoice;
-                        UUID SenderID = new UUID(Utils.BytesToString(messagePacket.ParamList[2].Parameter));
-                        string SenderName = Utils.BytesToString(messagePacket.ParamList[3].Parameter);
-                        string Message = Utils.BytesToString(messagePacket.ParamList[4].Parameter);
                         UUID sessionID = messagePacket.AgentData.SessionID;
+
+                        UUID SenderID;
+                        string SenderName;
+                        string Message;
+
+                        if (messagePacket.ParamList.Length < 5)
+                        {
+                            SenderID = AgentId;
+                            SenderName = Utils.BytesToString(messagePacket.ParamList[0].Parameter);
+                            Message = Utils.BytesToString(messagePacket.ParamList[1].Parameter);
+                        }
+                        else
+                        { 
+                            SenderID = new UUID(Utils.BytesToString(messagePacket.ParamList[2].Parameter));
+                            SenderName = Utils.BytesToString(messagePacket.ParamList[3].Parameter);
+                            Message = Utils.BytesToString(messagePacket.ParamList[4].Parameter);
+                        }
+
                         OnEstateBlueBoxMessageRequest(this, invoice, SenderID, sessionID, SenderName, Message);
                     }
                     return true;
@@ -11789,209 +11799,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP
             OutPacket(pack, ThrottleOutPacketType.Task);
         }
 
-        #region PriorityQueue
-        public class PriorityQueue
-        {
-            internal delegate bool UpdatePriorityHandler(ref uint priority, ISceneEntity entity);
-
-            // Heap[0] for self updates
-            // Heap[1..12] for entity updates
-
-            internal const uint m_numberOfQueues = 12;
-            private MinHeap<MinHeapItem>[] m_heaps = new MinHeap<MinHeapItem>[m_numberOfQueues];
-            private Dictionary<uint, LookupItem> m_lookupTable;
-            private object m_syncRoot = new object();
-            private uint m_nextQueue = 0;
-            private UInt64 m_nextRequest = 0;
-            
-            internal PriorityQueue() :
-                this(MinHeap<MinHeapItem>.DEFAULT_CAPACITY) { }
-            internal PriorityQueue(int capacity)
-            {
-                m_lookupTable = new Dictionary<uint, LookupItem>(capacity);
-
-                for (int i = 0; i < m_heaps.Length; ++i)
-                    m_heaps[i] = new MinHeap<MinHeapItem>(capacity);
-            }
-
-            public object SyncRoot { get { return this.m_syncRoot; } }
-
-            internal int Count
-            {
-                get
-                {
-                    int count = 0;
-                    for (int i = 0; i < m_heaps.Length; ++i)
-                        count += m_heaps[i].Count;
-                    return count;
-                }
-            }
-
-            public bool Enqueue(uint pqueue, EntityUpdate value)
-            {
-                LookupItem lookup;
-
-                uint localid = value.Entity.LocalId;
-                UInt64 entry = m_nextRequest++;
-                if (m_lookupTable.TryGetValue(localid, out lookup))
-                {
-                    entry = lookup.Heap[lookup.Handle].EntryOrder;
-                    value.Flags |=  lookup.Heap[lookup.Handle].Value.Flags;
-                    lookup.Heap.Remove(lookup.Handle);
-                }
-
-                pqueue = Util.Clamp<uint>(pqueue, 0, m_numberOfQueues - 1);
-                lookup.Heap = m_heaps[pqueue];
-                lookup.Heap.Add(new MinHeapItem(pqueue, entry, value), ref lookup.Handle);
-                m_lookupTable[localid] = lookup;
-
-                return true;
-            }
-
-            internal bool TryDequeue(out EntityUpdate value, out Int32 timeinqueue)
-            {
-                for (int i = 0; i < m_numberOfQueues; ++i)
-                {
-                    // To get the fair queing, we cycle through each of the
-                    // queues when finding an element to dequeue, this code
-                    // assumes that the distribution of updates in the queues
-                    // is polynomial, probably quadractic (eg distance of PI * R^2)
-                    uint h = (uint)((m_nextQueue + i) % m_numberOfQueues);
-                    if (m_heaps[h].Count > 0)
-                    {
-                        m_nextQueue = (uint)((h + 1) % m_numberOfQueues);
-
-                        MinHeapItem item = m_heaps[h].RemoveMin();
-                        m_lookupTable.Remove(item.Value.Entity.LocalId);
-                        timeinqueue = Util.EnvironmentTickCountSubtract(item.EntryTime);
-                        value = item.Value;
-                        
-                        return true;
-                    }
-                }
-
-                timeinqueue = 0;
-                value = default(EntityUpdate);
-                return false;
-            }
-
-            internal void Reprioritize(UpdatePriorityHandler handler)
-            {
-                MinHeapItem item;
-                foreach (LookupItem lookup in new List<LookupItem>(this.m_lookupTable.Values))
-                {
-                    if (lookup.Heap.TryGetValue(lookup.Handle, out item))
-                    {
-                        uint pqueue = item.PriorityQueue;
-                        uint localid = item.Value.Entity.LocalId;
-
-                        if (handler(ref pqueue, item.Value.Entity))
-                        {
-                            // unless the priority queue has changed, there is no need to modify
-                            // the entry
-                            pqueue = Util.Clamp<uint>(pqueue, 0, m_numberOfQueues - 1);
-                            if (pqueue != item.PriorityQueue)
-                            {
-                                lookup.Heap.Remove(lookup.Handle);
-
-                                LookupItem litem = lookup;
-                                litem.Heap = m_heaps[pqueue];
-                                litem.Heap.Add(new MinHeapItem(pqueue, item), ref litem.Handle);
-                                m_lookupTable[localid] = litem;
-                            }
-                        }
-                        else
-                        {
-                            m_log.WarnFormat("[LLCLIENTVIEW]: UpdatePriorityHandler returned false for {0}",item.Value.Entity.UUID);
-                            lookup.Heap.Remove(lookup.Handle);
-                            this.m_lookupTable.Remove(localid);
-                        }
-                    }
-                }
-            }
-
-            public override string ToString()
-            {
-                string s = "";
-                for (int i = 0; i < m_numberOfQueues; i++)
-                {
-                    if (s != "") s += ",";
-                    s += m_heaps[i].Count.ToString();
-                }
-                return s;
-            }
-            
-            #region MinHeapItem
-            private struct MinHeapItem : IComparable<MinHeapItem>
-            {
-                private EntityUpdate value;
-                internal EntityUpdate Value {
-                    get {
-                        return this.value;
-                    }
-                }
-
-                private uint pqueue;
-                internal uint PriorityQueue {
-                    get {
-                        return this.pqueue;
-                    }
-                }
-
-                private Int32 entrytime;
-                internal Int32 EntryTime {
-                    get {
-                        return this.entrytime;
-                    }
-                }
-
-                private UInt64 entryorder;
-                internal UInt64 EntryOrder 
-                {
-                    get {
-                        return this.entryorder;
-                    }
-                }
-                
-                internal MinHeapItem(uint pqueue, MinHeapItem other)
-                {
-                    this.entrytime = other.entrytime;
-                    this.entryorder = other.entryorder;
-                    this.value = other.value;
-                    this.pqueue = pqueue;
-                }
-                
-                internal MinHeapItem(uint pqueue, UInt64 entryorder, EntityUpdate value)
-                {
-                    this.entrytime = Util.EnvironmentTickCount();
-                    this.entryorder = entryorder;
-                    this.value = value;
-                    this.pqueue = pqueue;
-                }
-
-                public override string ToString()
-                {
-                    return String.Format("[{0},{1},{2}]",pqueue,entryorder,value.Entity.LocalId);
-                }
-
-                public int CompareTo(MinHeapItem other)
-                {
-                    // I'm assuming that the root part of an SOG is added to the update queue
-                    // before the component parts
-                    return Comparer<UInt64>.Default.Compare(this.EntryOrder, other.EntryOrder);
-                }
-            }
-            #endregion
-
-            #region LookupItem
-            private struct LookupItem
-            {
-                internal MinHeap<MinHeapItem> Heap;
-                internal IHandle Handle;
-            }
-            #endregion
-        }
-
         public struct PacketProcessor
         {
             public PacketMethod method;
@@ -12012,8 +11819,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP
             }
         }
 
-        #endregion
-
         public static OSD BuildEvent(string eventName, OSD eventBody)
         {
             OSDMap osdEvent = new OSDMap(2);