aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs
diff options
context:
space:
mode:
authorMelanie Thielker2008-12-17 20:34:37 +0000
committerMelanie Thielker2008-12-17 20:34:37 +0000
commit2bcf315ea2550a277fc59161724f1c6dad35e915 (patch)
tree99cb2180d15e0516c77100bcc6b93a07b4ad3cba /OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs
parentStop packets that may be resent from being returned to the packet pool. (diff)
downloadopensim-SC-2bcf315ea2550a277fc59161724f1c6dad35e915.zip
opensim-SC-2bcf315ea2550a277fc59161724f1c6dad35e915.tar.gz
opensim-SC-2bcf315ea2550a277fc59161724f1c6dad35e915.tar.bz2
opensim-SC-2bcf315ea2550a277fc59161724f1c6dad35e915.tar.xz
Revert 7754 and 7755 pending a rework
Diffstat (limited to '')
-rw-r--r--OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs39
1 files changed, 23 insertions, 16 deletions
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs b/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs
index 4383493..2d02dfc 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs
@@ -345,8 +345,9 @@ namespace OpenSim.Region.ClientStack.LindenUDP
345 LLQueItem qpack = ResendOutgoingPacketQueue.Dequeue(); 345 LLQueItem qpack = ResendOutgoingPacketQueue.Dequeue();
346 346
347 SendQueue.Enqueue(qpack); 347 SendQueue.Enqueue(qpack);
348 TotalThrottle.AddBytes(qpack.Length); 348 int qpackSize = qpack.Packet.ToBytes().Length;
349 ResendThrottle.AddBytes(qpack.Length); 349 TotalThrottle.AddBytes(qpackSize);
350 ResendThrottle.AddBytes(qpackSize);
350 351
351 qchanged = true; 352 qchanged = true;
352 } 353 }
@@ -356,8 +357,9 @@ namespace OpenSim.Region.ClientStack.LindenUDP
356 LLQueItem qpack = LandOutgoingPacketQueue.Dequeue(); 357 LLQueItem qpack = LandOutgoingPacketQueue.Dequeue();
357 358
358 SendQueue.Enqueue(qpack); 359 SendQueue.Enqueue(qpack);
359 TotalThrottle.AddBytes(qpack.Length); 360 int qpackSize = qpack.Packet.ToBytes().Length;
360 LandThrottle.AddBytes(qpack.Length); 361 TotalThrottle.AddBytes(qpackSize);
362 LandThrottle.AddBytes(qpackSize);
361 qchanged = true; 363 qchanged = true;
362 } 364 }
363 365
@@ -366,8 +368,9 @@ namespace OpenSim.Region.ClientStack.LindenUDP
366 LLQueItem qpack = WindOutgoingPacketQueue.Dequeue(); 368 LLQueItem qpack = WindOutgoingPacketQueue.Dequeue();
367 369
368 SendQueue.Enqueue(qpack); 370 SendQueue.Enqueue(qpack);
369 TotalThrottle.AddBytes(qpack.Length); 371 int qpackSize = qpack.Packet.ToBytes().Length;
370 WindThrottle.AddBytes(qpack.Length); 372 TotalThrottle.AddBytes(qpackSize);
373 WindThrottle.AddBytes(qpackSize);
371 qchanged = true; 374 qchanged = true;
372 } 375 }
373 376
@@ -376,8 +379,9 @@ namespace OpenSim.Region.ClientStack.LindenUDP
376 LLQueItem qpack = CloudOutgoingPacketQueue.Dequeue(); 379 LLQueItem qpack = CloudOutgoingPacketQueue.Dequeue();
377 380
378 SendQueue.Enqueue(qpack); 381 SendQueue.Enqueue(qpack);
379 TotalThrottle.AddBytes(qpack.Length); 382 int qpackSize = qpack.Packet.ToBytes().Length;
380 CloudThrottle.AddBytes(qpack.Length); 383 TotalThrottle.AddBytes(qpackSize);
384 CloudThrottle.AddBytes(qpackSize);
381 qchanged = true; 385 qchanged = true;
382 } 386 }
383 387
@@ -395,8 +399,9 @@ namespace OpenSim.Region.ClientStack.LindenUDP
395 SendQueue.Enqueue(qpack); 399 SendQueue.Enqueue(qpack);
396 } 400 }
397 401
398 TotalThrottle.AddBytes(qpack.Length); 402 int qpackSize = qpack.Packet.ToBytes().Length;
399 TaskThrottle.AddBytes(qpack.Length); 403 TotalThrottle.AddBytes(qpackSize);
404 TaskThrottle.AddBytes(qpackSize);
400 qchanged = true; 405 qchanged = true;
401 } 406 }
402 407
@@ -405,8 +410,9 @@ namespace OpenSim.Region.ClientStack.LindenUDP
405 LLQueItem qpack = TextureOutgoingPacketQueue.Dequeue(); 410 LLQueItem qpack = TextureOutgoingPacketQueue.Dequeue();
406 411
407 SendQueue.Enqueue(qpack); 412 SendQueue.Enqueue(qpack);
408 TotalThrottle.AddBytes(qpack.Length); 413 int qpackSize = qpack.Packet.ToBytes().Length;
409 TextureThrottle.AddBytes(qpack.Length); 414 TotalThrottle.AddBytes(qpackSize);
415 TextureThrottle.AddBytes(qpackSize);
410 qchanged = true; 416 qchanged = true;
411 } 417 }
412 418
@@ -415,8 +421,9 @@ namespace OpenSim.Region.ClientStack.LindenUDP
415 LLQueItem qpack = AssetOutgoingPacketQueue.Dequeue(); 421 LLQueItem qpack = AssetOutgoingPacketQueue.Dequeue();
416 422
417 SendQueue.Enqueue(qpack); 423 SendQueue.Enqueue(qpack);
418 TotalThrottle.AddBytes(qpack.Length); 424 int qpackSize = qpack.Packet.ToBytes().Length;
419 AssetThrottle.AddBytes(qpack.Length); 425 TotalThrottle.AddBytes(qpackSize);
426 AssetThrottle.AddBytes(qpackSize);
420 qchanged = true; 427 qchanged = true;
421 } 428 }
422 } 429 }
@@ -444,8 +451,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP
444 try 451 try
445 { 452 {
446 Monitor.Enter(this); 453 Monitor.Enter(this);
447 throttle.AddBytes(item.Length); 454 throttle.AddBytes(item.Packet.ToBytes().Length);
448 TotalThrottle.AddBytes(item.Length); 455 TotalThrottle.AddBytes(item.Packet.ToBytes().Length);
449 SendQueue.Enqueue(item); 456 SendQueue.Enqueue(item);
450 } 457 }
451 catch (Exception e) 458 catch (Exception e)