diff options
author | Melanie Thielker | 2008-12-17 20:34:37 +0000 |
---|---|---|
committer | Melanie Thielker | 2008-12-17 20:34:37 +0000 |
commit | 2bcf315ea2550a277fc59161724f1c6dad35e915 (patch) | |
tree | 99cb2180d15e0516c77100bcc6b93a07b4ad3cba /OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs | |
parent | Stop packets that may be resent from being returned to the packet pool. (diff) | |
download | opensim-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.cs | 39 |
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) |