ViewVC Help

View File | Revision Log | Show Annotations | View Changeset | Root Listing

root/svn/ircd-hybrid/trunk/src/channel.c

Comparing ircd-hybrid/trunk/src/channel.c (file contents):
Revision 3308 by michael, Mon Apr 14 19:08:17 2014 UTC vs.
Revision 4588 by michael, Tue Aug 26 15:59:07 2014 UTC

#	Line 15 | Line 15
15		*
16		*  You should have received a copy of the GNU General Public License
17		*  along with this program; if not, write to the Free Software
18	<	*  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307
18	>	*  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
19		*  USA
20		*/
21
#	Line 35 | Line 35
35		#include "irc_string.h"
36		#include "ircd.h"
37		#include "numeric.h"
38	<	#include "s_serv.h"
38	>	#include "server.h"
39		#include "send.h"
40		#include "event.h"
41		#include "memory.h"
42		#include "mempool.h"
43	<	#include "s_misc.h"
43	>	#include "misc.h"
44		#include "resv.h"
45
46
47	<	dlink_list global_channel_list;
47	>	dlink_list channel_list;
48		mp_pool_t *ban_pool;    /*! \todo ban_pool shouldn't be a global var */
49
50	+	struct event splitmode_event =
51	+	{
52	+	.name = "check_splitmode",
53	+	.handler = check_splitmode,
54	+	.when = 5
55	+	};
56	+
57		static mp_pool_t *member_pool, *channel_pool;
51	–	static char buf[IRCD_BUFSIZE];
58
59
60		/*! \brief Initializes the channel blockheap, adds known channel CAPAB
#	Line 109 | Line 115 | add_user_to_channel(struct Channel *chpt
115		}
116
117		ms = mp_pool_get(member_pool);
112	–	memset(ms, 0, sizeof(*ms));
113	–
118		ms->client_p = who;
119		ms->chptr = chptr;
120		ms->flags = flags;
121
122		dlinkAdd(ms, &ms->channode, &chptr->members);
123	+
124	+	if (MyConnect(who))
125	+	dlinkAdd(ms, &ms->locchannode, &chptr->locmembers);
126	+
127		dlinkAdd(ms, &ms->usernode, &who->channel);
128		}
129
#	Line 130 | Line 138 | remove_user_from_channel(struct Membersh
138		struct Channel *chptr = member->chptr;
139
140		dlinkDelete(&member->channode, &chptr->members);
141	+
142	+	if (MyConnect(client_p))
143	+	dlinkDelete(&member->locchannode, &chptr->locmembers);
144	+
145		dlinkDelete(&member->usernode, &client_p->channel);
146
147		mp_pool_release(member);
#	Line 148 | Line 160 | static void
160		send_members(struct Client *client_p, struct Channel *chptr,
161		char *modebuf, char *parabuf)
162		{
163	+	char buf[IRCD_BUFSIZE] = "";
164		const dlink_node *ptr = NULL;
165		int tlen;              /* length of text to append */
166		char *t, *start;       /* temp char pointer */
#	Line 160 | Line 173 | send_members(struct Client *client_p, st
173		{
174		const struct Membership *ms = ptr->data;
175
176	<	tlen = strlen(ms->client_p->id) + 1;  /* nick + space */
176	>	tlen = strlen(ms->client_p->id) + 1;  /* +1 for space */
177
178		if (ms->flags & CHFL_CHANOP)
179		++tlen;
167	–	#ifdef HALFOPS
180		if (ms->flags & CHFL_HALFOP)
181		++tlen;
170	–	#endif
182		if (ms->flags & CHFL_VOICE)
183		++tlen;
184
185		/*
186		* Space will be converted into CR, but we also need space for LF..
187	<	* That's why we use '- 1' here -adx
187	>	* That's why we use '- 1' here -adx
188		*/
189		if (t + tlen - buf > IRCD_BUFSIZE - 1)
190		{
#	Line 205 | Line 216 | send_members(struct Client *client_p, st
216		/*! \brief Sends +b/+e/+I
217		* \param client_p Client pointer to server
218		* \param chptr    Pointer to channel
219	<	* \param top      Pointer to top of mode link list to send
219	>	* \param list     Pointer to list of modes to send
220		* \param flag     Char flag flagging type of mode. Currently this can be 'b', e' or 'I'
221		*/
222		static void
223		send_mode_list(struct Client *client_p, struct Channel *chptr,
224	<	const dlink_list *top, char flag)
224	>	const dlink_list *list, const char flag)
225		{
226		const dlink_node *ptr = NULL;
227	+	char mbuf[IRCD_BUFSIZE] = "";
228		char pbuf[IRCD_BUFSIZE] = "";
229	<	int tlen, mlen, cur_len, count = 0;
229	>	int tlen, mlen, cur_len;
230		char *pp = pbuf;
231
232	<	if (top->length == 0)
232	>	if (list->length == 0)
233		return;
234
235	<	mlen = snprintf(buf, sizeof(buf), ":%s BMASK %lu %s %c :", me.id,
235	>	mlen = snprintf(mbuf, sizeof(mbuf), ":%s BMASK %lu %s %c :", me.id,
236		(unsigned long)chptr->channelts, chptr->chname, flag);
237		cur_len = mlen;
238
239	<	DLINK_FOREACH(ptr, top->head)
239	>	DLINK_FOREACH(ptr, list->head)
240		{
241		const struct Ban *banptr = ptr->data;
242
243	<	tlen = banptr->len + 3;
243	>	tlen = banptr->len + 3;  /* +3 for ! + @ + space */
244
245		/*
246	<	* Send buffer and start over if we cannot fit another ban,
235	<	* or if the target is non-ts6 and we have too many modes in
236	<	* in this line.
246	>	* Send buffer and start over if we cannot fit another ban
247		*/
248		if (cur_len + (tlen - 1) > IRCD_BUFSIZE - 2)
249		{
250		*(pp - 1) = '\0';  /* Get rid of trailing space on buffer */
251	<	sendto_one(client_p, "%s%s", buf, pbuf);
251	>	sendto_one(client_p, "%s%s", mbuf, pbuf);
252
253		cur_len = mlen;
254		pp = pbuf;
245	–	count = 0;
255		}
256
248	–	count++;
257		pp += sprintf(pp, "%s!%s@%s ", banptr->name, banptr->user,
258		banptr->host);
259		cur_len += tlen;
260		}
261
262		*(pp - 1) = '\0';  /* Get rid of trailing space on buffer */
263	<	sendto_one(client_p, "%s%s", buf, pbuf);
263	>	sendto_one(client_p, "%s%s", mbuf, pbuf);
264		}
265
266		/*! \brief Send "client_p" a full list of the modes for channel chptr
#	Line 282 | Line 290 | int
290		check_channel_name(const char *name, const int local)
291		{
292		const char *p = name;
293	<	const int max_length = local ? LOCAL_CHANNELLEN : CHANNELLEN;
293	>
294		assert(name != NULL);
295
296		if (!IsChanPrefix(*p))
#	Line 301 | Line 309 | check_channel_name(const char *name, con
309		return 0;
310		}
311
312	<	return p - name <= max_length;
312	>	return p - name <= CHANNELLEN;
313		}
314
315		void
#	Line 348 | Line 356 | make_channel(const char *chname)
356
357		chptr = mp_pool_get(channel_pool);
358
351	–	memset(chptr, 0, sizeof(*chptr));
352	–
359		/* Doesn't hurt to set it here */
360		chptr->channelts = CurrentTime;
361		chptr->last_join_time = CurrentTime;
362
363		strlcpy(chptr->chname, chname, sizeof(chptr->chname));
364	<	dlinkAdd(chptr, &chptr->node, &global_channel_list);
364	>	dlinkAdd(chptr, &chptr->node, &channel_list);
365
366		hash_add_channel(chptr);
367
#	Line 378 | Line 384 | destroy_channel(struct Channel *chptr)
384		free_channel_list(&chptr->exceptlist);
385		free_channel_list(&chptr->invexlist);
386
387	<	dlinkDelete(&chptr->node, &global_channel_list);
387	>	dlinkDelete(&chptr->node, &channel_list);
388		hash_del_channel(chptr);
389
390		mp_pool_release(chptr);
#	Line 409 | Line 415 | channel_member_names(struct Client *sour
415		int show_eon)
416		{
417		const dlink_node *ptr = NULL;
418	<	char lbuf[IRCD_BUFSIZE + 1] = "";
418	>	char buf[IRCD_BUFSIZE + 1] = "";
419		char *t = NULL, *start = NULL;
420		int tlen = 0;
421		int is_member = IsMember(source_p, chptr);
#	Line 418 | Line 424 | channel_member_names(struct Client *sour
424
425		if (PubChannel(chptr) || is_member)
426		{
427	<	t = lbuf + snprintf(lbuf, sizeof(lbuf), numeric_form(RPL_NAMREPLY),
428	<	me.name, source_p->name,
429	<	channel_pub_or_secret(chptr), chptr->chname);
427	>	t = buf + snprintf(buf, sizeof(buf), numeric_form(RPL_NAMREPLY),
428	>	me.name, source_p->name,
429	>	channel_pub_or_secret(chptr), chptr->chname);
430		start = t;
431
432		DLINK_FOREACH(ptr, chptr->members.head)
#	Line 431 | Line 437 | channel_member_names(struct Client *sour
437		continue;
438
439		if (!uhnames)
440	<	tlen = strlen(ms->client_p->name) + 1;  /* nick + space */
440	>	tlen = strlen(ms->client_p->name) + 1;  /* +1 for space */
441		else
442		tlen = strlen(ms->client_p->name) + strlen(ms->client_p->username) +
443	<	strlen(ms->client_p->host) + 3;
443	>	strlen(ms->client_p->host) + 3;  /* +3 for ! + @ + space */
444
445		if (!multi_prefix)
446		{
#	Line 451 | Line 457 | channel_member_names(struct Client *sour
457		++tlen;
458		}
459
460	<	if (t + tlen - lbuf > IRCD_BUFSIZE - 2)
460	>	if (t + tlen - buf > IRCD_BUFSIZE - 2)
461		{
462		*(t - 1) = '\0';
463	<	sendto_one(source_p, "%s", lbuf);
463	>	sendto_one(source_p, "%s", buf);
464		t = start;
465		}
466
#	Line 470 | Line 476 | channel_member_names(struct Client *sour
476		if (tlen)
477		{
478		*(t - 1) = '\0';
479	<	sendto_one(source_p, "%s", lbuf);
479	>	sendto_one(source_p, "%s", buf);
480		}
481		}
482
#	Line 490 | Line 496 | add_invite(struct Channel *chptr, struct
496		/*
497		* Delete last link in chain if the list is max length
498		*/
499	<	if (dlink_list_length(&who->localClient->invited) >=
500	<	ConfigChannel.max_chans_per_user)
501	<	del_invite(who->localClient->invited.tail->data, who);
499	>	if (dlink_list_length(&who->connection->invited) >=
500	>	ConfigChannel.max_channels)
501	>	del_invite(who->connection->invited.tail->data, who);
502
503		/* Add client to channel invite list */
504		dlinkAdd(who, make_dlink_node(), &chptr->invites);
505
506		/* Add channel to the end of the client invite list */
507	<	dlinkAdd(chptr, make_dlink_node(), &who->localClient->invited);
507	>	dlinkAdd(chptr, make_dlink_node(), &who->connection->invited);
508		}
509
510		/*! \brief Delete Invite block from channel invite list
#	Line 511 | Line 517 | del_invite(struct Channel *chptr, struct
517		{
518		dlink_node *ptr = NULL;
519
520	<	if ((ptr = dlinkFindDelete(&who->localClient->invited, chptr)))
520	>	if ((ptr = dlinkFindDelete(&who->connection->invited, chptr)))
521		free_dlink_node(ptr);
522
523		if ((ptr = dlinkFindDelete(&chptr->invites, who)))
#	Line 532 | Line 538 | del_invite(struct Channel *chptr, struct
538		const char *
539		get_member_status(const struct Membership *ms, const int combine)
540		{
541	<	static char buffer[4];
541	>	static char buffer[4];  /* 4 for @%+\0 */
542		char *p = buffer;
543
544		if (ms->flags & CHFL_CHANOP)
#	Line 542 | Line 548 | get_member_status(const struct Membershi
548		*p++ = '@';
549		}
550
545	–	#ifdef HALFOPS
551		if (ms->flags & CHFL_HALFOP)
552		{
553		if (!combine)
554		return "%";
555		*p++ = '%';
556		}
552	–	#endif
557
558		if (ms->flags & CHFL_VOICE)
559		*p++ = '+';
#	Line 582 | Line 586 | find_bmask(const struct Client *who, con
586		return 1;
587		break;
588		case HM_IPV4:
589	<	if (who->localClient->aftype == AF_INET)
590	<	if (match_ipv4(&who->localClient->ip, &bp->addr, bp->bits))
589	>	if (who->connection->aftype == AF_INET)
590	>	if (match_ipv4(&who->connection->ip, &bp->addr, bp->bits))
591		return 1;
592		break;
589	–	#ifdef IPV6
593		case HM_IPV6:
594	<	if (who->localClient->aftype == AF_INET6)
595	<	if (match_ipv6(&who->localClient->ip, &bp->addr, bp->bits))
594	>	if (who->connection->aftype == AF_INET6)
595	>	if (match_ipv6(&who->connection->ip, &bp->addr, bp->bits))
596		return 1;
597		break;
595	–	#endif
598		default:
599		assert(0);
600		}
#	Line 637 | Line 639 | can_join(struct Client *source_p, struct
639		return ERR_OPERONLYCHAN;
640
641		if (chptr->mode.mode & MODE_INVITEONLY)
642	<	if (!dlinkFind(&source_p->localClient->invited, chptr))
642	>	if (!dlinkFind(&source_p->connection->invited, chptr))
643		if (!find_bmask(source_p, &chptr->invexlist))
644		return ERR_INVITEONLYCHAN;
645
#	Line 684 | Line 686 | find_channel_link(struct Client *client_
686		return NULL;
687		}
688
689	<	/*
690	<	* Basically the same functionality as in bahamut
689	>	/*! Tests if a client can send to a channel
690	>	* \param message The actual message string the client wants to send
691	>	* \return 1 if the message does contain any control codes, 0 otherwise
692		*/
693		static int
694		msg_has_ctrls(const char *message)
#	Line 695 | Line 698 | msg_has_ctrls(const char *message)
698		for (; *p; ++p)
699		{
700		if (*p > 31 || *p == 1)
701	<	continue;
701	>	continue;  /* No control code or CTCP */
702
703	<	if (*p == 27)
703	>	if (*p == 27)  /* Escape */
704		{
705	+	/* ISO 2022 charset shift sequence */
706		if (*(p + 1) == '$' ||
707		*(p + 1) == '(')
708		{
#	Line 707 | Line 711 | msg_has_ctrls(const char *message)
711		}
712		}
713
714	<	return 1;
714	>	return 1;  /* Control code */
715		}
716
717		return 0;
#	Line 732 | Line 736 | can_send(struct Channel *chptr, struct C
736		return CAN_SEND_OPV;
737
738		if (MyClient(source_p) && !IsExemptResv(source_p))
739	<	if (!(HasUMode(source_p, UMODE_OPER) && ConfigFileEntry.oper_pass_resv))
739	>	if (!(HasUMode(source_p, UMODE_OPER) && ConfigGeneral.oper_pass_resv))
740		if ((conf = match_find_resv(chptr->chname)) && !resv_find_exempt(source_p, conf))
741		return ERR_CANNOTSENDTOCHAN;
742
#	Line 787 | Line 791 | check_spambot_warning(struct Client *sou
791		int decrement_count = 0;
792
793		if ((GlobalSetOptions.spam_num &&
794	<	(source_p->localClient->join_leave_count >=
794	>	(source_p->connection->join_leave_count >=
795		GlobalSetOptions.spam_num)))
796		{
797	<	if (source_p->localClient->oper_warn_count_down > 0)
798	<	source_p->localClient->oper_warn_count_down--;
797	>	if (source_p->connection->oper_warn_count_down > 0)
798	>	source_p->connection->oper_warn_count_down--;
799		else
800	<	source_p->localClient->oper_warn_count_down = 0;
800	>	source_p->connection->oper_warn_count_down = 0;
801
802	<	if (source_p->localClient->oper_warn_count_down == 0)
802	>	if (source_p->connection->oper_warn_count_down == 0)
803		{
804		/* It's already known as a possible spambot */
805		if (name)
#	Line 808 | Line 812 | check_spambot_warning(struct Client *sou
812		"User %s (%s@%s) is a possible spambot",
813		source_p->name, source_p->username,
814		source_p->host);
815	<	source_p->localClient->oper_warn_count_down = OPER_SPAM_COUNTDOWN;
815	>	source_p->connection->oper_warn_count_down = OPER_SPAM_COUNTDOWN;
816		}
817		}
818		else
819		{
820	<	if ((t_delta = (CurrentTime - source_p->localClient->last_leave_time)) >
820	>	if ((t_delta = (CurrentTime - source_p->connection->last_leave_time)) >
821		JOIN_LEAVE_COUNT_EXPIRE_TIME)
822		{
823		decrement_count = (t_delta / JOIN_LEAVE_COUNT_EXPIRE_TIME);
824	<	if (decrement_count > source_p->localClient->join_leave_count)
825	<	source_p->localClient->join_leave_count = 0;
824	>	if (decrement_count > source_p->connection->join_leave_count)
825	>	source_p->connection->join_leave_count = 0;
826		else
827	<	source_p->localClient->join_leave_count -= decrement_count;
827	>	source_p->connection->join_leave_count -= decrement_count;
828		}
829		else
830		{
831	<	if ((CurrentTime - (source_p->localClient->last_join_time)) <
831	>	if ((CurrentTime - (source_p->connection->last_join_time)) <
832		GlobalSetOptions.spam_time)
833	<	source_p->localClient->join_leave_count++;  /* It's a possible spambot */
833	>	source_p->connection->join_leave_count++;  /* It's a possible spambot */
834		}
835
836		if (name)
837	<	source_p->localClient->last_join_time = CurrentTime;
837	>	source_p->connection->last_join_time = CurrentTime;
838		else
839	<	source_p->localClient->last_leave_time = CurrentTime;
839	>	source_p->connection->last_leave_time = CurrentTime;
840		}
841		}
842
#	Line 846 | Line 850 | check_splitmode(void *unused)
850		if (splitchecking && (ConfigChannel.no_join_on_split ||
851		ConfigChannel.no_create_on_split))
852		{
853	<	const unsigned int server = dlink_list_length(&global_serv_list);
853	>	const unsigned int server = dlink_list_length(&global_server_list);
854
855		if (!splitmode && ((server < split_servers) || (Count.total < split_users)))
856		{
#	Line 854 | Line 858 | check_splitmode(void *unused)
858
859		sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
860		"Network split, activating splitmode");
861	<	eventAddIsh("check_splitmode", check_splitmode, NULL, 10);
861	>	event_add(&splitmode_event, NULL);
862		}
863	<	else if (splitmode && (server > split_servers) && (Count.total > split_users))
863	>	else if (splitmode && (server >= split_servers) && (Count.total >= split_users))
864		{
865		splitmode = 0;
866
867		sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
868		"Network rejoined, deactivating splitmode");
869	<	eventDelete(check_splitmode, NULL);
869	>	event_delete(&splitmode_event);
870		}
871		}
872		}
#	Line 875 | Line 879 | check_splitmode(void *unused)
879		* \param local      Whether the topic is set by a local client
880		*/
881		void
882	<	set_channel_topic(struct Channel *chptr, const char *topic,
882	>	channel_set_topic(struct Channel *chptr, const char *topic,
883		const char *topic_info, time_t topicts, int local)
884		{
885		if (local)
886	<	strlcpy(chptr->topic, topic, IRCD_MIN(sizeof(chptr->topic), ServerInfo.max_topic_length + 1));
886	>	strlcpy(chptr->topic, topic, IRCD_MIN(sizeof(chptr->topic), ConfigServerInfo.max_topic_length + 1));
887		else
888		strlcpy(chptr->topic, topic, sizeof(chptr->topic));
889
890		strlcpy(chptr->topic_info, topic_info, sizeof(chptr->topic_info));
891		chptr->topic_time = topicts;
892		}
893	+
894	+	/* do_join_0()
895	+	*
896	+	* inputs       - pointer to client doing join 0
897	+	* output       - NONE
898	+	* side effects - Use has decided to join 0. This is legacy
899	+	*                from the days when channels were numbers not names. *sigh*
900	+	*                There is a bunch of evilness necessary here due to
901	+	*                anti spambot code.
902	+	*/
903	+	void
904	+	channel_do_join_0(struct Client *source_p)
905	+	{
906	+	dlink_node *ptr = NULL, *ptr_next = NULL;
907	+
908	+	if (source_p->channel.head)
909	+	if (MyConnect(source_p) && !HasUMode(source_p, UMODE_OPER))
910	+	check_spambot_warning(source_p, NULL);
911	+
912	+	DLINK_FOREACH_SAFE(ptr, ptr_next, source_p->channel.head)
913	+	{
914	+	struct Channel *chptr = ((struct Membership *)ptr->data)->chptr;
915	+
916	+	sendto_server(source_p, NOCAPS, NOCAPS, ":%s PART %s",
917	+	source_p->id, chptr->chname);
918	+	sendto_channel_local(ALL_MEMBERS, 0, chptr, ":%s!%s@%s PART %s",
919	+	source_p->name, source_p->username,
920	+	source_p->host, chptr->chname);
921	+
922	+	remove_user_from_channel(ptr->data);
923	+	}
924	+	}
925	+
926	+	static char *
927	+	channel_find_last0(struct Client *source_p, char *chanlist)
928	+	{
929	+	int join0 = 0;
930	+
931	+	for (char *p = chanlist; *p; ++p)  /* Find last "JOIN 0" */
932	+	{
933	+	if (*p == '0' && (*(p + 1) == ',' || *(p + 1) == '\0'))
934	+	{
935	+	if ((*p + 1) == ',')
936	+	++p;
937	+
938	+	chanlist = p + 1;
939	+	join0 = 1;
940	+	}
941	+	else
942	+	{
943	+	while (*p != ',' && *p != '\0')  /* Skip past channel name */
944	+	++p;
945	+
946	+	if (*p == '\0')  /* Hit the end */
947	+	break;
948	+	}
949	+	}
950	+
951	+	if (join0)
952	+	channel_do_join_0(source_p);
953	+
954	+	return chanlist;
955	+	}
956	+
957	+	void
958	+	channel_do_join(struct Client *source_p, char *channel, char *key_list)
959	+	{
960	+	char *p = NULL;
961	+	char *chan = NULL;
962	+	char *chan_list = NULL;
963	+	struct Channel *chptr = NULL;
964	+	struct MaskItem *conf = NULL;
965	+	const struct ClassItem *class = get_class_ptr(&source_p->connection->confs);
966	+	int i = 0;
967	+	unsigned int flags = 0;
968	+
969	+	chan_list = channel_find_last0(source_p, channel);
970	+
971	+	for (chan = strtoken(&p, chan_list, ","); chan;
972	+	chan = strtoken(&p,      NULL, ","))
973	+	{
974	+	const char *key = NULL;
975	+
976	+	/* If we have any more keys, take the first for this channel. */
977	+	if (!EmptyString(key_list) && (key_list = strchr(key = key_list, ',')))
978	+	*key_list++ = '\0';
979	+
980	+	/* Empty keys are the same as no keys. */
981	+	if (key && *key == '\0')
982	+	key = NULL;
983	+
984	+	if (!check_channel_name(chan, 1))
985	+	{
986	+	sendto_one_numeric(source_p, &me, ERR_BADCHANNAME, chan);
987	+	continue;
988	+	}
989	+
990	+	if (!IsExemptResv(source_p) &&
991	+	!(HasUMode(source_p, UMODE_OPER) && ConfigGeneral.oper_pass_resv) &&
992	+	((conf = match_find_resv(chan)) && !resv_find_exempt(source_p, conf)))
993	+	{
994	+	++conf->count;
995	+	sendto_one_numeric(source_p, &me, ERR_CHANBANREASON,
996	+	chan, conf->reason ? conf->reason : "Reserved channel");
997	+	sendto_realops_flags(UMODE_REJ, L_ALL, SEND_NOTICE,
998	+	"Forbidding reserved channel %s from user %s",
999	+	chan, get_client_name(source_p, HIDE_IP));
1000	+	continue;
1001	+	}
1002	+
1003	+	if (dlink_list_length(&source_p->channel) >=
1004	+	((class->max_channels) ? class->max_channels : ConfigChannel.max_channels))
1005	+	{
1006	+	sendto_one_numeric(source_p, &me, ERR_TOOMANYCHANNELS, chan);
1007	+	break;
1008	+	}
1009	+
1010	+	if ((chptr = hash_find_channel(chan)))
1011	+	{
1012	+	if (IsMember(source_p, chptr))
1013	+	continue;
1014	+
1015	+	if (splitmode && !HasUMode(source_p, UMODE_OPER) &&
1016	+	ConfigChannel.no_join_on_split)
1017	+	{
1018	+	sendto_one_numeric(source_p, &me, ERR_UNAVAILRESOURCE, chptr->chname);
1019	+	continue;
1020	+	}
1021	+
1022	+	/*
1023	+	* can_join checks for +i key, bans.
1024	+	*/
1025	+	if ((i = can_join(source_p, chptr, key)))
1026	+	{
1027	+	sendto_one_numeric(source_p, &me, i, chptr->chname);
1028	+	continue;
1029	+	}
1030	+
1031	+	/*
1032	+	* This should never be the case unless there is some sort of
1033	+	* persistant channels.
1034	+	*/
1035	+	if (dlink_list_length(&chptr->members) == 0)
1036	+	flags = CHFL_CHANOP;
1037	+	else
1038	+	flags = 0;
1039	+	}
1040	+	else
1041	+	{
1042	+	if (splitmode && !HasUMode(source_p, UMODE_OPER) &&
1043	+	(ConfigChannel.no_create_on_split || ConfigChannel.no_join_on_split))
1044	+	{
1045	+	sendto_one_numeric(source_p, &me, ERR_UNAVAILRESOURCE, chan);
1046	+	continue;
1047	+	}
1048	+
1049	+	flags = CHFL_CHANOP;
1050	+	chptr = make_channel(chan);
1051	+	}
1052	+
1053	+	if (!HasUMode(source_p, UMODE_OPER))
1054	+	check_spambot_warning(source_p, chptr->chname);
1055	+
1056	+	add_user_to_channel(chptr, source_p, flags, 1);
1057	+
1058	+	/*
1059	+	*  Set timestamp if appropriate, and propagate
1060	+	*/
1061	+	if (flags == CHFL_CHANOP)
1062	+	{
1063	+	chptr->channelts = CurrentTime;
1064	+	chptr->mode.mode |= MODE_TOPICLIMIT;
1065	+	chptr->mode.mode |= MODE_NOPRIVMSGS;
1066	+
1067	+	sendto_server(source_p, NOCAPS, NOCAPS, ":%s SJOIN %lu %s +nt :@%s",
1068	+	me.id, (unsigned long)chptr->channelts,
1069	+	chptr->chname, source_p->id);
1070	+
1071	+	/*
1072	+	* Notify all other users on the new channel
1073	+	*/
1074	+	sendto_channel_local(ALL_MEMBERS, 0, chptr, ":%s!%s@%s JOIN :%s",
1075	+	source_p->name, source_p->username,
1076	+	source_p->host, chptr->chname);
1077	+	sendto_channel_local(ALL_MEMBERS, 0, chptr, ":%s MODE %s +nt",
1078	+	me.name, chptr->chname);
1079	+
1080	+	if (source_p->away[0])
1081	+	sendto_channel_local_butone(source_p, 0, CAP_AWAY_NOTIFY, chptr,
1082	+	":%s!%s@%s AWAY :%s",
1083	+	source_p->name, source_p->username,
1084	+	source_p->host, source_p->away);
1085	+	}
1086	+	else
1087	+	{
1088	+	sendto_server(source_p, NOCAPS, NOCAPS, ":%s JOIN %lu %s +",
1089	+	source_p->id, (unsigned long)chptr->channelts,
1090	+	chptr->chname);
1091	+	sendto_channel_local(ALL_MEMBERS, 0, chptr, ":%s!%s@%s JOIN :%s",
1092	+	source_p->name, source_p->username,
1093	+	source_p->host, chptr->chname);
1094	+
1095	+	if (source_p->away[0])
1096	+	sendto_channel_local_butone(source_p, 0, CAP_AWAY_NOTIFY, chptr,
1097	+	":%s!%s@%s AWAY :%s",
1098	+	source_p->name, source_p->username,
1099	+	source_p->host, source_p->away);
1100	+	}
1101	+
1102	+	del_invite(chptr, source_p);
1103	+
1104	+	if (chptr->topic[0])
1105	+	{
1106	+	sendto_one_numeric(source_p, &me, RPL_TOPIC, chptr->chname, chptr->topic);
1107	+	sendto_one_numeric(source_p, &me, RPL_TOPICWHOTIME, chptr->chname,
1108	+	chptr->topic_info, chptr->topic_time);
1109	+	}
1110	+
1111	+	channel_member_names(source_p, chptr, 1);
1112	+
1113	+	source_p->connection->last_join_time = CurrentTime;
1114	+	}
1115	+	}
1116	+
1117	+	/*! \brief Removes a client from a specific channel
1118	+	* \param source_p Pointer to source client to remove
1119	+	* \param name     Name of channel to remove from
1120	+	* \param reason   Part reason to show
1121	+	*/
1122	+	static void
1123	+	channel_part_one_client(struct Client *source_p, const char *name, const char *reason)
1124	+	{
1125	+	struct Channel *chptr = NULL;
1126	+	struct Membership *ms = NULL;
1127	+
1128	+	if ((chptr = hash_find_channel(name)) == NULL)
1129	+	{
1130	+	sendto_one_numeric(source_p, &me, ERR_NOSUCHCHANNEL, name);
1131	+	return;
1132	+	}
1133	+
1134	+	if ((ms = find_channel_link(source_p, chptr)) == NULL)
1135	+	{
1136	+	sendto_one_numeric(source_p, &me, ERR_NOTONCHANNEL, chptr->chname);
1137	+	return;
1138	+	}
1139	+
1140	+	if (MyConnect(source_p) && !HasUMode(source_p, UMODE_OPER))
1141	+	check_spambot_warning(source_p, NULL);
1142	+
1143	+	/*
1144	+	* Remove user from the old channel (if any)
1145	+	* only allow /part reasons in -m chans
1146	+	*/
1147	+	if (*reason && (!MyConnect(source_p) ||
1148	+	((can_send(chptr, source_p, ms, reason) &&
1149	+	(source_p->connection->firsttime + ConfigGeneral.anti_spam_exit_message_time)
1150	+	< CurrentTime))))
1151	+	{
1152	+	sendto_server(source_p, NOCAPS, NOCAPS, ":%s PART %s :%s",
1153	+	source_p->id, chptr->chname, reason);
1154	+	sendto_channel_local(ALL_MEMBERS, 0, chptr, ":%s!%s@%s PART %s :%s",
1155	+	source_p->name, source_p->username,
1156	+	source_p->host, chptr->chname, reason);
1157	+	}
1158	+	else
1159	+	{
1160	+	sendto_server(source_p, NOCAPS, NOCAPS, ":%s PART %s",
1161	+	source_p->id, chptr->chname);
1162	+	sendto_channel_local(ALL_MEMBERS, 0, chptr, ":%s!%s@%s PART %s",
1163	+	source_p->name, source_p->username,
1164	+	source_p->host, chptr->chname);
1165	+	}
1166	+
1167	+	remove_user_from_channel(ms);
1168	+	}
1169	+
1170	+	void
1171	+	channel_do_part(struct Client *source_p, char *channel, char *reason)
1172	+	{
1173	+	char *p = NULL, *name = NULL;
1174	+	char reasonbuf[KICKLEN + 1] = "";
1175	+
1176	+	if (!EmptyString(reason))
1177	+	strlcpy(reasonbuf, reason, sizeof(reasonbuf));
1178	+
1179	+	for (name = strtoken(&p, channel, ","); name;
1180	+	name = strtoken(&p,    NULL, ","))
1181	+	channel_part_one_client(source_p, name, reasonbuf);
1182	+	}

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines (old)
>	Changed lines (new)