diff options
author | Charles Krinke | 2009-04-21 20:44:17 +0000 |
---|---|---|
committer | Charles Krinke | 2009-04-21 20:44:17 +0000 |
commit | 5ea4faa6f209fd5c6a48cc704c595fb029b790f2 (patch) | |
tree | 5e5c5fbb3c1d9916c8f6f6967b8f63b5c83f49e9 /OpenSim/Region/OptionalModules | |
parent | * Comment out user profile cache update method for now (diff) | |
download | opensim-SC_OLD-5ea4faa6f209fd5c6a48cc704c595fb029b790f2.zip opensim-SC_OLD-5ea4faa6f209fd5c6a48cc704c595fb029b790f2.tar.gz opensim-SC_OLD-5ea4faa6f209fd5c6a48cc704c595fb029b790f2.tar.bz2 opensim-SC_OLD-5ea4faa6f209fd5c6a48cc704c595fb029b790f2.tar.xz |
Thank you kindly, MCortez, for a patch that:
* Refactors the xmlrpc calls to a single location to
make it easier to debug and include alternative
xmlrpc call mechanisms
* Includes an alternative xmlrpc call mechanism that
sets HTTP Keep-Alive to false which solves nearly all
System.Net exceptions on some windows environments
Diffstat (limited to 'OpenSim/Region/OptionalModules')
3 files changed, 217 insertions, 330 deletions
diff --git a/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupData.cs b/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupData.cs index eff76cf..3a728da 100644 --- a/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupData.cs +++ b/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupData.cs | |||
@@ -50,13 +50,24 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
50 | private static readonly ILog m_log = | 50 | private static readonly ILog m_log = |
51 | LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | 51 | LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); |
52 | 52 | ||
53 | private string m_serviceURL = "http://osflotsam.org/xmlrpc.php"; | 53 | private string m_serviceURL = string.Empty; |
54 | 54 | ||
55 | public const GroupPowers m_DefaultEveryonePowers = GroupPowers.AllowSetHome | GroupPowers.Accountable | GroupPowers.JoinChat | GroupPowers.AllowVoiceChat | GroupPowers.ReceiveNotices | GroupPowers.StartProposal | GroupPowers.VoteOnProposal; | 55 | public const GroupPowers m_DefaultEveryonePowers = GroupPowers.AllowSetHome | GroupPowers.Accountable | GroupPowers.JoinChat | GroupPowers.AllowVoiceChat | GroupPowers.ReceiveNotices | GroupPowers.StartProposal | GroupPowers.VoteOnProposal; |
56 | 56 | ||
57 | public XmlRpcGroupDataProvider(string serviceURL) | 57 | private bool m_disableKeepAlive = false; |
58 | |||
59 | public XmlRpcGroupDataProvider(string serviceURL, bool disableKeepAlive) | ||
58 | { | 60 | { |
59 | m_serviceURL = serviceURL; | 61 | m_serviceURL = serviceURL.Trim().ToLower(); |
62 | m_disableKeepAlive = disableKeepAlive; | ||
63 | |||
64 | if ((serviceURL == null) | ||
65 | || (serviceURL == string.Empty) | ||
66 | ) | ||
67 | { | ||
68 | throw new Exception("Please specify a valid ServiceURL for XmlRpcGroupDataProvider in OpenSim.ini, [Groups], XmlRpcServiceURL"); | ||
69 | } | ||
70 | |||
60 | } | 71 | } |
61 | 72 | ||
62 | /// <summary> | 73 | /// <summary> |
@@ -131,15 +142,14 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
131 | 142 | ||
132 | 143 | ||
133 | 144 | ||
134 | IList parameters = new ArrayList(); | 145 | |
135 | parameters.Add(param); | 146 | Hashtable respData = XmlRpcCall("groups.createGroup", param); |
136 | XmlRpcRequest req = new XmlRpcRequest("groups.createGroup", parameters); | ||
137 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
138 | Hashtable respData = (Hashtable)resp.Value; | ||
139 | 147 | ||
140 | if (respData.Contains("error")) | 148 | if (respData.Contains("error")) |
141 | { | 149 | { |
142 | LogRespDataToConsoleError(respData); | 150 | // UUID is not nullable |
151 | |||
152 | return UUID.Zero; | ||
143 | } | 153 | } |
144 | 154 | ||
145 | return UUID.Parse((string)respData["GroupID"]); | 155 | return UUID.Parse((string)respData["GroupID"]); |
@@ -157,16 +167,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
157 | param["AllowPublish"] = allowPublish == true ? 1 : 0; | 167 | param["AllowPublish"] = allowPublish == true ? 1 : 0; |
158 | param["MaturePublish"] = maturePublish == true ? 1 : 0; | 168 | param["MaturePublish"] = maturePublish == true ? 1 : 0; |
159 | 169 | ||
160 | IList parameters = new ArrayList(); | 170 | XmlRpcCall("groups.updateGroup", param); |
161 | parameters.Add(param); | ||
162 | XmlRpcRequest req = new XmlRpcRequest("groups.updateGroup", parameters); | ||
163 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
164 | Hashtable respData = (Hashtable)resp.Value; | ||
165 | |||
166 | if (respData.Contains("error")) | ||
167 | { | ||
168 | LogRespDataToConsoleError(respData); | ||
169 | } | ||
170 | } | 171 | } |
171 | 172 | ||
172 | public void AddGroupRole(UUID groupID, UUID roleID, string name, string description, string title, ulong powers) | 173 | public void AddGroupRole(UUID groupID, UUID roleID, string name, string description, string title, ulong powers) |
@@ -179,16 +180,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
179 | param["Title"] = title; | 180 | param["Title"] = title; |
180 | param["Powers"] = powers.ToString(); | 181 | param["Powers"] = powers.ToString(); |
181 | 182 | ||
182 | IList parameters = new ArrayList(); | 183 | XmlRpcCall("groups.addRoleToGroup", param); |
183 | parameters.Add(param); | ||
184 | XmlRpcRequest req = new XmlRpcRequest("groups.addRoleToGroup", parameters); | ||
185 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
186 | Hashtable respData = (Hashtable)resp.Value; | ||
187 | |||
188 | if (respData.Contains("error")) | ||
189 | { | ||
190 | LogRespDataToConsoleError(respData); | ||
191 | } | ||
192 | } | 184 | } |
193 | 185 | ||
194 | public void RemoveGroupRole(UUID groupID, UUID roleID) | 186 | public void RemoveGroupRole(UUID groupID, UUID roleID) |
@@ -197,16 +189,8 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
197 | param["GroupID"] = groupID.ToString(); | 189 | param["GroupID"] = groupID.ToString(); |
198 | param["RoleID"] = roleID.ToString(); | 190 | param["RoleID"] = roleID.ToString(); |
199 | 191 | ||
200 | IList parameters = new ArrayList(); | 192 | XmlRpcCall("groups.removeRoleFromGroup", param); |
201 | parameters.Add(param); | ||
202 | XmlRpcRequest req = new XmlRpcRequest("groups.removeRoleFromGroup", parameters); | ||
203 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
204 | Hashtable respData = (Hashtable)resp.Value; | ||
205 | 193 | ||
206 | if (respData.Contains("error")) | ||
207 | { | ||
208 | LogRespDataToConsoleError(respData); | ||
209 | } | ||
210 | } | 194 | } |
211 | 195 | ||
212 | public void UpdateGroupRole(UUID groupID, UUID roleID, string name, string description, string title, ulong powers) | 196 | public void UpdateGroupRole(UUID groupID, UUID roleID, string name, string description, string title, ulong powers) |
@@ -228,16 +212,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
228 | } | 212 | } |
229 | param["Powers"] = powers.ToString(); | 213 | param["Powers"] = powers.ToString(); |
230 | 214 | ||
231 | IList parameters = new ArrayList(); | 215 | XmlRpcCall("groups.updateGroupRole", param); |
232 | parameters.Add(param); | ||
233 | XmlRpcRequest req = new XmlRpcRequest("groups.updateGroupRole", parameters); | ||
234 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
235 | Hashtable respData = (Hashtable)resp.Value; | ||
236 | |||
237 | if (respData.Contains("error")) | ||
238 | { | ||
239 | LogRespDataToConsoleError(respData); | ||
240 | } | ||
241 | } | 216 | } |
242 | 217 | ||
243 | public GroupRecord GetGroupRecord(UUID GroupID, string GroupName) | 218 | public GroupRecord GetGroupRecord(UUID GroupID, string GroupName) |
@@ -253,18 +228,10 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
253 | } | 228 | } |
254 | 229 | ||
255 | 230 | ||
256 | IList parameters = new ArrayList(); | 231 | Hashtable respData = XmlRpcCall("groups.getGroup", param); |
257 | parameters.Add(param); | ||
258 | XmlRpcRequest req = new XmlRpcRequest("groups.getGroup", parameters); | ||
259 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
260 | Hashtable respData = (Hashtable)resp.Value; | ||
261 | 232 | ||
262 | if (respData.Contains("error")) | 233 | if (respData.Contains("error")) |
263 | { | 234 | { |
264 | if ((string)respData["error"] != "Group Not Found") | ||
265 | { | ||
266 | LogRespDataToConsoleError(respData); | ||
267 | } | ||
268 | return null; | 235 | return null; |
269 | } | 236 | } |
270 | 237 | ||
@@ -278,18 +245,11 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
278 | param["GroupID"] = GroupID.ToString(); | 245 | param["GroupID"] = GroupID.ToString(); |
279 | 246 | ||
280 | 247 | ||
281 | IList parameters = new ArrayList(); | 248 | Hashtable respData = XmlRpcCall("groups.getGroup", param); |
282 | parameters.Add(param); | ||
283 | XmlRpcRequest req = new XmlRpcRequest("groups.getGroup", parameters); | ||
284 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
285 | Hashtable respData = (Hashtable)resp.Value; | ||
286 | 249 | ||
287 | if (respData.Contains("error")) | 250 | if (respData.Contains("error")) |
288 | { | 251 | { |
289 | if ((string)respData["error"] != "Group Not Found") | 252 | // GroupProfileData is not nullable |
290 | { | ||
291 | LogRespDataToConsoleError(respData); | ||
292 | } | ||
293 | return new GroupProfileData(); | 253 | return new GroupProfileData(); |
294 | } | 254 | } |
295 | 255 | ||
@@ -333,40 +293,19 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
333 | { | 293 | { |
334 | 294 | ||
335 | GroupRecord group = new GroupRecord(); | 295 | GroupRecord group = new GroupRecord(); |
336 | m_log.Debug("GroupID"); | ||
337 | group.GroupID = UUID.Parse((string)groupProfile["GroupID"]); | 296 | group.GroupID = UUID.Parse((string)groupProfile["GroupID"]); |
338 | |||
339 | m_log.Debug("Name"); | ||
340 | group.GroupName = groupProfile["Name"].ToString(); | 297 | group.GroupName = groupProfile["Name"].ToString(); |
341 | |||
342 | m_log.Debug("Charter"); | ||
343 | if (groupProfile["Charter"] != null) | 298 | if (groupProfile["Charter"] != null) |
344 | { | 299 | { |
345 | group.Charter = (string)groupProfile["Charter"]; | 300 | group.Charter = (string)groupProfile["Charter"]; |
346 | } | 301 | } |
347 | |||
348 | m_log.Debug("ShowInList"); | ||
349 | group.ShowInList = ((string)groupProfile["ShowInList"]) == "1"; | 302 | group.ShowInList = ((string)groupProfile["ShowInList"]) == "1"; |
350 | |||
351 | m_log.Debug("InsigniaID"); | ||
352 | group.GroupPicture = UUID.Parse((string)groupProfile["InsigniaID"]); | 303 | group.GroupPicture = UUID.Parse((string)groupProfile["InsigniaID"]); |
353 | |||
354 | m_log.Debug("MembershipFee"); | ||
355 | group.MembershipFee = int.Parse((string)groupProfile["MembershipFee"]); | 304 | group.MembershipFee = int.Parse((string)groupProfile["MembershipFee"]); |
356 | |||
357 | m_log.Debug("OpenEnrollment"); | ||
358 | group.OpenEnrollment = ((string)groupProfile["OpenEnrollment"]) == "1"; | 305 | group.OpenEnrollment = ((string)groupProfile["OpenEnrollment"]) == "1"; |
359 | |||
360 | m_log.Debug("AllowPublish"); | ||
361 | group.AllowPublish = ((string)groupProfile["AllowPublish"]) == "1"; | 306 | group.AllowPublish = ((string)groupProfile["AllowPublish"]) == "1"; |
362 | |||
363 | m_log.Debug("MaturePublish"); | ||
364 | group.MaturePublish = ((string)groupProfile["MaturePublish"]) == "1"; | 307 | group.MaturePublish = ((string)groupProfile["MaturePublish"]) == "1"; |
365 | |||
366 | m_log.Debug("FounderID"); | ||
367 | group.FounderID = UUID.Parse((string)groupProfile["FounderID"]); | 308 | group.FounderID = UUID.Parse((string)groupProfile["FounderID"]); |
368 | |||
369 | m_log.Debug("OwnerRoleID"); | ||
370 | group.OwnerRoleID = UUID.Parse((string)groupProfile["OwnerRoleID"]); | 309 | group.OwnerRoleID = UUID.Parse((string)groupProfile["OwnerRoleID"]); |
371 | 310 | ||
372 | return group; | 311 | return group; |
@@ -379,17 +318,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
379 | param["AgentID"] = AgentID.ToString(); | 318 | param["AgentID"] = AgentID.ToString(); |
380 | param["GroupID"] = GroupID.ToString(); | 319 | param["GroupID"] = GroupID.ToString(); |
381 | 320 | ||
382 | IList parameters = new ArrayList(); | 321 | XmlRpcCall("groups.setAgentActiveGroup", param); |
383 | parameters.Add(param); | ||
384 | XmlRpcRequest req = new XmlRpcRequest("groups.setAgentActiveGroup", parameters); | ||
385 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
386 | Hashtable respData = (Hashtable)resp.Value; | ||
387 | |||
388 | if (respData.Contains("error")) | ||
389 | { | ||
390 | LogRespDataToConsoleError(respData); | ||
391 | } | ||
392 | |||
393 | } | 322 | } |
394 | 323 | ||
395 | public void SetAgentActiveGroupRole(UUID AgentID, UUID GroupID, UUID RoleID) | 324 | public void SetAgentActiveGroupRole(UUID AgentID, UUID GroupID, UUID RoleID) |
@@ -399,17 +328,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
399 | param["GroupID"] = GroupID.ToString(); | 328 | param["GroupID"] = GroupID.ToString(); |
400 | param["SelectedRoleID"] = RoleID.ToString(); | 329 | param["SelectedRoleID"] = RoleID.ToString(); |
401 | 330 | ||
402 | IList parameters = new ArrayList(); | 331 | XmlRpcCall("groups.setAgentGroupInfo", param); |
403 | parameters.Add(param); | ||
404 | XmlRpcRequest req = new XmlRpcRequest("groups.setAgentGroupInfo", parameters); | ||
405 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
406 | Hashtable respData = (Hashtable)resp.Value; | ||
407 | |||
408 | if (respData.Contains("error")) | ||
409 | { | ||
410 | LogRespDataToConsoleError(respData); | ||
411 | } | ||
412 | |||
413 | } | 332 | } |
414 | 333 | ||
415 | public void SetAgentGroupInfo(UUID AgentID, UUID GroupID, bool AcceptNotices, bool ListInProfile) | 334 | public void SetAgentGroupInfo(UUID AgentID, UUID GroupID, bool AcceptNotices, bool ListInProfile) |
@@ -420,16 +339,8 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
420 | param["AcceptNotices"] = AcceptNotices ? "1" : "0"; | 339 | param["AcceptNotices"] = AcceptNotices ? "1" : "0"; |
421 | param["ListInProfile"] = ListInProfile ? "1" : "0"; | 340 | param["ListInProfile"] = ListInProfile ? "1" : "0"; |
422 | 341 | ||
423 | IList parameters = new ArrayList(); | 342 | XmlRpcCall("groups.setAgentGroupInfo", param); |
424 | parameters.Add(param); | ||
425 | XmlRpcRequest req = new XmlRpcRequest("groups.setAgentGroupInfo", parameters); | ||
426 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
427 | Hashtable respData = (Hashtable)resp.Value; | ||
428 | 343 | ||
429 | if (respData.Contains("error")) | ||
430 | { | ||
431 | LogRespDataToConsoleError(respData); | ||
432 | } | ||
433 | } | 344 | } |
434 | 345 | ||
435 | public void AddAgentToGroupInvite(UUID inviteID, UUID groupID, UUID roleID, UUID agentID) | 346 | public void AddAgentToGroupInvite(UUID inviteID, UUID groupID, UUID roleID, UUID agentID) |
@@ -440,20 +351,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
440 | param["RoleID"] = roleID.ToString(); | 351 | param["RoleID"] = roleID.ToString(); |
441 | param["GroupID"] = groupID.ToString(); | 352 | param["GroupID"] = groupID.ToString(); |
442 | 353 | ||
443 | IList parameters = new ArrayList(); | 354 | XmlRpcCall("groups.addAgentToGroupInvite", param); |
444 | parameters.Add(param); | ||
445 | XmlRpcRequest req = new XmlRpcRequest("groups.addAgentToGroupInvite", parameters); | ||
446 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
447 | Hashtable respData = (Hashtable)resp.Value; | ||
448 | |||
449 | if (respData.Contains("error")) | ||
450 | { | ||
451 | if (respData["error"] != "Duplicate group invite requested") | ||
452 | { | ||
453 | LogRespDataToConsoleError(respData); | ||
454 | } | ||
455 | } | ||
456 | |||
457 | 355 | ||
458 | } | 356 | } |
459 | 357 | ||
@@ -462,17 +360,10 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
462 | Hashtable param = new Hashtable(); | 360 | Hashtable param = new Hashtable(); |
463 | param["InviteID"] = inviteID.ToString(); | 361 | param["InviteID"] = inviteID.ToString(); |
464 | 362 | ||
465 | IList parameters = new ArrayList(); | 363 | Hashtable respData = XmlRpcCall("groups.getAgentToGroupInvite", param); |
466 | parameters.Add(param); | ||
467 | XmlRpcRequest req = new XmlRpcRequest("groups.getAgentToGroupInvite", parameters); | ||
468 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
469 | Hashtable respData = (Hashtable)resp.Value; | ||
470 | |||
471 | 364 | ||
472 | if (respData.Contains("error")) | 365 | if (respData.Contains("error")) |
473 | { | 366 | { |
474 | LogRespDataToConsoleError(respData); | ||
475 | |||
476 | return null; | 367 | return null; |
477 | } | 368 | } |
478 | 369 | ||
@@ -490,16 +381,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
490 | Hashtable param = new Hashtable(); | 381 | Hashtable param = new Hashtable(); |
491 | param["InviteID"] = inviteID.ToString(); | 382 | param["InviteID"] = inviteID.ToString(); |
492 | 383 | ||
493 | IList parameters = new ArrayList(); | 384 | XmlRpcCall("groups.removeAgentToGroupInvite", param); |
494 | parameters.Add(param); | ||
495 | XmlRpcRequest req = new XmlRpcRequest("groups.removeAgentToGroupInvite", parameters); | ||
496 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
497 | Hashtable respData = (Hashtable)resp.Value; | ||
498 | |||
499 | if (respData.Contains("error")) | ||
500 | { | ||
501 | LogRespDataToConsoleError(respData); | ||
502 | } | ||
503 | } | 385 | } |
504 | 386 | ||
505 | public void AddAgentToGroup(UUID AgentID, UUID GroupID, UUID RoleID) | 387 | public void AddAgentToGroup(UUID AgentID, UUID GroupID, UUID RoleID) |
@@ -509,16 +391,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
509 | param["GroupID"] = GroupID.ToString(); | 391 | param["GroupID"] = GroupID.ToString(); |
510 | param["RoleID"] = RoleID.ToString(); | 392 | param["RoleID"] = RoleID.ToString(); |
511 | 393 | ||
512 | IList parameters = new ArrayList(); | 394 | XmlRpcCall("groups.addAgentToGroup", param); |
513 | parameters.Add(param); | ||
514 | XmlRpcRequest req = new XmlRpcRequest("groups.addAgentToGroup", parameters); | ||
515 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
516 | Hashtable respData = (Hashtable)resp.Value; | ||
517 | |||
518 | if (respData.Contains("error")) | ||
519 | { | ||
520 | LogRespDataToConsoleError(respData); | ||
521 | } | ||
522 | } | 395 | } |
523 | 396 | ||
524 | public void RemoveAgentFromGroup(UUID AgentID, UUID GroupID) | 397 | public void RemoveAgentFromGroup(UUID AgentID, UUID GroupID) |
@@ -527,16 +400,8 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
527 | param["AgentID"] = AgentID.ToString(); | 400 | param["AgentID"] = AgentID.ToString(); |
528 | param["GroupID"] = GroupID.ToString(); | 401 | param["GroupID"] = GroupID.ToString(); |
529 | 402 | ||
530 | IList parameters = new ArrayList(); | 403 | XmlRpcCall("groups.removeAgentFromGroup", param); |
531 | parameters.Add(param); | ||
532 | XmlRpcRequest req = new XmlRpcRequest("groups.removeAgentFromGroup", parameters); | ||
533 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
534 | Hashtable respData = (Hashtable)resp.Value; | ||
535 | 404 | ||
536 | if (respData.Contains("error")) | ||
537 | { | ||
538 | LogRespDataToConsoleError(respData); | ||
539 | } | ||
540 | } | 405 | } |
541 | 406 | ||
542 | public void AddAgentToGroupRole(UUID AgentID, UUID GroupID, UUID RoleID) | 407 | public void AddAgentToGroupRole(UUID AgentID, UUID GroupID, UUID RoleID) |
@@ -546,16 +411,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
546 | param["GroupID"] = GroupID.ToString(); | 411 | param["GroupID"] = GroupID.ToString(); |
547 | param["RoleID"] = RoleID.ToString(); | 412 | param["RoleID"] = RoleID.ToString(); |
548 | 413 | ||
549 | IList parameters = new ArrayList(); | 414 | XmlRpcCall("groups.addAgentToGroupRole", param); |
550 | parameters.Add(param); | ||
551 | XmlRpcRequest req = new XmlRpcRequest("groups.addAgentToGroupRole", parameters); | ||
552 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
553 | Hashtable respData = (Hashtable)resp.Value; | ||
554 | |||
555 | if (respData.Contains("error")) | ||
556 | { | ||
557 | LogRespDataToConsoleError(respData); | ||
558 | } | ||
559 | } | 415 | } |
560 | 416 | ||
561 | public void RemoveAgentFromGroupRole(UUID AgentID, UUID GroupID, UUID RoleID) | 417 | public void RemoveAgentFromGroupRole(UUID AgentID, UUID GroupID, UUID RoleID) |
@@ -565,16 +421,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
565 | param["GroupID"] = GroupID.ToString(); | 421 | param["GroupID"] = GroupID.ToString(); |
566 | param["RoleID"] = RoleID.ToString(); | 422 | param["RoleID"] = RoleID.ToString(); |
567 | 423 | ||
568 | IList parameters = new ArrayList(); | 424 | XmlRpcCall("groups.removeAgentFromGroupRole", param); |
569 | parameters.Add(param); | ||
570 | XmlRpcRequest req = new XmlRpcRequest("groups.removeAgentFromGroupRole", parameters); | ||
571 | XmlRpcResponse resp = req.Send(m_serviceURL, 3000); | ||
572 | Hashtable respData = (Hashtable)resp.Value; | ||
573 | |||
574 | if (respData.Contains("error")) | ||
575 | { | ||
576 | LogRespDataToConsoleError(respData); | ||
577 | } | ||
578 | } | 425 | } |
579 | 426 | ||
580 | 427 | ||
@@ -583,22 +430,11 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
583 | Hashtable param = new Hashtable(); | 430 | Hashtable param = new Hashtable(); |
584 | param["Search"] = search; | 431 | param["Search"] = search; |
585 | 432 | ||
586 | IList parameters = new ArrayList(); | 433 | Hashtable respData = XmlRpcCall("groups.findGroups", param); |
587 | parameters.Add(param); | ||
588 | XmlRpcRequest req = new XmlRpcRequest("groups.findGroups", parameters); | ||
589 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | ||
590 | Hashtable respData = (Hashtable)resp.Value; | ||
591 | 434 | ||
592 | List<DirGroupsReplyData> findings = new List<DirGroupsReplyData>(); | 435 | List<DirGroupsReplyData> findings = new List<DirGroupsReplyData>(); |
593 | 436 | ||
594 | if (respData.Contains("error")) | 437 | if (!respData.Contains("error")) |
595 | { | ||
596 | if (respData["error"].ToString() != "No groups found.") | ||
597 | { | ||
598 | LogRespDataToConsoleError(respData); | ||
599 | } | ||
600 | } | ||
601 | else | ||
602 | { | 438 | { |
603 | Hashtable results = (Hashtable)respData["results"]; | 439 | Hashtable results = (Hashtable)respData["results"]; |
604 | foreach (Hashtable groupFind in results.Values) | 440 | foreach (Hashtable groupFind in results.Values) |
@@ -622,18 +458,10 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
622 | param["AgentID"] = AgentID.ToString(); | 458 | param["AgentID"] = AgentID.ToString(); |
623 | param["GroupID"] = GroupID.ToString(); | 459 | param["GroupID"] = GroupID.ToString(); |
624 | 460 | ||
625 | IList parameters = new ArrayList(); | 461 | Hashtable respData = XmlRpcCall("groups.getAgentGroupMembership", param); |
626 | parameters.Add(param); | ||
627 | XmlRpcRequest req = new XmlRpcRequest("groups.getAgentGroupMembership", parameters); | ||
628 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | ||
629 | Hashtable respData = (Hashtable)resp.Value; | ||
630 | 462 | ||
631 | if (respData.Contains("error")) | 463 | if (respData.Contains("error")) |
632 | { | 464 | { |
633 | if ((string)respData["error"] != "None Found") | ||
634 | { | ||
635 | LogRespDataToConsoleError(respData); | ||
636 | } | ||
637 | return null; | 465 | return null; |
638 | } | 466 | } |
639 | 467 | ||
@@ -647,74 +475,27 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
647 | Hashtable param = new Hashtable(); | 475 | Hashtable param = new Hashtable(); |
648 | param["AgentID"] = AgentID.ToString(); | 476 | param["AgentID"] = AgentID.ToString(); |
649 | 477 | ||
650 | IList parameters = new ArrayList(); | 478 | Hashtable respData = XmlRpcCall("groups.getAgentActiveMembership", param); |
651 | parameters.Add(param); | ||
652 | XmlRpcRequest req = new XmlRpcRequest("groups.getAgentActiveMembership", parameters); | ||
653 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | ||
654 | Hashtable respData = (Hashtable)resp.Value; | ||
655 | 479 | ||
656 | if (respData.Contains("error")) | 480 | if (respData.Contains("error")) |
657 | { | 481 | { |
658 | if (respData["error"].ToString() == "No Active Group Specified") | ||
659 | { | ||
660 | return null; | 482 | return null; |
661 | } | 483 | } |
662 | LogRespDataToConsoleError(respData); | ||
663 | return null; | ||
664 | } | ||
665 | 484 | ||
666 | try | 485 | return HashTableToGroupMembershipData(respData); |
667 | { | ||
668 | GroupMembershipData data = HashTableToGroupMembershipData(respData); | ||
669 | return data; | ||
670 | } | ||
671 | catch (System.Exception e) | ||
672 | { | ||
673 | LogRespDataToConsoleError(respData); | ||
674 | throw e; | ||
675 | } | ||
676 | } | ||
677 | |||
678 | private void LogRespDataToConsoleError(Hashtable respData) | ||
679 | { | ||
680 | m_log.Error("[GROUPDATA] Error:"); | ||
681 | |||
682 | foreach (string key in respData.Keys) | ||
683 | { | ||
684 | m_log.ErrorFormat("[GROUPDATA] Key: {0}", key); | ||
685 | |||
686 | object o = respData[key]; | ||
687 | |||
688 | string[] lines = respData[key].ToString().Split(new char[] { '\n' }); | ||
689 | foreach (string line in lines) | ||
690 | { | ||
691 | m_log.ErrorFormat("[GROUPDATA] {0}", line); | ||
692 | } | 486 | } |
693 | 487 | ||
694 | } | ||
695 | } | ||
696 | 488 | ||
697 | public List<GroupMembershipData> GetAgentGroupMemberships(UUID AgentID) | 489 | public List<GroupMembershipData> GetAgentGroupMemberships(UUID AgentID) |
698 | { | 490 | { |
699 | Hashtable param = new Hashtable(); | 491 | Hashtable param = new Hashtable(); |
700 | param["AgentID"] = AgentID.ToString(); | 492 | param["AgentID"] = AgentID.ToString(); |
701 | 493 | ||
702 | IList parameters = new ArrayList(); | 494 | Hashtable respData = XmlRpcCall("groups.getAgentGroupMemberships", param); |
703 | parameters.Add(param); | ||
704 | XmlRpcRequest req = new XmlRpcRequest("groups.getAgentGroupMemberships", parameters); | ||
705 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | ||
706 | Hashtable respData = (Hashtable)resp.Value; | ||
707 | 495 | ||
708 | List<GroupMembershipData> memberships = new List<GroupMembershipData>(); | 496 | List<GroupMembershipData> memberships = new List<GroupMembershipData>(); |
709 | 497 | ||
710 | if (respData.Contains("error")) | 498 | if (!respData.Contains("error")) |
711 | { | ||
712 | if (respData["error"].ToString() != "No Memberships") | ||
713 | { | ||
714 | LogRespDataToConsoleError(respData); | ||
715 | } | ||
716 | } | ||
717 | else | ||
718 | { | 499 | { |
719 | foreach (object membership in respData.Values) | 500 | foreach (object membership in respData.Values) |
720 | { | 501 | { |
@@ -730,20 +511,12 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
730 | param["AgentID"] = AgentID.ToString(); | 511 | param["AgentID"] = AgentID.ToString(); |
731 | param["GroupID"] = GroupID.ToString(); | 512 | param["GroupID"] = GroupID.ToString(); |
732 | 513 | ||
733 | IList parameters = new ArrayList(); | 514 | Hashtable respData = XmlRpcCall("groups.getAgentRoles", param); |
734 | parameters.Add(param); | ||
735 | XmlRpcRequest req = new XmlRpcRequest("groups.getAgentRoles", parameters); | ||
736 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | ||
737 | Hashtable respData = (Hashtable)resp.Value; | ||
738 | 515 | ||
739 | List<GroupRolesData> Roles = new List<GroupRolesData>(); | 516 | List<GroupRolesData> Roles = new List<GroupRolesData>(); |
740 | 517 | ||
741 | if (respData.Contains("error")) | 518 | if (respData.Contains("error")) |
742 | { | 519 | { |
743 | if ((string)respData["error"] != "None found") | ||
744 | { | ||
745 | LogRespDataToConsoleError(respData); | ||
746 | } | ||
747 | return Roles; | 520 | return Roles; |
748 | } | 521 | } |
749 | 522 | ||
@@ -769,19 +542,15 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
769 | Hashtable param = new Hashtable(); | 542 | Hashtable param = new Hashtable(); |
770 | param["GroupID"] = GroupID.ToString(); | 543 | param["GroupID"] = GroupID.ToString(); |
771 | 544 | ||
772 | IList parameters = new ArrayList(); | 545 | Hashtable respData = XmlRpcCall("groups.getGroupRoles", param); |
773 | parameters.Add(param); | 546 | |
774 | XmlRpcRequest req = new XmlRpcRequest("groups.getGroupRoles", parameters); | 547 | List<GroupRolesData> Roles = new List<GroupRolesData>(); |
775 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | ||
776 | Hashtable respData = (Hashtable)resp.Value; | ||
777 | 548 | ||
778 | if (respData.Contains("error")) | 549 | if (respData.Contains("error")) |
779 | { | 550 | { |
780 | LogRespDataToConsoleError(respData); | 551 | return Roles; |
781 | return null; | ||
782 | } | 552 | } |
783 | 553 | ||
784 | List<GroupRolesData> Roles = new List<GroupRolesData>(); | ||
785 | foreach (Hashtable role in respData.Values) | 554 | foreach (Hashtable role in respData.Values) |
786 | { | 555 | { |
787 | GroupRolesData data = new GroupRolesData(); | 556 | GroupRolesData data = new GroupRolesData(); |
@@ -819,7 +588,10 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
819 | data.Active = data.GroupID.Equals(ActiveGroup); | 588 | data.Active = data.GroupID.Equals(ActiveGroup); |
820 | 589 | ||
821 | data.AllowPublish = ((string)respData["AllowPublish"] == "1"); | 590 | data.AllowPublish = ((string)respData["AllowPublish"] == "1"); |
591 | if (respData["Charter"] != null) | ||
592 | { | ||
822 | data.Charter = (string)respData["Charter"]; | 593 | data.Charter = (string)respData["Charter"]; |
594 | } | ||
823 | data.FounderID = new UUID((string)respData["FounderID"]); | 595 | data.FounderID = new UUID((string)respData["FounderID"]); |
824 | data.GroupID = new UUID((string)respData["GroupID"]); | 596 | data.GroupID = new UUID((string)respData["GroupID"]); |
825 | data.GroupName = (string)respData["GroupName"]; | 597 | data.GroupName = (string)respData["GroupName"]; |
@@ -836,19 +608,15 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
836 | Hashtable param = new Hashtable(); | 608 | Hashtable param = new Hashtable(); |
837 | param["GroupID"] = GroupID.ToString(); | 609 | param["GroupID"] = GroupID.ToString(); |
838 | 610 | ||
839 | IList parameters = new ArrayList(); | 611 | Hashtable respData = XmlRpcCall("groups.getGroupMembers", param); |
840 | parameters.Add(param); | 612 | |
841 | XmlRpcRequest req = new XmlRpcRequest("groups.getGroupMembers", parameters); | 613 | List<GroupMembersData> members = new List<GroupMembersData>(); |
842 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | ||
843 | Hashtable respData = (Hashtable)resp.Value; | ||
844 | 614 | ||
845 | if (respData.Contains("error")) | 615 | if (respData.Contains("error")) |
846 | { | 616 | { |
847 | LogRespDataToConsoleError(respData); | 617 | return members; |
848 | return null; | ||
849 | } | 618 | } |
850 | 619 | ||
851 | List<GroupMembersData> members = new List<GroupMembersData>(); | ||
852 | foreach (Hashtable membership in respData.Values) | 620 | foreach (Hashtable membership in respData.Values) |
853 | { | 621 | { |
854 | GroupMembersData data = new GroupMembersData(); | 622 | GroupMembersData data = new GroupMembersData(); |
@@ -873,19 +641,12 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
873 | Hashtable param = new Hashtable(); | 641 | Hashtable param = new Hashtable(); |
874 | param["GroupID"] = GroupID.ToString(); | 642 | param["GroupID"] = GroupID.ToString(); |
875 | 643 | ||
876 | IList parameters = new ArrayList(); | 644 | Hashtable respData = XmlRpcCall("groups.getGroupRoleMembers", param); |
877 | parameters.Add(param); | ||
878 | XmlRpcRequest req = new XmlRpcRequest("groups.getGroupRoleMembers", parameters); | ||
879 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | ||
880 | Hashtable respData = (Hashtable)resp.Value; | ||
881 | |||
882 | if (respData.Contains("error")) | ||
883 | { | ||
884 | LogRespDataToConsoleError(respData); | ||
885 | return null; | ||
886 | } | ||
887 | 645 | ||
888 | List<GroupRoleMembersData> members = new List<GroupRoleMembersData>(); | 646 | List<GroupRoleMembersData> members = new List<GroupRoleMembersData>(); |
647 | |||
648 | if (!respData.Contains("error")) | ||
649 | { | ||
889 | foreach (Hashtable membership in respData.Values) | 650 | foreach (Hashtable membership in respData.Values) |
890 | { | 651 | { |
891 | GroupRoleMembersData data = new GroupRoleMembersData(); | 652 | GroupRoleMembersData data = new GroupRoleMembersData(); |
@@ -895,7 +656,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
895 | 656 | ||
896 | members.Add(data); | 657 | members.Add(data); |
897 | } | 658 | } |
898 | 659 | } | |
899 | return members; | 660 | return members; |
900 | } | 661 | } |
901 | 662 | ||
@@ -904,22 +665,11 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
904 | Hashtable param = new Hashtable(); | 665 | Hashtable param = new Hashtable(); |
905 | param["GroupID"] = GroupID.ToString(); | 666 | param["GroupID"] = GroupID.ToString(); |
906 | 667 | ||
907 | IList parameters = new ArrayList(); | 668 | Hashtable respData = XmlRpcCall("groups.getGroupNotices", param); |
908 | parameters.Add(param); | ||
909 | XmlRpcRequest req = new XmlRpcRequest("groups.getGroupNotices", parameters); | ||
910 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | ||
911 | Hashtable respData = (Hashtable)resp.Value; | ||
912 | 669 | ||
913 | List<GroupNoticeData> values = new List<GroupNoticeData>(); | 670 | List<GroupNoticeData> values = new List<GroupNoticeData>(); |
914 | 671 | ||
915 | if (respData.Contains("error")) | 672 | if (!respData.Contains("error")) |
916 | { | ||
917 | if ((string)respData["error"] != "No Notices") | ||
918 | { | ||
919 | LogRespDataToConsoleError(respData); | ||
920 | } | ||
921 | } | ||
922 | else | ||
923 | { | 673 | { |
924 | foreach (Hashtable value in respData.Values) | 674 | foreach (Hashtable value in respData.Values) |
925 | { | 675 | { |
@@ -942,22 +692,13 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
942 | Hashtable param = new Hashtable(); | 692 | Hashtable param = new Hashtable(); |
943 | param["NoticeID"] = noticeID.ToString(); | 693 | param["NoticeID"] = noticeID.ToString(); |
944 | 694 | ||
945 | IList parameters = new ArrayList(); | 695 | Hashtable respData = XmlRpcCall("groups.getGroupNotice", param); |
946 | parameters.Add(param); | ||
947 | XmlRpcRequest req = new XmlRpcRequest("groups.getGroupNotice", parameters); | ||
948 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | ||
949 | Hashtable respData = (Hashtable)resp.Value; | ||
950 | |||
951 | 696 | ||
952 | 697 | ||
953 | if (respData.Contains("error")) | 698 | if (!respData.Contains("error")) |
954 | { | 699 | { |
955 | if ((string)respData["error"] != "Group Notice Not Found") | ||
956 | { | ||
957 | LogRespDataToConsoleError(respData); | ||
958 | return null; | 700 | return null; |
959 | } | 701 | } |
960 | } | ||
961 | 702 | ||
962 | GroupNoticeInfo data = new GroupNoticeInfo(); | 703 | GroupNoticeInfo data = new GroupNoticeInfo(); |
963 | data.GroupID = UUID.Parse((string)respData["GroupID"]); | 704 | data.GroupID = UUID.Parse((string)respData["GroupID"]); |
@@ -990,20 +731,78 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
990 | param["BinaryBucket"] = binBucket; | 731 | param["BinaryBucket"] = binBucket; |
991 | param["TimeStamp"] = ((uint)Util.UnixTimeSinceEpoch()).ToString(); | 732 | param["TimeStamp"] = ((uint)Util.UnixTimeSinceEpoch()).ToString(); |
992 | 733 | ||
734 | XmlRpcCall("groups.addGroupNotice", param); | ||
735 | } | ||
736 | |||
737 | private Hashtable XmlRpcCall(string function, Hashtable param) | ||
738 | { | ||
993 | IList parameters = new ArrayList(); | 739 | IList parameters = new ArrayList(); |
994 | parameters.Add(param); | 740 | parameters.Add(param); |
995 | XmlRpcRequest req = new XmlRpcRequest("groups.addGroupNotice", parameters); | 741 | |
742 | XmlRpcRequest req; | ||
743 | if (!m_disableKeepAlive) | ||
744 | { | ||
745 | req = new XmlRpcRequest(function, parameters); | ||
746 | } | ||
747 | else | ||
748 | { | ||
749 | // This seems to solve a major problem on some windows servers | ||
750 | req = new NoKeepAliveXmlRpcRequest(function, parameters); | ||
751 | } | ||
752 | |||
996 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); | 753 | XmlRpcResponse resp = req.Send(m_serviceURL, 10000); |
997 | Hashtable respData = (Hashtable)resp.Value; | ||
998 | 754 | ||
999 | List<GroupNoticeData> values = new List<GroupNoticeData>(); | 755 | if( resp.Value is Hashtable ) |
756 | { | ||
757 | Hashtable respData = (Hashtable)resp.Value; | ||
758 | if (respData.Contains("error") && !respData.Contains("succeed")) | ||
759 | { | ||
760 | LogRespDataToConsoleError(respData); | ||
761 | } | ||
1000 | 762 | ||
1001 | if (respData.Contains("error")) | 763 | return respData; |
764 | } | ||
765 | |||
766 | m_log.ErrorFormat("[XmlRpcGroupData] The XmlRpc server returned a {1} instead of a hashtable for {0}", function, resp.Value.GetType().ToString()); | ||
767 | |||
768 | if (resp.Value is ArrayList) | ||
1002 | { | 769 | { |
1003 | LogRespDataToConsoleError(respData); | 770 | ArrayList al = (ArrayList)resp.Value; |
771 | m_log.ErrorFormat("[XmlRpcGroupData] Contains {0} elements", al.Count); | ||
772 | |||
773 | foreach (object o in al) | ||
774 | { | ||
775 | m_log.ErrorFormat("[XmlRpcGroupData] {0} :: {1}", o.GetType().ToString(), o.ToString()); | ||
776 | } | ||
1004 | } | 777 | } |
778 | else | ||
779 | { | ||
780 | m_log.ErrorFormat("[XmlRpcGroupData] Function returned: {0}", resp.Value.ToString()); | ||
781 | } | ||
782 | |||
783 | Hashtable error = new Hashtable(); | ||
784 | error.Add("error", "invalid return value"); | ||
785 | return error; | ||
786 | } | ||
787 | |||
788 | private void LogRespDataToConsoleError(Hashtable respData) | ||
789 | { | ||
790 | m_log.Error("[GROUPDATA] Error:"); | ||
791 | |||
792 | foreach (string key in respData.Keys) | ||
793 | { | ||
794 | m_log.ErrorFormat("[GROUPDATA] Key: {0}", key); | ||
795 | |||
796 | object o = respData[key]; | ||
797 | |||
798 | string[] lines = respData[key].ToString().Split(new char[] { '\n' }); | ||
799 | foreach (string line in lines) | ||
800 | { | ||
801 | m_log.ErrorFormat("[GROUPDATA] {0}", line); | ||
1005 | } | 802 | } |
1006 | 803 | ||
804 | } | ||
805 | } | ||
1007 | 806 | ||
1008 | } | 807 | } |
1009 | 808 | ||
@@ -1015,3 +814,61 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
1015 | public byte[] BinaryBucket = new byte[0]; | 814 | public byte[] BinaryBucket = new byte[0]; |
1016 | } | 815 | } |
1017 | } | 816 | } |
817 | |||
818 | namespace Nwc.XmlRpc | ||
819 | { | ||
820 | using System; | ||
821 | using System.Collections; | ||
822 | using System.IO; | ||
823 | using System.Xml; | ||
824 | using System.Net; | ||
825 | using System.Text; | ||
826 | using System.Reflection; | ||
827 | |||
828 | /// <summary>Class supporting the request side of an XML-RPC transaction.</summary> | ||
829 | public class NoKeepAliveXmlRpcRequest : XmlRpcRequest | ||
830 | { | ||
831 | private Encoding _encoding = new ASCIIEncoding(); | ||
832 | private XmlRpcRequestSerializer _serializer = new XmlRpcRequestSerializer(); | ||
833 | private XmlRpcResponseDeserializer _deserializer = new XmlRpcResponseDeserializer(); | ||
834 | |||
835 | /// <summary>Instantiate an <c>XmlRpcRequest</c> for a specified method and parameters.</summary> | ||
836 | /// <param name="methodName"><c>String</c> designating the <i>object.method</i> on the server the request | ||
837 | /// should be directed to.</param> | ||
838 | /// <param name="parameters"><c>ArrayList</c> of XML-RPC type parameters to invoke the request with.</param> | ||
839 | public NoKeepAliveXmlRpcRequest(String methodName, IList parameters) | ||
840 | { | ||
841 | MethodName = methodName; | ||
842 | _params = parameters; | ||
843 | } | ||
844 | |||
845 | /// <summary>Send the request to the server.</summary> | ||
846 | /// <param name="url"><c>String</c> The url of the XML-RPC server.</param> | ||
847 | /// <returns><c>XmlRpcResponse</c> The response generated.</returns> | ||
848 | public XmlRpcResponse Send(String url) | ||
849 | { | ||
850 | HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url); | ||
851 | if (request == null) | ||
852 | throw new XmlRpcException(XmlRpcErrorCodes.TRANSPORT_ERROR, | ||
853 | XmlRpcErrorCodes.TRANSPORT_ERROR_MSG + ": Could not create request with " + url); | ||
854 | request.Method = "POST"; | ||
855 | request.ContentType = "text/xml"; | ||
856 | request.AllowWriteStreamBuffering = true; | ||
857 | request.KeepAlive = false; | ||
858 | |||
859 | Stream stream = request.GetRequestStream(); | ||
860 | XmlTextWriter xml = new XmlTextWriter(stream, _encoding); | ||
861 | _serializer.Serialize(xml, this); | ||
862 | xml.Flush(); | ||
863 | xml.Close(); | ||
864 | |||
865 | HttpWebResponse response = (HttpWebResponse)request.GetResponse(); | ||
866 | StreamReader input = new StreamReader(response.GetResponseStream()); | ||
867 | |||
868 | XmlRpcResponse resp = (XmlRpcResponse)_deserializer.Deserialize(input); | ||
869 | input.Close(); | ||
870 | response.Close(); | ||
871 | return resp; | ||
872 | } | ||
873 | } | ||
874 | } | ||
diff --git a/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupsMessaging.cs b/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupsMessaging.cs index 10561a6..34af325 100644 --- a/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupsMessaging.cs +++ b/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupsMessaging.cs | |||
@@ -212,6 +212,8 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
212 | // Incoming message from a group | 212 | // Incoming message from a group |
213 | if ((msg.dialog == (byte)InstantMessageDialog.SessionSend) && (msg.fromGroup == true)) | 213 | if ((msg.dialog == (byte)InstantMessageDialog.SessionSend) && (msg.fromGroup == true)) |
214 | { | 214 | { |
215 | if (m_debugEnabled) m_log.InfoFormat("[GROUPS-MESSAGING] OnGridInstantMessage from group session {0} going to agent {1}", msg.fromAgentID, msg.toAgentID); | ||
216 | |||
215 | if (m_ActiveClients.ContainsKey(msg.toAgentID)) | 217 | if (m_ActiveClients.ContainsKey(msg.toAgentID)) |
216 | { | 218 | { |
217 | UUID GroupID = new UUID(msg.fromAgentID); | 219 | UUID GroupID = new UUID(msg.fromAgentID); |
@@ -220,6 +222,7 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
220 | GroupRecord GroupInfo = m_GroupsModule.GetGroupRecord(GroupID); | 222 | GroupRecord GroupInfo = m_GroupsModule.GetGroupRecord(GroupID); |
221 | if (GroupInfo != null) | 223 | if (GroupInfo != null) |
222 | { | 224 | { |
225 | // TODO: Check to see if already a member of session, if so, do not send chatterbox, just forward message | ||
223 | 226 | ||
224 | if (m_debugEnabled) m_log.InfoFormat("[GROUPS-MESSAGING] Sending chatterbox invite instant message"); | 227 | if (m_debugEnabled) m_log.InfoFormat("[GROUPS-MESSAGING] Sending chatterbox invite instant message"); |
225 | 228 | ||
diff --git a/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupsModule.cs b/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupsModule.cs index a6f9ea1..ec26dff 100644 --- a/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupsModule.cs +++ b/OpenSim/Region/OptionalModules/Avatar/XmlRpcGroups/XmlRpcGroupsModule.cs | |||
@@ -53,14 +53,21 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
53 | public class XmlRpcGroupsModule : INonSharedRegionModule, IGroupsModule | 53 | public class XmlRpcGroupsModule : INonSharedRegionModule, IGroupsModule |
54 | { | 54 | { |
55 | /// <summary> | 55 | /// <summary> |
56 | /// To use this module, you must specify the following in your OpenSim.ini | 56 | /// ; To use this module, you must specify the following in your OpenSim.ini |
57 | /// [GROUPS] | 57 | /// [GROUPS] |
58 | /// Enabled = true | 58 | /// Enabled = true |
59 | /// Module = XmlRpcGroups | 59 | /// Module = XmlRpcGroups |
60 | /// XmlRpcServiceURL = http://osflotsam.org/xmlrpc.php | ||
60 | /// XmlRpcMessagingEnabled = true | 61 | /// XmlRpcMessagingEnabled = true |
61 | /// XmlRpcNoticesEnabled = true | 62 | /// XmlRpcNoticesEnabled = true |
62 | /// XmlRpcDebugEnabled = true | 63 | /// XmlRpcDebugEnabled = true |
63 | /// | 64 | /// |
65 | /// ; Disables HTTP Keep-Alive for Groups Module HTTP Requests, work around for | ||
66 | /// ; a problem discovered on some Windows based region servers. Only disable | ||
67 | /// ; if you see a large number (dozens) of the following Exceptions: | ||
68 | /// ; System.Net.WebException: The request was aborted: The request was canceled. | ||
69 | /// | ||
70 | /// XmlRpcDisableKeepAlive = false | ||
64 | /// </summary> | 71 | /// </summary> |
65 | 72 | ||
66 | private static readonly ILog m_log = | 73 | private static readonly ILog m_log = |
@@ -113,7 +120,9 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
113 | } | 120 | } |
114 | 121 | ||
115 | string ServiceURL = groupsConfig.GetString("XmlRpcServiceURL", m_defaultXmlRpcServiceURL); | 122 | string ServiceURL = groupsConfig.GetString("XmlRpcServiceURL", m_defaultXmlRpcServiceURL); |
116 | m_groupData = new XmlRpcGroupDataProvider(ServiceURL); | 123 | bool DisableKeepAlive = groupsConfig.GetBoolean("XmlRpcDisableKeepAlive", false); |
124 | |||
125 | m_groupData = new XmlRpcGroupDataProvider(ServiceURL, DisableKeepAlive); | ||
117 | m_log.InfoFormat("[GROUPS]: XmlRpc Service URL set to: {0}", ServiceURL); | 126 | m_log.InfoFormat("[GROUPS]: XmlRpc Service URL set to: {0}", ServiceURL); |
118 | 127 | ||
119 | m_GroupNoticesEnabled = groupsConfig.GetBoolean("XmlRpcNoticesEnabled", true); | 128 | m_GroupNoticesEnabled = groupsConfig.GetBoolean("XmlRpcNoticesEnabled", true); |
@@ -496,6 +505,24 @@ namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups | |||
496 | 505 | ||
497 | // Trigger the above event handler | 506 | // Trigger the above event handler |
498 | OnInstantMessage(null, msg); | 507 | OnInstantMessage(null, msg); |
508 | |||
509 | |||
510 | // If a message from a group arrives here, it may need to be forwarded to a local client | ||
511 | if (msg.fromGroup == true) | ||
512 | { | ||
513 | switch( msg.dialog ) | ||
514 | { | ||
515 | case (byte)InstantMessageDialog.GroupInvitation: | ||
516 | case (byte)InstantMessageDialog.GroupNotice: | ||
517 | UUID toAgentID = new UUID(msg.toAgentID); | ||
518 | if (m_ActiveClients.ContainsKey(toAgentID)) | ||
519 | { | ||
520 | m_ActiveClients[toAgentID].SendInstantMessage(msg); | ||
521 | } | ||
522 | break; | ||
523 | } | ||
524 | } | ||
525 | |||
499 | } | 526 | } |
500 | 527 | ||
501 | 528 | ||