aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Framework/Data.MySQL
diff options
context:
space:
mode:
Diffstat (limited to 'OpenSim/Framework/Data.MySQL')
-rw-r--r--OpenSim/Framework/Data.MySQL/MySQLDataStore.cs71
1 files changed, 43 insertions, 28 deletions
diff --git a/OpenSim/Framework/Data.MySQL/MySQLDataStore.cs b/OpenSim/Framework/Data.MySQL/MySQLDataStore.cs
index 478816c..6523105 100644
--- a/OpenSim/Framework/Data.MySQL/MySQLDataStore.cs
+++ b/OpenSim/Framework/Data.MySQL/MySQLDataStore.cs
@@ -418,41 +418,56 @@ namespace OpenSim.Framework.Data.MySQL
418 { 418 {
419 MainLog.Instance.Verbose("DATASTORE", "Tedds temp fix: Waiting 3 seconds for stuff to catch up. (Someone please fix! :))"); 419 MainLog.Instance.Verbose("DATASTORE", "Tedds temp fix: Waiting 3 seconds for stuff to catch up. (Someone please fix! :))");
420 System.Threading.Thread.Sleep(3000); 420 System.Threading.Thread.Sleep(3000);
421
422 lock (m_dataSet)
423 {
424 DataTable land = m_landTable;
425 DataTable landaccesslist = m_landAccessListTable;
426 421
427 DataRow landRow = land.Rows.Find(Util.ToRawUuidString(parcel.landData.globalID)); 422 int loopCount = 0;
428 if (landRow == null) 423 while (true)
429 { 424 {
430 landRow = land.NewRow(); 425 loopCount++;
431 fillLandRow(landRow, parcel.landData, regionUUID); 426 try
432 land.Rows.Add(landRow);
433 }
434 else
435 { 427 {
436 fillLandRow(landRow, parcel.landData, regionUUID); 428 lock (m_dataSet)
437 } 429 {
430 DataTable land = m_landTable;
431 DataTable landaccesslist = m_landAccessListTable;
438 432
439 using ( 433 DataRow landRow = land.Rows.Find(Util.ToRawUuidString(parcel.landData.globalID));
440 MySqlCommand cmd = 434 if (landRow == null)
441 new MySqlCommand("delete from landaccesslist where LandUUID=?LandUUID", m_connection)) 435 {
442 { 436 landRow = land.NewRow();
443 cmd.Parameters.Add(new MySqlParameter("?LandUUID", Util.ToRawUuidString(parcel.landData.globalID))); 437 fillLandRow(landRow, parcel.landData, regionUUID);
444 cmd.ExecuteNonQuery(); 438 land.Rows.Add(landRow);
445 } 439 }
440 else
441 {
442 fillLandRow(landRow, parcel.landData, regionUUID);
443 }
446 444
447 foreach (ParcelManager.ParcelAccessEntry entry in parcel.landData.parcelAccessList) 445 using (
446 MySqlCommand cmd =
447 new MySqlCommand("delete from landaccesslist where LandUUID=?LandUUID", m_connection))
448 {
449 cmd.Parameters.Add(
450 new MySqlParameter("?LandUUID", Util.ToRawUuidString(parcel.landData.globalID)));
451 cmd.ExecuteNonQuery();
452 }
453
454 foreach (ParcelManager.ParcelAccessEntry entry in parcel.landData.parcelAccessList)
455 {
456 DataRow newAccessRow = landaccesslist.NewRow();
457 fillLandAccessRow(newAccessRow, entry, parcel.landData.globalID);
458 landaccesslist.Rows.Add(newAccessRow);
459 }
460 }
461 Commit();
462 break;
463 }
464 catch (Exception ex)
448 { 465 {
449 DataRow newAccessRow = landaccesslist.NewRow(); 466 System.Console.WriteLine("Tedds temp fix exception, will repeat taks: " + ex.ToString());
450 fillLandAccessRow(newAccessRow, entry, parcel.landData.globalID); 467 if (loopCount > 3)
451 landaccesslist.Rows.Add(newAccessRow); 468 throw (ex);
452 } 469 }
453 } 470 }
454
455 Commit();
456 } 471 }
457 472
458 public List<LandData> LoadLandObjects(LLUUID regionUUID) 473 public List<LandData> LoadLandObjects(LLUUID regionUUID)