aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Region/CoreModules/Agent/Xfer/XferModule.cs
diff options
context:
space:
mode:
Diffstat (limited to 'OpenSim/Region/CoreModules/Agent/Xfer/XferModule.cs')
-rw-r--r--OpenSim/Region/CoreModules/Agent/Xfer/XferModule.cs31
1 files changed, 15 insertions, 16 deletions
diff --git a/OpenSim/Region/CoreModules/Agent/Xfer/XferModule.cs b/OpenSim/Region/CoreModules/Agent/Xfer/XferModule.cs
index 056e786..b897d04 100644
--- a/OpenSim/Region/CoreModules/Agent/Xfer/XferModule.cs
+++ b/OpenSim/Region/CoreModules/Agent/Xfer/XferModule.cs
@@ -122,7 +122,7 @@ namespace OpenSim.Region.CoreModules.Agent.Xfer
122 if(!inTimeTick) 122 if(!inTimeTick)
123 { 123 {
124 double now = Util.GetTimeStampMS(); 124 double now = Util.GetTimeStampMS();
125 if(now - lastTimeTick > 500.0) 125 if(now - lastTimeTick > 750.0)
126 { 126 {
127 127
128 if(Transfers.Count == 0 && NewFiles.Count == 0) 128 if(Transfers.Count == 0 && NewFiles.Count == 0)
@@ -334,7 +334,6 @@ namespace OpenSim.Region.CoreModules.Agent.Xfer
334 private int lastAckPacket; 334 private int lastAckPacket;
335 private int burstSize; // additional packets, so can be zero 335 private int burstSize; // additional packets, so can be zero
336 private int retries; 336 private int retries;
337 private bool inBurst;
338 337
339 public XferDownLoad(string fileName, byte[] data, ulong xferID, IClientAPI client, int burstsz) 338 public XferDownLoad(string fileName, byte[] data, ulong xferID, IClientAPI client, int burstsz)
340 { 339 {
@@ -397,15 +396,16 @@ namespace OpenSim.Region.CoreModules.Agent.Xfer
397 396
398 private void SendBurst(double now) 397 private void SendBurst(double now)
399 { 398 {
400 inBurst = true; 399 lock(myLock)
401 lastACKTimeMS = (int)now; // reset timeout 400 {
402 int start = lastAckPacket + 1; 401 lastACKTimeMS = (int)now; // reset timeout
403 int end = start + burstSize; 402 int start = lastAckPacket + 1;
404 if (end > LastPacket) 403 int end = start + burstSize;
405 end = LastPacket; 404 if (end > LastPacket)
406 while (start <= end) 405 end = LastPacket;
407 SendPacket(start++ , now); 406 while (start <= end)
408 inBurst = false; 407 SendPacket(start++ , now);
408 }
409 } 409 }
410 410
411 private void SendPacket(int pkt, double now) 411 private void SendPacket(int pkt, double now)
@@ -458,8 +458,7 @@ namespace OpenSim.Region.CoreModules.Agent.Xfer
458 double now = Util.GetTimeStampMS(); 458 double now = Util.GetTimeStampMS();
459 lastACKTimeMS = (int)now; 459 lastACKTimeMS = (int)now;
460 retries = 0; 460 retries = 0;
461 if (!inBurst) 461 SendPacket(lastSentPacket + 1, now);
462 SendPacket(lastSentPacket + 1, now);
463 return false; 462 return false;
464 } 463 }
465 } 464 }
@@ -468,15 +467,15 @@ namespace OpenSim.Region.CoreModules.Agent.Xfer
468 { 467 {
469 if (Monitor.TryEnter(myLock)) 468 if (Monitor.TryEnter(myLock))
470 { 469 {
471 if (!isDeleted && !inBurst) 470 if (!isDeleted)
472 { 471 {
473 double timeMS = now - lastACKTimeMS; 472 double timeMS = now - lastACKTimeMS;
474 473
475 double tout = 5 * remoteClient.PingTimeMS; 474 double tout = 5 * remoteClient.PingTimeMS;
476 if(tout > 10000) 475 if(tout > 10000)
477 tout = 10000; 476 tout = 10000;
478 else if (tout < 500) 477 else if (tout < 1000)
479 tout = 500; 478 tout = 1000;
480 if (timeMS > tout) 479 if (timeMS > tout)
481 { 480 {
482 if (++retries >= 4) 481 if (++retries >= 4)