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
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
|
/* +------------------------------------+
* | Inspire Internet Relay Chat Daemon |
* +------------------------------------+
*
* InspIRCd: (C) 2002-2008 InspIRCd Development Team
* See: http://www.inspircd.org/wiki/index.php/Credits
*
* This program is free but copyrighted software; see
* the file COPYING for details.
*
* ---------------------------------------------------
*/
/* $Core: libIRCDcull_list */
#include "inspircd.h"
#include "cull_list.h"
CullList::CullList(InspIRCd* Instance) : ServerInstance(Instance)
{
list.clear();
}
void CullList::AddItem(User* user)
{
if (user->quitting)
{
ServerInstance->Logs->Log("CULLLIST",DEBUG, "*** Warning *** - You tried to quit a user (%s) twice. Did your module call QuitUser twice?", user->nick.c_str());
return;
}
user->quitting = true;
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_hash::iterator iter = ServerInstance->Users->clientlist->find(u->nick);
const std::string& preset_reason = u->GetOperQuit();
std::string reason;
std::string oper_reason;
reason.assign(u->quitmsg, 0, MAXQUIT - 1);
oper_reason.assign(preset_reason.empty() ? preset_reason : u->operquitmsg, 0, MAXQUIT - 1);
if (u->registered != REG_ALL)
if (ServerInstance->Users->unregistered_count)
ServerInstance->Users->unregistered_count--;
if (IS_LOCAL(u))
{
if ((!u->sendq.empty()) && (!(*u->GetWriteError())))
u->FlushWriteBuf();
}
if (u->registered == REG_ALL)
{
FOREACH_MOD_I(ServerInstance,I_OnUserQuit,OnUserQuit(u, reason, oper_reason));
u->PurgeEmptyChannels();
u->WriteCommonQuit(reason, oper_reason);
}
FOREACH_MOD_I(ServerInstance,I_OnUserDisconnect,OnUserDisconnect(u));
if (IS_LOCAL(u))
{
if (u->io)
{
try
{
u->io->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(), oper_reason.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(), oper_reason.c_str());
}
}
u->AddToWhoWas();
}
bool deleteu = true;
if (iter != ServerInstance->Users->clientlist->end())
{
ServerInstance->Users->clientlist->erase(iter);
}
else
{
/*
* Trying to track down Jason's issue.. this should never happen obviously.
*/
ServerInstance->Logs->Log("CULLLIST", DEBUG, "iter == clientlist->end, can't remove them from hash... problematic?");
// deleteu = false;
// actually, delete them anyway.. the local vector is the real problem here
}
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
{
/*
* This code is in here to monitor an issue of Jason's, where it seems to be trying to quit already quit users.
* The only way that can happen is if this find fails, so log it just in case.
* Also, (perhaps incorrectly, but oh well), return here so we don't delete the user and then start trampling
* on deleted memory, which leads to big problems..
*/
ServerInstance->Logs->Log("CULLLIST", DEBUG, "Failed to remove user from vector, we're all gonna die!!! Not deleting the user to save our sanity");
deleteu = false;
}
}
if (deleteu)
{
delete u;
}
list.erase(list.begin());
}
return n;
}
|
