1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
/* +------------------------------------+
* | Inspire Internet Relay Chat Daemon |
* +------------------------------------+
*
* InspIRCd: (C) 2002-2009 InspIRCd Development Team
* See: http://wiki.inspircd.org/Credits
*
* This program is free but copyrighted software; see
* the file COPYING for details.
*
* ---------------------------------------------------
*/
/* $Core */
#include "inspircd.h"
#include "cull_list.h"
CullList::CullList(InspIRCd* Instance) : ServerInstance(Instance)
{
list.clear();
}
void CullList::AddItem(User* user)
{
list.push_back(user);
}
void CullList::MakeSilent(User* user)
{
user->quietquit = true;
return;
}
int CullList::Apply()
{
int n = list.size();
int i = 0;
while (list.size() && i++ != 100)
{
std::vector<User *>::iterator a = list.begin();
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;
list.erase(list.begin());
}
return n;
}
|
