diff options
Diffstat (limited to 'OpenSim/Services')
36 files changed, 821 insertions, 163 deletions
diff --git a/OpenSim/Services/AssetService/AssetService.cs b/OpenSim/Services/AssetService/AssetService.cs index 08fd3f8..90c30c8 100644 --- a/OpenSim/Services/AssetService/AssetService.cs +++ b/OpenSim/Services/AssetService/AssetService.cs | |||
@@ -159,7 +159,10 @@ namespace OpenSim.Services.AssetService | |||
159 | { | 159 | { |
160 | // m_log.DebugFormat( | 160 | // m_log.DebugFormat( |
161 | // "[ASSET SERVICE]: Storing asset {0} {1}, bytes {2}", asset.Name, asset.FullID, asset.Data.Length); | 161 | // "[ASSET SERVICE]: Storing asset {0} {1}, bytes {2}", asset.Name, asset.FullID, asset.Data.Length); |
162 | m_Database.StoreAsset(asset); | 162 | if (!m_Database.StoreAsset(asset)) |
163 | { | ||
164 | return UUID.Zero.ToString(); | ||
165 | } | ||
163 | } | 166 | } |
164 | // else | 167 | // else |
165 | // { | 168 | // { |
diff --git a/OpenSim/Services/AuthenticationService/AuthenticationServiceBase.cs b/OpenSim/Services/AuthenticationService/AuthenticationServiceBase.cs index 229f557..e42f9a0 100644 --- a/OpenSim/Services/AuthenticationService/AuthenticationServiceBase.cs +++ b/OpenSim/Services/AuthenticationService/AuthenticationServiceBase.cs | |||
@@ -30,10 +30,11 @@ using OpenMetaverse; | |||
30 | using log4net; | 30 | using log4net; |
31 | using Nini.Config; | 31 | using Nini.Config; |
32 | using System.Reflection; | 32 | using System.Reflection; |
33 | using OpenSim.Server.Base; | ||
34 | using OpenSim.Services.Interfaces; | ||
33 | using OpenSim.Data; | 35 | using OpenSim.Data; |
34 | using OpenSim.Framework; | 36 | using OpenSim.Framework; |
35 | using OpenSim.Services.Base; | 37 | using OpenSim.Services.Base; |
36 | using OpenSim.Services.Interfaces; | ||
37 | 38 | ||
38 | namespace OpenSim.Services.AuthenticationService | 39 | namespace OpenSim.Services.AuthenticationService |
39 | { | 40 | { |
@@ -50,6 +51,12 @@ namespace OpenSim.Services.AuthenticationService | |||
50 | MethodBase.GetCurrentMethod().DeclaringType); | 51 | MethodBase.GetCurrentMethod().DeclaringType); |
51 | 52 | ||
52 | protected IAuthenticationData m_Database; | 53 | protected IAuthenticationData m_Database; |
54 | protected IUserAccountService m_UserAccountService = null; | ||
55 | |||
56 | public AuthenticationServiceBase(IConfigSource config, IUserAccountService acct) : this(config) | ||
57 | { | ||
58 | m_UserAccountService = acct; | ||
59 | } | ||
53 | 60 | ||
54 | public AuthenticationServiceBase(IConfigSource config) : base(config) | 61 | public AuthenticationServiceBase(IConfigSource config) : base(config) |
55 | { | 62 | { |
diff --git a/OpenSim/Services/AuthenticationService/PasswordAuthenticationService.cs b/OpenSim/Services/AuthenticationService/PasswordAuthenticationService.cs index 5f1bde1..a069838 100644 --- a/OpenSim/Services/AuthenticationService/PasswordAuthenticationService.cs +++ b/OpenSim/Services/AuthenticationService/PasswordAuthenticationService.cs | |||
@@ -51,6 +51,12 @@ namespace OpenSim.Services.AuthenticationService | |||
51 | LogManager.GetLogger( | 51 | LogManager.GetLogger( |
52 | MethodBase.GetCurrentMethod().DeclaringType); | 52 | MethodBase.GetCurrentMethod().DeclaringType); |
53 | 53 | ||
54 | public PasswordAuthenticationService(IConfigSource config, IUserAccountService userService) : | ||
55 | base(config, userService) | ||
56 | { | ||
57 | m_log.Debug("[AUTH SERVICE]: Started with User Account access"); | ||
58 | } | ||
59 | |||
54 | public PasswordAuthenticationService(IConfigSource config) : | 60 | public PasswordAuthenticationService(IConfigSource config) : |
55 | base(config) | 61 | base(config) |
56 | { | 62 | { |
@@ -58,42 +64,90 @@ namespace OpenSim.Services.AuthenticationService | |||
58 | 64 | ||
59 | public string Authenticate(UUID principalID, string password, int lifetime) | 65 | public string Authenticate(UUID principalID, string password, int lifetime) |
60 | { | 66 | { |
67 | UUID realID; | ||
68 | return Authenticate(principalID, password, lifetime, out realID); | ||
69 | } | ||
70 | |||
71 | public string Authenticate(UUID principalID, string password, int lifetime, out UUID realID) | ||
72 | { | ||
73 | realID = UUID.Zero; | ||
74 | |||
75 | m_log.DebugFormat("[AUTH SERVICE]: Authenticating for {0}, user account service present: {1}", principalID, m_UserAccountService != null); | ||
61 | AuthenticationData data = m_Database.Get(principalID); | 76 | AuthenticationData data = m_Database.Get(principalID); |
77 | UserAccount user = null; | ||
78 | if (m_UserAccountService != null) | ||
79 | user = m_UserAccountService.GetUserAccount(UUID.Zero, principalID); | ||
62 | 80 | ||
63 | if (data == null) | 81 | if (data == null || data.Data == null) |
64 | { | 82 | { |
65 | m_log.DebugFormat("[AUTH SERVICE]: PrincipalID {0} not found", principalID); | 83 | m_log.DebugFormat("[AUTH SERVICE]: PrincipalID {0} or its data not found", principalID); |
66 | return String.Empty; | 84 | return String.Empty; |
67 | } | 85 | } |
68 | else if (data.Data == null) | 86 | |
87 | if (!data.Data.ContainsKey("passwordHash") || | ||
88 | !data.Data.ContainsKey("passwordSalt")) | ||
69 | { | 89 | { |
70 | m_log.DebugFormat("[AUTH SERVICE]: PrincipalID {0} data not found", principalID); | ||
71 | return String.Empty; | 90 | return String.Empty; |
72 | } | 91 | } |
73 | else if (!data.Data.ContainsKey("passwordHash") || !data.Data.ContainsKey("passwordSalt")) | 92 | |
93 | string hashed = Util.Md5Hash(password + ":" + | ||
94 | data.Data["passwordSalt"].ToString()); | ||
95 | |||
96 | m_log.DebugFormat("[PASS AUTH]: got {0}; hashed = {1}; stored = {2}", password, hashed, data.Data["passwordHash"].ToString()); | ||
97 | |||
98 | if (data.Data["passwordHash"].ToString() == hashed) | ||
99 | { | ||
100 | return GetToken(principalID, lifetime); | ||
101 | } | ||
102 | |||
103 | if (user == null) | ||
74 | { | 104 | { |
75 | m_log.DebugFormat( | 105 | m_log.DebugFormat("[PASS AUTH]: No user record for {0}", principalID); |
76 | "[AUTH SERVICE]: PrincipalID {0} data didn't contain either passwordHash or passwordSalt", principalID); | ||
77 | return String.Empty; | 106 | return String.Empty; |
78 | } | 107 | } |
79 | else | 108 | |
109 | int impersonateFlag = 1 << 6; | ||
110 | |||
111 | if ((user.UserFlags & impersonateFlag) == 0) | ||
112 | return String.Empty; | ||
113 | |||
114 | m_log.DebugFormat("[PASS AUTH]: Attempting impersonation"); | ||
115 | |||
116 | List<UserAccount> accounts = m_UserAccountService.GetUserAccountsWhere(UUID.Zero, "UserLevel >= 200"); | ||
117 | if (accounts == null || accounts.Count == 0) | ||
118 | return String.Empty; | ||
119 | |||
120 | foreach (UserAccount a in accounts) | ||
80 | { | 121 | { |
81 | string hashed = Util.Md5Hash(password + ":" + data.Data["passwordSalt"].ToString()); | 122 | data = m_Database.Get(a.PrincipalID); |
123 | if (data == null || data.Data == null || | ||
124 | !data.Data.ContainsKey("passwordHash") || | ||
125 | !data.Data.ContainsKey("passwordSalt")) | ||
126 | { | ||
127 | continue; | ||
128 | } | ||
129 | |||
130 | // m_log.DebugFormat("[PASS AUTH]: Trying {0}", data.PrincipalID); | ||
82 | 131 | ||
83 | m_log.DebugFormat("[PASS AUTH]: got {0}; hashed = {1}; stored = {2}", password, hashed, data.Data["passwordHash"].ToString()); | 132 | hashed = Util.Md5Hash(password + ":" + |
133 | data.Data["passwordSalt"].ToString()); | ||
84 | 134 | ||
85 | if (data.Data["passwordHash"].ToString() == hashed) | 135 | if (data.Data["passwordHash"].ToString() == hashed) |
86 | { | 136 | { |
137 | m_log.DebugFormat("[PASS AUTH]: {0} {1} impersonating {2}, proceeding with login", a.FirstName, a.LastName, principalID); | ||
138 | realID = a.PrincipalID; | ||
87 | return GetToken(principalID, lifetime); | 139 | return GetToken(principalID, lifetime); |
88 | } | 140 | } |
89 | else | 141 | // else |
90 | { | 142 | // { |
91 | m_log.DebugFormat( | 143 | // m_log.DebugFormat( |
92 | "[AUTH SERVICE]: Salted hash {0} of given password did not match salted hash of {1} for PrincipalID {2}. Authentication failure.", | 144 | // "[AUTH SERVICE]: Salted hash {0} of given password did not match salted hash of {1} for PrincipalID {2}. Authentication failure.", |
93 | hashed, data.Data["passwordHash"], principalID); | 145 | // hashed, data.Data["passwordHash"], data.PrincipalID); |
94 | return String.Empty; | 146 | // } |
95 | } | ||
96 | } | 147 | } |
148 | |||
149 | m_log.DebugFormat("[PASS AUTH]: Impersonation of {0} failed", principalID); | ||
150 | return String.Empty; | ||
97 | } | 151 | } |
98 | } | 152 | } |
99 | } \ No newline at end of file | 153 | } |
diff --git a/OpenSim/Services/AuthenticationService/WebkeyAuthenticationService.cs b/OpenSim/Services/AuthenticationService/WebkeyAuthenticationService.cs index 2344c0e..1510168 100644 --- a/OpenSim/Services/AuthenticationService/WebkeyAuthenticationService.cs +++ b/OpenSim/Services/AuthenticationService/WebkeyAuthenticationService.cs | |||
@@ -49,12 +49,23 @@ namespace OpenSim.Services.AuthenticationService | |||
49 | private static readonly ILog m_log = | 49 | private static readonly ILog m_log = |
50 | LogManager.GetLogger( | 50 | LogManager.GetLogger( |
51 | MethodBase.GetCurrentMethod().DeclaringType); | 51 | MethodBase.GetCurrentMethod().DeclaringType); |
52 | |||
53 | public WebkeyAuthenticationService(IConfigSource config, IUserAccountService userService) : | ||
54 | base(config, userService) | ||
55 | { | ||
56 | } | ||
52 | 57 | ||
53 | public WebkeyAuthenticationService(IConfigSource config) : | 58 | public WebkeyAuthenticationService(IConfigSource config) : |
54 | base(config) | 59 | base(config) |
55 | { | 60 | { |
56 | } | 61 | } |
57 | 62 | ||
63 | public string Authenticate(UUID principalID, string password, int lifetime, out UUID realID) | ||
64 | { | ||
65 | realID = UUID.Zero; | ||
66 | return Authenticate(principalID, password, lifetime); | ||
67 | } | ||
68 | |||
58 | public string Authenticate(UUID principalID, string password, int lifetime) | 69 | public string Authenticate(UUID principalID, string password, int lifetime) |
59 | { | 70 | { |
60 | if (new UUID(password) == UUID.Zero) | 71 | if (new UUID(password) == UUID.Zero) |
diff --git a/OpenSim/Services/AuthenticationService/WebkeyOrPasswordAuthenticationService.cs b/OpenSim/Services/AuthenticationService/WebkeyOrPasswordAuthenticationService.cs index 2c6cebd..bbc8470 100644 --- a/OpenSim/Services/AuthenticationService/WebkeyOrPasswordAuthenticationService.cs +++ b/OpenSim/Services/AuthenticationService/WebkeyOrPasswordAuthenticationService.cs | |||
@@ -55,14 +55,22 @@ namespace OpenSim.Services.AuthenticationService | |||
55 | 55 | ||
56 | public string Authenticate(UUID principalID, string password, int lifetime) | 56 | public string Authenticate(UUID principalID, string password, int lifetime) |
57 | { | 57 | { |
58 | UUID realID; | ||
59 | |||
60 | return Authenticate(principalID, password, lifetime, out realID); | ||
61 | } | ||
62 | |||
63 | public string Authenticate(UUID principalID, string password, int lifetime, out UUID realID) | ||
64 | { | ||
58 | AuthenticationData data = m_Database.Get(principalID); | 65 | AuthenticationData data = m_Database.Get(principalID); |
59 | string result = String.Empty; | 66 | string result = String.Empty; |
67 | realID = UUID.Zero; | ||
60 | if (data != null && data.Data != null) | 68 | if (data != null && data.Data != null) |
61 | { | 69 | { |
62 | if (data.Data.ContainsKey("webLoginKey")) | 70 | if (data.Data.ContainsKey("webLoginKey")) |
63 | { | 71 | { |
64 | m_log.DebugFormat("[AUTH SERVICE]: Attempting web key authentication for PrincipalID {0}", principalID); | 72 | m_log.DebugFormat("[AUTH SERVICE]: Attempting web key authentication for PrincipalID {0}", principalID); |
65 | result = m_svcChecks["web_login_key"].Authenticate(principalID, password, lifetime); | 73 | result = m_svcChecks["web_login_key"].Authenticate(principalID, password, lifetime, out realID); |
66 | if (result == String.Empty) | 74 | if (result == String.Empty) |
67 | { | 75 | { |
68 | m_log.DebugFormat("[AUTH SERVICE]: Web Login failed for PrincipalID {0}", principalID); | 76 | m_log.DebugFormat("[AUTH SERVICE]: Web Login failed for PrincipalID {0}", principalID); |
@@ -71,12 +79,15 @@ namespace OpenSim.Services.AuthenticationService | |||
71 | if (result == string.Empty && data.Data.ContainsKey("passwordHash") && data.Data.ContainsKey("passwordSalt")) | 79 | if (result == string.Empty && data.Data.ContainsKey("passwordHash") && data.Data.ContainsKey("passwordSalt")) |
72 | { | 80 | { |
73 | m_log.DebugFormat("[AUTH SERVICE]: Attempting password authentication for PrincipalID {0}", principalID); | 81 | m_log.DebugFormat("[AUTH SERVICE]: Attempting password authentication for PrincipalID {0}", principalID); |
74 | result = m_svcChecks["password"].Authenticate(principalID, password, lifetime); | 82 | result = m_svcChecks["password"].Authenticate(principalID, password, lifetime, out realID); |
75 | if (result == String.Empty) | 83 | if (result == String.Empty) |
76 | { | 84 | { |
77 | m_log.DebugFormat("[AUTH SERVICE]: Password login failed for PrincipalID {0}", principalID); | 85 | m_log.DebugFormat("[AUTH SERVICE]: Password login failed for PrincipalID {0}", principalID); |
78 | } | 86 | } |
79 | } | 87 | } |
88 | |||
89 | |||
90 | |||
80 | if (result == string.Empty) | 91 | if (result == string.Empty) |
81 | { | 92 | { |
82 | m_log.DebugFormat("[AUTH SERVICE]: Both password and webLoginKey-based authentication failed for PrincipalID {0}", principalID); | 93 | m_log.DebugFormat("[AUTH SERVICE]: Both password and webLoginKey-based authentication failed for PrincipalID {0}", principalID); |
@@ -86,7 +97,9 @@ namespace OpenSim.Services.AuthenticationService | |||
86 | { | 97 | { |
87 | m_log.DebugFormat("[AUTH SERVICE]: PrincipalID {0} or its data not found", principalID); | 98 | m_log.DebugFormat("[AUTH SERVICE]: PrincipalID {0} or its data not found", principalID); |
88 | } | 99 | } |
100 | |||
101 | |||
89 | return result; | 102 | return result; |
90 | } | 103 | } |
91 | } | 104 | } |
92 | } \ No newline at end of file | 105 | } |
diff --git a/OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs b/OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs index 2b2f11f..8b702e0 100644 --- a/OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs +++ b/OpenSim/Services/Connectors/Asset/AssetServicesConnector.cs | |||
@@ -27,9 +27,11 @@ | |||
27 | 27 | ||
28 | using log4net; | 28 | using log4net; |
29 | using System; | 29 | using System; |
30 | using System.Threading; | ||
30 | using System.Collections.Generic; | 31 | using System.Collections.Generic; |
31 | using System.IO; | 32 | using System.IO; |
32 | using System.Reflection; | 33 | using System.Reflection; |
34 | using System.Timers; | ||
33 | using Nini.Config; | 35 | using Nini.Config; |
34 | using OpenSim.Framework; | 36 | using OpenSim.Framework; |
35 | using OpenSim.Framework.Console; | 37 | using OpenSim.Framework.Console; |
@@ -47,14 +49,22 @@ namespace OpenSim.Services.Connectors | |||
47 | 49 | ||
48 | private string m_ServerURI = String.Empty; | 50 | private string m_ServerURI = String.Empty; |
49 | private IImprovedAssetCache m_Cache = null; | 51 | private IImprovedAssetCache m_Cache = null; |
52 | private int m_retryCounter; | ||
53 | private Dictionary<int, List<AssetBase>> m_retryQueue = new Dictionary<int, List<AssetBase>>(); | ||
54 | private System.Timers.Timer m_retryTimer; | ||
50 | private int m_maxAssetRequestConcurrency = 30; | 55 | private int m_maxAssetRequestConcurrency = 30; |
51 | 56 | ||
52 | private delegate void AssetRetrievedEx(AssetBase asset); | 57 | private delegate void AssetRetrievedEx(AssetBase asset); |
53 | 58 | ||
54 | // Keeps track of concurrent requests for the same asset, so that it's only loaded once. | 59 | // Keeps track of concurrent requests for the same asset, so that it's only loaded once. |
55 | // Maps: Asset ID -> Handlers which will be called when the asset has been loaded | 60 | // Maps: Asset ID -> Handlers which will be called when the asset has been loaded |
56 | private Dictionary<string, AssetRetrievedEx> m_AssetHandlers = new Dictionary<string, AssetRetrievedEx>(); | 61 | // private Dictionary<string, AssetRetrievedEx> m_AssetHandlers = new Dictionary<string, AssetRetrievedEx>(); |
57 | 62 | ||
63 | private Dictionary<string, List<AssetRetrievedEx>> m_AssetHandlers = new Dictionary<string, List<AssetRetrievedEx>>(); | ||
64 | |||
65 | private Dictionary<string, string> m_UriMap = new Dictionary<string, string>(); | ||
66 | |||
67 | private Thread[] m_fetchThreads; | ||
58 | 68 | ||
59 | public AssetServicesConnector() | 69 | public AssetServicesConnector() |
60 | { | 70 | { |
@@ -86,13 +96,108 @@ namespace OpenSim.Services.Connectors | |||
86 | string serviceURI = assetConfig.GetString("AssetServerURI", | 96 | string serviceURI = assetConfig.GetString("AssetServerURI", |
87 | String.Empty); | 97 | String.Empty); |
88 | 98 | ||
99 | m_ServerURI = serviceURI; | ||
100 | |||
89 | if (serviceURI == String.Empty) | 101 | if (serviceURI == String.Empty) |
90 | { | 102 | { |
91 | m_log.Error("[ASSET CONNECTOR]: No Server URI named in section AssetService"); | 103 | m_log.Error("[ASSET CONNECTOR]: No Server URI named in section AssetService"); |
92 | throw new Exception("Asset connector init error"); | 104 | throw new Exception("Asset connector init error"); |
93 | } | 105 | } |
94 | 106 | ||
95 | m_ServerURI = serviceURI; | 107 | |
108 | m_retryTimer = new System.Timers.Timer(); | ||
109 | m_retryTimer.Elapsed += new ElapsedEventHandler(retryCheck); | ||
110 | m_retryTimer.Interval = 60000; | ||
111 | |||
112 | Uri serverUri = new Uri(m_ServerURI); | ||
113 | |||
114 | string groupHost = serverUri.Host; | ||
115 | |||
116 | for (int i = 0 ; i < 256 ; i++) | ||
117 | { | ||
118 | string prefix = i.ToString("x2"); | ||
119 | groupHost = assetConfig.GetString("AssetServerHost_"+prefix, groupHost); | ||
120 | |||
121 | m_UriMap[prefix] = groupHost; | ||
122 | //m_log.DebugFormat("[ASSET]: Using {0} for prefix {1}", groupHost, prefix); | ||
123 | } | ||
124 | |||
125 | m_fetchThreads = new Thread[2]; | ||
126 | |||
127 | for (int i = 0 ; i < 2 ; i++) | ||
128 | { | ||
129 | m_fetchThreads[i] = new Thread(AssetRequestProcessor); | ||
130 | m_fetchThreads[i].Start(); | ||
131 | } | ||
132 | } | ||
133 | |||
134 | private string MapServer(string id) | ||
135 | { | ||
136 | UriBuilder serverUri = new UriBuilder(m_ServerURI); | ||
137 | |||
138 | string prefix = id.Substring(0, 2).ToLower(); | ||
139 | |||
140 | string host; | ||
141 | |||
142 | // HG URLs will not be valid UUIDS | ||
143 | if (m_UriMap.ContainsKey(prefix)) | ||
144 | host = m_UriMap[prefix]; | ||
145 | else | ||
146 | host = m_UriMap["00"]; | ||
147 | |||
148 | serverUri.Host = host; | ||
149 | |||
150 | // m_log.DebugFormat("[ASSET]: Using {0} for host name for prefix {1}", host, prefix); | ||
151 | |||
152 | string ret = serverUri.Uri.AbsoluteUri; | ||
153 | if (ret.EndsWith("/")) | ||
154 | ret = ret.Substring(0, ret.Length - 1); | ||
155 | return ret; | ||
156 | } | ||
157 | |||
158 | protected void retryCheck(object source, ElapsedEventArgs e) | ||
159 | { | ||
160 | m_retryCounter++; | ||
161 | if (m_retryCounter > 60) m_retryCounter -= 60; | ||
162 | List<int> keys = new List<int>(); | ||
163 | foreach (int a in m_retryQueue.Keys) | ||
164 | { | ||
165 | keys.Add(a); | ||
166 | } | ||
167 | foreach (int a in keys) | ||
168 | { | ||
169 | //We exponentially fall back on frequency until we reach one attempt per hour | ||
170 | //The net result is that we end up in the queue for roughly 24 hours.. | ||
171 | //24 hours worth of assets could be a lot, so the hope is that the region admin | ||
172 | //will have gotten the asset connector back online quickly! | ||
173 | |||
174 | int timefactor = a ^ 2; | ||
175 | if (timefactor > 60) | ||
176 | { | ||
177 | timefactor = 60; | ||
178 | } | ||
179 | |||
180 | //First, find out if we care about this timefactor | ||
181 | if (timefactor % a == 0) | ||
182 | { | ||
183 | //Yes, we do! | ||
184 | List<AssetBase> retrylist = m_retryQueue[a]; | ||
185 | m_retryQueue.Remove(a); | ||
186 | |||
187 | foreach(AssetBase ass in retrylist) | ||
188 | { | ||
189 | Store(ass); //Store my ass. This function will put it back in the dictionary if it fails | ||
190 | } | ||
191 | } | ||
192 | } | ||
193 | |||
194 | if (m_retryQueue.Count == 0) | ||
195 | { | ||
196 | //It might only be one tick per minute, but I have | ||
197 | //repented and abandoned my wasteful ways | ||
198 | m_retryCounter = 0; | ||
199 | m_retryTimer.Stop(); | ||
200 | } | ||
96 | } | 201 | } |
97 | 202 | ||
98 | protected void SetCache(IImprovedAssetCache cache) | 203 | protected void SetCache(IImprovedAssetCache cache) |
@@ -102,15 +207,13 @@ namespace OpenSim.Services.Connectors | |||
102 | 207 | ||
103 | public AssetBase Get(string id) | 208 | public AssetBase Get(string id) |
104 | { | 209 | { |
105 | // m_log.DebugFormat("[ASSET SERVICE CONNECTOR]: Synchronous get request for {0}", id); | 210 | string uri = MapServer(id) + "/assets/" + id; |
106 | |||
107 | string uri = m_ServerURI + "/assets/" + id; | ||
108 | 211 | ||
109 | AssetBase asset = null; | 212 | AssetBase asset = null; |
110 | if (m_Cache != null) | 213 | if (m_Cache != null) |
111 | asset = m_Cache.Get(id); | 214 | asset = m_Cache.Get(id); |
112 | 215 | ||
113 | if (asset == null) | 216 | if (asset == null || asset.Data == null || asset.Data.Length == 0) |
114 | { | 217 | { |
115 | asset = SynchronousRestObjectRequester. | 218 | asset = SynchronousRestObjectRequester. |
116 | MakeRequest<int, AssetBase>("GET", uri, 0, m_maxAssetRequestConcurrency); | 219 | MakeRequest<int, AssetBase>("GET", uri, 0, m_maxAssetRequestConcurrency); |
@@ -141,7 +244,7 @@ namespace OpenSim.Services.Connectors | |||
141 | return fullAsset.Metadata; | 244 | return fullAsset.Metadata; |
142 | } | 245 | } |
143 | 246 | ||
144 | string uri = m_ServerURI + "/assets/" + id + "/metadata"; | 247 | string uri = MapServer(id) + "/assets/" + id + "/metadata"; |
145 | 248 | ||
146 | AssetMetadata asset = SynchronousRestObjectRequester. | 249 | AssetMetadata asset = SynchronousRestObjectRequester. |
147 | MakeRequest<int, AssetMetadata>("GET", uri, 0); | 250 | MakeRequest<int, AssetMetadata>("GET", uri, 0); |
@@ -158,7 +261,7 @@ namespace OpenSim.Services.Connectors | |||
158 | return fullAsset.Data; | 261 | return fullAsset.Data; |
159 | } | 262 | } |
160 | 263 | ||
161 | RestClient rc = new RestClient(m_ServerURI); | 264 | RestClient rc = new RestClient(MapServer(id)); |
162 | rc.AddResourcePath("assets"); | 265 | rc.AddResourcePath("assets"); |
163 | rc.AddResourcePath(id); | 266 | rc.AddResourcePath(id); |
164 | rc.AddResourcePath("data"); | 267 | rc.AddResourcePath("data"); |
@@ -181,66 +284,109 @@ namespace OpenSim.Services.Connectors | |||
181 | return null; | 284 | return null; |
182 | } | 285 | } |
183 | 286 | ||
184 | public bool Get(string id, Object sender, AssetRetrieved handler) | 287 | private class QueuedAssetRequest |
185 | { | 288 | { |
186 | // m_log.DebugFormat("[ASSET SERVICE CONNECTOR]: Potentially asynchronous get request for {0}", id); | 289 | public string uri; |
290 | public string id; | ||
291 | } | ||
187 | 292 | ||
188 | string uri = m_ServerURI + "/assets/" + id; | 293 | private OpenMetaverse.BlockingQueue<QueuedAssetRequest> m_requestQueue = |
294 | new OpenMetaverse.BlockingQueue<QueuedAssetRequest>(); | ||
189 | 295 | ||
190 | AssetBase asset = null; | 296 | private void AssetRequestProcessor() |
191 | if (m_Cache != null) | 297 | { |
192 | asset = m_Cache.Get(id); | 298 | QueuedAssetRequest r; |
193 | 299 | ||
194 | if (asset == null) | 300 | while (true) |
195 | { | 301 | { |
196 | lock (m_AssetHandlers) | 302 | r = m_requestQueue.Dequeue(); |
197 | { | ||
198 | AssetRetrievedEx handlerEx = new AssetRetrievedEx(delegate(AssetBase _asset) { handler(id, sender, _asset); }); | ||
199 | |||
200 | AssetRetrievedEx handlers; | ||
201 | if (m_AssetHandlers.TryGetValue(id, out handlers)) | ||
202 | { | ||
203 | // Someone else is already loading this asset. It will notify our handler when done. | ||
204 | handlers += handlerEx; | ||
205 | return true; | ||
206 | } | ||
207 | 303 | ||
208 | // Load the asset ourselves | 304 | string uri = r.uri; |
209 | handlers += handlerEx; | 305 | string id = r.id; |
210 | m_AssetHandlers.Add(id, handlers); | ||
211 | } | ||
212 | 306 | ||
213 | bool success = false; | 307 | bool success = false; |
214 | try | 308 | try |
215 | { | 309 | { |
216 | AsynchronousRestObjectRequester.MakeRequest<int, AssetBase>("GET", uri, 0, | 310 | AssetBase a = SynchronousRestObjectRequester.MakeRequest<int, AssetBase>("GET", uri, 0, 30); |
217 | delegate(AssetBase a) | 311 | if (a != null) |
218 | { | 312 | { |
219 | if (m_Cache != null) | 313 | if (m_Cache != null) |
220 | m_Cache.Cache(a); | 314 | m_Cache.Cache(a); |
221 | 315 | ||
222 | AssetRetrievedEx handlers; | 316 | List<AssetRetrievedEx> handlers; |
223 | lock (m_AssetHandlers) | 317 | lock (m_AssetHandlers) |
318 | { | ||
319 | handlers = m_AssetHandlers[id]; | ||
320 | m_AssetHandlers.Remove(id); | ||
321 | } | ||
322 | foreach (AssetRetrievedEx h in handlers) | ||
323 | { | ||
324 | Util.FireAndForget(x => | ||
224 | { | 325 | { |
225 | handlers = m_AssetHandlers[id]; | 326 | h.Invoke(a); |
226 | m_AssetHandlers.Remove(id); | 327 | }); |
227 | } | 328 | } |
228 | handlers.Invoke(a); | 329 | if (handlers != null) |
229 | }, m_maxAssetRequestConcurrency); | 330 | handlers.Clear(); |
230 | 331 | ||
231 | success = true; | 332 | success = true; |
333 | } | ||
232 | } | 334 | } |
233 | finally | 335 | finally |
234 | { | 336 | { |
235 | if (!success) | 337 | if (!success) |
236 | { | 338 | { |
339 | List<AssetRetrievedEx> handlers; | ||
237 | lock (m_AssetHandlers) | 340 | lock (m_AssetHandlers) |
238 | { | 341 | { |
342 | handlers = m_AssetHandlers[id]; | ||
239 | m_AssetHandlers.Remove(id); | 343 | m_AssetHandlers.Remove(id); |
240 | } | 344 | } |
345 | if (handlers != null) | ||
346 | handlers.Clear(); | ||
241 | } | 347 | } |
242 | } | 348 | } |
243 | } | 349 | } |
350 | } | ||
351 | |||
352 | public bool Get(string id, Object sender, AssetRetrieved handler) | ||
353 | { | ||
354 | string uri = MapServer(id) + "/assets/" + id; | ||
355 | |||
356 | AssetBase asset = null; | ||
357 | if (m_Cache != null) | ||
358 | asset = m_Cache.Get(id); | ||
359 | |||
360 | if (asset == null || asset.Data == null || asset.Data.Length == 0) | ||
361 | { | ||
362 | lock (m_AssetHandlers) | ||
363 | { | ||
364 | AssetRetrievedEx handlerEx = new AssetRetrievedEx(delegate(AssetBase _asset) { handler(id, sender, _asset); }); | ||
365 | |||
366 | // AssetRetrievedEx handlers; | ||
367 | List<AssetRetrievedEx> handlers; | ||
368 | if (m_AssetHandlers.TryGetValue(id, out handlers)) | ||
369 | { | ||
370 | // Someone else is already loading this asset. It will notify our handler when done. | ||
371 | // handlers += handlerEx; | ||
372 | handlers.Add(handlerEx); | ||
373 | return true; | ||
374 | } | ||
375 | |||
376 | // Load the asset ourselves | ||
377 | // handlers += handlerEx; | ||
378 | handlers = new List<AssetRetrievedEx>(); | ||
379 | handlers.Add(handlerEx); | ||
380 | |||
381 | m_AssetHandlers.Add(id, handlers); | ||
382 | } | ||
383 | |||
384 | QueuedAssetRequest request = new QueuedAssetRequest(); | ||
385 | request.id = id; | ||
386 | request.uri = uri; | ||
387 | |||
388 | m_requestQueue.Enqueue(request); | ||
389 | } | ||
244 | else | 390 | else |
245 | { | 391 | { |
246 | handler(id, sender, asset); | 392 | handler(id, sender, asset); |
@@ -251,38 +397,95 @@ namespace OpenSim.Services.Connectors | |||
251 | 397 | ||
252 | public string Store(AssetBase asset) | 398 | public string Store(AssetBase asset) |
253 | { | 399 | { |
254 | if (asset.Temporary || asset.Local) | 400 | // Have to assign the asset ID here. This isn't likely to |
401 | // trigger since current callers don't pass emtpy IDs | ||
402 | // We need the asset ID to route the request to the proper | ||
403 | // cluster member, so we can't have the server assign one. | ||
404 | if (asset.ID == string.Empty) | ||
255 | { | 405 | { |
256 | if (m_Cache != null) | 406 | if (asset.FullID == UUID.Zero) |
257 | m_Cache.Cache(asset); | 407 | { |
408 | asset.FullID = UUID.Random(); | ||
409 | } | ||
410 | asset.ID = asset.FullID.ToString(); | ||
411 | } | ||
412 | else if (asset.FullID == UUID.Zero) | ||
413 | { | ||
414 | UUID uuid = UUID.Zero; | ||
415 | if (UUID.TryParse(asset.ID, out uuid)) | ||
416 | { | ||
417 | asset.FullID = uuid; | ||
418 | } | ||
419 | else | ||
420 | { | ||
421 | asset.FullID = UUID.Random(); | ||
422 | } | ||
423 | } | ||
258 | 424 | ||
425 | if (m_Cache != null) | ||
426 | m_Cache.Cache(asset); | ||
427 | if (asset.Temporary || asset.Local) | ||
428 | { | ||
259 | return asset.ID; | 429 | return asset.ID; |
260 | } | 430 | } |
261 | 431 | ||
262 | string uri = m_ServerURI + "/assets/"; | 432 | string uri = MapServer(asset.FullID.ToString()) + "/assets/"; |
263 | 433 | ||
264 | string newID = string.Empty; | 434 | string newID = string.Empty; |
265 | try | 435 | try |
266 | { | 436 | { |
267 | newID = SynchronousRestObjectRequester. | 437 | newID = SynchronousRestObjectRequester. |
268 | MakeRequest<AssetBase, string>("POST", uri, asset); | 438 | MakeRequest<AssetBase, string>("POST", uri, asset, 25); |
439 | if (newID == null || newID == "") | ||
440 | { | ||
441 | newID = UUID.Zero.ToString(); | ||
442 | } | ||
269 | } | 443 | } |
270 | catch (Exception e) | 444 | catch (Exception e) |
271 | { | 445 | { |
272 | m_log.WarnFormat("[ASSET CONNECTOR]: Unable to send asset {0} to asset server. Reason: {1}", asset.ID, e.Message); | 446 | newID = UUID.Zero.ToString(); |
273 | } | 447 | } |
274 | 448 | ||
275 | if (newID != String.Empty) | 449 | if (newID == UUID.Zero.ToString()) |
450 | { | ||
451 | //The asset upload failed, put it in a queue for later | ||
452 | asset.UploadAttempts++; | ||
453 | if (asset.UploadAttempts > 30) | ||
454 | { | ||
455 | //By this stage we've been in the queue for a good few hours; | ||
456 | //We're going to drop the asset. | ||
457 | m_log.ErrorFormat("[Assets] Dropping asset {0} - Upload has been in the queue for too long.", asset.ID.ToString()); | ||
458 | } | ||
459 | else | ||
460 | { | ||
461 | if (!m_retryQueue.ContainsKey(asset.UploadAttempts)) | ||
462 | { | ||
463 | m_retryQueue.Add(asset.UploadAttempts, new List<AssetBase>()); | ||
464 | } | ||
465 | List<AssetBase> m_queue = m_retryQueue[asset.UploadAttempts]; | ||
466 | m_queue.Add(asset); | ||
467 | m_log.WarnFormat("[Assets] Upload failed: {0} - Requeuing asset for another run.", asset.ID.ToString()); | ||
468 | m_retryTimer.Start(); | ||
469 | } | ||
470 | } | ||
471 | else | ||
276 | { | 472 | { |
277 | // Placing this here, so that this work with old asset servers that don't send any reply back | 473 | if (asset.UploadAttempts > 0) |
278 | // SynchronousRestObjectRequester returns somethins that is not an empty string | 474 | { |
279 | if (newID != null) | 475 | m_log.InfoFormat("[Assets] Upload of {0} succeeded after {1} failed attempts", asset.ID.ToString(), asset.UploadAttempts.ToString()); |
280 | asset.ID = newID; | 476 | } |
477 | if (newID != String.Empty) | ||
478 | { | ||
479 | // Placing this here, so that this work with old asset servers that don't send any reply back | ||
480 | // SynchronousRestObjectRequester returns somethins that is not an empty string | ||
481 | if (newID != null) | ||
482 | asset.ID = newID; | ||
281 | 483 | ||
282 | if (m_Cache != null) | 484 | if (m_Cache != null) |
283 | m_Cache.Cache(asset); | 485 | m_Cache.Cache(asset); |
486 | } | ||
284 | } | 487 | } |
285 | return newID; | 488 | return asset.ID; |
286 | } | 489 | } |
287 | 490 | ||
288 | public bool UpdateContent(string id, byte[] data) | 491 | public bool UpdateContent(string id, byte[] data) |
@@ -303,7 +506,7 @@ namespace OpenSim.Services.Connectors | |||
303 | } | 506 | } |
304 | asset.Data = data; | 507 | asset.Data = data; |
305 | 508 | ||
306 | string uri = m_ServerURI + "/assets/" + id; | 509 | string uri = MapServer(id) + "/assets/" + id; |
307 | 510 | ||
308 | if (SynchronousRestObjectRequester. | 511 | if (SynchronousRestObjectRequester. |
309 | MakeRequest<AssetBase, bool>("POST", uri, asset)) | 512 | MakeRequest<AssetBase, bool>("POST", uri, asset)) |
@@ -318,7 +521,7 @@ namespace OpenSim.Services.Connectors | |||
318 | 521 | ||
319 | public bool Delete(string id) | 522 | public bool Delete(string id) |
320 | { | 523 | { |
321 | string uri = m_ServerURI + "/assets/" + id; | 524 | string uri = MapServer(id) + "/assets/" + id; |
322 | 525 | ||
323 | if (SynchronousRestObjectRequester. | 526 | if (SynchronousRestObjectRequester. |
324 | MakeRequest<int, bool>("DELETE", uri, 0)) | 527 | MakeRequest<int, bool>("DELETE", uri, 0)) |
diff --git a/OpenSim/Services/Connectors/Authentication/AuthenticationServicesConnector.cs b/OpenSim/Services/Connectors/Authentication/AuthenticationServicesConnector.cs index 2b77154..f996aca 100644 --- a/OpenSim/Services/Connectors/Authentication/AuthenticationServicesConnector.cs +++ b/OpenSim/Services/Connectors/Authentication/AuthenticationServicesConnector.cs | |||
@@ -81,6 +81,13 @@ namespace OpenSim.Services.Connectors | |||
81 | m_ServerURI = serviceURI; | 81 | m_ServerURI = serviceURI; |
82 | } | 82 | } |
83 | 83 | ||
84 | public string Authenticate(UUID principalID, string password, int lifetime, out UUID realID) | ||
85 | { | ||
86 | realID = UUID.Zero; | ||
87 | |||
88 | return Authenticate(principalID, password, lifetime); | ||
89 | } | ||
90 | |||
84 | public string Authenticate(UUID principalID, string password, int lifetime) | 91 | public string Authenticate(UUID principalID, string password, int lifetime) |
85 | { | 92 | { |
86 | Dictionary<string, object> sendData = new Dictionary<string, object>(); | 93 | Dictionary<string, object> sendData = new Dictionary<string, object>(); |
diff --git a/OpenSim/Services/Connectors/Friends/FriendsSimConnector.cs b/OpenSim/Services/Connectors/Friends/FriendsSimConnector.cs index 6d5ce4b..45f4514 100644 --- a/OpenSim/Services/Connectors/Friends/FriendsSimConnector.cs +++ b/OpenSim/Services/Connectors/Friends/FriendsSimConnector.cs | |||
@@ -144,44 +144,48 @@ namespace OpenSim.Services.Connectors.Friends | |||
144 | 144 | ||
145 | private bool Call(GridRegion region, Dictionary<string, object> sendData) | 145 | private bool Call(GridRegion region, Dictionary<string, object> sendData) |
146 | { | 146 | { |
147 | string reqString = ServerUtils.BuildQueryString(sendData); | 147 | Util.FireAndForget(x => { |
148 | //m_log.DebugFormat("[FRIENDS SIM CONNECTOR]: queryString = {0}", reqString); | 148 | string reqString = ServerUtils.BuildQueryString(sendData); |
149 | if (region == null) | 149 | //m_log.DebugFormat("[FRIENDS SIM CONNECTOR]: queryString = {0}", reqString); |
150 | return false; | 150 | if (region == null) |
151 | 151 | return; | |
152 | string path = ServicePath(); | 152 | |
153 | if (!region.ServerURI.EndsWith("/")) | 153 | string path = ServicePath(); |
154 | path = "/" + path; | 154 | if (!region.ServerURI.EndsWith("/")) |
155 | string uri = region.ServerURI + path; | 155 | path = "/" + path; |
156 | // m_log.DebugFormat("[FRIENDS SIM CONNECTOR]: calling {0}", uri); | 156 | string uri = region.ServerURI + path; |
157 | 157 | // m_log.DebugFormat("[FRIENDS SIM CONNECTOR]: calling {0}", uri); | |
158 | try | 158 | |
159 | { | 159 | try |
160 | string reply = SynchronousRestFormsRequester.MakeRequest("POST", uri, reqString); | ||
161 | if (reply != string.Empty) | ||
162 | { | 160 | { |
163 | Dictionary<string, object> replyData = ServerUtils.ParseXmlResponse(reply); | 161 | string reply = SynchronousRestFormsRequester.MakeRequest("POST", uri, reqString); |
164 | 162 | if (reply != string.Empty) | |
165 | if (replyData.ContainsKey("RESULT")) | ||
166 | { | 163 | { |
167 | if (replyData["RESULT"].ToString().ToLower() == "true") | 164 | Dictionary<string, object> replyData = ServerUtils.ParseXmlResponse(reply); |
168 | return true; | 165 | |
166 | if (replyData.ContainsKey("RESULT")) | ||
167 | { | ||
168 | // if (replyData["RESULT"].ToString().ToLower() == "true") | ||
169 | // return; | ||
170 | // else | ||
171 | return; | ||
172 | } | ||
169 | else | 173 | else |
170 | return false; | 174 | m_log.DebugFormat("[FRIENDS SIM CONNECTOR]: reply data does not contain result field"); |
175 | |||
171 | } | 176 | } |
172 | else | 177 | else |
173 | m_log.DebugFormat("[FRIENDS SIM CONNECTOR]: reply data does not contain result field"); | 178 | m_log.DebugFormat("[FRIENDS SIM CONNECTOR]: received empty reply"); |
174 | 179 | } | |
180 | catch (Exception e) | ||
181 | { | ||
182 | m_log.DebugFormat("[FRIENDS SIM CONNECTOR]: Exception when contacting remote sim at {0}: {1}", uri, e.Message); | ||
175 | } | 183 | } |
176 | else | 184 | |
177 | m_log.DebugFormat("[FRIENDS SIM CONNECTOR]: received empty reply"); | 185 | return; |
178 | } | 186 | }); |
179 | catch (Exception e) | 187 | |
180 | { | 188 | return true; |
181 | m_log.DebugFormat("[FRIENDS SIM CONNECTOR]: Exception when contacting remote sim at {0}: {1}", uri, e.Message); | ||
182 | } | ||
183 | |||
184 | return false; | ||
185 | } | 189 | } |
186 | } | 190 | } |
187 | } | 191 | } |
diff --git a/OpenSim/Services/Connectors/Grid/GridServicesConnector.cs b/OpenSim/Services/Connectors/Grid/GridServicesConnector.cs index 34ed0d7..f982cc1 100644 --- a/OpenSim/Services/Connectors/Grid/GridServicesConnector.cs +++ b/OpenSim/Services/Connectors/Grid/GridServicesConnector.cs | |||
@@ -48,6 +48,9 @@ namespace OpenSim.Services.Connectors | |||
48 | 48 | ||
49 | private string m_ServerURI = String.Empty; | 49 | private string m_ServerURI = String.Empty; |
50 | 50 | ||
51 | private ExpiringCache<ulong, GridRegion> m_regionCache = | ||
52 | new ExpiringCache<ulong, GridRegion>(); | ||
53 | |||
51 | public GridServicesConnector() | 54 | public GridServicesConnector() |
52 | { | 55 | { |
53 | } | 56 | } |
@@ -272,6 +275,11 @@ namespace OpenSim.Services.Connectors | |||
272 | 275 | ||
273 | public GridRegion GetRegionByPosition(UUID scopeID, int x, int y) | 276 | public GridRegion GetRegionByPosition(UUID scopeID, int x, int y) |
274 | { | 277 | { |
278 | ulong regionHandle = Util.UIntsToLong((uint)x, (uint)y); | ||
279 | |||
280 | if (m_regionCache.Contains(regionHandle)) | ||
281 | return (GridRegion)m_regionCache[regionHandle]; | ||
282 | |||
275 | Dictionary<string, object> sendData = new Dictionary<string, object>(); | 283 | Dictionary<string, object> sendData = new Dictionary<string, object>(); |
276 | 284 | ||
277 | sendData["SCOPEID"] = scopeID.ToString(); | 285 | sendData["SCOPEID"] = scopeID.ToString(); |
@@ -313,6 +321,8 @@ namespace OpenSim.Services.Connectors | |||
313 | else | 321 | else |
314 | m_log.DebugFormat("[GRID CONNECTOR]: GetRegionByPosition received null reply"); | 322 | m_log.DebugFormat("[GRID CONNECTOR]: GetRegionByPosition received null reply"); |
315 | 323 | ||
324 | m_regionCache.Add(regionHandle, rinfo, TimeSpan.FromSeconds(600)); | ||
325 | |||
316 | return rinfo; | 326 | return rinfo; |
317 | } | 327 | } |
318 | 328 | ||
diff --git a/OpenSim/Services/Connectors/Hypergrid/GatekeeperServiceConnector.cs b/OpenSim/Services/Connectors/Hypergrid/GatekeeperServiceConnector.cs index 5bcff48..d840527 100644 --- a/OpenSim/Services/Connectors/Hypergrid/GatekeeperServiceConnector.cs +++ b/OpenSim/Services/Connectors/Hypergrid/GatekeeperServiceConnector.cs | |||
@@ -158,6 +158,7 @@ namespace OpenSim.Services.Connectors.Hypergrid | |||
158 | try | 158 | try |
159 | { | 159 | { |
160 | WebClient c = new WebClient(); | 160 | WebClient c = new WebClient(); |
161 | //m_log.Debug("JPEG: " + imageURL); | ||
161 | string name = regionID.ToString(); | 162 | string name = regionID.ToString(); |
162 | filename = Path.Combine(storagePath, name + ".jpg"); | 163 | filename = Path.Combine(storagePath, name + ".jpg"); |
163 | m_log.DebugFormat("[GATEKEEPER SERVICE CONNECTOR]: Map image at {0}, cached at {1}", imageURL, filename); | 164 | m_log.DebugFormat("[GATEKEEPER SERVICE CONNECTOR]: Map image at {0}, cached at {1}", imageURL, filename); |
@@ -186,11 +187,10 @@ namespace OpenSim.Services.Connectors.Hypergrid | |||
186 | 187 | ||
187 | ass.Data = imageData; | 188 | ass.Data = imageData; |
188 | 189 | ||
189 | mapTile = ass.FullID; | ||
190 | |||
191 | // finally | ||
192 | m_AssetService.Store(ass); | 190 | m_AssetService.Store(ass); |
193 | 191 | ||
192 | // finally | ||
193 | mapTile = ass.FullID; | ||
194 | } | 194 | } |
195 | catch // LEGIT: Catching problems caused by OpenJPEG p/invoke | 195 | catch // LEGIT: Catching problems caused by OpenJPEG p/invoke |
196 | { | 196 | { |
diff --git a/OpenSim/Services/Connectors/Hypergrid/UserAgentServiceConnector.cs b/OpenSim/Services/Connectors/Hypergrid/UserAgentServiceConnector.cs index 47d0cce..d7e38f1 100644 --- a/OpenSim/Services/Connectors/Hypergrid/UserAgentServiceConnector.cs +++ b/OpenSim/Services/Connectors/Hypergrid/UserAgentServiceConnector.cs | |||
@@ -98,8 +98,6 @@ namespace OpenSim.Services.Connectors.Hypergrid | |||
98 | throw new Exception("UserAgent connector init error"); | 98 | throw new Exception("UserAgent connector init error"); |
99 | } | 99 | } |
100 | m_ServerURL = serviceURI; | 100 | m_ServerURL = serviceURI; |
101 | if (!m_ServerURL.EndsWith("/")) | ||
102 | m_ServerURL += "/"; | ||
103 | 101 | ||
104 | m_log.DebugFormat("[USER AGENT CONNECTOR]: UserAgentServiceConnector started for {0}", m_ServerURL); | 102 | m_log.DebugFormat("[USER AGENT CONNECTOR]: UserAgentServiceConnector started for {0}", m_ServerURL); |
105 | } | 103 | } |
diff --git a/OpenSim/Services/Connectors/Land/LandServicesConnector.cs b/OpenSim/Services/Connectors/Land/LandServicesConnector.cs index 30a73a4..833e22a 100644 --- a/OpenSim/Services/Connectors/Land/LandServicesConnector.cs +++ b/OpenSim/Services/Connectors/Land/LandServicesConnector.cs | |||
@@ -130,4 +130,4 @@ namespace OpenSim.Services.Connectors | |||
130 | return landData; | 130 | return landData; |
131 | } | 131 | } |
132 | } | 132 | } |
133 | } \ No newline at end of file | 133 | } |
diff --git a/OpenSim/Services/Connectors/MapImage/MapImageServicesConnector.cs b/OpenSim/Services/Connectors/MapImage/MapImageServicesConnector.cs index 30bfb70..267dd71 100644 --- a/OpenSim/Services/Connectors/MapImage/MapImageServicesConnector.cs +++ b/OpenSim/Services/Connectors/MapImage/MapImageServicesConnector.cs | |||
@@ -86,6 +86,66 @@ namespace OpenSim.Services.Connectors | |||
86 | m_ServerURI = serviceURI.TrimEnd('/'); | 86 | m_ServerURI = serviceURI.TrimEnd('/'); |
87 | } | 87 | } |
88 | 88 | ||
89 | public bool RemoveMapTile(int x, int y, out string reason) | ||
90 | { | ||
91 | reason = string.Empty; | ||
92 | int tickstart = Util.EnvironmentTickCount(); | ||
93 | Dictionary<string, object> sendData = new Dictionary<string, object>(); | ||
94 | sendData["X"] = x.ToString(); | ||
95 | sendData["Y"] = y.ToString(); | ||
96 | |||
97 | string reqString = ServerUtils.BuildQueryString(sendData); | ||
98 | string uri = m_ServerURI + "/removemap"; | ||
99 | |||
100 | try | ||
101 | { | ||
102 | string reply = SynchronousRestFormsRequester.MakeRequest("POST", | ||
103 | uri, | ||
104 | reqString); | ||
105 | if (reply != string.Empty) | ||
106 | { | ||
107 | Dictionary<string, object> replyData = ServerUtils.ParseXmlResponse(reply); | ||
108 | |||
109 | if (replyData.ContainsKey("Result") && (replyData["Result"].ToString().ToLower() == "success")) | ||
110 | { | ||
111 | return true; | ||
112 | } | ||
113 | else if (replyData.ContainsKey("Result") && (replyData["Result"].ToString().ToLower() == "failure")) | ||
114 | { | ||
115 | m_log.DebugFormat("[MAP IMAGE CONNECTOR]: Delete failed: {0}", replyData["Message"].ToString()); | ||
116 | reason = replyData["Message"].ToString(); | ||
117 | return false; | ||
118 | } | ||
119 | else if (!replyData.ContainsKey("Result")) | ||
120 | { | ||
121 | m_log.DebugFormat("[MAP IMAGE CONNECTOR]: reply data does not contain result field"); | ||
122 | } | ||
123 | else | ||
124 | { | ||
125 | m_log.DebugFormat("[MAP IMAGE CONNECTOR]: unexpected result {0}", replyData["Result"].ToString()); | ||
126 | reason = "Unexpected result " + replyData["Result"].ToString(); | ||
127 | } | ||
128 | |||
129 | } | ||
130 | else | ||
131 | { | ||
132 | m_log.DebugFormat("[MAP IMAGE CONNECTOR]: Map post received null reply"); | ||
133 | } | ||
134 | } | ||
135 | catch (Exception e) | ||
136 | { | ||
137 | m_log.DebugFormat("[MAP IMAGE CONNECTOR]: Exception when contacting map server at {0}: {1}", uri, e.Message); | ||
138 | } | ||
139 | finally | ||
140 | { | ||
141 | // This just dumps a warning for any operation that takes more than 100 ms | ||
142 | int tickdiff = Util.EnvironmentTickCountSubtract(tickstart); | ||
143 | m_log.DebugFormat("[MAP IMAGE CONNECTOR]: map tile deleted in {0}ms", tickdiff); | ||
144 | } | ||
145 | |||
146 | return false; | ||
147 | } | ||
148 | |||
89 | public bool AddMapTile(int x, int y, byte[] jpgData, out string reason) | 149 | public bool AddMapTile(int x, int y, byte[] jpgData, out string reason) |
90 | { | 150 | { |
91 | reason = string.Empty; | 151 | reason = string.Empty; |
diff --git a/OpenSim/Services/Connectors/Neighbour/NeighbourServicesConnector.cs b/OpenSim/Services/Connectors/Neighbour/NeighbourServicesConnector.cs index 5948380..b36fa23 100644 --- a/OpenSim/Services/Connectors/Neighbour/NeighbourServicesConnector.cs +++ b/OpenSim/Services/Connectors/Neighbour/NeighbourServicesConnector.cs | |||
@@ -153,9 +153,9 @@ namespace OpenSim.Services.Connectors | |||
153 | } | 153 | } |
154 | catch (Exception e) | 154 | catch (Exception e) |
155 | { | 155 | { |
156 | m_log.WarnFormat( | 156 | // m_log.WarnFormat( |
157 | "[NEIGHBOUR SERVICE CONNCTOR]: Unable to send HelloNeighbour from {0} to {1}. Exception {2}{3}", | 157 | // "[NEIGHBOUR SERVICE CONNCTOR]: Unable to send HelloNeighbour from {0} to {1}. Exception {2}{3}", |
158 | thisRegion.RegionName, region.RegionName, e.Message, e.StackTrace); | 158 | // thisRegion.RegionName, region.RegionName, e.Message, e.StackTrace); |
159 | 159 | ||
160 | return false; | 160 | return false; |
161 | } | 161 | } |
@@ -202,4 +202,4 @@ namespace OpenSim.Services.Connectors | |||
202 | return true; | 202 | return true; |
203 | } | 203 | } |
204 | } | 204 | } |
205 | } \ No newline at end of file | 205 | } |
diff --git a/OpenSim/Services/Connectors/Presence/PresenceServicesConnector.cs b/OpenSim/Services/Connectors/Presence/PresenceServicesConnector.cs index f7d8c53..378aab6 100644 --- a/OpenSim/Services/Connectors/Presence/PresenceServicesConnector.cs +++ b/OpenSim/Services/Connectors/Presence/PresenceServicesConnector.cs | |||
@@ -304,6 +304,17 @@ namespace OpenSim.Services.Connectors | |||
304 | { | 304 | { |
305 | pinfo = new PresenceInfo((Dictionary<string, object>)replyData["result"]); | 305 | pinfo = new PresenceInfo((Dictionary<string, object>)replyData["result"]); |
306 | } | 306 | } |
307 | else | ||
308 | { | ||
309 | if (replyData["result"].ToString() == "null") | ||
310 | return null; | ||
311 | |||
312 | m_log.DebugFormat("[PRESENCE CONNECTOR]: Invalid reply (result not dictionary) received from presence server when querying for sessionID {0}", sessionID.ToString()); | ||
313 | } | ||
314 | } | ||
315 | else | ||
316 | { | ||
317 | m_log.DebugFormat("[PRESENCE CONNECTOR]: Invalid reply received from presence server when querying for sessionID {0}", sessionID.ToString()); | ||
307 | } | 318 | } |
308 | 319 | ||
309 | return pinfo; | 320 | return pinfo; |
diff --git a/OpenSim/Services/Connectors/SimianGrid/SimianAuthenticationServiceConnector.cs b/OpenSim/Services/Connectors/SimianGrid/SimianAuthenticationServiceConnector.cs index 6603f6e..03b19ae 100644 --- a/OpenSim/Services/Connectors/SimianGrid/SimianAuthenticationServiceConnector.cs +++ b/OpenSim/Services/Connectors/SimianGrid/SimianAuthenticationServiceConnector.cs | |||
@@ -102,6 +102,12 @@ namespace OpenSim.Services.Connectors.SimianGrid | |||
102 | m_log.Info("[SIMIAN AUTH CONNECTOR]: No AuthenticationServerURI specified, disabling connector"); | 102 | m_log.Info("[SIMIAN AUTH CONNECTOR]: No AuthenticationServerURI specified, disabling connector"); |
103 | } | 103 | } |
104 | 104 | ||
105 | public string Authenticate(UUID principalID, string password, int lifetime, out UUID realID) | ||
106 | { | ||
107 | realID = UUID.Zero; | ||
108 | return Authenticate(principalID, password, lifetime); | ||
109 | } | ||
110 | |||
105 | public string Authenticate(UUID principalID, string password, int lifetime) | 111 | public string Authenticate(UUID principalID, string password, int lifetime) |
106 | { | 112 | { |
107 | NameValueCollection requestArgs = new NameValueCollection | 113 | NameValueCollection requestArgs = new NameValueCollection |
diff --git a/OpenSim/Services/Connectors/SimianGrid/SimianGridServiceConnector.cs b/OpenSim/Services/Connectors/SimianGrid/SimianGridServiceConnector.cs index 038a4bf..20eaa3a 100644 --- a/OpenSim/Services/Connectors/SimianGrid/SimianGridServiceConnector.cs +++ b/OpenSim/Services/Connectors/SimianGrid/SimianGridServiceConnector.cs | |||
@@ -28,6 +28,8 @@ | |||
28 | using System; | 28 | using System; |
29 | using System.Collections.Generic; | 29 | using System.Collections.Generic; |
30 | using System.Collections.Specialized; | 30 | using System.Collections.Specialized; |
31 | using System.Drawing; | ||
32 | using System.Drawing.Imaging; | ||
31 | using System.IO; | 33 | using System.IO; |
32 | using System.Net; | 34 | using System.Net; |
33 | using System.Reflection; | 35 | using System.Reflection; |
@@ -100,6 +102,15 @@ namespace OpenSim.Services.Connectors.SimianGrid | |||
100 | 102 | ||
101 | public string RegisterRegion(UUID scopeID, GridRegion regionInfo) | 103 | public string RegisterRegion(UUID scopeID, GridRegion regionInfo) |
102 | { | 104 | { |
105 | IPEndPoint ext = regionInfo.ExternalEndPoint; | ||
106 | if (ext == null) return "Region registration for " + regionInfo.RegionName + " failed: Could not resolve EndPoint"; | ||
107 | // Generate and upload our map tile in PNG format to the SimianGrid AddMapTile service | ||
108 | // Scene scene; | ||
109 | // if (m_scenes.TryGetValue(regionInfo.RegionID, out scene)) | ||
110 | // UploadMapTile(scene); | ||
111 | // else | ||
112 | // m_log.Warn("Registering region " + regionInfo.RegionName + " (" + regionInfo.RegionID + ") that we are not tracking"); | ||
113 | |||
103 | Vector3d minPosition = new Vector3d(regionInfo.RegionLocX, regionInfo.RegionLocY, 0.0); | 114 | Vector3d minPosition = new Vector3d(regionInfo.RegionLocX, regionInfo.RegionLocY, 0.0); |
104 | Vector3d maxPosition = minPosition + new Vector3d(Constants.RegionSize, Constants.RegionSize, Constants.RegionHeight); | 115 | Vector3d maxPosition = minPosition + new Vector3d(Constants.RegionSize, Constants.RegionSize, Constants.RegionHeight); |
105 | 116 | ||
@@ -108,7 +119,7 @@ namespace OpenSim.Services.Connectors.SimianGrid | |||
108 | { "ServerURI", OSD.FromString(regionInfo.ServerURI) }, | 119 | { "ServerURI", OSD.FromString(regionInfo.ServerURI) }, |
109 | { "InternalAddress", OSD.FromString(regionInfo.InternalEndPoint.Address.ToString()) }, | 120 | { "InternalAddress", OSD.FromString(regionInfo.InternalEndPoint.Address.ToString()) }, |
110 | { "InternalPort", OSD.FromInteger(regionInfo.InternalEndPoint.Port) }, | 121 | { "InternalPort", OSD.FromInteger(regionInfo.InternalEndPoint.Port) }, |
111 | { "ExternalAddress", OSD.FromString(regionInfo.ExternalEndPoint.Address.ToString()) }, | 122 | { "ExternalAddress", OSD.FromString(ext.Address.ToString()) }, |
112 | { "ExternalPort", OSD.FromInteger(regionInfo.ExternalEndPoint.Port) }, | 123 | { "ExternalPort", OSD.FromInteger(regionInfo.ExternalEndPoint.Port) }, |
113 | { "MapTexture", OSD.FromUUID(regionInfo.TerrainImage) }, | 124 | { "MapTexture", OSD.FromUUID(regionInfo.TerrainImage) }, |
114 | { "Access", OSD.FromInteger(regionInfo.Access) }, | 125 | { "Access", OSD.FromInteger(regionInfo.Access) }, |
@@ -399,6 +410,83 @@ namespace OpenSim.Services.Connectors.SimianGrid | |||
399 | 410 | ||
400 | #endregion IGridService | 411 | #endregion IGridService |
401 | 412 | ||
413 | private void UploadMapTile(IScene scene) | ||
414 | { | ||
415 | string errorMessage = null; | ||
416 | |||
417 | // Create a PNG map tile and upload it to the AddMapTile API | ||
418 | byte[] pngData = Utils.EmptyBytes; | ||
419 | IMapImageGenerator tileGenerator = scene.RequestModuleInterface<IMapImageGenerator>(); | ||
420 | if (tileGenerator == null) | ||
421 | { | ||
422 | m_log.Warn("[SIMIAN GRID CONNECTOR]: Cannot upload PNG map tile without an IMapImageGenerator"); | ||
423 | return; | ||
424 | } | ||
425 | |||
426 | using (Image mapTile = tileGenerator.CreateMapTile()) | ||
427 | { | ||
428 | using (MemoryStream stream = new MemoryStream()) | ||
429 | { | ||
430 | mapTile.Save(stream, ImageFormat.Png); | ||
431 | pngData = stream.ToArray(); | ||
432 | } | ||
433 | } | ||
434 | |||
435 | List<MultipartForm.Element> postParameters = new List<MultipartForm.Element>() | ||
436 | { | ||
437 | new MultipartForm.Parameter("X", scene.RegionInfo.RegionLocX.ToString()), | ||
438 | new MultipartForm.Parameter("Y", scene.RegionInfo.RegionLocY.ToString()), | ||
439 | new MultipartForm.File("Tile", "tile.png", "image/png", pngData) | ||
440 | }; | ||
441 | |||
442 | // Make the remote storage request | ||
443 | try | ||
444 | { | ||
445 | HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(m_ServerURI); | ||
446 | |||
447 | HttpWebResponse response = MultipartForm.Post(request, postParameters); | ||
448 | using (Stream responseStream = response.GetResponseStream()) | ||
449 | { | ||
450 | string responseStr = null; | ||
451 | |||
452 | try | ||
453 | { | ||
454 | responseStr = responseStream.GetStreamString(); | ||
455 | OSD responseOSD = OSDParser.Deserialize(responseStr); | ||
456 | if (responseOSD.Type == OSDType.Map) | ||
457 | { | ||
458 | OSDMap responseMap = (OSDMap)responseOSD; | ||
459 | if (responseMap["Success"].AsBoolean()) | ||
460 | m_log.Info("[SIMIAN GRID CONNECTOR]: Uploaded " + pngData.Length + " byte PNG map tile to AddMapTile"); | ||
461 | else | ||
462 | errorMessage = "Upload failed: " + responseMap["Message"].AsString(); | ||
463 | } | ||
464 | else | ||
465 | { | ||
466 | errorMessage = "Response format was invalid:\n" + responseStr; | ||
467 | } | ||
468 | } | ||
469 | catch (Exception ex) | ||
470 | { | ||
471 | if (!String.IsNullOrEmpty(responseStr)) | ||
472 | errorMessage = "Failed to parse the response:\n" + responseStr; | ||
473 | else | ||
474 | errorMessage = "Failed to retrieve the response: " + ex.Message; | ||
475 | } | ||
476 | } | ||
477 | } | ||
478 | catch (WebException ex) | ||
479 | { | ||
480 | errorMessage = ex.Message; | ||
481 | } | ||
482 | |||
483 | if (!String.IsNullOrEmpty(errorMessage)) | ||
484 | { | ||
485 | m_log.WarnFormat("[SIMIAN GRID CONNECTOR]: Failed to store {0} byte PNG map tile for {1}: {2}", | ||
486 | pngData.Length, scene.RegionInfo.RegionName, errorMessage.Replace('\n', ' ')); | ||
487 | } | ||
488 | } | ||
489 | |||
402 | private GridRegion GetNearestRegion(Vector3d position, bool onlyEnabled) | 490 | private GridRegion GetNearestRegion(Vector3d position, bool onlyEnabled) |
403 | { | 491 | { |
404 | NameValueCollection requestArgs = new NameValueCollection | 492 | NameValueCollection requestArgs = new NameValueCollection |
diff --git a/OpenSim/Services/Connectors/SimianGrid/SimianUserAccountServiceConnector.cs b/OpenSim/Services/Connectors/SimianGrid/SimianUserAccountServiceConnector.cs index 6e32b3a..fcb5115 100644 --- a/OpenSim/Services/Connectors/SimianGrid/SimianUserAccountServiceConnector.cs +++ b/OpenSim/Services/Connectors/SimianGrid/SimianUserAccountServiceConnector.cs | |||
@@ -191,6 +191,11 @@ namespace OpenSim.Services.Connectors.SimianGrid | |||
191 | return accounts; | 191 | return accounts; |
192 | } | 192 | } |
193 | 193 | ||
194 | public List<UserAccount> GetUserAccountsWhere(UUID scopeID, string query) | ||
195 | { | ||
196 | return null; | ||
197 | } | ||
198 | |||
194 | public bool StoreUserAccount(UserAccount data) | 199 | public bool StoreUserAccount(UserAccount data) |
195 | { | 200 | { |
196 | // m_log.InfoFormat("[SIMIAN ACCOUNT CONNECTOR]: Storing user account for " + data.Name); | 201 | // m_log.InfoFormat("[SIMIAN ACCOUNT CONNECTOR]: Storing user account for " + data.Name); |
diff --git a/OpenSim/Services/Connectors/Simulation/SimulationDataService.cs b/OpenSim/Services/Connectors/Simulation/SimulationDataService.cs index 504fcaf..96c02d9 100644 --- a/OpenSim/Services/Connectors/Simulation/SimulationDataService.cs +++ b/OpenSim/Services/Connectors/Simulation/SimulationDataService.cs | |||
@@ -164,6 +164,11 @@ namespace OpenSim.Services.Connectors | |||
164 | m_database.RemoveRegionEnvironmentSettings(regionUUID); | 164 | m_database.RemoveRegionEnvironmentSettings(regionUUID); |
165 | } | 165 | } |
166 | 166 | ||
167 | public UUID[] GetObjectIDs(UUID regionID) | ||
168 | { | ||
169 | return m_database.GetObjectIDs(regionID); | ||
170 | } | ||
171 | |||
167 | public void SaveExtra(UUID regionID, string name, string val) | 172 | public void SaveExtra(UUID regionID, string name, string val) |
168 | { | 173 | { |
169 | m_database.SaveExtra(regionID, name, val); | 174 | m_database.SaveExtra(regionID, name, val); |
diff --git a/OpenSim/Services/Connectors/Simulation/SimulationServiceConnector.cs b/OpenSim/Services/Connectors/Simulation/SimulationServiceConnector.cs index 57f2ffa..ef2494a 100644 --- a/OpenSim/Services/Connectors/Simulation/SimulationServiceConnector.cs +++ b/OpenSim/Services/Connectors/Simulation/SimulationServiceConnector.cs | |||
@@ -86,6 +86,7 @@ namespace OpenSim.Services.Connectors.Simulation | |||
86 | reason = String.Empty; | 86 | reason = String.Empty; |
87 | if (destination == null) | 87 | if (destination == null) |
88 | { | 88 | { |
89 | reason = "Destination not found"; | ||
89 | m_log.Debug("[REMOTE SIMULATION CONNECTOR]: Given destination is null"); | 90 | m_log.Debug("[REMOTE SIMULATION CONNECTOR]: Given destination is null"); |
90 | return false; | 91 | return false; |
91 | } | 92 | } |
@@ -359,6 +360,10 @@ namespace OpenSim.Services.Connectors.Simulation | |||
359 | return false; | 360 | return false; |
360 | } | 361 | } |
361 | 362 | ||
363 | OSDMap resp = (OSDMap)result["_Result"]; | ||
364 | success = resp["success"].AsBoolean(); | ||
365 | reason = resp["reason"].AsString(); | ||
366 | |||
362 | return success; | 367 | return success; |
363 | } | 368 | } |
364 | catch (Exception e) | 369 | catch (Exception e) |
@@ -387,26 +392,35 @@ namespace OpenSim.Services.Connectors.Simulation | |||
387 | return true; | 392 | return true; |
388 | } | 393 | } |
389 | 394 | ||
390 | /// <summary> | 395 | private bool CloseAgent(GridRegion destination, UUID id, bool ChildOnly) |
391 | /// </summary> | ||
392 | public bool CloseAgent(GridRegion destination, UUID id) | ||
393 | { | 396 | { |
394 | // m_log.DebugFormat("[REMOTE SIMULATION CONNECTOR]: CloseAgent start"); | 397 | // m_log.DebugFormat("[REMOTE SIMULATION CONNECTOR]: CloseAgent start"); |
398 | Util.FireAndForget(x => { | ||
399 | string uri = destination.ServerURI + AgentPath() + id + "/" + destination.RegionID.ToString() + "/"; | ||
395 | 400 | ||
396 | string uri = destination.ServerURI + AgentPath() + id + "/" + destination.RegionID.ToString() + "/"; | 401 | try |
397 | 402 | { | |
398 | try | 403 | WebUtil.ServiceOSDRequest(uri, null, "DELETE", 10000, false); |
399 | { | 404 | } |
400 | WebUtil.ServiceOSDRequest(uri, null, "DELETE", 10000, false); | 405 | catch (Exception e) |
401 | } | 406 | { |
402 | catch (Exception e) | 407 | m_log.WarnFormat("[REMOTE SIMULATION CONNECTOR] CloseAgent failed with exception; {0}",e.ToString()); |
403 | { | 408 | } |
404 | m_log.WarnFormat("[REMOTE SIMULATION CONNECTOR] CloseAgent failed with exception; {0}",e.ToString()); | 409 | }); |
405 | } | ||
406 | 410 | ||
407 | return true; | 411 | return true; |
408 | } | 412 | } |
409 | 413 | ||
414 | public bool CloseChildAgent(GridRegion destination, UUID id) | ||
415 | { | ||
416 | return CloseAgent(destination, id, true); | ||
417 | } | ||
418 | |||
419 | public bool CloseAgent(GridRegion destination, UUID id) | ||
420 | { | ||
421 | return CloseAgent(destination, id, false); | ||
422 | } | ||
423 | |||
410 | #endregion Agents | 424 | #endregion Agents |
411 | 425 | ||
412 | #region Objects | 426 | #region Objects |
@@ -444,11 +458,14 @@ namespace OpenSim.Services.Connectors.Simulation | |||
444 | args["destination_name"] = OSD.FromString(destination.RegionName); | 458 | args["destination_name"] = OSD.FromString(destination.RegionName); |
445 | args["destination_uuid"] = OSD.FromString(destination.RegionID.ToString()); | 459 | args["destination_uuid"] = OSD.FromString(destination.RegionID.ToString()); |
446 | 460 | ||
447 | WebUtil.PostToService(uri, args, 40000); | 461 | OSDMap response = WebUtil.PostToService(uri, args, 40000); |
462 | if (response["Success"] == "False") | ||
463 | return false; | ||
448 | } | 464 | } |
449 | catch (Exception e) | 465 | catch (Exception e) |
450 | { | 466 | { |
451 | m_log.WarnFormat("[REMOTE SIMULATION CONNECTOR] CreateObject failed with exception; {0}",e.ToString()); | 467 | m_log.WarnFormat("[REMOTE SIMULATION CONNECTOR] CreateObject failed with exception; {0}",e.ToString()); |
468 | return false; | ||
452 | } | 469 | } |
453 | 470 | ||
454 | return true; | 471 | return true; |
diff --git a/OpenSim/Services/Connectors/UserAccounts/UserAccountServicesConnector.cs b/OpenSim/Services/Connectors/UserAccounts/UserAccountServicesConnector.cs index 97d9458..6b2d710 100644 --- a/OpenSim/Services/Connectors/UserAccounts/UserAccountServicesConnector.cs +++ b/OpenSim/Services/Connectors/UserAccounts/UserAccountServicesConnector.cs | |||
@@ -187,6 +187,11 @@ namespace OpenSim.Services.Connectors | |||
187 | return accounts; | 187 | return accounts; |
188 | } | 188 | } |
189 | 189 | ||
190 | public List<UserAccount> GetUserAccountsWhere(UUID scopeID, string where) | ||
191 | { | ||
192 | return null; // Not implemented for regions | ||
193 | } | ||
194 | |||
190 | public virtual bool StoreUserAccount(UserAccount data) | 195 | public virtual bool StoreUserAccount(UserAccount data) |
191 | { | 196 | { |
192 | Dictionary<string, object> sendData = new Dictionary<string, object>(); | 197 | Dictionary<string, object> sendData = new Dictionary<string, object>(); |
diff --git a/OpenSim/Services/GridService/GridService.cs b/OpenSim/Services/GridService/GridService.cs index daebf8b..7f71835 100644 --- a/OpenSim/Services/GridService/GridService.cs +++ b/OpenSim/Services/GridService/GridService.cs | |||
@@ -283,7 +283,7 @@ namespace OpenSim.Services.GridService | |||
283 | 283 | ||
284 | int flags = Convert.ToInt32(region.Data["flags"]); | 284 | int flags = Convert.ToInt32(region.Data["flags"]); |
285 | 285 | ||
286 | if (!m_DeleteOnUnregister || (flags & (int)OpenSim.Framework.RegionFlags.Persistent) != 0) | 286 | if ((!m_DeleteOnUnregister) || ((flags & (int)OpenSim.Framework.RegionFlags.Persistent) != 0)) |
287 | { | 287 | { |
288 | flags &= ~(int)OpenSim.Framework.RegionFlags.RegionOnline; | 288 | flags &= ~(int)OpenSim.Framework.RegionFlags.RegionOnline; |
289 | region.Data["flags"] = flags.ToString(); | 289 | region.Data["flags"] = flags.ToString(); |
@@ -298,7 +298,6 @@ namespace OpenSim.Services.GridService | |||
298 | } | 298 | } |
299 | 299 | ||
300 | return true; | 300 | return true; |
301 | |||
302 | } | 301 | } |
303 | 302 | ||
304 | return m_Database.Delete(regionID); | 303 | return m_Database.Delete(regionID); |
diff --git a/OpenSim/Services/HypergridService/UserAccountCache.cs b/OpenSim/Services/HypergridService/UserAccountCache.cs index 65f9dd5..e0a3e61 100644 --- a/OpenSim/Services/HypergridService/UserAccountCache.cs +++ b/OpenSim/Services/HypergridService/UserAccountCache.cs | |||
@@ -90,6 +90,11 @@ namespace OpenSim.Services.HypergridService | |||
90 | return null; | 90 | return null; |
91 | } | 91 | } |
92 | 92 | ||
93 | public List<UserAccount> GetUserAccountsWhere(UUID scopeID, string query) | ||
94 | { | ||
95 | return null; | ||
96 | } | ||
97 | |||
93 | public List<UserAccount> GetUserAccounts(UUID scopeID, string query) | 98 | public List<UserAccount> GetUserAccounts(UUID scopeID, string query) |
94 | { | 99 | { |
95 | return null; | 100 | return null; |
diff --git a/OpenSim/Services/HypergridService/UserAgentService.cs b/OpenSim/Services/HypergridService/UserAgentService.cs index 737e9c9..ec76508 100644 --- a/OpenSim/Services/HypergridService/UserAgentService.cs +++ b/OpenSim/Services/HypergridService/UserAgentService.cs | |||
@@ -387,13 +387,11 @@ namespace OpenSim.Services.HypergridService | |||
387 | 387 | ||
388 | if (m_TravelingAgents.ContainsKey(sessionID)) | 388 | if (m_TravelingAgents.ContainsKey(sessionID)) |
389 | { | 389 | { |
390 | bool result = m_TravelingAgents[sessionID].ClientIPAddress == reportedIP || | 390 | m_log.DebugFormat("[USER AGENT SERVICE]: Comparing with login IP {0} and MyIP {1}", |
391 | m_TravelingAgents[sessionID].MyIpAddress == reportedIP; // NATed | 391 | m_TravelingAgents[sessionID].ClientIPAddress, m_TravelingAgents[sessionID].MyIpAddress); |
392 | |||
393 | m_log.DebugFormat("[USER AGENT SERVICE]: Comparing {0} with login IP {1} and MyIP {1}; result is {3}", | ||
394 | reportedIP, m_TravelingAgents[sessionID].ClientIPAddress, m_TravelingAgents[sessionID].MyIpAddress, result); | ||
395 | 392 | ||
396 | return result; | 393 | return m_TravelingAgents[sessionID].ClientIPAddress == reportedIP || |
394 | m_TravelingAgents[sessionID].MyIpAddress == reportedIP; // NATed | ||
397 | } | 395 | } |
398 | 396 | ||
399 | return false; | 397 | return false; |
diff --git a/OpenSim/Services/Interfaces/IAttachmentsService.cs b/OpenSim/Services/Interfaces/IAttachmentsService.cs new file mode 100644 index 0000000..bdde369 --- /dev/null +++ b/OpenSim/Services/Interfaces/IAttachmentsService.cs | |||
@@ -0,0 +1,17 @@ | |||
1 | //////////////////////////////////////////////////////////////// | ||
2 | // | ||
3 | // (c) 2009, 2010 Careminster Limited and Melanie Thielker | ||
4 | // | ||
5 | // All rights reserved | ||
6 | // | ||
7 | using System; | ||
8 | using Nini.Config; | ||
9 | |||
10 | namespace OpenSim.Services.Interfaces | ||
11 | { | ||
12 | public interface IAttachmentsService | ||
13 | { | ||
14 | string Get(string id); | ||
15 | void Store(string id, string data); | ||
16 | } | ||
17 | } | ||
diff --git a/OpenSim/Services/Interfaces/IAuthenticationService.cs b/OpenSim/Services/Interfaces/IAuthenticationService.cs index cee8bc0..cdcfad9 100644 --- a/OpenSim/Services/Interfaces/IAuthenticationService.cs +++ b/OpenSim/Services/Interfaces/IAuthenticationService.cs | |||
@@ -67,6 +67,7 @@ namespace OpenSim.Services.Interfaces | |||
67 | // various services. | 67 | // various services. |
68 | // | 68 | // |
69 | string Authenticate(UUID principalID, string password, int lifetime); | 69 | string Authenticate(UUID principalID, string password, int lifetime); |
70 | string Authenticate(UUID principalID, string password, int lifetime, out UUID realID); | ||
70 | 71 | ||
71 | ////////////////////////////////////////////////////// | 72 | ////////////////////////////////////////////////////// |
72 | // Verification | 73 | // Verification |
diff --git a/OpenSim/Services/Interfaces/IAvatarService.cs b/OpenSim/Services/Interfaces/IAvatarService.cs index 6ca0b15..3663a7a 100644 --- a/OpenSim/Services/Interfaces/IAvatarService.cs +++ b/OpenSim/Services/Interfaces/IAvatarService.cs | |||
@@ -162,10 +162,16 @@ namespace OpenSim.Services.Interfaces | |||
162 | } | 162 | } |
163 | 163 | ||
164 | // Visual Params | 164 | // Visual Params |
165 | string[] vps = new string[AvatarAppearance.VISUALPARAM_COUNT]; | 165 | // string[] vps = new string[AvatarAppearance.VISUALPARAM_COUNT]; |
166 | // byte[] binary = appearance.VisualParams; | ||
167 | |||
168 | // for (int i = 0 ; i < AvatarAppearance.VISUALPARAM_COUNT ; i++) | ||
169 | |||
170 | |||
166 | byte[] binary = appearance.VisualParams; | 171 | byte[] binary = appearance.VisualParams; |
172 | string[] vps = new string[binary.Length]; | ||
167 | 173 | ||
168 | for (int i = 0 ; i < AvatarAppearance.VISUALPARAM_COUNT ; i++) | 174 | for (int i = 0; i < binary.Length; i++) |
169 | { | 175 | { |
170 | vps[i] = binary[i].ToString(); | 176 | vps[i] = binary[i].ToString(); |
171 | } | 177 | } |
@@ -202,7 +208,13 @@ namespace OpenSim.Services.Interfaces | |||
202 | appearance.Serial = Int32.Parse(Data["Serial"]); | 208 | appearance.Serial = Int32.Parse(Data["Serial"]); |
203 | 209 | ||
204 | if (Data.ContainsKey("AvatarHeight")) | 210 | if (Data.ContainsKey("AvatarHeight")) |
205 | appearance.AvatarHeight = float.Parse(Data["AvatarHeight"]); | 211 | { |
212 | float h = float.Parse(Data["AvatarHeight"]); | ||
213 | if( h == 0f) | ||
214 | h = 1.9f; | ||
215 | appearance.SetSize(new Vector3(0.45f, 0.6f, h )); | ||
216 | // appearance.AvatarHeight = float.Parse(Data["AvatarHeight"]); | ||
217 | } | ||
206 | 218 | ||
207 | // Legacy Wearables | 219 | // Legacy Wearables |
208 | if (Data.ContainsKey("BodyItem")) | 220 | if (Data.ContainsKey("BodyItem")) |
@@ -273,10 +285,14 @@ namespace OpenSim.Services.Interfaces | |||
273 | if (Data.ContainsKey("VisualParams")) | 285 | if (Data.ContainsKey("VisualParams")) |
274 | { | 286 | { |
275 | string[] vps = Data["VisualParams"].Split(new char[] {','}); | 287 | string[] vps = Data["VisualParams"].Split(new char[] {','}); |
276 | byte[] binary = new byte[AvatarAppearance.VISUALPARAM_COUNT]; | 288 | // byte[] binary = new byte[AvatarAppearance.VISUALPARAM_COUNT]; |
289 | |||
290 | // for (int i = 0 ; i < vps.Length && i < binary.Length ; i++) | ||
291 | byte[] binary = new byte[vps.Length]; | ||
277 | 292 | ||
278 | for (int i = 0 ; i < vps.Length && i < binary.Length ; i++) | 293 | for (int i = 0; i < vps.Length; i++) |
279 | binary[i] = (byte)Convert.ToInt32(vps[i]); | 294 | |
295 | binary[i] = (byte)Convert.ToInt32(vps[i]); | ||
280 | 296 | ||
281 | appearance.VisualParams = binary; | 297 | appearance.VisualParams = binary; |
282 | } | 298 | } |
@@ -342,6 +358,7 @@ namespace OpenSim.Services.Interfaces | |||
342 | appearance.Wearables[AvatarWearable.EYES].Wear( | 358 | appearance.Wearables[AvatarWearable.EYES].Wear( |
343 | AvatarWearable.DefaultWearables[ | 359 | AvatarWearable.DefaultWearables[ |
344 | AvatarWearable.EYES][0]); | 360 | AvatarWearable.EYES][0]); |
361 | |||
345 | } | 362 | } |
346 | catch | 363 | catch |
347 | { | 364 | { |
diff --git a/OpenSim/Services/Interfaces/IBakedTextureService.cs b/OpenSim/Services/Interfaces/IBakedTextureService.cs new file mode 100644 index 0000000..8206ecd --- /dev/null +++ b/OpenSim/Services/Interfaces/IBakedTextureService.cs | |||
@@ -0,0 +1,17 @@ | |||
1 | //////////////////////////////////////////////////////////////// | ||
2 | // | ||
3 | // (c) 2009, 2010 Careminster Limited and Melanie Thielker | ||
4 | // | ||
5 | // All rights reserved | ||
6 | // | ||
7 | using System; | ||
8 | using Nini.Config; | ||
9 | |||
10 | namespace OpenSim.Services.Interfaces | ||
11 | { | ||
12 | public interface IBakedTextureService | ||
13 | { | ||
14 | string Get(string id); | ||
15 | void Store(string id, string data); | ||
16 | } | ||
17 | } | ||
diff --git a/OpenSim/Services/Interfaces/IGridService.cs b/OpenSim/Services/Interfaces/IGridService.cs index d7da056..3f4c958 100644 --- a/OpenSim/Services/Interfaces/IGridService.cs +++ b/OpenSim/Services/Interfaces/IGridService.cs | |||
@@ -337,9 +337,13 @@ namespace OpenSim.Services.Interfaces | |||
337 | } | 337 | } |
338 | catch (SocketException e) | 338 | catch (SocketException e) |
339 | { | 339 | { |
340 | throw new Exception( | 340 | /*throw new Exception( |
341 | "Unable to resolve local hostname " + m_externalHostName + " innerException of type '" + | 341 | "Unable to resolve local hostname " + m_externalHostName + " innerException of type '" + |
342 | e + "' attached to this exception", e); | 342 | e + "' attached to this exception", e);*/ |
343 | // Don't throw a fatal exception here, instead, return Null and handle it in the caller. | ||
344 | // Reason is, on systems such as OSgrid it has occured that known hostnames stop | ||
345 | // resolving and thus make surrounding regions crash out with this exception. | ||
346 | return null; | ||
343 | } | 347 | } |
344 | 348 | ||
345 | return new IPEndPoint(ia, m_internalEndPoint.Port); | 349 | return new IPEndPoint(ia, m_internalEndPoint.Port); |
@@ -398,6 +402,12 @@ namespace OpenSim.Services.Interfaces | |||
398 | if (kvp.ContainsKey("regionName")) | 402 | if (kvp.ContainsKey("regionName")) |
399 | RegionName = (string)kvp["regionName"]; | 403 | RegionName = (string)kvp["regionName"]; |
400 | 404 | ||
405 | if (kvp.ContainsKey("access")) | ||
406 | { | ||
407 | byte access = Convert.ToByte((string)kvp["access"]); | ||
408 | Maturity = (int)Util.ConvertAccessLevelToMaturity(access); | ||
409 | } | ||
410 | |||
401 | if (kvp.ContainsKey("serverIP")) | 411 | if (kvp.ContainsKey("serverIP")) |
402 | { | 412 | { |
403 | //int port = 0; | 413 | //int port = 0; |
diff --git a/OpenSim/Services/Interfaces/IMapImageService.cs b/OpenSim/Services/Interfaces/IMapImageService.cs index a7b2cf1..78daa5f 100644 --- a/OpenSim/Services/Interfaces/IMapImageService.cs +++ b/OpenSim/Services/Interfaces/IMapImageService.cs | |||
@@ -35,6 +35,7 @@ namespace OpenSim.Services.Interfaces | |||
35 | { | 35 | { |
36 | //List<MapBlockData> GetMapBlocks(UUID scopeID, int minX, int minY, int maxX, int maxY); | 36 | //List<MapBlockData> GetMapBlocks(UUID scopeID, int minX, int minY, int maxX, int maxY); |
37 | bool AddMapTile(int x, int y, byte[] imageData, out string reason); | 37 | bool AddMapTile(int x, int y, byte[] imageData, out string reason); |
38 | bool RemoveMapTile(int x, int y, out string reason); | ||
38 | byte[] GetMapTile(string fileName, out string format); | 39 | byte[] GetMapTile(string fileName, out string format); |
39 | } | 40 | } |
40 | } | 41 | } |
diff --git a/OpenSim/Services/Interfaces/ISimulationService.cs b/OpenSim/Services/Interfaces/ISimulationService.cs index b10a85c..a963b8e 100644 --- a/OpenSim/Services/Interfaces/ISimulationService.cs +++ b/OpenSim/Services/Interfaces/ISimulationService.cs | |||
@@ -90,6 +90,14 @@ namespace OpenSim.Services.Interfaces | |||
90 | bool ReleaseAgent(UUID originRegion, UUID id, string uri); | 90 | bool ReleaseAgent(UUID originRegion, UUID id, string uri); |
91 | 91 | ||
92 | /// <summary> | 92 | /// <summary> |
93 | /// Close child agent. | ||
94 | /// </summary> | ||
95 | /// <param name="regionHandle"></param> | ||
96 | /// <param name="id"></param> | ||
97 | /// <returns></returns> | ||
98 | bool CloseChildAgent(GridRegion destination, UUID id); | ||
99 | |||
100 | /// <summary> | ||
93 | /// Close agent. | 101 | /// Close agent. |
94 | /// </summary> | 102 | /// </summary> |
95 | /// <param name="regionHandle"></param> | 103 | /// <param name="regionHandle"></param> |
diff --git a/OpenSim/Services/Interfaces/IUserAccountService.cs b/OpenSim/Services/Interfaces/IUserAccountService.cs index 1b85980..6d5d2a0 100644 --- a/OpenSim/Services/Interfaces/IUserAccountService.cs +++ b/OpenSim/Services/Interfaces/IUserAccountService.cs | |||
@@ -91,6 +91,7 @@ namespace OpenSim.Services.Interfaces | |||
91 | public int UserLevel; | 91 | public int UserLevel; |
92 | public int UserFlags; | 92 | public int UserFlags; |
93 | public string UserTitle; | 93 | public string UserTitle; |
94 | public string UserCountry; | ||
94 | public Boolean LocalToGrid = true; | 95 | public Boolean LocalToGrid = true; |
95 | 96 | ||
96 | public Dictionary<string, object> ServiceURLs; | 97 | public Dictionary<string, object> ServiceURLs; |
@@ -120,6 +121,8 @@ namespace OpenSim.Services.Interfaces | |||
120 | UserFlags = Convert.ToInt32(kvp["UserFlags"].ToString()); | 121 | UserFlags = Convert.ToInt32(kvp["UserFlags"].ToString()); |
121 | if (kvp.ContainsKey("UserTitle")) | 122 | if (kvp.ContainsKey("UserTitle")) |
122 | UserTitle = kvp["UserTitle"].ToString(); | 123 | UserTitle = kvp["UserTitle"].ToString(); |
124 | if (kvp.ContainsKey("UserCountry")) | ||
125 | UserCountry = kvp["UserCountry"].ToString(); | ||
123 | if (kvp.ContainsKey("LocalToGrid")) | 126 | if (kvp.ContainsKey("LocalToGrid")) |
124 | Boolean.TryParse(kvp["LocalToGrid"].ToString(), out LocalToGrid); | 127 | Boolean.TryParse(kvp["LocalToGrid"].ToString(), out LocalToGrid); |
125 | 128 | ||
@@ -155,6 +158,7 @@ namespace OpenSim.Services.Interfaces | |||
155 | result["UserLevel"] = UserLevel.ToString(); | 158 | result["UserLevel"] = UserLevel.ToString(); |
156 | result["UserFlags"] = UserFlags.ToString(); | 159 | result["UserFlags"] = UserFlags.ToString(); |
157 | result["UserTitle"] = UserTitle; | 160 | result["UserTitle"] = UserTitle; |
161 | result["UserCountry"] = UserCountry; | ||
158 | result["LocalToGrid"] = LocalToGrid.ToString(); | 162 | result["LocalToGrid"] = LocalToGrid.ToString(); |
159 | 163 | ||
160 | string str = string.Empty; | 164 | string str = string.Empty; |
@@ -182,6 +186,7 @@ namespace OpenSim.Services.Interfaces | |||
182 | /// <param name="query"></param> | 186 | /// <param name="query"></param> |
183 | /// <returns></returns> | 187 | /// <returns></returns> |
184 | List<UserAccount> GetUserAccounts(UUID scopeID, string query); | 188 | List<UserAccount> GetUserAccounts(UUID scopeID, string query); |
189 | List<UserAccount> GetUserAccountsWhere(UUID scopeID, string where); | ||
185 | 190 | ||
186 | /// <summary> | 191 | /// <summary> |
187 | /// Store the data given, wich replaces the stored data, therefore must be complete. | 192 | /// Store the data given, wich replaces the stored data, therefore must be complete. |
diff --git a/OpenSim/Services/LLLoginService/LLLoginResponse.cs b/OpenSim/Services/LLLoginService/LLLoginResponse.cs index 9ec744f..e2f947c 100644 --- a/OpenSim/Services/LLLoginService/LLLoginResponse.cs +++ b/OpenSim/Services/LLLoginService/LLLoginResponse.cs | |||
@@ -55,6 +55,7 @@ namespace OpenSim.Services.LLLoginService | |||
55 | public static LLFailedLoginResponse InventoryProblem; | 55 | public static LLFailedLoginResponse InventoryProblem; |
56 | public static LLFailedLoginResponse DeadRegionProblem; | 56 | public static LLFailedLoginResponse DeadRegionProblem; |
57 | public static LLFailedLoginResponse LoginBlockedProblem; | 57 | public static LLFailedLoginResponse LoginBlockedProblem; |
58 | public static LLFailedLoginResponse UnverifiedAccountProblem; | ||
58 | public static LLFailedLoginResponse AlreadyLoggedInProblem; | 59 | public static LLFailedLoginResponse AlreadyLoggedInProblem; |
59 | public static LLFailedLoginResponse InternalError; | 60 | public static LLFailedLoginResponse InternalError; |
60 | 61 | ||
@@ -75,6 +76,10 @@ namespace OpenSim.Services.LLLoginService | |||
75 | LoginBlockedProblem = new LLFailedLoginResponse("presence", | 76 | LoginBlockedProblem = new LLFailedLoginResponse("presence", |
76 | "Logins are currently restricted. Please try again later.", | 77 | "Logins are currently restricted. Please try again later.", |
77 | "false"); | 78 | "false"); |
79 | UnverifiedAccountProblem = new LLFailedLoginResponse("presence", | ||
80 | "Your account has not yet been verified. Please check " + | ||
81 | "your email and click the provided link.", | ||
82 | "false"); | ||
78 | AlreadyLoggedInProblem = new LLFailedLoginResponse("presence", | 83 | AlreadyLoggedInProblem = new LLFailedLoginResponse("presence", |
79 | "You appear to be already logged in. " + | 84 | "You appear to be already logged in. " + |
80 | "If this is not the case please wait for your session to timeout. " + | 85 | "If this is not the case please wait for your session to timeout. " + |
@@ -145,6 +150,7 @@ namespace OpenSim.Services.LLLoginService | |||
145 | private UUID agentID; | 150 | private UUID agentID; |
146 | private UUID sessionID; | 151 | private UUID sessionID; |
147 | private UUID secureSessionID; | 152 | private UUID secureSessionID; |
153 | private UUID realID; | ||
148 | 154 | ||
149 | // Login Flags | 155 | // Login Flags |
150 | private string dst; | 156 | private string dst; |
@@ -227,7 +233,7 @@ namespace OpenSim.Services.LLLoginService | |||
227 | GridRegion destination, List<InventoryFolderBase> invSkel, FriendInfo[] friendsList, ILibraryService libService, | 233 | GridRegion destination, List<InventoryFolderBase> invSkel, FriendInfo[] friendsList, ILibraryService libService, |
228 | string where, string startlocation, Vector3 position, Vector3 lookAt, List<InventoryItemBase> gestures, string message, | 234 | string where, string startlocation, Vector3 position, Vector3 lookAt, List<InventoryItemBase> gestures, string message, |
229 | GridRegion home, IPEndPoint clientIP, string mapTileURL, string profileURL, string openIDURL, string searchURL, string currency, | 235 | GridRegion home, IPEndPoint clientIP, string mapTileURL, string profileURL, string openIDURL, string searchURL, string currency, |
230 | string DSTZone) | 236 | string DSTZone, UUID realID) |
231 | : this() | 237 | : this() |
232 | { | 238 | { |
233 | FillOutInventoryData(invSkel, libService); | 239 | FillOutInventoryData(invSkel, libService); |
@@ -240,6 +246,7 @@ namespace OpenSim.Services.LLLoginService | |||
240 | AgentID = account.PrincipalID; | 246 | AgentID = account.PrincipalID; |
241 | SessionID = aCircuit.SessionID; | 247 | SessionID = aCircuit.SessionID; |
242 | SecureSessionID = aCircuit.SecureSessionID; | 248 | SecureSessionID = aCircuit.SecureSessionID; |
249 | RealID = realID; | ||
243 | Message = message; | 250 | Message = message; |
244 | BuddList = ConvertFriendListItem(friendsList); | 251 | BuddList = ConvertFriendListItem(friendsList); |
245 | StartLocation = where; | 252 | StartLocation = where; |
@@ -375,6 +382,7 @@ namespace OpenSim.Services.LLLoginService | |||
375 | private void FillOutRegionData(GridRegion destination) | 382 | private void FillOutRegionData(GridRegion destination) |
376 | { | 383 | { |
377 | IPEndPoint endPoint = destination.ExternalEndPoint; | 384 | IPEndPoint endPoint = destination.ExternalEndPoint; |
385 | if (endPoint == null) return; | ||
378 | SimAddress = endPoint.Address.ToString(); | 386 | SimAddress = endPoint.Address.ToString(); |
379 | SimPort = (uint)endPoint.Port; | 387 | SimPort = (uint)endPoint.Port; |
380 | RegionX = (uint)destination.RegionLocX; | 388 | RegionX = (uint)destination.RegionLocX; |
@@ -450,6 +458,7 @@ namespace OpenSim.Services.LLLoginService | |||
450 | SessionID = UUID.Random(); | 458 | SessionID = UUID.Random(); |
451 | SecureSessionID = UUID.Random(); | 459 | SecureSessionID = UUID.Random(); |
452 | AgentID = UUID.Random(); | 460 | AgentID = UUID.Random(); |
461 | RealID = UUID.Zero; | ||
453 | 462 | ||
454 | Hashtable InitialOutfitHash = new Hashtable(); | 463 | Hashtable InitialOutfitHash = new Hashtable(); |
455 | InitialOutfitHash["folder_name"] = "Nightclub Female"; | 464 | InitialOutfitHash["folder_name"] = "Nightclub Female"; |
@@ -493,6 +502,7 @@ namespace OpenSim.Services.LLLoginService | |||
493 | responseData["http_port"] = (Int32)SimHttpPort; | 502 | responseData["http_port"] = (Int32)SimHttpPort; |
494 | 503 | ||
495 | responseData["agent_id"] = AgentID.ToString(); | 504 | responseData["agent_id"] = AgentID.ToString(); |
505 | responseData["real_id"] = RealID.ToString(); | ||
496 | responseData["session_id"] = SessionID.ToString(); | 506 | responseData["session_id"] = SessionID.ToString(); |
497 | responseData["secure_session_id"] = SecureSessionID.ToString(); | 507 | responseData["secure_session_id"] = SecureSessionID.ToString(); |
498 | responseData["circuit_code"] = CircuitCode; | 508 | responseData["circuit_code"] = CircuitCode; |
@@ -575,6 +585,7 @@ namespace OpenSim.Services.LLLoginService | |||
575 | map["sim_ip"] = OSD.FromString(SimAddress); | 585 | map["sim_ip"] = OSD.FromString(SimAddress); |
576 | 586 | ||
577 | map["agent_id"] = OSD.FromUUID(AgentID); | 587 | map["agent_id"] = OSD.FromUUID(AgentID); |
588 | map["real_id"] = OSD.FromUUID(RealID); | ||
578 | map["session_id"] = OSD.FromUUID(SessionID); | 589 | map["session_id"] = OSD.FromUUID(SessionID); |
579 | map["secure_session_id"] = OSD.FromUUID(SecureSessionID); | 590 | map["secure_session_id"] = OSD.FromUUID(SecureSessionID); |
580 | map["circuit_code"] = OSD.FromInteger(CircuitCode); | 591 | map["circuit_code"] = OSD.FromInteger(CircuitCode); |
@@ -882,6 +893,12 @@ namespace OpenSim.Services.LLLoginService | |||
882 | set { secureSessionID = value; } | 893 | set { secureSessionID = value; } |
883 | } | 894 | } |
884 | 895 | ||
896 | public UUID RealID | ||
897 | { | ||
898 | get { return realID; } | ||
899 | set { realID = value; } | ||
900 | } | ||
901 | |||
885 | public Int32 CircuitCode | 902 | public Int32 CircuitCode |
886 | { | 903 | { |
887 | get { return circuitCode; } | 904 | get { return circuitCode; } |
diff --git a/OpenSim/Services/LLLoginService/LLLoginService.cs b/OpenSim/Services/LLLoginService/LLLoginService.cs index 53a22d4..ede2353 100644 --- a/OpenSim/Services/LLLoginService/LLLoginService.cs +++ b/OpenSim/Services/LLLoginService/LLLoginService.cs | |||
@@ -141,7 +141,8 @@ namespace OpenSim.Services.LLLoginService | |||
141 | Object[] args = new Object[] { config }; | 141 | Object[] args = new Object[] { config }; |
142 | m_UserAccountService = ServerUtils.LoadPlugin<IUserAccountService>(accountService, args); | 142 | m_UserAccountService = ServerUtils.LoadPlugin<IUserAccountService>(accountService, args); |
143 | m_GridUserService = ServerUtils.LoadPlugin<IGridUserService>(gridUserService, args); | 143 | m_GridUserService = ServerUtils.LoadPlugin<IGridUserService>(gridUserService, args); |
144 | m_AuthenticationService = ServerUtils.LoadPlugin<IAuthenticationService>(authService, args); | 144 | Object[] authArgs = new Object[] { config, m_UserAccountService }; |
145 | m_AuthenticationService = ServerUtils.LoadPlugin<IAuthenticationService>(authService, authArgs); | ||
145 | m_InventoryService = ServerUtils.LoadPlugin<IInventoryService>(invService, args); | 146 | m_InventoryService = ServerUtils.LoadPlugin<IInventoryService>(invService, args); |
146 | 147 | ||
147 | if (gridService != string.Empty) | 148 | if (gridService != string.Empty) |
@@ -290,6 +291,12 @@ namespace OpenSim.Services.LLLoginService | |||
290 | return LLFailedLoginResponse.UserProblem; | 291 | return LLFailedLoginResponse.UserProblem; |
291 | } | 292 | } |
292 | 293 | ||
294 | if (account.UserLevel < 0) | ||
295 | { | ||
296 | m_log.InfoFormat("[LLOGIN SERVICE]: Login failed, reason: Unverified account"); | ||
297 | return LLFailedLoginResponse.UnverifiedAccountProblem; | ||
298 | } | ||
299 | |||
293 | if (account.UserLevel < m_MinLoginLevel) | 300 | if (account.UserLevel < m_MinLoginLevel) |
294 | { | 301 | { |
295 | m_log.InfoFormat( | 302 | m_log.InfoFormat( |
@@ -321,7 +328,8 @@ namespace OpenSim.Services.LLLoginService | |||
321 | if (!passwd.StartsWith("$1$")) | 328 | if (!passwd.StartsWith("$1$")) |
322 | passwd = "$1$" + Util.Md5Hash(passwd); | 329 | passwd = "$1$" + Util.Md5Hash(passwd); |
323 | passwd = passwd.Remove(0, 3); //remove $1$ | 330 | passwd = passwd.Remove(0, 3); //remove $1$ |
324 | string token = m_AuthenticationService.Authenticate(account.PrincipalID, passwd, 30); | 331 | UUID realID; |
332 | string token = m_AuthenticationService.Authenticate(account.PrincipalID, passwd, 30, out realID); | ||
325 | UUID secureSession = UUID.Zero; | 333 | UUID secureSession = UUID.Zero; |
326 | if ((token == string.Empty) || (token != string.Empty && !UUID.TryParse(token, out secureSession))) | 334 | if ((token == string.Empty) || (token != string.Empty && !UUID.TryParse(token, out secureSession))) |
327 | { | 335 | { |
@@ -453,7 +461,7 @@ namespace OpenSim.Services.LLLoginService | |||
453 | = new LLLoginResponse( | 461 | = new LLLoginResponse( |
454 | account, aCircuit, guinfo, destination, inventorySkel, friendsList, m_LibraryService, | 462 | account, aCircuit, guinfo, destination, inventorySkel, friendsList, m_LibraryService, |
455 | where, startLocation, position, lookAt, gestures, m_WelcomeMessage, home, clientIP, | 463 | where, startLocation, position, lookAt, gestures, m_WelcomeMessage, home, clientIP, |
456 | m_MapTileURL, m_ProfileURL, m_OpenIDURL, m_SearchURL, m_Currency, m_DSTZone); | 464 | m_MapTileURL, m_ProfileURL, m_OpenIDURL, m_SearchURL, m_Currency, m_DSTZone, realID); |
457 | 465 | ||
458 | m_log.DebugFormat("[LLOGIN SERVICE]: All clear. Sending login response to {0} {1}", firstName, lastName); | 466 | m_log.DebugFormat("[LLOGIN SERVICE]: All clear. Sending login response to {0} {1}", firstName, lastName); |
459 | 467 | ||
diff --git a/OpenSim/Services/MapImageService/MapImageService.cs b/OpenSim/Services/MapImageService/MapImageService.cs index a85ee70..e2f256f 100644 --- a/OpenSim/Services/MapImageService/MapImageService.cs +++ b/OpenSim/Services/MapImageService/MapImageService.cs | |||
@@ -112,9 +112,38 @@ namespace OpenSim.Services.MapImageService | |||
112 | reason = e.Message; | 112 | reason = e.Message; |
113 | return false; | 113 | return false; |
114 | } | 114 | } |
115 | } | ||
116 | |||
117 | return UpdateMultiResolutionFiles(x, y, out reason); | ||
118 | } | ||
119 | |||
120 | public bool RemoveMapTile(int x, int y, out string reason) | ||
121 | { | ||
122 | reason = String.Empty; | ||
123 | string fileName = GetFileName(1, x, y); | ||
124 | |||
125 | lock (m_Sync) | ||
126 | { | ||
127 | try | ||
128 | { | ||
129 | File.Delete(fileName); | ||
130 | } | ||
131 | catch (Exception e) | ||
132 | { | ||
133 | m_log.WarnFormat("[MAP IMAGE SERVICE]: Unable to save delete file {0}: {1}", fileName, e); | ||
134 | reason = e.Message; | ||
135 | return false; | ||
136 | } | ||
137 | } | ||
115 | 138 | ||
116 | // Also save in png format? | 139 | return UpdateMultiResolutionFiles(x, y, out reason); |
140 | } | ||
117 | 141 | ||
142 | private bool UpdateMultiResolutionFiles(int x, int y, out string reason) | ||
143 | { | ||
144 | reason = String.Empty; | ||
145 | lock (m_Sync) | ||
146 | { | ||
118 | // Stitch seven more aggregate tiles together | 147 | // Stitch seven more aggregate tiles together |
119 | for (uint zoomLevel = 2; zoomLevel <= ZOOM_LEVELS; zoomLevel++) | 148 | for (uint zoomLevel = 2; zoomLevel <= ZOOM_LEVELS; zoomLevel++) |
120 | { | 149 | { |
@@ -126,7 +155,7 @@ namespace OpenSim.Services.MapImageService | |||
126 | 155 | ||
127 | if (!CreateTile(zoomLevel, x1, y1)) | 156 | if (!CreateTile(zoomLevel, x1, y1)) |
128 | { | 157 | { |
129 | m_log.WarnFormat("[MAP IMAGE SERVICE]: Unable to create tile for {0} at zoom level {1}", fileName, zoomLevel); | 158 | m_log.WarnFormat("[MAP IMAGE SERVICE]: Unable to create tile for {0},{1} at zoom level {1}", x, y, zoomLevel); |
130 | reason = string.Format("Map tile at zoom level {0} failed", zoomLevel); | 159 | reason = string.Format("Map tile at zoom level {0} failed", zoomLevel); |
131 | return false; | 160 | return false; |
132 | } | 161 | } |
diff --git a/OpenSim/Services/UserAccountService/UserAccountService.cs b/OpenSim/Services/UserAccountService/UserAccountService.cs index 1852e4f..772ab97 100644 --- a/OpenSim/Services/UserAccountService/UserAccountService.cs +++ b/OpenSim/Services/UserAccountService/UserAccountService.cs | |||
@@ -171,6 +171,10 @@ namespace OpenSim.Services.UserAccountService | |||
171 | Int32.TryParse(d.Data["UserLevel"], out u.UserLevel); | 171 | Int32.TryParse(d.Data["UserLevel"], out u.UserLevel); |
172 | if (d.Data.ContainsKey("UserFlags") && d.Data["UserFlags"] != null) | 172 | if (d.Data.ContainsKey("UserFlags") && d.Data["UserFlags"] != null) |
173 | Int32.TryParse(d.Data["UserFlags"], out u.UserFlags); | 173 | Int32.TryParse(d.Data["UserFlags"], out u.UserFlags); |
174 | if (d.Data.ContainsKey("UserCountry") && d.Data["UserCountry"] != null) | ||
175 | u.UserCountry = d.Data["UserCountry"].ToString(); | ||
176 | else | ||
177 | u.UserTitle = string.Empty; | ||
174 | 178 | ||
175 | if (d.Data.ContainsKey("ServiceURLs") && d.Data["ServiceURLs"] != null) | 179 | if (d.Data.ContainsKey("ServiceURLs") && d.Data["ServiceURLs"] != null) |
176 | { | 180 | { |
@@ -292,7 +296,22 @@ namespace OpenSim.Services.UserAccountService | |||
292 | 296 | ||
293 | public List<UserAccount> GetUserAccounts(UUID scopeID, string query) | 297 | public List<UserAccount> GetUserAccounts(UUID scopeID, string query) |
294 | { | 298 | { |
295 | UserAccountData[] d = m_Database.GetUsers(scopeID, query); | 299 | UserAccountData[] d = m_Database.GetUsers(scopeID, query.Trim()); |
300 | |||
301 | if (d == null) | ||
302 | return new List<UserAccount>(); | ||
303 | |||
304 | List<UserAccount> ret = new List<UserAccount>(); | ||
305 | |||
306 | foreach (UserAccountData data in d) | ||
307 | ret.Add(MakeUserAccount(data)); | ||
308 | |||
309 | return ret; | ||
310 | } | ||
311 | |||
312 | public List<UserAccount> GetUserAccountsWhere(UUID scopeID, string where) | ||
313 | { | ||
314 | UserAccountData[] d = m_Database.GetUsersWhere(scopeID, where); | ||
296 | 315 | ||
297 | if (d == null) | 316 | if (d == null) |
298 | return new List<UserAccount>(); | 317 | return new List<UserAccount>(); |