diff options
Diffstat (limited to 'OpenSim/Framework/Servers/HttpServer')
-rw-r--r-- | OpenSim/Framework/Servers/HttpServer/PollServiceEventArgs.cs | 10 | ||||
-rw-r--r-- | OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs | 13 |
2 files changed, 11 insertions, 12 deletions
diff --git a/OpenSim/Framework/Servers/HttpServer/PollServiceEventArgs.cs b/OpenSim/Framework/Servers/HttpServer/PollServiceEventArgs.cs index 9b27a6e..f85509a 100644 --- a/OpenSim/Framework/Servers/HttpServer/PollServiceEventArgs.cs +++ b/OpenSim/Framework/Servers/HttpServer/PollServiceEventArgs.cs | |||
@@ -46,8 +46,14 @@ namespace OpenSim.Framework.Servers.HttpServer | |||
46 | public RequestMethod Request; | 46 | public RequestMethod Request; |
47 | public UUID Id; | 47 | public UUID Id; |
48 | public int TimeOutms; | 48 | public int TimeOutms; |
49 | public EventType Type; | 49 | public EventType Type; |
50 | public bool GetEventsNeedsRequest = true; | 50 | // must be set true for cases where GetEvents needs to access the request body |
51 | // at each pool. http can start processing before having the full body | ||
52 | // but not sure if this is active for poll events | ||
53 | // if original coder thinked its needed i keep it | ||
54 | // if the Event has a Request method this seems to smoke for now | ||
55 | // seems for now nothing actually uses this so default to false | ||
56 | public bool GetEventsNeedsRequestBody = false; | ||
51 | 57 | ||
52 | public enum EventType : int | 58 | public enum EventType : int |
53 | { | 59 | { |
diff --git a/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs b/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs index c234537..c379747 100644 --- a/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs +++ b/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs | |||
@@ -278,15 +278,7 @@ namespace OpenSim.Framework.Servers.HttpServer | |||
278 | Thread.Sleep(1000); // let the world move | 278 | Thread.Sleep(1000); // let the world move |
279 | 279 | ||
280 | foreach (Thread t in m_workerThreads) | 280 | foreach (Thread t in m_workerThreads) |
281 | { | 281 | Watchdog.AbortThread(t.ManagedThreadId); |
282 | try | ||
283 | { | ||
284 | t.Abort(); | ||
285 | } | ||
286 | catch | ||
287 | { | ||
288 | } | ||
289 | } | ||
290 | 282 | ||
291 | try | 283 | try |
292 | { | 284 | { |
@@ -345,10 +337,11 @@ namespace OpenSim.Framework.Servers.HttpServer | |||
345 | if (req.PollServiceArgs.HasEvents(req.RequestID, req.PollServiceArgs.Id)) | 337 | if (req.PollServiceArgs.HasEvents(req.RequestID, req.PollServiceArgs.Id)) |
346 | { | 338 | { |
347 | string strreq = ""; | 339 | string strreq = ""; |
348 | if (req.PollServiceArgs.GetEventsNeedsRequest) | 340 | if (req.PollServiceArgs.GetEventsNeedsRequestBody) |
349 | { | 341 | { |
350 | try | 342 | try |
351 | { | 343 | { |
344 | // should we try to seek back? fear we can't | ||
352 | str = new StreamReader(req.Request.Body); | 345 | str = new StreamReader(req.Request.Body); |
353 | strreq = str.ReadToEnd(); | 346 | strreq = str.ReadToEnd(); |
354 | str.Close(); | 347 | str.Close(); |