aboutsummaryrefslogtreecommitdiffstatshomepage
diff options
context:
space:
mode:
authorJohn Hurliman2010-05-21 13:55:36 -0700
committerJohn Hurliman2010-05-21 13:55:36 -0700
commit93ef65c69055157e0b7d51e544abe5a1035f40f0 (patch)
tree0afcfd50591e34f0a5d7efa474f300cf09083f69
parentminor: remove LongRunning test designator from TestAddSceneObject() since it ... (diff)
downloadopensim-SC-93ef65c69055157e0b7d51e544abe5a1035f40f0.zip
opensim-SC-93ef65c69055157e0b7d51e544abe5a1035f40f0.tar.gz
opensim-SC-93ef65c69055157e0b7d51e544abe5a1035f40f0.tar.bz2
opensim-SC-93ef65c69055157e0b7d51e544abe5a1035f40f0.tar.xz
* Moving all of the prioritization/reprioritization code into a new file Prioritizer.cs
* Simplified the interest management code to make it easier to add new policies. Prioritization and reprioritization share code paths now * Improved the distance and front back policies to always give your avatar the highest priority
-rw-r--r--OpenSim/Client/MXP/ClientStack/MXPClientView.cs2
-rw-r--r--OpenSim/Client/Sirikata/ClientStack/SirikataClientView.cs2
-rw-r--r--OpenSim/Client/VWoHTTP/ClientStack/VWHClientView.cs2
-rw-r--r--OpenSim/Framework/IClientAPI.cs21
-rw-r--r--OpenSim/Framework/ISceneEntity.cs1
-rw-r--r--OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs46
-rw-r--r--OpenSim/Region/Examples/SimpleModule/MyNpcCharacter.cs2
-rw-r--r--OpenSim/Region/Framework/Scenes/EntityBase.cs3
-rw-r--r--OpenSim/Region/Framework/Scenes/Prioritizer.cs122
-rw-r--r--OpenSim/Region/Framework/Scenes/Scene.cs96
-rw-r--r--OpenSim/Region/Framework/Scenes/SceneObjectGroup.cs101
-rw-r--r--OpenSim/Region/Framework/Scenes/ScenePresence.cs118
-rw-r--r--OpenSim/Region/OptionalModules/Agent/InternetRelayClientView/Server/IRCClientView.cs2
-rw-r--r--OpenSim/Region/OptionalModules/World/NPC/NPCAvatar.cs2
-rw-r--r--OpenSim/Tests/Common/Mock/TestClient.cs2
15 files changed, 207 insertions, 315 deletions
diff --git a/OpenSim/Client/MXP/ClientStack/MXPClientView.cs b/OpenSim/Client/MXP/ClientStack/MXPClientView.cs
index a62d897..3e92658 100644
--- a/OpenSim/Client/MXP/ClientStack/MXPClientView.cs
+++ b/OpenSim/Client/MXP/ClientStack/MXPClientView.cs
@@ -1065,7 +1065,7 @@ namespace OpenSim.Client.MXP.ClientStack
1065 throw new System.NotImplementedException(); 1065 throw new System.NotImplementedException();
1066 } 1066 }
1067 1067
1068 public void ReprioritizeUpdates(UpdatePriorityHandler handler) 1068 public void ReprioritizeUpdates()
1069 { 1069 {
1070 } 1070 }
1071 1071
diff --git a/OpenSim/Client/Sirikata/ClientStack/SirikataClientView.cs b/OpenSim/Client/Sirikata/ClientStack/SirikataClientView.cs
index d1f0988..c293480 100644
--- a/OpenSim/Client/Sirikata/ClientStack/SirikataClientView.cs
+++ b/OpenSim/Client/Sirikata/ClientStack/SirikataClientView.cs
@@ -609,7 +609,7 @@ namespace OpenSim.Client.Sirikata.ClientStack
609 throw new System.NotImplementedException(); 609 throw new System.NotImplementedException();
610 } 610 }
611 611
612 public void ReprioritizeUpdates(UpdatePriorityHandler handler) 612 public void ReprioritizeUpdates()
613 { 613 {
614 throw new System.NotImplementedException(); 614 throw new System.NotImplementedException();
615 } 615 }
diff --git a/OpenSim/Client/VWoHTTP/ClientStack/VWHClientView.cs b/OpenSim/Client/VWoHTTP/ClientStack/VWHClientView.cs
index c0da326..51026ab 100644
--- a/OpenSim/Client/VWoHTTP/ClientStack/VWHClientView.cs
+++ b/OpenSim/Client/VWoHTTP/ClientStack/VWHClientView.cs
@@ -615,7 +615,7 @@ namespace OpenSim.Client.VWoHTTP.ClientStack
615 throw new System.NotImplementedException(); 615 throw new System.NotImplementedException();
616 } 616 }
617 617
618 public void ReprioritizeUpdates(UpdatePriorityHandler handler) 618 public void ReprioritizeUpdates()
619 { 619 {
620 throw new System.NotImplementedException(); 620 throw new System.NotImplementedException();
621 } 621 }
diff --git a/OpenSim/Framework/IClientAPI.cs b/OpenSim/Framework/IClientAPI.cs
index 00681cf..f51bf71 100644
--- a/OpenSim/Framework/IClientAPI.cs
+++ b/OpenSim/Framework/IClientAPI.cs
@@ -458,8 +458,6 @@ namespace OpenSim.Framework
458 public delegate void PlacesQuery(UUID QueryID, UUID TransactionID, string QueryText, uint QueryFlags, byte Category, string SimName, IClientAPI client); 458 public delegate void PlacesQuery(UUID QueryID, UUID TransactionID, string QueryText, uint QueryFlags, byte Category, string SimName, IClientAPI client);
459 459
460 public delegate void AgentFOV(IClientAPI client, float verticalAngle); 460 public delegate void AgentFOV(IClientAPI client, float verticalAngle);
461
462 public delegate double UpdatePriorityHandler(UpdatePriorityData data);
463 461
464 public delegate void MuteListEntryUpdate(IClientAPI client, UUID MuteID, string Name, int Flags,UUID AgentID); 462 public delegate void MuteListEntryUpdate(IClientAPI client, UUID MuteID, string Name, int Flags,UUID AgentID);
465 463
@@ -571,17 +569,16 @@ namespace OpenSim.Framework
571 public float dwell; 569 public float dwell;
572 } 570 }
573 571
574 public struct UpdatePriorityData { 572 public class EntityUpdate
575 private double m_priority; 573 {
576 private uint m_localID; 574 public ISceneEntity Entity;
575 public PrimUpdateFlags Flags;
577 576
578 public UpdatePriorityData(double priority, uint localID) { 577 public EntityUpdate(ISceneEntity entity, PrimUpdateFlags flags)
579 this.m_priority = priority; 578 {
580 this.m_localID = localID; 579 Entity = entity;
580 Flags = flags;
581 } 581 }
582
583 public double priority { get { return this.m_priority; } }
584 public uint localID { get { return this.m_localID; } }
585 } 582 }
586 583
587 /// <summary> 584 /// <summary>
@@ -1024,7 +1021,7 @@ namespace OpenSim.Framework
1024 1021
1025 void SendAvatarDataImmediate(ISceneEntity avatar); 1022 void SendAvatarDataImmediate(ISceneEntity avatar);
1026 void SendPrimUpdate(ISceneEntity entity, PrimUpdateFlags updateFlags); 1023 void SendPrimUpdate(ISceneEntity entity, PrimUpdateFlags updateFlags);
1027 void ReprioritizeUpdates(UpdatePriorityHandler handler); 1024 void ReprioritizeUpdates();
1028 void FlushPrimUpdates(); 1025 void FlushPrimUpdates();
1029 1026
1030 void SendInventoryFolderDetails(UUID ownerID, UUID folderID, List<InventoryItemBase> items, 1027 void SendInventoryFolderDetails(UUID ownerID, UUID folderID, List<InventoryItemBase> items,
diff --git a/OpenSim/Framework/ISceneEntity.cs b/OpenSim/Framework/ISceneEntity.cs
index fa3c514..5ac364f 100644
--- a/OpenSim/Framework/ISceneEntity.cs
+++ b/OpenSim/Framework/ISceneEntity.cs
@@ -33,5 +33,6 @@ namespace OpenSim.Framework
33 { 33 {
34 UUID UUID { get; } 34 UUID UUID { get; }
35 uint LocalId { get; } 35 uint LocalId { get; }
36 Vector3 AbsolutePosition { get; }
36 } 37 }
37} 38}
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs b/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs
index c8a542b..9eb35fa 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs
@@ -50,18 +50,6 @@ using Nini.Config;
50 50
51namespace OpenSim.Region.ClientStack.LindenUDP 51namespace OpenSim.Region.ClientStack.LindenUDP
52{ 52{
53 public class EntityUpdate
54 {
55 public ISceneEntity Entity;
56 public PrimUpdateFlags Flags;
57
58 public EntityUpdate(ISceneEntity entity, PrimUpdateFlags flags)
59 {
60 Entity = entity;
61 Flags = flags;
62 }
63 }
64
65 public delegate bool PacketMethod(IClientAPI simClient, Packet packet); 53 public delegate bool PacketMethod(IClientAPI simClient, Packet packet);
66 54
67 /// <summary> 55 /// <summary>
@@ -325,6 +313,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
325 313
326 private int m_cachedTextureSerial; 314 private int m_cachedTextureSerial;
327 private PriorityQueue m_entityUpdates; 315 private PriorityQueue m_entityUpdates;
316 private Prioritizer m_prioritizer;
328 317
329 /// <value> 318 /// <value>
330 /// List used in construction of data blocks for an object update packet. This is to stop us having to 319 /// List used in construction of data blocks for an object update packet. This is to stop us having to
@@ -462,6 +451,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP
462 m_propertiesPacketTimer = new Timer(100); 451 m_propertiesPacketTimer = new Timer(100);
463 m_propertiesPacketTimer.Elapsed += ProcessObjectPropertiesPacket; 452 m_propertiesPacketTimer.Elapsed += ProcessObjectPropertiesPacket;
464 453
454 m_prioritizer = new Prioritizer(m_scene);
455
465 RegisterLocalPacketHandlers(); 456 RegisterLocalPacketHandlers();
466 } 457 }
467 458
@@ -3457,14 +3448,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
3457 /// </summary> 3448 /// </summary>
3458 public void SendPrimUpdate(ISceneEntity entity, PrimUpdateFlags updateFlags) 3449 public void SendPrimUpdate(ISceneEntity entity, PrimUpdateFlags updateFlags)
3459 { 3450 {
3460 double priority; 3451 double priority = m_prioritizer.GetUpdatePriority(this, entity);
3461
3462 if (entity is SceneObjectPart)
3463 priority = ((SceneObjectPart)entity).ParentGroup.GetUpdatePriority(this);
3464 else if (entity is ScenePresence)
3465 priority = ((ScenePresence)entity).GetUpdatePriority(this);
3466 else
3467 priority = 0.0d;
3468 3452
3469 lock (m_entityUpdates.SyncRoot) 3453 lock (m_entityUpdates.SyncRoot)
3470 m_entityUpdates.Enqueue(priority, new EntityUpdate(entity, updateFlags), entity.LocalId); 3454 m_entityUpdates.Enqueue(priority, new EntityUpdate(entity, updateFlags), entity.LocalId);
@@ -3613,19 +3597,23 @@ namespace OpenSim.Region.ClientStack.LindenUDP
3613 #endregion Packet Sending 3597 #endregion Packet Sending
3614 } 3598 }
3615 3599
3616 public void ReprioritizeUpdates(UpdatePriorityHandler handler) 3600 public void ReprioritizeUpdates()
3617 { 3601 {
3618 //m_log.Debug("[CLIENT]: Reprioritizing prim updates for " + m_firstName + " " + m_lastName); 3602 //m_log.Debug("[CLIENT]: Reprioritizing prim updates for " + m_firstName + " " + m_lastName);
3619 3603
3620 PriorityQueue.UpdatePriorityHandler update_priority_handler =
3621 delegate(ref double priority, uint local_id)
3622 {
3623 priority = handler(new UpdatePriorityData(priority, local_id));
3624 return priority != double.NaN;
3625 };
3626
3627 lock (m_entityUpdates.SyncRoot) 3604 lock (m_entityUpdates.SyncRoot)
3628 m_entityUpdates.Reprioritize(update_priority_handler); 3605 m_entityUpdates.Reprioritize(UpdatePriorityHandler);
3606 }
3607
3608 private bool UpdatePriorityHandler(ref double priority, uint localID)
3609 {
3610 EntityBase entity;
3611 if (m_scene.Entities.TryGetValue(localID, out entity))
3612 {
3613 priority = m_prioritizer.GetUpdatePriority(this, entity);
3614 }
3615
3616 return priority != double.NaN;
3629 } 3617 }
3630 3618
3631 public void FlushPrimUpdates() 3619 public void FlushPrimUpdates()
diff --git a/OpenSim/Region/Examples/SimpleModule/MyNpcCharacter.cs b/OpenSim/Region/Examples/SimpleModule/MyNpcCharacter.cs
index aac47d1..967438f 100644
--- a/OpenSim/Region/Examples/SimpleModule/MyNpcCharacter.cs
+++ b/OpenSim/Region/Examples/SimpleModule/MyNpcCharacter.cs
@@ -548,7 +548,7 @@ namespace OpenSim.Region.Examples.SimpleModule
548 { 548 {
549 } 549 }
550 550
551 public void ReprioritizeUpdates(UpdatePriorityHandler handler) 551 public void ReprioritizeUpdates()
552 { 552 {
553 } 553 }
554 554
diff --git a/OpenSim/Region/Framework/Scenes/EntityBase.cs b/OpenSim/Region/Framework/Scenes/EntityBase.cs
index 1c76c54..4e25c46 100644
--- a/OpenSim/Region/Framework/Scenes/EntityBase.cs
+++ b/OpenSim/Region/Framework/Scenes/EntityBase.cs
@@ -28,11 +28,12 @@
28using System; 28using System;
29using System.Runtime.Serialization; 29using System.Runtime.Serialization;
30using System.Security.Permissions; 30using System.Security.Permissions;
31using OpenSim.Framework;
31using OpenMetaverse; 32using OpenMetaverse;
32 33
33namespace OpenSim.Region.Framework.Scenes 34namespace OpenSim.Region.Framework.Scenes
34{ 35{
35 public abstract class EntityBase 36 public abstract class EntityBase : ISceneEntity
36 { 37 {
37 /// <summary> 38 /// <summary>
38 /// The scene to which this entity belongs 39 /// The scene to which this entity belongs
diff --git a/OpenSim/Region/Framework/Scenes/Prioritizer.cs b/OpenSim/Region/Framework/Scenes/Prioritizer.cs
new file mode 100644
index 0000000..af25014
--- /dev/null
+++ b/OpenSim/Region/Framework/Scenes/Prioritizer.cs
@@ -0,0 +1,122 @@
1using System;
2using System.Collections.Generic;
3using log4net;
4using Nini.Config;
5using OpenSim.Framework;
6using OpenMetaverse;
7
8namespace OpenSim.Region.Framework.Scenes
9{
10 public enum UpdatePrioritizationSchemes
11 {
12 Time = 0,
13 Distance = 1,
14 SimpleAngularDistance = 2,
15 FrontBack = 3,
16 }
17
18 public class Prioritizer
19 {
20 private static readonly ILog m_log = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
21
22 private Scene m_scene;
23
24 public Prioritizer(Scene scene)
25 {
26 m_scene = scene;
27 }
28
29 public double GetUpdatePriority(IClientAPI client, ISceneEntity entity)
30 {
31 switch (m_scene.UpdatePrioritizationScheme)
32 {
33 case UpdatePrioritizationSchemes.Time:
34 return GetPriorityByTime();
35 case UpdatePrioritizationSchemes.Distance:
36 return GetPriorityByDistance(client, entity);
37 case UpdatePrioritizationSchemes.SimpleAngularDistance:
38 return GetPriorityByDistance(client, entity);
39 case UpdatePrioritizationSchemes.FrontBack:
40 return GetPriorityByFrontBack(client, entity);
41 default:
42 throw new InvalidOperationException("UpdatePrioritizationScheme not defined.");
43 }
44 }
45
46 private double GetPriorityByTime()
47 {
48 return DateTime.UtcNow.ToOADate();
49 }
50
51 private double GetPriorityByDistance(IClientAPI client, ISceneEntity entity)
52 {
53 ScenePresence presence = m_scene.GetScenePresence(client.AgentId);
54 if (presence != null)
55 {
56 // If this is an update for our own avatar give it the highest priority
57 if (presence == entity)
58 return 0.0;
59
60 // Use the camera position for local agents and avatar position for remote agents
61 Vector3 presencePos = (presence.IsChildAgent) ?
62 presence.AbsolutePosition :
63 presence.CameraPosition;
64
65 // Use group position for child prims
66 Vector3 entityPos;
67 if (entity is SceneObjectPart)
68 entityPos = m_scene.GetGroupByPrim(entity.LocalId).AbsolutePosition;
69 else
70 entityPos = entity.AbsolutePosition;
71
72 return Vector3.DistanceSquared(presencePos, entityPos);
73 }
74
75 return double.NaN;
76 }
77
78 private double GetPriorityByFrontBack(IClientAPI client, ISceneEntity entity)
79 {
80 ScenePresence presence = m_scene.GetScenePresence(client.AgentId);
81 if (presence != null)
82 {
83 // If this is an update for our own avatar give it the highest priority
84 if (presence == entity)
85 return 0.0;
86
87 // Use group position for child prims
88 Vector3 entityPos = entity.AbsolutePosition;
89 if (entity is SceneObjectPart)
90 entityPos = m_scene.GetGroupByPrim(entity.LocalId).AbsolutePosition;
91 else
92 entityPos = entity.AbsolutePosition;
93
94 if (!presence.IsChildAgent)
95 {
96 // Root agent. Use distance from camera and a priority decrease for objects behind us
97 Vector3 camPosition = presence.CameraPosition;
98 Vector3 camAtAxis = presence.CameraAtAxis;
99
100 // Distance
101 double priority = Vector3.DistanceSquared(camPosition, entityPos);
102
103 // Plane equation
104 float d = -Vector3.Dot(camPosition, camAtAxis);
105 float p = Vector3.Dot(camAtAxis, entityPos) + d;
106 if (p < 0.0f) priority *= 2.0;
107
108 return priority;
109 }
110 else
111 {
112 // Child agent. Use the normal distance method
113 Vector3 presencePos = presence.AbsolutePosition;
114
115 return Vector3.DistanceSquared(presencePos, entityPos);
116 }
117 }
118
119 return double.NaN;
120 }
121 }
122}
diff --git a/OpenSim/Region/Framework/Scenes/Scene.cs b/OpenSim/Region/Framework/Scenes/Scene.cs
index de8ecc2..f35dffc 100644
--- a/OpenSim/Region/Framework/Scenes/Scene.cs
+++ b/OpenSim/Region/Framework/Scenes/Scene.cs
@@ -58,13 +58,6 @@ namespace OpenSim.Region.Framework.Scenes
58 58
59 public partial class Scene : SceneBase 59 public partial class Scene : SceneBase
60 { 60 {
61 public enum UpdatePrioritizationSchemes {
62 Time = 0,
63 Distance = 1,
64 SimpleAngularDistance = 2,
65 FrontBack = 3,
66 }
67
68 public delegate void SynchronizeSceneHandler(Scene scene); 61 public delegate void SynchronizeSceneHandler(Scene scene);
69 public SynchronizeSceneHandler SynchronizeScene = null; 62 public SynchronizeSceneHandler SynchronizeScene = null;
70 63
@@ -388,12 +381,6 @@ namespace OpenSim.Region.Framework.Scenes
388 private int m_lastUpdate; 381 private int m_lastUpdate;
389 private bool m_firstHeartbeat = true; 382 private bool m_firstHeartbeat = true;
390 383
391 private UpdatePrioritizationSchemes m_update_prioritization_scheme = UpdatePrioritizationSchemes.Time;
392 private bool m_reprioritization_enabled = true;
393 private double m_reprioritization_interval = 5000.0;
394 private double m_root_reprioritization_distance = 10.0;
395 private double m_child_reprioritization_distance = 20.0;
396
397 private object m_deleting_scene_object = new object(); 384 private object m_deleting_scene_object = new object();
398 385
399 // the minimum time that must elapse before a changed object will be considered for persisted 386 // the minimum time that must elapse before a changed object will be considered for persisted
@@ -401,15 +388,21 @@ namespace OpenSim.Region.Framework.Scenes
401 // the maximum time that must elapse before a changed object will be considered for persisted 388 // the maximum time that must elapse before a changed object will be considered for persisted
402 public long m_persistAfter = DEFAULT_MAX_TIME_FOR_PERSISTENCE * 10000000L; 389 public long m_persistAfter = DEFAULT_MAX_TIME_FOR_PERSISTENCE * 10000000L;
403 390
391 private UpdatePrioritizationSchemes m_priorityScheme = UpdatePrioritizationSchemes.Time;
392 private bool m_reprioritizationEnabled = true;
393 private double m_reprioritizationInterval = 5000.0;
394 private double m_rootReprioritizationDistance = 10.0;
395 private double m_childReprioritizationDistance = 20.0;
396
404 #endregion 397 #endregion
405 398
406 #region Properties 399 #region Properties
407 400
408 public UpdatePrioritizationSchemes UpdatePrioritizationScheme { get { return this.m_update_prioritization_scheme; } } 401 public UpdatePrioritizationSchemes UpdatePrioritizationScheme { get { return m_priorityScheme; } }
409 public bool IsReprioritizationEnabled { get { return m_reprioritization_enabled; } } 402 public bool IsReprioritizationEnabled { get { return m_reprioritizationEnabled; } }
410 public double ReprioritizationInterval { get { return m_reprioritization_interval; } } 403 public double ReprioritizationInterval { get { return m_reprioritizationInterval; } }
411 public double RootReprioritizationDistance { get { return m_root_reprioritization_distance; } } 404 public double RootReprioritizationDistance { get { return m_rootReprioritizationDistance; } }
412 public double ChildReprioritizationDistance { get { return m_child_reprioritization_distance; } } 405 public double ChildReprioritizationDistance { get { return m_childReprioritizationDistance; } }
413 406
414 public AgentCircuitManager AuthenticateHandler 407 public AgentCircuitManager AuthenticateHandler
415 { 408 {
@@ -611,6 +604,8 @@ namespace OpenSim.Region.Framework.Scenes
611 m_asyncSceneObjectDeleter = new AsyncSceneObjectGroupDeleter(this); 604 m_asyncSceneObjectDeleter = new AsyncSceneObjectGroupDeleter(this);
612 m_asyncSceneObjectDeleter.Enabled = true; 605 m_asyncSceneObjectDeleter.Enabled = true;
613 606
607 #region Region Settings
608
614 // Load region settings 609 // Load region settings
615 m_regInfo.RegionSettings = m_storageManager.DataStore.LoadRegionSettings(m_regInfo.RegionID); 610 m_regInfo.RegionSettings = m_storageManager.DataStore.LoadRegionSettings(m_regInfo.RegionID);
616 if (m_storageManager.EstateDataStore != null) 611 if (m_storageManager.EstateDataStore != null)
@@ -657,6 +652,8 @@ namespace OpenSim.Region.Framework.Scenes
657 } 652 }
658 } 653 }
659 654
655 #endregion Region Settings
656
660 MainConsole.Instance.Commands.AddCommand("region", false, "reload estate", 657 MainConsole.Instance.Commands.AddCommand("region", false, "reload estate",
661 "reload estate", 658 "reload estate",
662 "Reload the estate data", HandleReloadEstate); 659 "Reload the estate data", HandleReloadEstate);
@@ -701,6 +698,8 @@ namespace OpenSim.Region.Framework.Scenes
701 698
702 m_simulatorVersion = simulatorVersion + " (" + Util.GetRuntimeInformation() + ")"; 699 m_simulatorVersion = simulatorVersion + " (" + Util.GetRuntimeInformation() + ")";
703 700
701 #region Region Config
702
704 try 703 try
705 { 704 {
706 // Region config overrides global config 705 // Region config overrides global config
@@ -754,38 +753,6 @@ namespace OpenSim.Region.Framework.Scenes
754 753
755 m_strictAccessControl = startupConfig.GetBoolean("StrictAccessControl", m_strictAccessControl); 754 m_strictAccessControl = startupConfig.GetBoolean("StrictAccessControl", m_strictAccessControl);
756 755
757 IConfig interest_management_config = m_config.Configs["InterestManagement"];
758 if (interest_management_config != null)
759 {
760 string update_prioritization_scheme = interest_management_config.GetString("UpdatePrioritizationScheme", "Time").Trim().ToLower();
761 switch (update_prioritization_scheme)
762 {
763 case "time":
764 m_update_prioritization_scheme = UpdatePrioritizationSchemes.Time;
765 break;
766 case "distance":
767 m_update_prioritization_scheme = UpdatePrioritizationSchemes.Distance;
768 break;
769 case "simpleangulardistance":
770 m_update_prioritization_scheme = UpdatePrioritizationSchemes.SimpleAngularDistance;
771 break;
772 case "frontback":
773 m_update_prioritization_scheme = UpdatePrioritizationSchemes.FrontBack;
774 break;
775 default:
776 m_log.Warn("[SCENE]: UpdatePrioritizationScheme was not recognized, setting to default settomg of Time");
777 m_update_prioritization_scheme = UpdatePrioritizationSchemes.Time;
778 break;
779 }
780
781 m_reprioritization_enabled = interest_management_config.GetBoolean("ReprioritizationEnabled", true);
782 m_reprioritization_interval = interest_management_config.GetDouble("ReprioritizationInterval", 5000.0);
783 m_root_reprioritization_distance = interest_management_config.GetDouble("RootReprioritizationDistance", 10.0);
784 m_child_reprioritization_distance = interest_management_config.GetDouble("ChildReprioritizationDistance", 20.0);
785 }
786
787 m_log.Info("[SCENE]: Using the " + m_update_prioritization_scheme + " prioritization scheme");
788
789 #region BinaryStats 756 #region BinaryStats
790 757
791 try 758 try
@@ -822,6 +789,35 @@ namespace OpenSim.Region.Framework.Scenes
822 { 789 {
823 m_log.Warn("[SCENE]: Failed to load StartupConfig"); 790 m_log.Warn("[SCENE]: Failed to load StartupConfig");
824 } 791 }
792
793 #endregion Region Config
794
795 #region Interest Management
796
797 IConfig interestConfig = m_config.Configs["InterestManagement"];
798 if (interestConfig != null)
799 {
800 string update_prioritization_scheme = interestConfig.GetString("UpdatePrioritizationScheme", "Time").Trim().ToLower();
801
802 try
803 {
804 m_priorityScheme = (UpdatePrioritizationSchemes)Enum.Parse(typeof(UpdatePrioritizationSchemes), update_prioritization_scheme, true);
805 }
806 catch (Exception)
807 {
808 m_log.Warn("[PRIORITIZER]: UpdatePrioritizationScheme was not recognized, setting to default prioritizer Time");
809 m_priorityScheme = UpdatePrioritizationSchemes.Time;
810 }
811
812 m_reprioritizationEnabled = interestConfig.GetBoolean("ReprioritizationEnabled", true);
813 m_reprioritizationInterval = interestConfig.GetDouble("ReprioritizationInterval", 5000.0);
814 m_rootReprioritizationDistance = interestConfig.GetDouble("RootReprioritizationDistance", 10.0);
815 m_childReprioritizationDistance = interestConfig.GetDouble("ChildReprioritizationDistance", 20.0);
816 }
817
818 m_log.Info("[SCENE]: Using the " + m_priorityScheme + " prioritization scheme");
819
820 #endregion Interest Management
825 } 821 }
826 822
827 /// <summary> 823 /// <summary>
diff --git a/OpenSim/Region/Framework/Scenes/SceneObjectGroup.cs b/OpenSim/Region/Framework/Scenes/SceneObjectGroup.cs
index 8aefd50..4453beb 100644
--- a/OpenSim/Region/Framework/Scenes/SceneObjectGroup.cs
+++ b/OpenSim/Region/Framework/Scenes/SceneObjectGroup.cs
@@ -3602,106 +3602,7 @@ namespace OpenSim.Region.Framework.Scenes
3602 3602
3603 SetFromItemID(uuid); 3603 SetFromItemID(uuid);
3604 } 3604 }
3605 #endregion
3606 3605
3607 public double GetUpdatePriority(IClientAPI client) 3606 #endregion
3608 {
3609 switch (Scene.UpdatePrioritizationScheme)
3610 {
3611 case Scene.UpdatePrioritizationSchemes.Time:
3612 return GetPriorityByTime();
3613 case Scene.UpdatePrioritizationSchemes.Distance:
3614 return GetPriorityByDistance(client);
3615 case Scene.UpdatePrioritizationSchemes.SimpleAngularDistance:
3616 return GetPriorityBySimpleAngularDistance(client);
3617 case Scenes.Scene.UpdatePrioritizationSchemes.FrontBack:
3618 return GetPriorityByFrontBack(client);
3619 default:
3620 throw new InvalidOperationException("UpdatePrioritizationScheme not defined");
3621 }
3622 }
3623
3624 private double GetPriorityByTime()
3625 {
3626 return DateTime.Now.ToOADate();
3627 }
3628
3629 private double GetPriorityByDistance(IClientAPI client)
3630 {
3631 ScenePresence presence = Scene.GetScenePresence(client.AgentId);
3632 if (presence != null)
3633 {
3634 return GetPriorityByDistance((presence.IsChildAgent) ?
3635 presence.AbsolutePosition : presence.CameraPosition);
3636 }
3637 return double.NaN;
3638 }
3639
3640 private double GetPriorityBySimpleAngularDistance(IClientAPI client)
3641 {
3642 ScenePresence presence = Scene.GetScenePresence(client.AgentId);
3643 if (presence != null)
3644 {
3645 return GetPriorityBySimpleAngularDistance((presence.IsChildAgent) ?
3646 presence.AbsolutePosition : presence.CameraPosition);
3647 }
3648 return double.NaN;
3649 }
3650
3651 private double GetPriorityByFrontBack(IClientAPI client)
3652 {
3653 ScenePresence presence = Scene.GetScenePresence(client.AgentId);
3654 if (presence != null)
3655 {
3656 return GetPriorityByFrontBack(presence.CameraPosition, presence.CameraAtAxis);
3657 }
3658 return double.NaN;
3659 }
3660
3661 public double GetPriorityByDistance(Vector3 position)
3662 {
3663 return Vector3.Distance(AbsolutePosition, position);
3664 }
3665
3666 public double GetPriorityBySimpleAngularDistance(Vector3 position)
3667 {
3668 double distance = Vector3.Distance(position, AbsolutePosition);
3669 if (distance >= double.Epsilon)
3670 {
3671 float height;
3672 Vector3 box = GetAxisAlignedBoundingBox(out height);
3673
3674 double angle = box.X / distance;
3675 double max = angle;
3676
3677 angle = box.Y / distance;
3678 if (max < angle)
3679 max = angle;
3680
3681 angle = box.Z / distance;
3682 if (max < angle)
3683 max = angle;
3684
3685 return -max;
3686 }
3687 else
3688 return double.MinValue;
3689 }
3690
3691 public double GetPriorityByFrontBack(Vector3 camPosition, Vector3 camAtAxis)
3692 {
3693 // Distance
3694 double priority = Vector3.Distance(camPosition, AbsolutePosition);
3695
3696 // Scale
3697 //priority -= GroupScale().Length();
3698
3699 // Plane equation
3700 float d = -Vector3.Dot(camPosition, camAtAxis);
3701 float p = Vector3.Dot(camAtAxis, AbsolutePosition) + d;
3702 if (p < 0.0f) priority *= 2.0f;
3703
3704 return priority;
3705 }
3706 } 3607 }
3707} 3608}
diff --git a/OpenSim/Region/Framework/Scenes/ScenePresence.cs b/OpenSim/Region/Framework/Scenes/ScenePresence.cs
index ee0eb07..2ce1b68 100644
--- a/OpenSim/Region/Framework/Scenes/ScenePresence.cs
+++ b/OpenSim/Region/Framework/Scenes/ScenePresence.cs
@@ -3777,123 +3777,9 @@ namespace OpenSim.Region.Framework.Scenes
3777 } 3777 }
3778 } 3778 }
3779 3779
3780 public double GetUpdatePriority(IClientAPI client)
3781 {
3782 switch (Scene.UpdatePrioritizationScheme)
3783 {
3784 case Scene.UpdatePrioritizationSchemes.Time:
3785 return GetPriorityByTime();
3786 case Scene.UpdatePrioritizationSchemes.Distance:
3787 return GetPriorityByDistance(client);
3788 case Scene.UpdatePrioritizationSchemes.SimpleAngularDistance:
3789 return GetPriorityByDistance(client);
3790 case Scenes.Scene.UpdatePrioritizationSchemes.FrontBack:
3791 return GetPriorityByFrontBack(client);
3792 default:
3793 throw new InvalidOperationException("UpdatePrioritizationScheme not defined.");
3794 }
3795 }
3796
3797 private double GetPriorityByTime()
3798 {
3799 return DateTime.Now.ToOADate();
3800 }
3801
3802 private double GetPriorityByDistance(IClientAPI client)
3803 {
3804 ScenePresence presence = Scene.GetScenePresence(client.AgentId);
3805 if (presence != null)
3806 {
3807 return GetPriorityByDistance((presence.IsChildAgent) ?
3808 presence.AbsolutePosition : presence.CameraPosition);
3809 }
3810 return double.NaN;
3811 }
3812
3813 private double GetPriorityByFrontBack(IClientAPI client)
3814 {
3815 ScenePresence presence = Scene.GetScenePresence(client.AgentId);
3816 if (presence != null)
3817 {
3818 return GetPriorityByFrontBack(presence.CameraPosition, presence.CameraAtAxis);
3819 }
3820 return double.NaN;
3821 }
3822
3823 private double GetPriorityByDistance(Vector3 position)
3824 {
3825 return Vector3.Distance(AbsolutePosition, position);
3826 }
3827
3828 private double GetPriorityByFrontBack(Vector3 camPosition, Vector3 camAtAxis)
3829 {
3830 // Distance
3831 double priority = Vector3.Distance(camPosition, AbsolutePosition);
3832
3833 // Plane equation
3834 float d = -Vector3.Dot(camPosition, camAtAxis);
3835 float p = Vector3.Dot(camAtAxis, AbsolutePosition) + d;
3836 if (p < 0.0f) priority *= 2.0f;
3837
3838 return priority;
3839 }
3840
3841 private double GetSOGUpdatePriority(SceneObjectGroup sog)
3842 {
3843 switch (Scene.UpdatePrioritizationScheme)
3844 {
3845 case Scene.UpdatePrioritizationSchemes.Time:
3846 throw new InvalidOperationException("UpdatePrioritizationScheme for time not supported for reprioritization");
3847 case Scene.UpdatePrioritizationSchemes.Distance:
3848 return sog.GetPriorityByDistance((IsChildAgent) ? AbsolutePosition : CameraPosition);
3849 case Scene.UpdatePrioritizationSchemes.SimpleAngularDistance:
3850 return sog.GetPriorityBySimpleAngularDistance((IsChildAgent) ? AbsolutePosition : CameraPosition);
3851 case Scenes.Scene.UpdatePrioritizationSchemes.FrontBack:
3852 return sog.GetPriorityByFrontBack(CameraPosition, CameraAtAxis);
3853 default:
3854 throw new InvalidOperationException("UpdatePrioritizationScheme not defined");
3855 }
3856 }
3857
3858 private double UpdatePriority(UpdatePriorityData data)
3859 {
3860 EntityBase entity;
3861 SceneObjectGroup group;
3862
3863 if (Scene.Entities.TryGetValue(data.localID, out entity))
3864 {
3865 group = entity as SceneObjectGroup;
3866 if (group != null)
3867 return GetSOGUpdatePriority(group);
3868
3869 ScenePresence presence = entity as ScenePresence;
3870 if (presence == null)
3871 throw new InvalidOperationException("entity found is neither SceneObjectGroup nor ScenePresence");
3872 switch (Scene.UpdatePrioritizationScheme)
3873 {
3874 case Scene.UpdatePrioritizationSchemes.Time:
3875 throw new InvalidOperationException("UpdatePrioritization for time not supported for reprioritization");
3876 case Scene.UpdatePrioritizationSchemes.Distance:
3877 case Scene.UpdatePrioritizationSchemes.SimpleAngularDistance:
3878 return GetPriorityByDistance((IsChildAgent) ? AbsolutePosition : CameraPosition);
3879 case Scenes.Scene.UpdatePrioritizationSchemes.FrontBack:
3880 return GetPriorityByFrontBack(CameraPosition, CameraAtAxis);
3881 default:
3882 throw new InvalidOperationException("UpdatePrioritizationScheme not defined");
3883 }
3884 }
3885 else
3886 {
3887 group = Scene.GetGroupByPrim(data.localID);
3888 if (group != null)
3889 return GetSOGUpdatePriority(group);
3890 }
3891 return double.NaN;
3892 }
3893
3894 private void ReprioritizeUpdates() 3780 private void ReprioritizeUpdates()
3895 { 3781 {
3896 if (Scene.IsReprioritizationEnabled && Scene.UpdatePrioritizationScheme != Scene.UpdatePrioritizationSchemes.Time) 3782 if (Scene.IsReprioritizationEnabled && Scene.UpdatePrioritizationScheme != UpdatePrioritizationSchemes.Time)
3897 { 3783 {
3898 lock (m_reprioritization_timer) 3784 lock (m_reprioritization_timer)
3899 { 3785 {
@@ -3907,7 +3793,7 @@ namespace OpenSim.Region.Framework.Scenes
3907 3793
3908 private void Reprioritize(object sender, ElapsedEventArgs e) 3794 private void Reprioritize(object sender, ElapsedEventArgs e)
3909 { 3795 {
3910 m_controllingClient.ReprioritizeUpdates(UpdatePriority); 3796 m_controllingClient.ReprioritizeUpdates();
3911 3797
3912 lock (m_reprioritization_timer) 3798 lock (m_reprioritization_timer)
3913 { 3799 {
diff --git a/OpenSim/Region/OptionalModules/Agent/InternetRelayClientView/Server/IRCClientView.cs b/OpenSim/Region/OptionalModules/Agent/InternetRelayClientView/Server/IRCClientView.cs
index 84faac0..27de529 100644
--- a/OpenSim/Region/OptionalModules/Agent/InternetRelayClientView/Server/IRCClientView.cs
+++ b/OpenSim/Region/OptionalModules/Agent/InternetRelayClientView/Server/IRCClientView.cs
@@ -1065,7 +1065,7 @@ namespace OpenSim.Region.OptionalModules.Agent.InternetRelayClientView.Server
1065 1065
1066 } 1066 }
1067 1067
1068 public void ReprioritizeUpdates(UpdatePriorityHandler handler) 1068 public void ReprioritizeUpdates()
1069 { 1069 {
1070 1070
1071 } 1071 }
diff --git a/OpenSim/Region/OptionalModules/World/NPC/NPCAvatar.cs b/OpenSim/Region/OptionalModules/World/NPC/NPCAvatar.cs
index 9066691..d2279c7 100644
--- a/OpenSim/Region/OptionalModules/World/NPC/NPCAvatar.cs
+++ b/OpenSim/Region/OptionalModules/World/NPC/NPCAvatar.cs
@@ -638,7 +638,7 @@ namespace OpenSim.Region.OptionalModules.World.NPC
638 { 638 {
639 } 639 }
640 640
641 public void ReprioritizeUpdates(UpdatePriorityHandler handler) 641 public void ReprioritizeUpdates()
642 { 642 {
643 } 643 }
644 644
diff --git a/OpenSim/Tests/Common/Mock/TestClient.cs b/OpenSim/Tests/Common/Mock/TestClient.cs
index edb7642..6b0efe9 100644
--- a/OpenSim/Tests/Common/Mock/TestClient.cs
+++ b/OpenSim/Tests/Common/Mock/TestClient.cs
@@ -641,7 +641,7 @@ namespace OpenSim.Tests.Common.Mock
641 { 641 {
642 } 642 }
643 643
644 public void ReprioritizeUpdates(UpdatePriorityHandler handler) 644 public void ReprioritizeUpdates()
645 { 645 {
646 } 646 }
647 647