diff options
author | UbitUmarov | 2015-09-22 18:39:59 +0100 |
---|---|---|
committer | UbitUmarov | 2015-09-22 18:39:59 +0100 |
commit | a8dc07ff5c0ba1c09e9a5beaf76f3b078670c74f (patch) | |
tree | e3d088abe02e6a6f53cf8e5c412b0402212c7000 /OpenSim/Region/ClientStack/Linden/UDP/LLUDPClient.cs | |
parent | last merging of sog m_linkedAvatars into m_sittingAvatars - untested. (diff) | |
download | opensim-SC-a8dc07ff5c0ba1c09e9a5beaf76f3b078670c74f.zip opensim-SC-a8dc07ff5c0ba1c09e9a5beaf76f3b078670c74f.tar.gz opensim-SC-a8dc07ff5c0ba1c09e9a5beaf76f3b078670c74f.tar.bz2 opensim-SC-a8dc07ff5c0ba1c09e9a5beaf76f3b078670c74f.tar.xz |
removed a protocol breaking lludp debug option that no one should try, changed terrain send throotle to be by packets in queue, reduced odds of MTU violation on terrain send (still bad). Most UDP protocol implementations may not mind much, but our code still does
Diffstat (limited to '')
-rw-r--r-- | OpenSim/Region/ClientStack/Linden/UDP/LLUDPClient.cs | 28 |
1 files changed, 4 insertions, 24 deletions
diff --git a/OpenSim/Region/ClientStack/Linden/UDP/LLUDPClient.cs b/OpenSim/Region/ClientStack/Linden/UDP/LLUDPClient.cs index 8d4117d..507c07c 100644 --- a/OpenSim/Region/ClientStack/Linden/UDP/LLUDPClient.cs +++ b/OpenSim/Region/ClientStack/Linden/UDP/LLUDPClient.cs | |||
@@ -122,11 +122,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
122 | /// <summary>Sequence numbers of packets we've received (for duplicate checking)</summary> | 122 | /// <summary>Sequence numbers of packets we've received (for duplicate checking)</summary> |
123 | public readonly IncomingPacketHistoryCollection PacketArchive = new IncomingPacketHistoryCollection(200); | 123 | public readonly IncomingPacketHistoryCollection PacketArchive = new IncomingPacketHistoryCollection(200); |
124 | 124 | ||
125 | /// <summary> | ||
126 | /// If true then we take action in response to unacked reliably sent packets such as resending the packet. | ||
127 | /// </summary> | ||
128 | public bool ProcessUnackedSends { get; set; } | ||
129 | |||
130 | /// <summary>Packets we have sent that need to be ACKed by the client</summary> | 125 | /// <summary>Packets we have sent that need to be ACKed by the client</summary> |
131 | public readonly UnackedPacketCollection NeedAcks = new UnackedPacketCollection(); | 126 | public readonly UnackedPacketCollection NeedAcks = new UnackedPacketCollection(); |
132 | 127 | ||
@@ -252,8 +247,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
252 | if (maxRTO != 0) | 247 | if (maxRTO != 0) |
253 | m_maxRTO = maxRTO; | 248 | m_maxRTO = maxRTO; |
254 | 249 | ||
255 | ProcessUnackedSends = true; | ||
256 | |||
257 | m_burstTime = rates.BrustTime; | 250 | m_burstTime = rates.BrustTime; |
258 | float m_burst = rates.ClientMaxRate * m_burstTime; | 251 | float m_burst = rates.ClientMaxRate * m_burstTime; |
259 | 252 | ||
@@ -357,8 +350,9 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
357 | /// <param name="throttleType"></param> | 350 | /// <param name="throttleType"></param> |
358 | public int GetPacketsQueuedCount(ThrottleOutPacketType throttleType) | 351 | public int GetPacketsQueuedCount(ThrottleOutPacketType throttleType) |
359 | { | 352 | { |
360 | if ((int)throttleType > 0) | 353 | int icat = (int)throttleType; |
361 | return m_packetOutboxes[(int)throttleType].Count; | 354 | if (icat > 0 && icat < THROTTLE_CATEGORY_COUNT) |
355 | return m_packetOutboxes[icat].Count; | ||
362 | else | 356 | else |
363 | return 0; | 357 | return 0; |
364 | } | 358 | } |
@@ -544,21 +538,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
544 | 538 | ||
545 | return data; | 539 | return data; |
546 | } | 540 | } |
547 | 541 | ||
548 | public int GetCatBytesInSendQueue(ThrottleOutPacketType cat) | ||
549 | { | ||
550 | ; | ||
551 | int icat = (int)cat; | ||
552 | if (icat > 0 && icat < THROTTLE_CATEGORY_COUNT) | ||
553 | { | ||
554 | TokenBucket bucket = m_throttleCategories[icat]; | ||
555 | return m_packetOutboxes[icat].Count; | ||
556 | } | ||
557 | else | ||
558 | return 0; | ||
559 | } | ||
560 | |||
561 | |||
562 | public int GetCatBytesCanSend(ThrottleOutPacketType cat, int timeMS) | 542 | public int GetCatBytesCanSend(ThrottleOutPacketType cat, int timeMS) |
563 | { | 543 | { |
564 | int icat = (int)cat; | 544 | int icat = (int)cat; |