diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/cull_list.cpp | 93 | ||||
| -rw-r--r-- | src/inspircd.cpp | 4 | ||||
| -rw-r--r-- | src/modules/m_spanningtree/treeserver.cpp | 2 | ||||
| -rw-r--r-- | src/usermanager.cpp | 67 |
4 files changed, 70 insertions, 96 deletions
diff --git a/src/cull_list.cpp b/src/cull_list.cpp index 07649ed81..79c077ead 100644 --- a/src/cull_list.cpp +++ b/src/cull_list.cpp @@ -16,99 +16,10 @@ #include "inspircd.h" #include "cull_list.h" -CullList::CullList(InspIRCd* Instance) : ServerInstance(Instance) -{ -} - -void CullList::AddItem(User* user) -{ - list.push_back(user); -} - -void CullList::MakeSilent(User* user) -{ - user->quietquit = true; - return; -} - void CullList::Apply() { - for(std::vector<User *>::iterator a = list.begin(); a != list.end(); a++) - { - User *u = *a; - // user has been moved onto their UID; that's why this isn't find(u->nick) - user_hash::iterator iter = ServerInstance->Users->clientlist->find(u->uuid); - - if (u->registered != REG_ALL) - if (ServerInstance->Users->unregistered_count) - ServerInstance->Users->unregistered_count--; - - if (IS_LOCAL(u)) - { - if (!u->sendq.empty()) - u->FlushWriteBuf(); - - if (u->GetIOHook()) - { - try - { - u->GetIOHook()->OnRawSocketClose(u->GetFd()); - } - catch (CoreException& modexcept) - { - ServerInstance->Logs->Log("CULLLIST",DEBUG, "%s threw an exception: %s", modexcept.GetSource(), modexcept.GetReason()); - } - } - - ServerInstance->SE->DelFd(u); - u->CloseSocket(); - } - - /* - * this must come before the ServerInstance->SNO->WriteToSnoMaskso that it doesnt try to fill their buffer with anything - * if they were an oper with +sn +qQ. - */ - if (u->registered == REG_ALL) - { - if (IS_LOCAL(u)) - { - if (!u->quietquit) - { - ServerInstance->SNO->WriteToSnoMask('q',"Client exiting: %s!%s@%s [%s]", u->nick.c_str(), u->ident.c_str(), u->host.c_str(), u->operquitmsg.c_str()); - } - } - else - { - if ((!ServerInstance->SilentULine(u->server)) && (!u->quietquit)) - { - ServerInstance->SNO->WriteToSnoMask('Q',"Client exiting on server %s: %s!%s@%s [%s]", u->server, u->nick.c_str(), u->ident.c_str(), u->host.c_str(), u->operquitmsg.c_str()); - } - } - u->AddToWhoWas(); - } - - if (iter != ServerInstance->Users->clientlist->end()) - { - ServerInstance->Users->clientlist->erase(iter); - } - else - { - ServerInstance->Logs->Log("CULLLIST", DEBUG, "iter == clientlist->end, can't remove them from hash... problematic.."); - } - - if (IS_LOCAL(u)) - { - std::vector<User*>::iterator x = find(ServerInstance->Users->local_users.begin(),ServerInstance->Users->local_users.end(),u); - if (x != ServerInstance->Users->local_users.end()) - ServerInstance->Users->local_users.erase(x); - else - { - ServerInstance->Logs->Log("CULLLIST", DEBUG, "Failed to remove user from vector.."); - } - } - - delete u; - } + for(std::vector<classbase*>::iterator i = list.begin(); i != list.end(); i++) + delete *i; list.clear(); } diff --git a/src/inspircd.cpp b/src/inspircd.cpp index cc69374ec..94dd41da0 100644 --- a/src/inspircd.cpp +++ b/src/inspircd.cpp @@ -317,9 +317,7 @@ void InspIRCd::WritePID(const std::string &filename) } } -InspIRCd::InspIRCd(int argc, char** argv) - : GlobalCulls(this), - +InspIRCd::InspIRCd(int argc, char** argv) : /* Functor initialisation. Note that the ordering here is very important. * * THIS MUST MATCH ORDER OF DECLARATION OF THE HandleWhateverFunc classes diff --git a/src/modules/m_spanningtree/treeserver.cpp b/src/modules/m_spanningtree/treeserver.cpp index 97aab7266..6c8c6a33c 100644 --- a/src/modules/m_spanningtree/treeserver.cpp +++ b/src/modules/m_spanningtree/treeserver.cpp @@ -182,7 +182,7 @@ int TreeServer::QuitUsers(const std::string &reason) ServerInstance->Users->QuitUser(a, reason_s); if (this->Utils->quiet_bursts) - ServerInstance->GlobalCulls.MakeSilent(a); + a->quietquit = true; } } return time_to_die.size(); diff --git a/src/usermanager.cpp b/src/usermanager.cpp index a31ac086e..31ffad007 100644 --- a/src/usermanager.cpp +++ b/src/usermanager.cpp @@ -204,8 +204,73 @@ void UserManager::QuitUser(User *user, const std::string &quitreason, const char FOREACH_MOD_I(ServerInstance,I_OnUserDisconnect,OnUserDisconnect(user)); - // Move the user onto their UID, to allow nick to be reused immediately user->UpdateNickHash(user->uuid.c_str()); + + user_hash::iterator iter = this->clientlist->find(user->uuid); + + if (user->registered != REG_ALL) + if (ServerInstance->Users->unregistered_count) + ServerInstance->Users->unregistered_count--; + + if (IS_LOCAL(user)) + { + if (!user->sendq.empty()) + user->FlushWriteBuf(); + + if (user->GetIOHook()) + { + try + { + user->GetIOHook()->OnRawSocketClose(user->GetFd()); + } + catch (CoreException& modexcept) + { + ServerInstance->Logs->Log("USERS",DEBUG, "%s threw an exception: %s", modexcept.GetSource(), modexcept.GetReason()); + } + } + + ServerInstance->SE->DelFd(user); + user->CloseSocket(); + } + + /* + * this must come before the ServerInstance->SNO->WriteToSnoMaskso that it doesnt try to fill their buffer with anything + * if they were an oper with +sn +qQ. + */ + if (user->registered == REG_ALL) + { + if (IS_LOCAL(user)) + { + if (!user->quietquit) + { + ServerInstance->SNO->WriteToSnoMask('q',"Client exiting: %s!%s@%s [%s]", + user->nick.c_str(), user->ident.c_str(), user->host.c_str(), user->operquitmsg.c_str()); + } + } + else + { + if ((!ServerInstance->SilentULine(user->server)) && (!user->quietquit)) + { + ServerInstance->SNO->WriteToSnoMask('Q',"Client exiting on server %s: %s!%s@%s [%s]", + user->server, user->nick.c_str(), user->ident.c_str(), user->host.c_str(), user->operquitmsg.c_str()); + } + } + user->AddToWhoWas(); + } + + if (iter != this->clientlist->end()) + this->clientlist->erase(iter); + else + ServerInstance->Logs->Log("USERS", DEBUG, "iter == clientlist->end, can't remove them from hash... problematic.."); + + if (IS_LOCAL(user)) + { + std::vector<User*>::iterator x = find(local_users.begin(),local_users.end(),user); + if (x != local_users.end()) + local_users.erase(x); + else + ServerInstance->Logs->Log("USERS", DEBUG, "Failed to remove user from vector"); + } } |