diff options
author | Diva Canto | 2010-05-08 07:44:07 -0700 |
---|---|---|
committer | Diva Canto | 2010-05-08 07:44:07 -0700 |
commit | d72769930aebb14ae4bfee9803adb13fbb44eb8b (patch) | |
tree | 32e9a36cab73a8ddb3528d50281c261815c44658 /OpenSim/Region/CoreModules | |
parent | test commit for panda (diff) | |
download | opensim-SC-d72769930aebb14ae4bfee9803adb13fbb44eb8b.zip opensim-SC-d72769930aebb14ae4bfee9803adb13fbb44eb8b.tar.gz opensim-SC-d72769930aebb14ae4bfee9803adb13fbb44eb8b.tar.bz2 opensim-SC-d72769930aebb14ae4bfee9803adb13fbb44eb8b.tar.xz |
More cleaning on presence. Friends online/offline works again.
Diffstat (limited to 'OpenSim/Region/CoreModules')
3 files changed, 89 insertions, 98 deletions
diff --git a/OpenSim/Region/CoreModules/Avatar/Friends/FriendsModule.cs b/OpenSim/Region/CoreModules/Avatar/Friends/FriendsModule.cs index febd4ca..0c81f44 100644 --- a/OpenSim/Region/CoreModules/Avatar/Friends/FriendsModule.cs +++ b/OpenSim/Region/CoreModules/Avatar/Friends/FriendsModule.cs | |||
@@ -345,8 +345,10 @@ namespace OpenSim.Region.CoreModules.Avatar.Friends | |||
345 | UserAccount account = m_Scenes[0].UserAccountService.GetUserAccount(client.Scene.RegionInfo.ScopeID, new UUID(im.fromAgentID)); | 345 | UserAccount account = m_Scenes[0].UserAccountService.GetUserAccount(client.Scene.RegionInfo.ScopeID, new UUID(im.fromAgentID)); |
346 | im.fromAgentName = account.FirstName + " " + account.LastName; | 346 | im.fromAgentName = account.FirstName + " " + account.LastName; |
347 | 347 | ||
348 | PresenceInfo presence = null; | ||
348 | PresenceInfo[] presences = PresenceService.GetAgents(new string[] { fid }); | 349 | PresenceInfo[] presences = PresenceService.GetAgents(new string[] { fid }); |
349 | PresenceInfo presence = PresenceInfo.GetOnlinePresence(presences); | 350 | if (presences != null && presences.Length > 0) |
351 | presence = presences[0]; | ||
350 | if (presence != null) | 352 | if (presence != null) |
351 | im.offline = 0; | 353 | im.offline = 0; |
352 | 354 | ||
@@ -380,13 +382,8 @@ namespace OpenSim.Region.CoreModules.Avatar.Friends | |||
380 | PresenceInfo[] presence = PresenceService.GetAgents(friendList.ToArray()); | 382 | PresenceInfo[] presence = PresenceService.GetAgents(friendList.ToArray()); |
381 | 383 | ||
382 | foreach (PresenceInfo pi in presence) | 384 | foreach (PresenceInfo pi in presence) |
383 | { | 385 | online.Add(new UUID(pi.UserID)); |
384 | if (pi.Online) | 386 | //m_log.DebugFormat("[XXX] {0} friend online {1}", userID, pi.UserID); |
385 | { | ||
386 | online.Add(new UUID(pi.UserID)); | ||
387 | //m_log.DebugFormat("[XXX] {0} friend online {1}", userID, pi.UserID); | ||
388 | } | ||
389 | } | ||
390 | 387 | ||
391 | return online; | 388 | return online; |
392 | } | 389 | } |
@@ -462,11 +459,14 @@ namespace OpenSim.Region.CoreModules.Avatar.Friends | |||
462 | 459 | ||
463 | // The friend is not here [as root]. Let's forward. | 460 | // The friend is not here [as root]. Let's forward. |
464 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { friendID.ToString() }); | 461 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { friendID.ToString() }); |
465 | PresenceInfo friendSession = PresenceInfo.GetOnlinePresence(friendSessions); | 462 | if (friendSessions != null && friendSessions.Length > 0) |
466 | if (friendSession != null) | ||
467 | { | 463 | { |
468 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | 464 | PresenceInfo friendSession = friendSessions[0]; |
469 | m_FriendsSimConnector.StatusNotify(region, userID, friendID, online); | 465 | if (friendSession != null) |
466 | { | ||
467 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | ||
468 | m_FriendsSimConnector.StatusNotify(region, userID, friendID, online); | ||
469 | } | ||
470 | } | 470 | } |
471 | 471 | ||
472 | // Friend is not online. Ignore. | 472 | // Friend is not online. Ignore. |
@@ -504,13 +504,15 @@ namespace OpenSim.Region.CoreModules.Avatar.Friends | |||
504 | 504 | ||
505 | // The prospective friend is not here [as root]. Let's forward. | 505 | // The prospective friend is not here [as root]. Let's forward. |
506 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { friendID.ToString() }); | 506 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { friendID.ToString() }); |
507 | PresenceInfo friendSession = PresenceInfo.GetOnlinePresence(friendSessions); | 507 | if (friendSessions != null && friendSessions.Length > 0) |
508 | if (friendSession != null) | ||
509 | { | 508 | { |
510 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | 509 | PresenceInfo friendSession = friendSessions[0]; |
511 | m_FriendsSimConnector.FriendshipOffered(region, agentID, friendID, im.message); | 510 | if (friendSession != null) |
511 | { | ||
512 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | ||
513 | m_FriendsSimConnector.FriendshipOffered(region, agentID, friendID, im.message); | ||
514 | } | ||
512 | } | 515 | } |
513 | |||
514 | // If the prospective friend is not online, he'll get the message upon login. | 516 | // If the prospective friend is not online, he'll get the message upon login. |
515 | } | 517 | } |
516 | 518 | ||
@@ -536,14 +538,16 @@ namespace OpenSim.Region.CoreModules.Avatar.Friends | |||
536 | 538 | ||
537 | // The friend is not here | 539 | // The friend is not here |
538 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { friendID.ToString() }); | 540 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { friendID.ToString() }); |
539 | PresenceInfo friendSession = PresenceInfo.GetOnlinePresence(friendSessions); | 541 | if (friendSessions != null && friendSessions.Length > 0) |
540 | if (friendSession != null) | ||
541 | { | 542 | { |
542 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | 543 | PresenceInfo friendSession = friendSessions[0]; |
543 | m_FriendsSimConnector.FriendshipApproved(region, agentID, client.Name, friendID); | 544 | if (friendSession != null) |
544 | client.SendAgentOnline(new UUID[] { friendID }); | 545 | { |
546 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | ||
547 | m_FriendsSimConnector.FriendshipApproved(region, agentID, client.Name, friendID); | ||
548 | client.SendAgentOnline(new UUID[] { friendID }); | ||
549 | } | ||
545 | } | 550 | } |
546 | |||
547 | } | 551 | } |
548 | 552 | ||
549 | private void OnDenyFriendRequest(IClientAPI client, UUID agentID, UUID friendID, List<UUID> callingCardFolders) | 553 | private void OnDenyFriendRequest(IClientAPI client, UUID agentID, UUID friendID, List<UUID> callingCardFolders) |
@@ -562,11 +566,14 @@ namespace OpenSim.Region.CoreModules.Avatar.Friends | |||
562 | return; | 566 | return; |
563 | 567 | ||
564 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { friendID.ToString() }); | 568 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { friendID.ToString() }); |
565 | PresenceInfo friendSession = PresenceInfo.GetOnlinePresence(friendSessions); | 569 | if (friendSessions != null && friendSessions.Length > 0) |
566 | if (friendSession != null) | ||
567 | { | 570 | { |
568 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | 571 | PresenceInfo friendSession = friendSessions[0]; |
569 | m_FriendsSimConnector.FriendshipDenied(region, agentID, client.Name, friendID); | 572 | if (friendSession != null) |
573 | { | ||
574 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | ||
575 | m_FriendsSimConnector.FriendshipDenied(region, agentID, client.Name, friendID); | ||
576 | } | ||
570 | } | 577 | } |
571 | } | 578 | } |
572 | 579 | ||
@@ -589,11 +596,14 @@ namespace OpenSim.Region.CoreModules.Avatar.Friends | |||
589 | return; | 596 | return; |
590 | 597 | ||
591 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { exfriendID.ToString() }); | 598 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { exfriendID.ToString() }); |
592 | PresenceInfo friendSession = PresenceInfo.GetOnlinePresence(friendSessions); | 599 | if (friendSessions != null && friendSessions.Length > 0) |
593 | if (friendSession != null) | ||
594 | { | 600 | { |
595 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | 601 | PresenceInfo friendSession = friendSessions[0]; |
596 | m_FriendsSimConnector.FriendshipTerminated(region, agentID, exfriendID); | 602 | if (friendSession != null) |
603 | { | ||
604 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | ||
605 | m_FriendsSimConnector.FriendshipTerminated(region, agentID, exfriendID); | ||
606 | } | ||
597 | } | 607 | } |
598 | } | 608 | } |
599 | 609 | ||
@@ -631,13 +641,16 @@ namespace OpenSim.Region.CoreModules.Avatar.Friends | |||
631 | return; | 641 | return; |
632 | 642 | ||
633 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { target.ToString() }); | 643 | PresenceInfo[] friendSessions = PresenceService.GetAgents(new string[] { target.ToString() }); |
634 | PresenceInfo friendSession = PresenceInfo.GetOnlinePresence(friendSessions); | 644 | if (friendSessions != null && friendSessions.Length > 0) |
635 | if (friendSession != null) | ||
636 | { | 645 | { |
637 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); | 646 | PresenceInfo friendSession = friendSessions[0]; |
638 | // TODO: You might want to send the delta to save the lookup | 647 | if (friendSession != null) |
639 | // on the other end!! | 648 | { |
640 | m_FriendsSimConnector.GrantRights(region, requester, target, myFlags, rights); | 649 | GridRegion region = GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, friendSession.RegionID); |
650 | // TODO: You might want to send the delta to save the lookup | ||
651 | // on the other end!! | ||
652 | m_FriendsSimConnector.GrantRights(region, requester, target, myFlags, rights); | ||
653 | } | ||
641 | } | 654 | } |
642 | } | 655 | } |
643 | } | 656 | } |
diff --git a/OpenSim/Region/CoreModules/Avatar/InstantMessage/MessageTransferModule.cs b/OpenSim/Region/CoreModules/Avatar/InstantMessage/MessageTransferModule.cs index ad050a1..5d20e63 100644 --- a/OpenSim/Region/CoreModules/Avatar/InstantMessage/MessageTransferModule.cs +++ b/OpenSim/Region/CoreModules/Avatar/InstantMessage/MessageTransferModule.cs | |||
@@ -471,7 +471,6 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage | |||
471 | if (m_UserRegionMap.ContainsKey(toAgentID)) | 471 | if (m_UserRegionMap.ContainsKey(toAgentID)) |
472 | { | 472 | { |
473 | upd = new PresenceInfo(); | 473 | upd = new PresenceInfo(); |
474 | upd.Online = true; | ||
475 | upd.RegionID = m_UserRegionMap[toAgentID]; | 474 | upd.RegionID = m_UserRegionMap[toAgentID]; |
476 | 475 | ||
477 | // We need to compare the current regionhandle with the previous region handle | 476 | // We need to compare the current regionhandle with the previous region handle |
@@ -493,15 +492,8 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage | |||
493 | { | 492 | { |
494 | // Non-cached user agent lookup. | 493 | // Non-cached user agent lookup. |
495 | PresenceInfo[] presences = PresenceService.GetAgents(new string[] { toAgentID.ToString() }); | 494 | PresenceInfo[] presences = PresenceService.GetAgents(new string[] { toAgentID.ToString() }); |
496 | if (presences != null) | 495 | if (presences != null && presences.Length > 0) |
497 | { | 496 | upd = presences[0]; |
498 | foreach (PresenceInfo p in presences) | ||
499 | if (p.Online) | ||
500 | { | ||
501 | upd = presences[0]; | ||
502 | break; | ||
503 | } | ||
504 | } | ||
505 | 497 | ||
506 | if (upd != null) | 498 | if (upd != null) |
507 | { | 499 | { |
@@ -525,61 +517,53 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage | |||
525 | 517 | ||
526 | if (upd != null) | 518 | if (upd != null) |
527 | { | 519 | { |
528 | if (upd.Online) | 520 | GridRegion reginfo = m_Scenes[0].GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, |
521 | upd.RegionID); | ||
522 | if (reginfo != null) | ||
529 | { | 523 | { |
530 | GridRegion reginfo = m_Scenes[0].GridService.GetRegionByUUID(m_Scenes[0].RegionInfo.ScopeID, | 524 | Hashtable msgdata = ConvertGridInstantMessageToXMLRPC(im); |
531 | upd.RegionID); | 525 | // Not actually used anymore, left in for compatibility |
532 | if (reginfo != null) | 526 | // Remove at next interface change |
527 | // | ||
528 | msgdata["region_handle"] = 0; | ||
529 | bool imresult = doIMSending(reginfo, msgdata); | ||
530 | if (imresult) | ||
533 | { | 531 | { |
534 | Hashtable msgdata = ConvertGridInstantMessageToXMLRPC(im); | 532 | // IM delivery successful, so store the Agent's location in our local cache. |
535 | // Not actually used anymore, left in for compatibility | 533 | lock (m_UserRegionMap) |
536 | // Remove at next interface change | ||
537 | // | ||
538 | msgdata["region_handle"] = 0; | ||
539 | bool imresult = doIMSending(reginfo, msgdata); | ||
540 | if (imresult) | ||
541 | { | 534 | { |
542 | // IM delivery successful, so store the Agent's location in our local cache. | 535 | if (m_UserRegionMap.ContainsKey(toAgentID)) |
543 | lock (m_UserRegionMap) | ||
544 | { | 536 | { |
545 | if (m_UserRegionMap.ContainsKey(toAgentID)) | 537 | m_UserRegionMap[toAgentID] = upd.RegionID; |
546 | { | 538 | } |
547 | m_UserRegionMap[toAgentID] = upd.RegionID; | 539 | else |
548 | } | 540 | { |
549 | else | 541 | m_UserRegionMap.Add(toAgentID, upd.RegionID); |
550 | { | ||
551 | m_UserRegionMap.Add(toAgentID, upd.RegionID); | ||
552 | } | ||
553 | } | 542 | } |
554 | result(true); | ||
555 | } | ||
556 | else | ||
557 | { | ||
558 | // try again, but lookup user this time. | ||
559 | // Warning, this must call the Async version | ||
560 | // of this method or we'll be making thousands of threads | ||
561 | // The version within the spawned thread is SendGridInstantMessageViaXMLRPCAsync | ||
562 | // The version that spawns the thread is SendGridInstantMessageViaXMLRPC | ||
563 | |||
564 | // This is recursive!!!!! | ||
565 | SendGridInstantMessageViaXMLRPCAsync(im, result, | ||
566 | upd.RegionID); | ||
567 | } | 543 | } |
544 | result(true); | ||
568 | } | 545 | } |
569 | else | 546 | else |
570 | { | 547 | { |
571 | m_log.WarnFormat("[GRID INSTANT MESSAGE]: Unable to find region {0}", upd.RegionID); | 548 | // try again, but lookup user this time. |
572 | HandleUndeliveredMessage(im, result); | 549 | // Warning, this must call the Async version |
550 | // of this method or we'll be making thousands of threads | ||
551 | // The version within the spawned thread is SendGridInstantMessageViaXMLRPCAsync | ||
552 | // The version that spawns the thread is SendGridInstantMessageViaXMLRPC | ||
553 | |||
554 | // This is recursive!!!!! | ||
555 | SendGridInstantMessageViaXMLRPCAsync(im, result, | ||
556 | upd.RegionID); | ||
573 | } | 557 | } |
574 | } | 558 | } |
575 | else | 559 | else |
576 | { | 560 | { |
561 | m_log.WarnFormat("[GRID INSTANT MESSAGE]: Unable to find region {0}", upd.RegionID); | ||
577 | HandleUndeliveredMessage(im, result); | 562 | HandleUndeliveredMessage(im, result); |
578 | } | 563 | } |
579 | } | 564 | } |
580 | else | 565 | else |
581 | { | 566 | { |
582 | m_log.WarnFormat("[GRID INSTANT MESSAGE]: Unable to find user {0}", toAgentID); | ||
583 | HandleUndeliveredMessage(im, result); | 567 | HandleUndeliveredMessage(im, result); |
584 | } | 568 | } |
585 | } | 569 | } |
diff --git a/OpenSim/Region/CoreModules/Avatar/InstantMessage/PresenceModule.cs b/OpenSim/Region/CoreModules/Avatar/InstantMessage/PresenceModule.cs index bafad82..dd17f3c 100644 --- a/OpenSim/Region/CoreModules/Avatar/InstantMessage/PresenceModule.cs +++ b/OpenSim/Region/CoreModules/Avatar/InstantMessage/PresenceModule.cs | |||
@@ -133,20 +133,14 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage | |||
133 | foreach (PresenceInfo pi in status) | 133 | foreach (PresenceInfo pi in status) |
134 | { | 134 | { |
135 | UUID uuid = new UUID(pi.UserID); | 135 | UUID uuid = new UUID(pi.UserID); |
136 | if (pi.Online) | 136 | if (!online.Contains(uuid)) |
137 | { | 137 | online.Add(uuid); |
138 | if (!online.Contains(uuid)) | 138 | } |
139 | { | 139 | foreach (string s in args) |
140 | online.Add(uuid); | 140 | { |
141 | if (offline.Contains(uuid)) | 141 | UUID uuid = new UUID(s); |
142 | offline.Remove(uuid); | 142 | if (!online.Contains(uuid) && !offline.Contains(uuid)) |
143 | } | 143 | offline.Add(uuid); |
144 | } | ||
145 | else | ||
146 | { | ||
147 | if (!online.Contains(uuid) && !offline.Contains(uuid)) | ||
148 | offline.Add(uuid); | ||
149 | } | ||
150 | } | 144 | } |
151 | 145 | ||
152 | if (online.Count > 0) | 146 | if (online.Count > 0) |