diff options
| author | Diva Canto | 2013-07-18 17:17:20 -0700 |
|---|---|---|
| committer | Diva Canto | 2013-07-21 08:57:16 -0700 |
| commit | 98d47ea428cd31b302e33dc6015a889d38bcb267 (patch) | |
| tree | 5c40354d68f3fe019330c5cd23acd5f994a77a45 /OpenSim | |
| parent | Do some simple queue empty checks in the main outgoing udp loop instead of al... (diff) | |
| download | opensim-SC_OLD-98d47ea428cd31b302e33dc6015a889d38bcb267.zip opensim-SC_OLD-98d47ea428cd31b302e33dc6015a889d38bcb267.tar.gz opensim-SC_OLD-98d47ea428cd31b302e33dc6015a889d38bcb267.tar.bz2 opensim-SC_OLD-98d47ea428cd31b302e33dc6015a889d38bcb267.tar.xz | |
Delay the enqueueing of non-longpoll requests for 100ms. No need to have these requests actively on the processing queue if it seems they're not ready.
Diffstat (limited to 'OpenSim')
| -rw-r--r-- | OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs b/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs index e811079..727dbe5 100644 --- a/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs +++ b/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs | |||
| @@ -96,7 +96,17 @@ namespace OpenSim.Framework.Servers.HttpServer | |||
| 96 | private void ReQueueEvent(PollServiceHttpRequest req) | 96 | private void ReQueueEvent(PollServiceHttpRequest req) |
| 97 | { | 97 | { |
| 98 | if (m_running) | 98 | if (m_running) |
| 99 | m_requests.Enqueue(req); | 99 | { |
| 100 | // delay the enqueueing for 100ms. There's no need to have the event | ||
| 101 | // actively on the queue | ||
| 102 | Timer t = new Timer(self => { | ||
| 103 | ((Timer)self).Dispose(); | ||
| 104 | m_requests.Enqueue(req); | ||
| 105 | }); | ||
| 106 | |||
| 107 | t.Change(100, Timeout.Infinite); | ||
| 108 | |||
| 109 | } | ||
| 100 | } | 110 | } |
| 101 | 111 | ||
| 102 | public void Enqueue(PollServiceHttpRequest req) | 112 | public void Enqueue(PollServiceHttpRequest req) |