i2p/haiku-beta6
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added cleanup of dead nodes.

Browse Source 
git-svn-id: file:///srv/svn/repos/haiku/trunk/current@2370 a95241bf-73f2-0310-859d-f6bbb57e9c96
This commit is contained in:
beveloper
2003-01-06 14:23:20 +00:00
parent f143877df9
commit a99e278308
1 changed files with 29 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/servers/media/NodeManager.cpp
+29 -1
View File
@@ -614,8 +614,36 @@ void
NodeManager::CleanupTeam(team_id team) NodeManager::CleanupTeam(team_id team)
{ {
BAutolock lock(fLocker); BAutolock lock(fLocker);
FATAL("NodeManager::CleanupTeam: should cleanup team %ld\n", team);
fDefaultManager->CleanupTeam(team); fDefaultManager->CleanupTeam(team);
FATAL("NodeManager::CleanupTeam: team %ld\n", team);
registered_node *rn;
for (fRegisteredNodeMap->Rewind(); fRegisteredNodeMap->GetNext(&rn); ) {
// if the team hosting this node is gone, remove node from database
if (rn->team == team) {
FATAL("NodeManager::CleanupTeam: removing node id %ld, team %ld\n", rn->nodeid, team);
fRegisteredNodeMap->RemoveCurrent();
continue;
}
// check the list of teams that have references to this node, and remove the team
team_id *pteam;
int32 *prefcount;
for (rn->teamrefcount.Rewind(); rn->teamrefcount.GetNext(&prefcount); ) {
rn->teamrefcount.GetCurrentKey(&pteam);
if (*pteam == team) {
FATAL("NodeManager::CleanupTeam: removing %ld refs from node id %ld, team %ld\n", *prefcount, rn->nodeid, team);
rn->teamrefcount.RemoveCurrent();
break;
}
}
// if the team refcount is now empty, also remove the node
if (rn->teamrefcount.IsEmpty()) {
FATAL("NodeManager::CleanupTeam: removing node id %ld that has no teams\n", rn->nodeid);
fRegisteredNodeMap->RemoveCurrent();
}
}
} }
status_t status_t