1 files changed, 25 insertions, 21 deletions

diff --git a/OpenSim/Grid/Manager/OpenGridServices.Manager/BlockingQueue.cs b/OpenSim/Data/MySQL/MySQLGridUserData.cs
index 2e39cd0..df29ecd 100644
--- a/OpenSim/Grid/Manager/OpenGridServices.Manager/BlockingQueue.cs
+++ b/OpenSim/Data/MySQL/MySQLGridUserData.cs
@@ -26,35 +26,39 @@
  */
 
 using System;
-using System.Threading;
 using System.Collections.Generic;
-using System.Text;
+using System.Data;
+using System.Reflection;
+using System.Threading;
+using log4net;
+using OpenMetaverse;
+using OpenSim.Framework;
+using MySql.Data.MySqlClient;
 
-namespace OpenGridServices.Manager
+namespace OpenSim.Data.MySQL
 {
-    public class BlockingQueue<T>
+    /// <summary>
+    /// A MySQL Interface for user grid data
+    /// </summary>
+    public class MySQLGridUserData : MySQLGenericTableHandler<GridUserData>, IGridUserData
     {
-        private Queue<T> _queue = new Queue<T>();
-        private object _queueSync = new object();
+//        private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+
+        public MySQLGridUserData(string connectionString, string realm) : base(connectionString, realm, "UserGrid") {}
 
-        public void Enqueue(T value)
+        public GridUserData GetGridUserData(string userID)
         {
-            lock (_queueSync)
-            {
-                _queue.Enqueue(value);
-                Monitor.Pulse(_queueSync);
-            }
+            GridUserData[] ret = Get("UserID", userID);
+
+            if (ret.Length == 0)
+                return null;
+
+            return ret[0];
         }
 
-        public T Dequeue()
+        public bool StoreGridUserData(GridUserData data)
         {
-            lock (_queueSync)
-            {
-                if (_queue.Count < 1)
-                    Monitor.Wait(_queueSync);
-
-                return _queue.Dequeue();
-            }
+            return Store(data);
         }
     }
-}
+}
\ No newline at end of file