]> git.netwichtig.de Git - user/henk/code/inspircd.git/blob - src/users.cpp
dab3aad6c402f5993e397c2e462905935f5031b5
[user/henk/code/inspircd.git] / src / users.cpp
1 /*
2  * InspIRCd -- Internet Relay Chat Daemon
3  *
4  *   Copyright (C) 2009-2010 Daniel De Graaf <danieldg@inspircd.org>
5  *   Copyright (C) 2006-2009 Robin Burchell <robin+git@viroteck.net>
6  *   Copyright (C) 2006-2007, 2009 Dennis Friis <peavey@inspircd.org>
7  *   Copyright (C) 2008 John Brooks <john.brooks@dereferenced.net>
8  *   Copyright (C) 2008 Thomas Stagner <aquanight@inspircd.org>
9  *   Copyright (C) 2008 Oliver Lupton <oliverlupton@gmail.com>
10  *   Copyright (C) 2003-2008 Craig Edwards <craigedwards@brainbox.cc>
11  *
12  * This file is part of InspIRCd.  InspIRCd is free software: you can
13  * redistribute it and/or modify it under the terms of the GNU General Public
14  * License as published by the Free Software Foundation, version 2.
15  *
16  * This program is distributed in the hope that it will be useful, but WITHOUT
17  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
18  * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
19  * details.
20  *
21  * You should have received a copy of the GNU General Public License
22  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
23  */
24
25
26 #include "inspircd.h"
27 #include <stdarg.h>
28 #include "socketengine.h"
29 #include "xline.h"
30 #include "bancache.h"
31
32 already_sent_t LocalUser::already_sent_id = 0;
33
34 bool User::IsNoticeMaskSet(unsigned char sm)
35 {
36         if (!isalpha(sm))
37                 return false;
38         return (snomasks[sm-65]);
39 }
40
41 bool User::IsModeSet(unsigned char m)
42 {
43         if (!isalpha(m))
44                 return false;
45         return (modes[m-65]);
46 }
47
48 const char* User::FormatModes(bool showparameters)
49 {
50         static std::string data;
51         std::string params;
52         data.clear();
53
54         for (unsigned char n = 0; n < 64; n++)
55         {
56                 if (modes[n])
57                 {
58                         data.push_back(n + 65);
59                         ModeHandler* mh = ServerInstance->Modes->FindMode(n + 65, MODETYPE_USER);
60                         if (showparameters && mh && mh->GetNumParams(true))
61                         {
62                                 std::string p = mh->GetUserParameter(this);
63                                 if (p.length())
64                                         params.append(" ").append(p);
65                         }
66                 }
67         }
68         data += params;
69         return data.c_str();
70 }
71
72 User::User(const std::string& uid, Server* srv, int type)
73         : uuid(uid), server(srv), usertype(type)
74 {
75         age = ServerInstance->Time();
76         signon = 0;
77         registered = 0;
78         quitting = false;
79         client_sa.sa.sa_family = AF_UNSPEC;
80
81         ServerInstance->Logs->Log("USERS", LOG_DEBUG, "New UUID for user: %s", uuid.c_str());
82
83         if (!ServerInstance->Users->uuidlist->insert(std::make_pair(uuid, this)).second)
84                 throw CoreException("Duplicate UUID "+std::string(uuid)+" in User constructor");
85 }
86
87 LocalUser::LocalUser(int myfd, irc::sockets::sockaddrs* client, irc::sockets::sockaddrs* servaddr)
88         : User(ServerInstance->UIDGen.GetUID(), ServerInstance->FakeClient->server, USERTYPE_LOCAL), eh(this),
89         localuseriter(ServerInstance->Users->local_users.end()),
90         bytes_in(0), bytes_out(0), cmds_in(0), cmds_out(0), nping(0), CommandFloodPenalty(0),
91         already_sent(0)
92 {
93         exempt = quitting_sendq = false;
94         idle_lastmsg = 0;
95         ident = "unknown";
96         lastping = 0;
97         eh.SetFd(myfd);
98         memcpy(&client_sa, client, sizeof(irc::sockets::sockaddrs));
99         memcpy(&server_sa, servaddr, sizeof(irc::sockets::sockaddrs));
100         dhost = host = GetIPString();
101 }
102
103 User::~User()
104 {
105         if (ServerInstance->Users->uuidlist->find(uuid) != ServerInstance->Users->uuidlist->end())
106                 ServerInstance->Logs->Log("USERS", LOG_DEFAULT, "User destructor for %s called without cull", uuid.c_str());
107 }
108
109 const std::string& User::MakeHost()
110 {
111         if (!this->cached_makehost.empty())
112                 return this->cached_makehost;
113
114         // XXX: Is there really a need to cache this?
115         this->cached_makehost = ident + "@" + host;
116         return this->cached_makehost;
117 }
118
119 const std::string& User::MakeHostIP()
120 {
121         if (!this->cached_hostip.empty())
122                 return this->cached_hostip;
123
124         // XXX: Is there really a need to cache this?
125         this->cached_hostip = ident + "@" + this->GetIPString();
126         return this->cached_hostip;
127 }
128
129 const std::string& User::GetFullHost()
130 {
131         if (!this->cached_fullhost.empty())
132                 return this->cached_fullhost;
133
134         // XXX: Is there really a need to cache this?
135         this->cached_fullhost = nick + "!" + ident + "@" + dhost;
136         return this->cached_fullhost;
137 }
138
139 const std::string& User::GetFullRealHost()
140 {
141         if (!this->cached_fullrealhost.empty())
142                 return this->cached_fullrealhost;
143
144         // XXX: Is there really a need to cache this?
145         this->cached_fullrealhost = nick + "!" + ident + "@" + host;
146         return this->cached_fullrealhost;
147 }
148
149 InviteList& LocalUser::GetInviteList()
150 {
151         RemoveExpiredInvites();
152         return invites;
153 }
154
155 bool LocalUser::RemoveInvite(Channel* chan)
156 {
157         Invitation* inv = Invitation::Find(chan, this);
158         if (inv)
159         {
160                 inv->cull();
161                 delete inv;
162                 return true;
163         }
164         return false;
165 }
166
167 void LocalUser::RemoveExpiredInvites()
168 {
169         Invitation::Find(NULL, this);
170 }
171
172 bool User::HasModePermission(unsigned char, ModeType)
173 {
174         return true;
175 }
176
177 bool LocalUser::HasModePermission(unsigned char mode, ModeType type)
178 {
179         if (!this->IsOper())
180                 return false;
181
182         if (mode < 'A' || mode > ('A' + 64)) return false;
183
184         return ((type == MODETYPE_USER ? oper->AllowedUserModes : oper->AllowedChanModes))[(mode - 'A')];
185
186 }
187 /*
188  * users on remote servers can completely bypass all permissions based checks.
189  * This prevents desyncs when one server has different type/class tags to another.
190  * That having been said, this does open things up to the possibility of source changes
191  * allowing remote kills, etc - but if they have access to the src, they most likely have
192  * access to the conf - so it's an end to a means either way.
193  */
194 bool User::HasPermission(const std::string&)
195 {
196         return true;
197 }
198
199 bool LocalUser::HasPermission(const std::string &command)
200 {
201         // are they even an oper at all?
202         if (!this->IsOper())
203         {
204                 return false;
205         }
206
207         if (oper->AllowedOperCommands.find(command) != oper->AllowedOperCommands.end())
208                 return true;
209         else if (oper->AllowedOperCommands.find("*") != oper->AllowedOperCommands.end())
210                 return true;
211
212         return false;
213 }
214
215 bool User::HasPrivPermission(const std::string &privstr, bool noisy)
216 {
217         return true;
218 }
219
220 bool LocalUser::HasPrivPermission(const std::string &privstr, bool noisy)
221 {
222         if (!this->IsOper())
223         {
224                 if (noisy)
225                         this->WriteNotice("You are not an oper");
226                 return false;
227         }
228
229         if (oper->AllowedPrivs.find(privstr) != oper->AllowedPrivs.end())
230         {
231                 return true;
232         }
233         else if (oper->AllowedPrivs.find("*") != oper->AllowedPrivs.end())
234         {
235                 return true;
236         }
237
238         if (noisy)
239                 this->WriteNotice("Oper type " + oper->name + " does not have access to priv " + privstr);
240
241         return false;
242 }
243
244 void UserIOHandler::OnDataReady()
245 {
246         if (user->quitting)
247                 return;
248
249         if (recvq.length() > user->MyClass->GetRecvqMax() && !user->HasPrivPermission("users/flood/increased-buffers"))
250         {
251                 ServerInstance->Users->QuitUser(user, "RecvQ exceeded");
252                 ServerInstance->SNO->WriteToSnoMask('a', "User %s RecvQ of %lu exceeds connect class maximum of %lu",
253                         user->nick.c_str(), (unsigned long)recvq.length(), user->MyClass->GetRecvqMax());
254                 return;
255         }
256         unsigned long sendqmax = ULONG_MAX;
257         if (!user->HasPrivPermission("users/flood/increased-buffers"))
258                 sendqmax = user->MyClass->GetSendqSoftMax();
259         unsigned long penaltymax = ULONG_MAX;
260         if (!user->HasPrivPermission("users/flood/no-fakelag"))
261                 penaltymax = user->MyClass->GetPenaltyThreshold() * 1000;
262
263         while (user->CommandFloodPenalty < penaltymax && getSendQSize() < sendqmax)
264         {
265                 std::string line;
266                 line.reserve(ServerInstance->Config->Limits.MaxLine);
267                 std::string::size_type qpos = 0;
268                 while (qpos < recvq.length())
269                 {
270                         char c = recvq[qpos++];
271                         switch (c)
272                         {
273                         case '\0':
274                                 c = ' ';
275                                 break;
276                         case '\r':
277                                 continue;
278                         case '\n':
279                                 goto eol_found;
280                         }
281                         if (line.length() < ServerInstance->Config->Limits.MaxLine - 2)
282                                 line.push_back(c);
283                 }
284                 // if we got here, the recvq ran out before we found a newline
285                 return;
286 eol_found:
287                 // just found a newline. Terminate the string, and pull it out of recvq
288                 recvq = recvq.substr(qpos);
289
290                 // TODO should this be moved to when it was inserted in recvq?
291                 ServerInstance->stats->statsRecv += qpos;
292                 user->bytes_in += qpos;
293                 user->cmds_in++;
294
295                 ServerInstance->Parser->ProcessBuffer(line, user);
296                 if (user->quitting)
297                         return;
298         }
299         if (user->CommandFloodPenalty >= penaltymax && !user->MyClass->fakelag)
300                 ServerInstance->Users->QuitUser(user, "Excess Flood");
301 }
302
303 void UserIOHandler::AddWriteBuf(const std::string &data)
304 {
305         if (user->quitting_sendq)
306                 return;
307         if (!user->quitting && getSendQSize() + data.length() > user->MyClass->GetSendqHardMax() &&
308                 !user->HasPrivPermission("users/flood/increased-buffers"))
309         {
310                 user->quitting_sendq = true;
311                 ServerInstance->GlobalCulls.AddSQItem(user);
312                 return;
313         }
314
315         // We still want to append data to the sendq of a quitting user,
316         // e.g. their ERROR message that says 'closing link'
317
318         WriteData(data);
319 }
320
321 void UserIOHandler::OnError(BufferedSocketError)
322 {
323         ServerInstance->Users->QuitUser(user, getError());
324 }
325
326 CullResult User::cull()
327 {
328         if (!quitting)
329                 ServerInstance->Users->QuitUser(this, "Culled without QuitUser");
330         PurgeEmptyChannels();
331
332         if (client_sa.sa.sa_family != AF_UNSPEC)
333                 ServerInstance->Users->RemoveCloneCounts(this);
334
335         return Extensible::cull();
336 }
337
338 CullResult LocalUser::cull()
339 {
340         // The iterator is initialized to local_users.end() in the constructor. It is
341         // overwritten in UserManager::AddUser() with the real iterator so this check
342         // is only a precaution currently.
343         if (localuseriter != ServerInstance->Users->local_users.end())
344         {
345                 ServerInstance->Users->local_count--;
346                 ServerInstance->Users->local_users.erase(localuseriter);
347         }
348         else
349                 ServerInstance->Logs->Log("USERS", LOG_DEFAULT, "ERROR: LocalUserIter does not point to a valid entry for " + this->nick);
350
351         ClearInvites();
352         eh.cull();
353         return User::cull();
354 }
355
356 CullResult FakeUser::cull()
357 {
358         // Fake users don't quit, they just get culled.
359         quitting = true;
360         // Fake users are not inserted into UserManager::clientlist, they're only in the uuidlist
361         ServerInstance->Users->uuidlist->erase(uuid);
362         return User::cull();
363 }
364
365 void User::Oper(OperInfo* info)
366 {
367         ModeHandler* opermh = ServerInstance->Modes->FindMode('o', MODETYPE_USER);
368         if (this->IsModeSet(opermh))
369                 this->UnOper();
370
371         this->SetMode(opermh, true);
372         this->oper = info;
373         this->WriteServ("MODE %s :+o", this->nick.c_str());
374         FOREACH_MOD(OnOper, (this, info->name));
375
376         std::string opername;
377         if (info->oper_block)
378                 opername = info->oper_block->getString("name");
379
380         if (IS_LOCAL(this))
381         {
382                 LocalUser* l = IS_LOCAL(this);
383                 std::string vhost = oper->getConfig("vhost");
384                 if (!vhost.empty())
385                         l->ChangeDisplayedHost(vhost.c_str());
386                 std::string opClass = oper->getConfig("class");
387                 if (!opClass.empty())
388                         l->SetClass(opClass);
389         }
390
391         ServerInstance->SNO->WriteToSnoMask('o',"%s (%s@%s) is now an IRC operator of type %s (using oper '%s')",
392                 nick.c_str(), ident.c_str(), host.c_str(), oper->name.c_str(), opername.c_str());
393         this->WriteNumeric(RPL_YOUAREOPER, ":You are now %s %s", strchr("aeiouAEIOU", oper->name[0]) ? "an" : "a", oper->name.c_str());
394
395         ServerInstance->Logs->Log("OPER", LOG_DEFAULT, "%s opered as type: %s", GetFullRealHost().c_str(), oper->name.c_str());
396         ServerInstance->Users->all_opers.push_back(this);
397
398         // Expand permissions from config for faster lookup
399         if (IS_LOCAL(this))
400                 oper->init();
401
402         FOREACH_MOD(OnPostOper, (this, oper->name, opername));
403 }
404
405 void OperInfo::init()
406 {
407         AllowedOperCommands.clear();
408         AllowedPrivs.clear();
409         AllowedUserModes.reset();
410         AllowedChanModes.reset();
411         AllowedUserModes['o' - 'A'] = true; // Call me paranoid if you want.
412
413         for(std::vector<reference<ConfigTag> >::iterator iter = class_blocks.begin(); iter != class_blocks.end(); ++iter)
414         {
415                 ConfigTag* tag = *iter;
416                 std::string mycmd, mypriv;
417                 /* Process commands */
418                 irc::spacesepstream CommandList(tag->getString("commands"));
419                 while (CommandList.GetToken(mycmd))
420                 {
421                         AllowedOperCommands.insert(mycmd);
422                 }
423
424                 irc::spacesepstream PrivList(tag->getString("privs"));
425                 while (PrivList.GetToken(mypriv))
426                 {
427                         AllowedPrivs.insert(mypriv);
428                 }
429
430                 std::string modes = tag->getString("usermodes");
431                 for (std::string::const_iterator c = modes.begin(); c != modes.end(); ++c)
432                 {
433                         if (*c == '*')
434                         {
435                                 this->AllowedUserModes.set();
436                         }
437                         else if (*c >= 'A' && *c < 'z')
438                         {
439                                 this->AllowedUserModes[*c - 'A'] = true;
440                         }
441                 }
442
443                 modes = tag->getString("chanmodes");
444                 for (std::string::const_iterator c = modes.begin(); c != modes.end(); ++c)
445                 {
446                         if (*c == '*')
447                         {
448                                 this->AllowedChanModes.set();
449                         }
450                         else if (*c >= 'A' && *c < 'z')
451                         {
452                                 this->AllowedChanModes[*c - 'A'] = true;
453                         }
454                 }
455         }
456 }
457
458 void User::UnOper()
459 {
460         if (!this->IsOper())
461                 return;
462
463         /*
464          * unset their oper type (what IS_OPER checks).
465          * note, order is important - this must come before modes as -o attempts
466          * to call UnOper. -- w00t
467          */
468         oper = NULL;
469
470
471         /* Remove all oper only modes from the user when the deoper - Bug #466*/
472         std::string moderemove("-");
473
474         for (unsigned char letter = 'A'; letter <= 'z'; letter++)
475         {
476                 ModeHandler* mh = ServerInstance->Modes->FindMode(letter, MODETYPE_USER);
477                 if (mh && mh->NeedsOper())
478                         moderemove += letter;
479         }
480
481
482         std::vector<std::string> parameters;
483         parameters.push_back(this->nick);
484         parameters.push_back(moderemove);
485
486         ServerInstance->Modes->Process(parameters, this);
487
488         /* remove the user from the oper list. Will remove multiple entries as a safeguard against bug #404 */
489         ServerInstance->Users->all_opers.remove(this);
490
491         ModeHandler* opermh = ServerInstance->Modes->FindMode('o', MODETYPE_USER);
492         this->SetMode(opermh, false);
493 }
494
495 /*
496  * Check class restrictions
497  */
498 void LocalUser::CheckClass(bool clone_count)
499 {
500         ConnectClass* a = this->MyClass;
501
502         if (!a)
503         {
504                 ServerInstance->Users->QuitUser(this, "Access denied by configuration");
505                 return;
506         }
507         else if (a->type == CC_DENY)
508         {
509                 ServerInstance->Users->QuitUser(this, a->config->getString("reason", "Unauthorised connection"));
510                 return;
511         }
512         else if (clone_count)
513         {
514                 if ((a->GetMaxLocal()) && (ServerInstance->Users->LocalCloneCount(this) > a->GetMaxLocal()))
515                 {
516                         ServerInstance->Users->QuitUser(this, "No more connections allowed from your host via this connect class (local)");
517                         if (a->maxconnwarn)
518                                 ServerInstance->SNO->WriteToSnoMask('a', "WARNING: maximum LOCAL connections (%ld) exceeded for IP %s", a->GetMaxLocal(), this->GetIPString().c_str());
519                         return;
520                 }
521                 else if ((a->GetMaxGlobal()) && (ServerInstance->Users->GlobalCloneCount(this) > a->GetMaxGlobal()))
522                 {
523                         ServerInstance->Users->QuitUser(this, "No more connections allowed from your host via this connect class (global)");
524                         if (a->maxconnwarn)
525                                 ServerInstance->SNO->WriteToSnoMask('a', "WARNING: maximum GLOBAL connections (%ld) exceeded for IP %s", a->GetMaxGlobal(), this->GetIPString().c_str());
526                         return;
527                 }
528         }
529
530         this->nping = ServerInstance->Time() + a->GetPingTime() + ServerInstance->Config->dns_timeout;
531 }
532
533 bool LocalUser::CheckLines(bool doZline)
534 {
535         const char* check[] = { "G" , "K", (doZline) ? "Z" : NULL, NULL };
536
537         if (!this->exempt)
538         {
539                 for (int n = 0; check[n]; ++n)
540                 {
541                         XLine *r = ServerInstance->XLines->MatchesLine(check[n], this);
542
543                         if (r)
544                         {
545                                 r->Apply(this);
546                                 return true;
547                         }
548                 }
549         }
550
551         return false;
552 }
553
554 void LocalUser::FullConnect()
555 {
556         ServerInstance->stats->statsConnects++;
557         this->idle_lastmsg = ServerInstance->Time();
558
559         /*
560          * You may be thinking "wtf, we checked this in User::AddClient!" - and yes, we did, BUT.
561          * At the time AddClient is called, we don't have a resolved host, by here we probably do - which
562          * may put the user into a totally seperate class with different restrictions! so we *must* check again.
563          * Don't remove this! -- w00t
564          */
565         MyClass = NULL;
566         SetClass();
567         CheckClass();
568         CheckLines();
569
570         if (quitting)
571                 return;
572
573         this->WriteNumeric(RPL_WELCOME, ":Welcome to the %s IRC Network %s", ServerInstance->Config->Network.c_str(), GetFullRealHost().c_str());
574         this->WriteNumeric(RPL_YOURHOSTIS, ":Your host is %s, running version %s", ServerInstance->Config->ServerName.c_str(), BRANCH);
575         this->WriteNumeric(RPL_SERVERCREATED, ":This server was created %s %s", __TIME__, __DATE__);
576
577         const std::string& modelist = ServerInstance->Modes->GetModeListFor004Numeric();
578         this->WriteNumeric(RPL_SERVERVERSION, "%s %s %s", ServerInstance->Config->ServerName.c_str(), BRANCH, modelist.c_str());
579
580         ServerInstance->ISupport.SendTo(this);
581
582         /* Now registered */
583         if (ServerInstance->Users->unregistered_count)
584                 ServerInstance->Users->unregistered_count--;
585
586         /* Trigger MOTD and LUSERS output, give modules a chance too */
587         ModResult MOD_RESULT;
588         std::string command("LUSERS");
589         std::vector<std::string> parameters;
590         FIRST_MOD_RESULT(OnPreCommand, MOD_RESULT, (command, parameters, this, true, command));
591         if (!MOD_RESULT)
592                 ServerInstance->Parser->CallHandler(command, parameters, this);
593
594         MOD_RESULT = MOD_RES_PASSTHRU;
595         command = "MOTD";
596         FIRST_MOD_RESULT(OnPreCommand, MOD_RESULT, (command, parameters, this, true, command));
597         if (!MOD_RESULT)
598                 ServerInstance->Parser->CallHandler(command, parameters, this);
599
600         if (ServerInstance->Config->RawLog)
601                 WriteServ("PRIVMSG %s :*** Raw I/O logging is enabled on this server. All messages, passwords, and commands are being recorded.", nick.c_str());
602
603         /*
604          * We don't set REG_ALL until triggering OnUserConnect, so some module events don't spew out stuff
605          * for a user that doesn't exist yet.
606          */
607         FOREACH_MOD(OnUserConnect, (this));
608
609         this->registered = REG_ALL;
610
611         FOREACH_MOD(OnPostConnect, (this));
612
613         ServerInstance->SNO->WriteToSnoMask('c',"Client connecting on port %d (class %s): %s (%s) [%s]",
614                 this->GetServerPort(), this->MyClass->name.c_str(), GetFullRealHost().c_str(), this->GetIPString().c_str(), this->fullname.c_str());
615         ServerInstance->Logs->Log("BANCACHE", LOG_DEBUG, "BanCache: Adding NEGATIVE hit for " + this->GetIPString());
616         ServerInstance->BanCache->AddHit(this->GetIPString(), "", "");
617         // reset the flood penalty (which could have been raised due to things like auto +x)
618         CommandFloodPenalty = 0;
619 }
620
621 void User::InvalidateCache()
622 {
623         /* Invalidate cache */
624         cached_fullhost.clear();
625         cached_hostip.clear();
626         cached_makehost.clear();
627         cached_fullrealhost.clear();
628 }
629
630 bool User::ChangeNick(const std::string& newnick, bool force)
631 {
632         if (quitting)
633         {
634                 ServerInstance->Logs->Log("USERS", LOG_DEFAULT, "ERROR: Attempted to change nick of a quitting user: " + this->nick);
635                 return false;
636         }
637
638         if (!force)
639         {
640                 ModResult MOD_RESULT;
641                 FIRST_MOD_RESULT(OnUserPreNick, MOD_RESULT, (this, newnick));
642
643                 if (MOD_RESULT == MOD_RES_DENY)
644                 {
645                         ServerInstance->stats->statsCollisions++;
646                         return false;
647                 }
648         }
649
650         if (assign(newnick) == assign(nick))
651         {
652                 // case change, don't need to check Q:lines and such
653                 // and, if it's identical including case, we can leave right now
654                 if (newnick == nick)
655                         return true;
656         }
657         else
658         {
659                 /*
660                  * Don't check Q:Lines if it's a server-enforced change, just on the off-chance some fucking *moron*
661                  * tries to Q:Line SIDs, also, this means we just get our way period, as it really should be.
662                  * Thanks Kein for finding this. -- w00t
663                  *
664                  * Also don't check Q:Lines for remote nickchanges, they should have our Q:Lines anyway to enforce themselves.
665                  *              -- w00t
666                  */
667                 if (IS_LOCAL(this) && !force)
668                 {
669                         XLine* mq = ServerInstance->XLines->MatchesLine("Q",newnick);
670                         if (mq)
671                         {
672                                 if (this->registered == REG_ALL)
673                                 {
674                                         ServerInstance->SNO->WriteGlobalSno('a', "Q-Lined nickname %s from %s: %s",
675                                                 newnick.c_str(), GetFullRealHost().c_str(), mq->reason.c_str());
676                                 }
677                                 this->WriteNumeric(ERR_ERRONEUSNICKNAME, "%s :Invalid nickname: %s", newnick.c_str(), mq->reason.c_str());
678                                 return false;
679                         }
680
681                         if (ServerInstance->Config->RestrictBannedUsers)
682                         {
683                                 for (UCListIter i = this->chans.begin(); i != this->chans.end(); i++)
684                                 {
685                                         Channel *chan = *i;
686                                         if (chan->GetPrefixValue(this) < VOICE_VALUE && chan->IsBanned(this))
687                                         {
688                                                 this->WriteNumeric(ERR_CANNOTSENDTOCHAN, "%s :Cannot send to channel (you're banned)", chan->name.c_str());
689                                                 return false;
690                                         }
691                                 }
692                         }
693                 }
694
695                 /*
696                  * Uh oh.. if the nickname is in use, and it's not in use by the person using it (doh) --
697                  * then we have a potential collide. Check whether someone else is camping on the nick
698                  * (i.e. connect -> send NICK, don't send USER.) If they are camping, force-change the
699                  * camper to their UID, and allow the incoming nick change.
700                  *
701                  * If the guy using the nick is already using it, tell the incoming nick change to gtfo,
702                  * because the nick is already (rightfully) in use. -- w00t
703                  */
704                 User* InUse = ServerInstance->FindNickOnly(newnick);
705                 if (InUse && (InUse != this))
706                 {
707                         if (InUse->registered != REG_ALL)
708                         {
709                                 /* force the camper to their UUID, and ask them to re-send a NICK. */
710                                 InUse->WriteTo(InUse, "NICK %s", InUse->uuid.c_str());
711                                 InUse->WriteNumeric(ERR_NICKNAMEINUSE, "%s :Nickname overruled.", InUse->nick.c_str());
712
713                                 ServerInstance->Users->clientlist->erase(InUse->nick);
714                                 (*(ServerInstance->Users->clientlist))[InUse->uuid] = InUse;
715
716                                 InUse->nick = InUse->uuid;
717                                 InUse->InvalidateCache();
718                                 InUse->registered &= ~REG_NICK;
719                         }
720                         else
721                         {
722                                 /* No camping, tell the incoming user  to stop trying to change nick ;p */
723                                 this->WriteNumeric(ERR_NICKNAMEINUSE, "%s :Nickname is already in use.", newnick.c_str());
724                                 return false;
725                         }
726                 }
727         }
728
729         if (this->registered == REG_ALL)
730                 this->WriteCommon("NICK %s",newnick.c_str());
731         std::string oldnick = nick;
732         nick = newnick;
733
734         InvalidateCache();
735         ServerInstance->Users->clientlist->erase(oldnick);
736         (*(ServerInstance->Users->clientlist))[newnick] = this;
737
738         if (registered == REG_ALL)
739                 FOREACH_MOD(OnUserPostNick, (this,oldnick));
740
741         return true;
742 }
743
744 int LocalUser::GetServerPort()
745 {
746         switch (this->server_sa.sa.sa_family)
747         {
748                 case AF_INET6:
749                         return htons(this->server_sa.in6.sin6_port);
750                 case AF_INET:
751                         return htons(this->server_sa.in4.sin_port);
752         }
753         return 0;
754 }
755
756 const std::string& User::GetIPString()
757 {
758         int port;
759         if (cachedip.empty())
760         {
761                 irc::sockets::satoap(client_sa, cachedip, port);
762                 /* IP addresses starting with a : on irc are a Bad Thing (tm) */
763                 if (cachedip[0] == ':')
764                         cachedip.insert(cachedip.begin(),1,'0');
765         }
766
767         return cachedip;
768 }
769
770 irc::sockets::cidr_mask User::GetCIDRMask()
771 {
772         int range = 0;
773         switch (client_sa.sa.sa_family)
774         {
775                 case AF_INET6:
776                         range = ServerInstance->Config->c_ipv6_range;
777                         break;
778                 case AF_INET:
779                         range = ServerInstance->Config->c_ipv4_range;
780                         break;
781         }
782         return irc::sockets::cidr_mask(client_sa, range);
783 }
784
785 bool User::SetClientIP(const char* sip, bool recheck_eline)
786 {
787         cachedip.clear();
788         cached_hostip.clear();
789         return irc::sockets::aptosa(sip, 0, client_sa);
790 }
791
792 void User::SetClientIP(const irc::sockets::sockaddrs& sa, bool recheck_eline)
793 {
794         cachedip.clear();
795         cached_hostip.clear();
796         memcpy(&client_sa, &sa, sizeof(irc::sockets::sockaddrs));
797 }
798
799 bool LocalUser::SetClientIP(const char* sip, bool recheck_eline)
800 {
801         irc::sockets::sockaddrs sa;
802         if (!irc::sockets::aptosa(sip, 0, sa))
803                 // Invalid
804                 return false;
805
806         LocalUser::SetClientIP(sa, recheck_eline);
807         return true;
808 }
809
810 void LocalUser::SetClientIP(const irc::sockets::sockaddrs& sa, bool recheck_eline)
811 {
812         if (sa != client_sa)
813         {
814                 User::SetClientIP(sa);
815                 if (recheck_eline)
816                         this->exempt = (ServerInstance->XLines->MatchesLine("E", this) != NULL);
817
818                 FOREACH_MOD(OnSetUserIP, (this));
819         }
820 }
821
822 static std::string wide_newline("\r\n");
823
824 void User::Write(const std::string& text)
825 {
826 }
827
828 void User::Write(const char *text, ...)
829 {
830 }
831
832 void LocalUser::Write(const std::string& text)
833 {
834         if (!ServerInstance->SE->BoundsCheckFd(&eh))
835                 return;
836
837         if (text.length() > ServerInstance->Config->Limits.MaxLine - 2)
838         {
839                 // this should happen rarely or never. Crop the string at 512 and try again.
840                 std::string try_again = text.substr(0, ServerInstance->Config->Limits.MaxLine - 2);
841                 Write(try_again);
842                 return;
843         }
844
845         ServerInstance->Logs->Log("USEROUTPUT", LOG_RAWIO, "C[%s] O %s", uuid.c_str(), text.c_str());
846
847         eh.AddWriteBuf(text);
848         eh.AddWriteBuf(wide_newline);
849
850         ServerInstance->stats->statsSent += text.length() + 2;
851         this->bytes_out += text.length() + 2;
852         this->cmds_out++;
853 }
854
855 /** Write()
856  */
857 void LocalUser::Write(const char *text, ...)
858 {
859         std::string textbuffer;
860         VAFORMAT(textbuffer, text, text);
861         this->Write(textbuffer);
862 }
863
864 void User::WriteServ(const std::string& text)
865 {
866         this->Write(":%s %s",ServerInstance->Config->ServerName.c_str(),text.c_str());
867 }
868
869 /** WriteServ()
870  *  Same as Write(), except `text' is prefixed with `:server.name '.
871  */
872 void User::WriteServ(const char* text, ...)
873 {
874         std::string textbuffer;
875         VAFORMAT(textbuffer, text, text);
876         this->WriteServ(textbuffer);
877 }
878
879 void User::WriteNotice(const std::string& text)
880 {
881         this->WriteServ("NOTICE " + (this->registered == REG_ALL ? this->nick : "*") + " :" + text);
882 }
883
884 void User::WriteNumeric(unsigned int numeric, const char* text, ...)
885 {
886         std::string textbuffer;
887         VAFORMAT(textbuffer, text, text);
888         this->WriteNumeric(numeric, textbuffer);
889 }
890
891 void User::WriteNumeric(unsigned int numeric, const std::string &text)
892 {
893         ModResult MOD_RESULT;
894
895         FIRST_MOD_RESULT(OnNumeric, MOD_RESULT, (this, numeric, text));
896
897         if (MOD_RESULT == MOD_RES_DENY)
898                 return;
899         
900         const std::string message = InspIRCd::Format(":%s %03u %s %s", ServerInstance->Config->ServerName.c_str(),
901                 numeric, !this->nick.empty() ? this->nick.c_str() : "*", text.c_str());
902         this->Write(message);
903 }
904
905 void User::WriteFrom(User *user, const std::string &text)
906 {
907         const std::string message = ":" + user->GetFullHost() + " " + text;
908         this->Write(message);
909 }
910
911
912 /* write text from an originating user to originating user */
913
914 void User::WriteFrom(User *user, const char* text, ...)
915 {
916         std::string textbuffer;
917         VAFORMAT(textbuffer, text, text);
918         this->WriteFrom(user, textbuffer);
919 }
920
921
922 /* write text to an destination user from a source user (e.g. user privmsg) */
923
924 void User::WriteTo(User *dest, const char *data, ...)
925 {
926         std::string textbuffer;
927         VAFORMAT(textbuffer, data, data);
928         this->WriteTo(dest, textbuffer);
929 }
930
931 void User::WriteTo(User *dest, const std::string &data)
932 {
933         dest->WriteFrom(this, data);
934 }
935
936 void User::WriteCommon(const char* text, ...)
937 {
938         if (this->registered != REG_ALL || quitting)
939                 return;
940
941         std::string textbuffer;
942         VAFORMAT(textbuffer, text, text);
943         textbuffer = ":" + this->GetFullHost() + " " + textbuffer;
944         this->WriteCommonRaw(textbuffer, true);
945 }
946
947 void User::WriteCommonExcept(const char* text, ...)
948 {
949         if (this->registered != REG_ALL || quitting)
950                 return;
951
952         std::string textbuffer;
953         VAFORMAT(textbuffer, text, text);
954         textbuffer = ":" + this->GetFullHost() + " " + textbuffer;
955         this->WriteCommonRaw(textbuffer, false);
956 }
957
958 void User::WriteCommonRaw(const std::string &line, bool include_self)
959 {
960         if (this->registered != REG_ALL || quitting)
961                 return;
962
963         LocalUser::already_sent_id++;
964
965         UserChanList include_c(chans);
966         std::map<User*,bool> exceptions;
967
968         exceptions[this] = include_self;
969
970         FOREACH_MOD(OnBuildNeighborList, (this, include_c, exceptions));
971
972         for (std::map<User*,bool>::iterator i = exceptions.begin(); i != exceptions.end(); ++i)
973         {
974                 LocalUser* u = IS_LOCAL(i->first);
975                 if (u && !u->quitting)
976                 {
977                         u->already_sent = LocalUser::already_sent_id;
978                         if (i->second)
979                                 u->Write(line);
980                 }
981         }
982         for (UCListIter v = include_c.begin(); v != include_c.end(); ++v)
983         {
984                 Channel* c = *v;
985                 const UserMembList* ulist = c->GetUsers();
986                 for (UserMembList::const_iterator i = ulist->begin(); i != ulist->end(); i++)
987                 {
988                         LocalUser* u = IS_LOCAL(i->first);
989                         if (u && !u->quitting && u->already_sent != LocalUser::already_sent_id)
990                         {
991                                 u->already_sent = LocalUser::already_sent_id;
992                                 u->Write(line);
993                         }
994                 }
995         }
996 }
997
998 void User::WriteCommonQuit(const std::string &normal_text, const std::string &oper_text)
999 {
1000         if (this->registered != REG_ALL)
1001                 return;
1002
1003         already_sent_t uniq_id = ++LocalUser::already_sent_id;
1004
1005         const std::string normalMessage = ":" + this->GetFullHost() + " QUIT :" + normal_text;
1006         const std::string operMessage = ":" + this->GetFullHost() + " QUIT :" + oper_text;
1007
1008         UserChanList include_c(chans);
1009         std::map<User*,bool> exceptions;
1010
1011         FOREACH_MOD(OnBuildNeighborList, (this, include_c, exceptions));
1012
1013         for (std::map<User*,bool>::iterator i = exceptions.begin(); i != exceptions.end(); ++i)
1014         {
1015                 LocalUser* u = IS_LOCAL(i->first);
1016                 if (u && !u->quitting)
1017                 {
1018                         u->already_sent = uniq_id;
1019                         if (i->second)
1020                                 u->Write(u->IsOper() ? operMessage : normalMessage);
1021                 }
1022         }
1023         for (UCListIter v = include_c.begin(); v != include_c.end(); ++v)
1024         {
1025                 const UserMembList* ulist = (*v)->GetUsers();
1026                 for (UserMembList::const_iterator i = ulist->begin(); i != ulist->end(); i++)
1027                 {
1028                         LocalUser* u = IS_LOCAL(i->first);
1029                         if (u && !u->quitting && (u->already_sent != uniq_id))
1030                         {
1031                                 u->already_sent = uniq_id;
1032                                 u->Write(u->IsOper() ? operMessage : normalMessage);
1033                         }
1034                 }
1035         }
1036 }
1037
1038 void LocalUser::SendText(const std::string& line)
1039 {
1040         Write(line);
1041 }
1042
1043 void RemoteUser::SendText(const std::string& line)
1044 {
1045         ServerInstance->PI->PushToClient(this, line);
1046 }
1047
1048 void FakeUser::SendText(const std::string& line)
1049 {
1050 }
1051
1052 void User::SendText(const char *text, ...)
1053 {
1054         std::string line;
1055         VAFORMAT(line, text, text);
1056         SendText(line);
1057 }
1058
1059 void User::SendText(const std::string& linePrefix, std::stringstream& textStream)
1060 {
1061         std::string line;
1062         std::string word;
1063         while (textStream >> word)
1064         {
1065                 size_t lineLength = linePrefix.length() + line.length() + word.length() + 3; // "\s\n\r"
1066                 if (lineLength > ServerInstance->Config->Limits.MaxLine)
1067                 {
1068                         SendText(linePrefix + line);
1069                         line.clear();
1070                 }
1071                 line += " " + word;
1072         }
1073         SendText(linePrefix + line);
1074 }
1075
1076 /* return 0 or 1 depending if users u and u2 share one or more common channels
1077  * (used by QUIT, NICK etc which arent channel specific notices)
1078  *
1079  * The old algorithm in 1.0 for this was relatively inefficient, iterating over
1080  * the first users channels then the second users channels within the outer loop,
1081  * therefore it was a maximum of x*y iterations (upon returning 0 and checking
1082  * all possible iterations). However this new function instead checks against the
1083  * channel's userlist in the inner loop which is a std::map<User*,User*>
1084  * and saves us time as we already know what pointer value we are after.
1085  * Don't quote me on the maths as i am not a mathematician or computer scientist,
1086  * but i believe this algorithm is now x+(log y) maximum iterations instead.
1087  */
1088 bool User::SharesChannelWith(User *other)
1089 {
1090         if ((this->registered != REG_ALL) || (other->registered != REG_ALL))
1091                 return false;
1092
1093         /* Outer loop */
1094         for (UCListIter i = this->chans.begin(); i != this->chans.end(); i++)
1095         {
1096                 /* Eliminate the inner loop (which used to be ~equal in size to the outer loop)
1097                  * by replacing it with a map::find which *should* be more efficient
1098                  */
1099                 if ((*i)->HasUser(other))
1100                         return true;
1101         }
1102         return false;
1103 }
1104
1105 bool User::ChangeName(const std::string& gecos)
1106 {
1107         if (!this->fullname.compare(gecos))
1108                 return true;
1109
1110         if (IS_LOCAL(this))
1111         {
1112                 ModResult MOD_RESULT;
1113                 FIRST_MOD_RESULT(OnChangeLocalUserGECOS, MOD_RESULT, (IS_LOCAL(this),gecos));
1114                 if (MOD_RESULT == MOD_RES_DENY)
1115                         return false;
1116                 FOREACH_MOD(OnChangeName, (this,gecos));
1117         }
1118         this->fullname.assign(gecos, 0, ServerInstance->Config->Limits.MaxGecos);
1119
1120         return true;
1121 }
1122
1123 bool User::ChangeDisplayedHost(const std::string& shost)
1124 {
1125         if (dhost == shost)
1126                 return true;
1127
1128         if (IS_LOCAL(this))
1129         {
1130                 ModResult MOD_RESULT;
1131                 FIRST_MOD_RESULT(OnChangeLocalUserHost, MOD_RESULT, (IS_LOCAL(this),shost));
1132                 if (MOD_RESULT == MOD_RES_DENY)
1133                         return false;
1134         }
1135
1136         FOREACH_MOD(OnChangeHost, (this,shost));
1137
1138         this->dhost.assign(shost, 0, 64);
1139         this->InvalidateCache();
1140
1141         if (IS_LOCAL(this))
1142                 this->WriteNumeric(RPL_YOURDISPLAYEDHOST, "%s :is now your displayed host", this->dhost.c_str());
1143
1144         return true;
1145 }
1146
1147 bool User::ChangeIdent(const std::string& newident)
1148 {
1149         if (this->ident == newident)
1150                 return true;
1151
1152         FOREACH_MOD(OnChangeIdent, (this,newident));
1153
1154         this->ident.assign(newident, 0, ServerInstance->Config->Limits.IdentMax);
1155         this->InvalidateCache();
1156
1157         return true;
1158 }
1159
1160 void User::SendAll(const char* command, const char* text, ...)
1161 {
1162         std::string textbuffer;
1163         VAFORMAT(textbuffer, text, text);
1164         const std::string message = ":" + this->GetFullHost() + " " + command + " $* :" + textbuffer;
1165
1166         for (LocalUserList::const_iterator i = ServerInstance->Users->local_users.begin(); i != ServerInstance->Users->local_users.end(); i++)
1167         {
1168                 if ((*i)->registered == REG_ALL)
1169                         (*i)->Write(message);
1170         }
1171 }
1172
1173 /*
1174  * Sets a user's connection class.
1175  * If the class name is provided, it will be used. Otherwise, the class will be guessed using host/ip/ident/etc.
1176  * NOTE: If the <ALLOW> or <DENY> tag specifies an ip, and this user resolves,
1177  * then their ip will be taken as 'priority' anyway, so for example,
1178  * <connect allow="127.0.0.1"> will match joe!bloggs@localhost
1179  */
1180 void LocalUser::SetClass(const std::string &explicit_name)
1181 {
1182         ConnectClass *found = NULL;
1183
1184         ServerInstance->Logs->Log("CONNECTCLASS", LOG_DEBUG, "Setting connect class for UID %s", this->uuid.c_str());
1185
1186         if (!explicit_name.empty())
1187         {
1188                 for (ClassVector::iterator i = ServerInstance->Config->Classes.begin(); i != ServerInstance->Config->Classes.end(); i++)
1189                 {
1190                         ConnectClass* c = *i;
1191
1192                         if (explicit_name == c->name)
1193                         {
1194                                 ServerInstance->Logs->Log("CONNECTCLASS", LOG_DEBUG, "Explicitly set to %s", explicit_name.c_str());
1195                                 found = c;
1196                         }
1197                 }
1198         }
1199         else
1200         {
1201                 for (ClassVector::iterator i = ServerInstance->Config->Classes.begin(); i != ServerInstance->Config->Classes.end(); i++)
1202                 {
1203                         ConnectClass* c = *i;
1204                         ServerInstance->Logs->Log("CONNECTCLASS", LOG_DEBUG, "Checking %s", c->GetName().c_str());
1205
1206                         ModResult MOD_RESULT;
1207                         FIRST_MOD_RESULT(OnSetConnectClass, MOD_RESULT, (this,c));
1208                         if (MOD_RESULT == MOD_RES_DENY)
1209                                 continue;
1210                         if (MOD_RESULT == MOD_RES_ALLOW)
1211                         {
1212                                 ServerInstance->Logs->Log("CONNECTCLASS", LOG_DEBUG, "Class forced by module to %s", c->GetName().c_str());
1213                                 found = c;
1214                                 break;
1215                         }
1216
1217                         if (c->type == CC_NAMED)
1218                                 continue;
1219
1220                         bool regdone = (registered != REG_NONE);
1221                         if (c->config->getBool("registered", regdone) != regdone)
1222                                 continue;
1223
1224                         /* check if host matches.. */
1225                         if (!InspIRCd::MatchCIDR(this->GetIPString(), c->GetHost(), NULL) &&
1226                             !InspIRCd::MatchCIDR(this->host, c->GetHost(), NULL))
1227                         {
1228                                 ServerInstance->Logs->Log("CONNECTCLASS", LOG_DEBUG, "No host match (for %s)", c->GetHost().c_str());
1229                                 continue;
1230                         }
1231
1232                         /*
1233                          * deny change if change will take class over the limit check it HERE, not after we found a matching class,
1234                          * because we should attempt to find another class if this one doesn't match us. -- w00t
1235                          */
1236                         if (c->limit && (c->GetReferenceCount() >= c->limit))
1237                         {
1238                                 ServerInstance->Logs->Log("CONNECTCLASS", LOG_DEBUG, "OOPS: Connect class limit (%lu) hit, denying", c->limit);
1239                                 continue;
1240                         }
1241
1242                         /* if it requires a port ... */
1243                         int port = c->config->getInt("port");
1244                         if (port)
1245                         {
1246                                 ServerInstance->Logs->Log("CONNECTCLASS", LOG_DEBUG, "Requires port (%d)", port);
1247
1248                                 /* and our port doesn't match, fail. */
1249                                 if (this->GetServerPort() != port)
1250                                         continue;
1251                         }
1252
1253                         if (regdone && !c->config->getString("password").empty())
1254                         {
1255                                 if (ServerInstance->PassCompare(this, c->config->getString("password"), password, c->config->getString("hash")))
1256                                 {
1257                                         ServerInstance->Logs->Log("CONNECTCLASS", LOG_DEBUG, "Bad password, skipping");
1258                                         continue;
1259                                 }
1260                         }
1261
1262                         /* we stop at the first class that meets ALL critera. */
1263                         found = c;
1264                         break;
1265                 }
1266         }
1267
1268         /*
1269          * Okay, assuming we found a class that matches.. switch us into that class, keeping refcounts up to date.
1270          */
1271         if (found)
1272         {
1273                 MyClass = found;
1274         }
1275 }
1276
1277 void User::PurgeEmptyChannels()
1278 {
1279         // firstly decrement the count on each channel
1280         for (UCListIter f = this->chans.begin(); f != this->chans.end(); f++)
1281         {
1282                 Channel* c = *f;
1283                 c->DelUser(this);
1284         }
1285
1286         this->UnOper();
1287 }
1288
1289 const std::string& FakeUser::GetFullHost()
1290 {
1291         if (!ServerInstance->Config->HideWhoisServer.empty())
1292                 return ServerInstance->Config->HideWhoisServer;
1293         return server->GetName();
1294 }
1295
1296 const std::string& FakeUser::GetFullRealHost()
1297 {
1298         if (!ServerInstance->Config->HideWhoisServer.empty())
1299                 return ServerInstance->Config->HideWhoisServer;
1300         return server->GetName();
1301 }
1302
1303 ConnectClass::ConnectClass(ConfigTag* tag, char t, const std::string& mask)
1304         : config(tag), type(t), fakelag(true), name("unnamed"), registration_timeout(0), host(mask),
1305         pingtime(0), softsendqmax(0), hardsendqmax(0), recvqmax(0),
1306         penaltythreshold(0), commandrate(0), maxlocal(0), maxglobal(0), maxconnwarn(true), maxchans(0),
1307         limit(0), resolvehostnames(true)
1308 {
1309 }
1310
1311 ConnectClass::ConnectClass(ConfigTag* tag, char t, const std::string& mask, const ConnectClass& parent)
1312         : config(tag), type(t), fakelag(parent.fakelag), name("unnamed"),
1313         registration_timeout(parent.registration_timeout), host(mask), pingtime(parent.pingtime),
1314         softsendqmax(parent.softsendqmax), hardsendqmax(parent.hardsendqmax), recvqmax(parent.recvqmax),
1315         penaltythreshold(parent.penaltythreshold), commandrate(parent.commandrate),
1316         maxlocal(parent.maxlocal), maxglobal(parent.maxglobal), maxconnwarn(parent.maxconnwarn), maxchans(parent.maxchans),
1317         limit(parent.limit), resolvehostnames(parent.resolvehostnames)
1318 {
1319 }
1320
1321 void ConnectClass::Update(const ConnectClass* src)
1322 {
1323         config = src->config;
1324         type = src->type;
1325         fakelag = src->fakelag;
1326         name = src->name;
1327         registration_timeout = src->registration_timeout;
1328         host = src->host;
1329         pingtime = src->pingtime;
1330         softsendqmax = src->softsendqmax;
1331         hardsendqmax = src->hardsendqmax;
1332         recvqmax = src->recvqmax;
1333         penaltythreshold = src->penaltythreshold;
1334         commandrate = src->commandrate;
1335         maxlocal = src->maxlocal;
1336         maxglobal = src->maxglobal;
1337         maxconnwarn = src->maxconnwarn;
1338         maxchans = src->maxchans;
1339         limit = src->limit;
1340         resolvehostnames = src->resolvehostnames;
1341 }