From 2a3c79df83e800d5dfe75a1a3b140ed81da2b1d6 Mon Sep 17 00:00:00 2001
From: Sean Dague
Date: Mon, 16 Jul 2007 15:40:11 +0000
Subject: changed to native line ending encoding
---
.../Storage/LocalStorageDb4o/Db4LocalStorage.cs | 532 ++++++++++-----------
1 file changed, 266 insertions(+), 266 deletions(-)
(limited to 'OpenSim/Region/Storage/LocalStorageDb4o/Db4LocalStorage.cs')
diff --git a/OpenSim/Region/Storage/LocalStorageDb4o/Db4LocalStorage.cs b/OpenSim/Region/Storage/LocalStorageDb4o/Db4LocalStorage.cs
index 8214bc8..8d9f473 100644
--- a/OpenSim/Region/Storage/LocalStorageDb4o/Db4LocalStorage.cs
+++ b/OpenSim/Region/Storage/LocalStorageDb4o/Db4LocalStorage.cs
@@ -1,267 +1,267 @@
-/*
-* Copyright (c) Contributors, http://www.openmetaverse.org/
-* See CONTRIBUTORS.TXT for a full list of copyright holders.
-*
-* Redistribution and use in source and binary forms, with or without
-* modification, are permitted provided that the following conditions are met:
-* * Redistributions of source code must retain the above copyright
-* notice, this list of conditions and the following disclaimer.
-* * Redistributions in binary form must reproduce the above copyright
-* notice, this list of conditions and the following disclaimer in the
-* documentation and/or other materials provided with the distribution.
-* * Neither the name of the OpenSim Project nor the
-* names of its contributors may be used to endorse or promote products
-* derived from this software without specific prior written permission.
-*
-* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS AND ANY
-* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
-* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
-* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
-* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
-* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
-* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
-* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
-* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
-* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-*
-*/
-using System;
-using Db4objects.Db4o;
-using libsecondlife;
-using OpenSim.Framework.Console;
-using OpenSim.Framework.Interfaces;
-using OpenSim.Framework.Types;
-
-namespace OpenSim.Region.Storage.LocalStorageDb4o
-{
- ///
- ///
- ///
- public class Db4LocalStorage : ILocalStorage
- {
- private IObjectContainer db;
- private string datastore;
-
- public Db4LocalStorage()
- {
-
- }
-
- public void Initialise(string dfile)
- {
- MainLog.Instance.Warn("Db4LocalStorage Opening " + dfile);
- datastore = dfile;
- try
- {
- db = Db4oFactory.OpenFile(datastore);
- MainLog.Instance.Verbose("Db4LocalStorage creation");
- }
- catch (Exception e)
- {
- db.Close();
- MainLog.Instance.Warn("Db4LocalStorage :Constructor - Exception occured");
- MainLog.Instance.Warn(e.ToString());
- }
- }
-
- public void StorePrim(PrimData prim)
- {
- IObjectSet result = db.Query(new UUIDPrimQuery(prim.FullID));
- if (result.Count > 0)
- {
- //prim already in storage
- //so update it
- PrimData found = (PrimData)result.Next();
- found.PathBegin = prim.PathBegin;
- found.PathCurve = prim.PathCurve;
- found.PathEnd = prim.PathEnd;
- found.PathRadiusOffset = prim.PathRadiusOffset;
- found.PathRevolutions = prim.PathRevolutions;
- found.PathScaleX = prim.PathScaleX;
- found.PathScaleY = prim.PathScaleY;
- found.PathShearX = prim.PathShearX;
- found.PathShearY = prim.PathShearY;
- found.PathSkew = prim.PathSkew;
- found.PathTaperX = prim.PathTaperX;
- found.PathTaperY = prim.PathTaperY;
- found.PathTwist = prim.PathTwist;
- found.PathTwistBegin = prim.PathTwistBegin;
- found.PCode = prim.PCode;
- found.ProfileBegin = prim.ProfileBegin;
- found.ProfileCurve = prim.ProfileCurve;
- found.ProfileEnd = prim.ProfileEnd;
- found.ProfileHollow = prim.ProfileHollow;
- found.Position = prim.Position;
- found.Rotation = prim.Rotation;
- found.TextureEntry = prim.TextureEntry;
- db.Set(found);
- db.Commit();
- }
- else
- {
- //not in storage
- db.Set(prim);
- db.Commit();
- }
- }
-
- public void RemovePrim(LLUUID primID)
- {
- IObjectSet result = db.Query(new UUIDPrimQuery(primID));
- if (result.Count > 0)
- {
- PrimData found = (PrimData)result.Next();
- db.Delete(found);
- }
- }
-
-
- public void LoadPrimitives(ILocalStorageReceiver receiver)
- {
- IObjectSet result = db.Get(typeof(PrimData));
- MainLog.Instance.Verbose("Db4LocalStorage.cs: LoadPrimitives() - number of prims in storages is " + result.Count);
- foreach (PrimData prim in result)
- {
- receiver.PrimFromStorage(prim);
- }
- }
-
- public float[] LoadWorld()
- {
- MainLog.Instance.Verbose("LoadWorld() - Loading world....");
- float[] heightmap = null;
- MainLog.Instance.Verbose("LoadWorld() - Looking for a heightmap in local DB");
- IObjectSet world_result = db.Get(typeof(MapStorage));
- if (world_result.Count > 0)
- {
- MainLog.Instance.Verbose("LoadWorld() - Found a heightmap in local database, loading");
- MapStorage map = (MapStorage)world_result.Next();
- //blank.LandMap = map.Map;
- heightmap = map.Map;
- }
- return heightmap;
- }
-
- public void SaveMap(float[] heightmap)
- {
- IObjectSet world_result = db.Get(typeof(MapStorage));
- if (world_result.Count > 0)
- {
- MainLog.Instance.Verbose("SaveWorld() - updating saved copy of heightmap in local database");
- MapStorage map = (MapStorage)world_result.Next();
- db.Delete(map);
- }
- MapStorage map1 = new MapStorage();
- map1.Map = heightmap; //OpenSim_Main.local_world.LandMap;
- db.Set(map1);
- db.Commit();
- }
-
- public void SaveParcel(ParcelData parcel)
- {
- IObjectSet result = db.Query(new UUIDParcelQuery(parcel.globalID));
- if (result.Count > 0)
- {
- //Old Parcel
- ParcelData updateParcel = (ParcelData)result.Next();
- updateParcel.AABBMax = parcel.AABBMax;
- updateParcel.AABBMin = parcel.AABBMin;
- updateParcel.area = parcel.area;
- updateParcel.auctionID = parcel.auctionID;
- updateParcel.authBuyerID = parcel.authBuyerID;
- updateParcel.category = parcel.category;
- updateParcel.claimDate = parcel.claimDate;
- updateParcel.claimPrice = parcel.claimPrice;
- updateParcel.groupID = parcel.groupID;
- updateParcel.groupPrims = parcel.groupPrims;
- updateParcel.isGroupOwned = parcel.isGroupOwned;
- updateParcel.landingType = parcel.landingType;
- updateParcel.mediaAutoScale = parcel.mediaAutoScale;
- updateParcel.mediaID = parcel.mediaID;
- updateParcel.mediaURL = parcel.mediaURL;
- updateParcel.musicURL = parcel.musicURL;
- updateParcel.localID = parcel.localID;
- updateParcel.ownerID = parcel.ownerID;
- updateParcel.passHours = parcel.passHours;
- updateParcel.passPrice = parcel.passPrice;
- updateParcel.parcelBitmapByteArray = (byte[])parcel.parcelBitmapByteArray.Clone();
- updateParcel.parcelDesc = parcel.parcelDesc;
- updateParcel.parcelFlags = parcel.parcelFlags;
- updateParcel.parcelName = parcel.parcelName;
- updateParcel.parcelStatus = parcel.parcelStatus;
- updateParcel.salePrice = parcel.salePrice;
- updateParcel.snapshotID = parcel.snapshotID;
- updateParcel.userLocation = parcel.userLocation;
- updateParcel.userLookAt = parcel.userLookAt;
-
- db.Set(updateParcel);
- }
- else
- {
- db.Set(parcel);
- }
- db.Commit();
- }
-
- public void SaveParcels(ParcelData[] parcel_data)
- {
- MainLog.Instance.Notice("Parcel Backup: Saving Parcels...");
- int i;
- for (i = 0; i < parcel_data.GetLength(0); i++)
- {
-
- SaveParcel(parcel_data[i]);
-
- }
- MainLog.Instance.Notice("Parcel Backup: Parcel Save Complete");
- }
-
- public void RemoveParcel(ParcelData parcel)
- {
- IObjectSet result = db.Query(new UUIDParcelQuery(parcel.globalID));
- if (result.Count > 0)
- {
- db.Delete(result[0]);
- }
- db.Commit();
- }
- public void RemoveAllParcels()
- {
- MainLog.Instance.Notice("Parcel Backup: Removing all parcels...");
- IObjectSet result = db.Get(typeof(ParcelData));
- if (result.Count > 0)
- {
- foreach (ParcelData parcelData in result)
- {
- RemoveParcel(parcelData);
- }
- }
- }
-
- public void LoadParcels(ILocalStorageParcelReceiver recv)
- {
- MainLog.Instance.Notice("Parcel Backup: Loading Parcels...");
- IObjectSet result = db.Get(typeof(ParcelData));
- if (result.Count > 0)
- {
- MainLog.Instance.Notice("Parcel Backup: Parcels exist in database.");
- foreach (ParcelData parcelData in result)
- {
-
- recv.ParcelFromStorage(parcelData);
- }
- }
- else
- {
- MainLog.Instance.Notice("Parcel Backup: No parcels exist. Creating basic parcel.");
- recv.NoParcelDataFromStorage();
- }
- MainLog.Instance.Notice("Parcel Backup: Parcels Restored");
- }
- public void ShutDown()
- {
- db.Commit();
- db.Close();
- }
- }
+/*
+* Copyright (c) Contributors, http://www.openmetaverse.org/
+* See CONTRIBUTORS.TXT for a full list of copyright holders.
+*
+* Redistribution and use in source and binary forms, with or without
+* modification, are permitted provided that the following conditions are met:
+* * Redistributions of source code must retain the above copyright
+* notice, this list of conditions and the following disclaimer.
+* * Redistributions in binary form must reproduce the above copyright
+* notice, this list of conditions and the following disclaimer in the
+* documentation and/or other materials provided with the distribution.
+* * Neither the name of the OpenSim Project nor the
+* names of its contributors may be used to endorse or promote products
+* derived from this software without specific prior written permission.
+*
+* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS AND ANY
+* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
+* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+*
+*/
+using System;
+using Db4objects.Db4o;
+using libsecondlife;
+using OpenSim.Framework.Console;
+using OpenSim.Framework.Interfaces;
+using OpenSim.Framework.Types;
+
+namespace OpenSim.Region.Storage.LocalStorageDb4o
+{
+ ///
+ ///
+ ///
+ public class Db4LocalStorage : ILocalStorage
+ {
+ private IObjectContainer db;
+ private string datastore;
+
+ public Db4LocalStorage()
+ {
+
+ }
+
+ public void Initialise(string dfile)
+ {
+ MainLog.Instance.Warn("Db4LocalStorage Opening " + dfile);
+ datastore = dfile;
+ try
+ {
+ db = Db4oFactory.OpenFile(datastore);
+ MainLog.Instance.Verbose("Db4LocalStorage creation");
+ }
+ catch (Exception e)
+ {
+ db.Close();
+ MainLog.Instance.Warn("Db4LocalStorage :Constructor - Exception occured");
+ MainLog.Instance.Warn(e.ToString());
+ }
+ }
+
+ public void StorePrim(PrimData prim)
+ {
+ IObjectSet result = db.Query(new UUIDPrimQuery(prim.FullID));
+ if (result.Count > 0)
+ {
+ //prim already in storage
+ //so update it
+ PrimData found = (PrimData)result.Next();
+ found.PathBegin = prim.PathBegin;
+ found.PathCurve = prim.PathCurve;
+ found.PathEnd = prim.PathEnd;
+ found.PathRadiusOffset = prim.PathRadiusOffset;
+ found.PathRevolutions = prim.PathRevolutions;
+ found.PathScaleX = prim.PathScaleX;
+ found.PathScaleY = prim.PathScaleY;
+ found.PathShearX = prim.PathShearX;
+ found.PathShearY = prim.PathShearY;
+ found.PathSkew = prim.PathSkew;
+ found.PathTaperX = prim.PathTaperX;
+ found.PathTaperY = prim.PathTaperY;
+ found.PathTwist = prim.PathTwist;
+ found.PathTwistBegin = prim.PathTwistBegin;
+ found.PCode = prim.PCode;
+ found.ProfileBegin = prim.ProfileBegin;
+ found.ProfileCurve = prim.ProfileCurve;
+ found.ProfileEnd = prim.ProfileEnd;
+ found.ProfileHollow = prim.ProfileHollow;
+ found.Position = prim.Position;
+ found.Rotation = prim.Rotation;
+ found.TextureEntry = prim.TextureEntry;
+ db.Set(found);
+ db.Commit();
+ }
+ else
+ {
+ //not in storage
+ db.Set(prim);
+ db.Commit();
+ }
+ }
+
+ public void RemovePrim(LLUUID primID)
+ {
+ IObjectSet result = db.Query(new UUIDPrimQuery(primID));
+ if (result.Count > 0)
+ {
+ PrimData found = (PrimData)result.Next();
+ db.Delete(found);
+ }
+ }
+
+
+ public void LoadPrimitives(ILocalStorageReceiver receiver)
+ {
+ IObjectSet result = db.Get(typeof(PrimData));
+ MainLog.Instance.Verbose("Db4LocalStorage.cs: LoadPrimitives() - number of prims in storages is " + result.Count);
+ foreach (PrimData prim in result)
+ {
+ receiver.PrimFromStorage(prim);
+ }
+ }
+
+ public float[] LoadWorld()
+ {
+ MainLog.Instance.Verbose("LoadWorld() - Loading world....");
+ float[] heightmap = null;
+ MainLog.Instance.Verbose("LoadWorld() - Looking for a heightmap in local DB");
+ IObjectSet world_result = db.Get(typeof(MapStorage));
+ if (world_result.Count > 0)
+ {
+ MainLog.Instance.Verbose("LoadWorld() - Found a heightmap in local database, loading");
+ MapStorage map = (MapStorage)world_result.Next();
+ //blank.LandMap = map.Map;
+ heightmap = map.Map;
+ }
+ return heightmap;
+ }
+
+ public void SaveMap(float[] heightmap)
+ {
+ IObjectSet world_result = db.Get(typeof(MapStorage));
+ if (world_result.Count > 0)
+ {
+ MainLog.Instance.Verbose("SaveWorld() - updating saved copy of heightmap in local database");
+ MapStorage map = (MapStorage)world_result.Next();
+ db.Delete(map);
+ }
+ MapStorage map1 = new MapStorage();
+ map1.Map = heightmap; //OpenSim_Main.local_world.LandMap;
+ db.Set(map1);
+ db.Commit();
+ }
+
+ public void SaveParcel(ParcelData parcel)
+ {
+ IObjectSet result = db.Query(new UUIDParcelQuery(parcel.globalID));
+ if (result.Count > 0)
+ {
+ //Old Parcel
+ ParcelData updateParcel = (ParcelData)result.Next();
+ updateParcel.AABBMax = parcel.AABBMax;
+ updateParcel.AABBMin = parcel.AABBMin;
+ updateParcel.area = parcel.area;
+ updateParcel.auctionID = parcel.auctionID;
+ updateParcel.authBuyerID = parcel.authBuyerID;
+ updateParcel.category = parcel.category;
+ updateParcel.claimDate = parcel.claimDate;
+ updateParcel.claimPrice = parcel.claimPrice;
+ updateParcel.groupID = parcel.groupID;
+ updateParcel.groupPrims = parcel.groupPrims;
+ updateParcel.isGroupOwned = parcel.isGroupOwned;
+ updateParcel.landingType = parcel.landingType;
+ updateParcel.mediaAutoScale = parcel.mediaAutoScale;
+ updateParcel.mediaID = parcel.mediaID;
+ updateParcel.mediaURL = parcel.mediaURL;
+ updateParcel.musicURL = parcel.musicURL;
+ updateParcel.localID = parcel.localID;
+ updateParcel.ownerID = parcel.ownerID;
+ updateParcel.passHours = parcel.passHours;
+ updateParcel.passPrice = parcel.passPrice;
+ updateParcel.parcelBitmapByteArray = (byte[])parcel.parcelBitmapByteArray.Clone();
+ updateParcel.parcelDesc = parcel.parcelDesc;
+ updateParcel.parcelFlags = parcel.parcelFlags;
+ updateParcel.parcelName = parcel.parcelName;
+ updateParcel.parcelStatus = parcel.parcelStatus;
+ updateParcel.salePrice = parcel.salePrice;
+ updateParcel.snapshotID = parcel.snapshotID;
+ updateParcel.userLocation = parcel.userLocation;
+ updateParcel.userLookAt = parcel.userLookAt;
+
+ db.Set(updateParcel);
+ }
+ else
+ {
+ db.Set(parcel);
+ }
+ db.Commit();
+ }
+
+ public void SaveParcels(ParcelData[] parcel_data)
+ {
+ MainLog.Instance.Notice("Parcel Backup: Saving Parcels...");
+ int i;
+ for (i = 0; i < parcel_data.GetLength(0); i++)
+ {
+
+ SaveParcel(parcel_data[i]);
+
+ }
+ MainLog.Instance.Notice("Parcel Backup: Parcel Save Complete");
+ }
+
+ public void RemoveParcel(ParcelData parcel)
+ {
+ IObjectSet result = db.Query(new UUIDParcelQuery(parcel.globalID));
+ if (result.Count > 0)
+ {
+ db.Delete(result[0]);
+ }
+ db.Commit();
+ }
+ public void RemoveAllParcels()
+ {
+ MainLog.Instance.Notice("Parcel Backup: Removing all parcels...");
+ IObjectSet result = db.Get(typeof(ParcelData));
+ if (result.Count > 0)
+ {
+ foreach (ParcelData parcelData in result)
+ {
+ RemoveParcel(parcelData);
+ }
+ }
+ }
+
+ public void LoadParcels(ILocalStorageParcelReceiver recv)
+ {
+ MainLog.Instance.Notice("Parcel Backup: Loading Parcels...");
+ IObjectSet result = db.Get(typeof(ParcelData));
+ if (result.Count > 0)
+ {
+ MainLog.Instance.Notice("Parcel Backup: Parcels exist in database.");
+ foreach (ParcelData parcelData in result)
+ {
+
+ recv.ParcelFromStorage(parcelData);
+ }
+ }
+ else
+ {
+ MainLog.Instance.Notice("Parcel Backup: No parcels exist. Creating basic parcel.");
+ recv.NoParcelDataFromStorage();
+ }
+ MainLog.Instance.Notice("Parcel Backup: Parcels Restored");
+ }
+ public void ShutDown()
+ {
+ db.Commit();
+ db.Close();
+ }
+ }
}
\ No newline at end of file
--
cgit v1.1