[ViewVC] Diff of: cvs/deliantra/server/socket/request.C

Comparing deliantra/server/socket/request.C (file contents):
Revision 1.46 by root, Tue Dec 19 05:12:52 2006 UTC vs.
Revision 1.58 by root, Thu Jan 4 16:19:32 2007 UTC

…		…
138	}	138	}
139		139
140	static void	140	static void
141	clear_map (player *pl)	141	clear_map (player *pl)
142	{	142	{
143	memset (&pl->socket->lastmap, 0, sizeof (pl->socket->lastmap));	143	memset (&pl->ns->lastmap, 0, sizeof (pl->ns->lastmap));
144		144
145	if (pl->socket->newmapcmd == 1)	145	if (pl->ns->newmapcmd == 1)
146	pl->socket->send_packet ("newmap");	146	pl->ns->send_packet ("newmap");
147		147
148	pl->socket->floorbox_reset ();	148	pl->ns->floorbox_reset ();
149	}	149	}
150		150
151	/** check for map change and send new map data */	151	/** check for map change and send new map data */
152	static void	152	static void
153	check_map_change (player *pl)	153	check_map_change (player *pl)
154	{	154	{
155	client &socket = *pl->socket;	155	client &socket = *pl->ns;
156	object *ob = pl->ob;	156	object *ob = pl->ob;
157	char buf[MAX_BUF]; /* eauugggh */	157	char buf[MAX_BUF]; /* eauugggh */
158		158
159	if (socket.current_map != ob->map)	159	if (socket.current_map != ob->map)
160	{	160	{
…		…
176	flags \|= 4;	176	flags \|= 4;
177	if (ob->map->tile_path[3])	177	if (ob->map->tile_path[3])
178	flags \|= 8;	178	flags \|= 8;
179		179
180	snprintf (buf, MAX_BUF, "mapinfo - spatial %d %d %d %d %d %s",	180	snprintf (buf, MAX_BUF, "mapinfo - spatial %d %d %d %d %d %s",
181	flags, socket.mapx / 2 - ob->x, socket.mapy / 2 - ob->y, ob->map->width, ob->map->height, ob->map->path);	181	flags, socket.mapx / 2 - ob->x, socket.mapy / 2 - ob->y, ob->map->width, ob->map->height, &ob->map->path);
182	}	182	}
183	else	183	else
184	snprintf (buf, MAX_BUF, "mapinfo current");	184	snprintf (buf, MAX_BUF, "mapinfo current");
185		185
186	socket.send_packet (buf);	186	socket.send_packet (buf);
…		…
280	buf += 8;	280	buf += 8;
281		281
282	// initial map and its origin	282	// initial map and its origin
283	maptile *map = pl->ob->map;	283	maptile *map = pl->ob->map;
284	sint16 dx, dy;	284	sint16 dx, dy;
285	int mapx = pl->socket->mapx / 2 - pl->ob->x;	285	int mapx = pl->ns->mapx / 2 - pl->ob->x;
286	int mapy = pl->socket->mapy / 2 - pl->ob->y;	286	int mapy = pl->ns->mapy / 2 - pl->ob->y;
287	int max_distance = 8; // limit maximum path length to something generous	287	int max_distance = 8; // limit maximum path length to something generous
288		288
289	while (*buf && map && max_distance)	289	while (*buf && map && max_distance)
290	{	290	{
291	int dir = *buf++;	291	int dir = *buf++;
292		292
293	switch (dir)	293	switch (dir)
294	{	294	{
295	case '1':	295	case '1':
296	dx = 0;	296	dx = 0;
297	dy = -1;	297	dy = -1;
298	map = get_map_from_coord (map, &dx, &dy);	298	map = map->xy_find (dx, dy);
299	map && (mapy -= map->height);	299	map && (mapy -= map->height);
300	break;	300	break;
301	case '2':	301	case '2':
302	mapx += map->width;	302	mapx += map->width;
303	dx = map->width;	303	dx = map->width;
304	dy = 0;	304	dy = 0;
305	map = get_map_from_coord (map, &dx, &dy);	305	map = map->xy_find (dx, dy);
306	break;	306	break;
307	case '3':	307	case '3':
308	mapy += map->height;	308	mapy += map->height;
309	dx = 0;	309	dx = 0;
310	dy = map->height;	310	dy = map->height;
311	map = get_map_from_coord (map, &dx, &dy);	311	map = map->xy_find (dx, dy);
312	break;	312	break;
313	case '4':	313	case '4':
314	dx = -1;	314	dx = -1;
315	dy = 0;	315	dy = 0;
316	map = get_map_from_coord (map, &dx, &dy);	316	map = map->xy_find (dx, dy);
317	map && (mapx -= map->width);	317	map && (mapx -= map->width);
318	break;	318	break;
319	}	319	}
320		320
321	--max_distance;	321	--max_distance;
322	}	322	}
323		323
…		…
334	if (map->tile_path[2])	334	if (map->tile_path[2])
335	flags \|= 4;	335	flags \|= 4;
336	if (map->tile_path[3])	336	if (map->tile_path[3])
337	flags \|= 8;	337	flags \|= 8;
338		338
339	snprintf (bigbuf, MAX_BUF, "mapinfo %s spatial %d %d %d %d %d %s", token, flags, mapx, mapy, map->width, map->height, map->path);	339	snprintf (bigbuf, MAX_BUF, "mapinfo %s spatial %d %d %d %d %d %s", token, flags, mapx, mapy, map->width, map->height, &map->path);
340	}	340	}
341	else	341	else
342	snprintf (bigbuf, MAX_BUF, "mapinfo %s nomap", token);	342	snprintf (bigbuf, MAX_BUF, "mapinfo %s nomap", token);
343	}	343	}
344	else	344	else
345	snprintf (bigbuf, MAX_BUF, "mapinfo %s unsupported", token);	345	snprintf (bigbuf, MAX_BUF, "mapinfo %s unsupported", token);
346		346
347	pl->socket->send_packet (bigbuf);	347	pl->ns->send_packet (bigbuf);
348	}	348	}
349		349
350	/** This is the Setup cmd - easy first implementation */	350	/** This is the Setup cmd - easy first implementation */
351	void	351	void
352	SetUp (char buf, int len, client ns)	352	SetUp (char buf, int len, client ns)
…		…
399	{	399	{
400	ns->sound = atoi (param);	400	ns->sound = atoi (param);
401	safe_strcat (cmdback, param, &slen, HUGE_BUF);	401	safe_strcat (cmdback, param, &slen, HUGE_BUF);
402	}	402	}
403	else if (!strcmp (cmd, "exp64"))	403	else if (!strcmp (cmd, "exp64"))
404	{
405	ns->exp64 = atoi (param);
406	safe_strcat (cmdback, param, &slen, HUGE_BUF);	404	safe_strcat (cmdback, param, &slen, HUGE_BUF);
407	}
408	else if (!strcmp (cmd, "spellmon"))	405	else if (!strcmp (cmd, "spellmon"))
409	{	406	{
410	ns->monitor_spells = atoi (param);	407	ns->monitor_spells = atoi (param);
411	safe_strcat (cmdback, param, &slen, HUGE_BUF);	408	safe_strcat (cmdback, param, &slen, HUGE_BUF);
412	}	409	}
…		…
569	* it either has to be here or init_sockets needs to be exported.	566	* it either has to be here or init_sockets needs to be exported.
570	*/	567	*/
571	void	568	void
572	AddMeCmd (char buf, int len, client ns)	569	AddMeCmd (char buf, int len, client ns)
573	{	570	{
574	if (ns->status != Ns_Add \|\| add_player (ns))	571	INVOKE_CLIENT (ADDME, ns, ARG_DATA (buf, len));
575	ns->send_packet ("addme_failed");
576	else
577	ns->send_packet ("addme_success");
578	}	572	}
579		573
580	/** Reply to ExtendedInfos command */	574	/** Reply to ExtendedInfos command */
581	void	575	void
582	ToggleExtendedInfos (char buf, int len, client ns)	576	ToggleExtendedInfos (char buf, int len, client ns)
…		…
719	if (!(ns->faces_sent[smoothface] & NS_FACESENT_FACE))	713	if (!(ns->faces_sent[smoothface] & NS_FACESENT_FACE))
720	esrv_send_face (ns, smoothface, 0);	714	esrv_send_face (ns, smoothface, 0);
721		715
722	ns->faces_sent[face] \|= NS_FACESENT_SMOOTH;	716	ns->faces_sent[face] \|= NS_FACESENT_SMOOTH;
723		717
724	packet sl;	718	packet sl ("smooth");
725		719
726	sl << "smooth "
727	<< uint16 (face)	720	sl << uint16 (face)
728	<< uint16 (smoothface);	721	<< uint16 (smoothface);
729		722
730	ns->send_packet (sl);	723	ns->send_packet (sl);
731	}	724	}
732		725
…		…
809	int time = FABS (pl->ob->speed) < 0.001	802	int time = FABS (pl->ob->speed) < 0.001
810	? time = MAX_TIME * 100	803	? time = MAX_TIME * 100
811	: time = (int) (MAX_TIME / FABS (pl->ob->speed));	804	: time = (int) (MAX_TIME / FABS (pl->ob->speed));
812		805
813	/* Send confirmation of command execution now */	806	/* Send confirmation of command execution now */
814	packet sl;	807	packet sl ("comc");
815	sl << "comc " << uint16 (cmdid) << uint32 (time);	808	sl << uint16 (cmdid) << uint32 (time);
816	pl->socket->send_packet (sl);	809	pl->ns->send_packet (sl);
817	}	810	}
818
819		811
820	/** This is a reply to a previous query. */	812	/** This is a reply to a previous query. */
821	void	813	void
822	ReplyCmd (char buf, int len, player pl)	814	ReplyCmd (char buf, int len, client ns)
823	{	815	{
		816	if (ns->state == ST_CUSTOM)
		817	{
		818	INVOKE_CLIENT (REPLY, ns, ARG_DATA (buf, len));
		819	return;
		820	}
		821
		822	if (!ns->pl)
		823	return; //TODO: depends on the exact reply we are after
		824	//TODO: but right now, we always have a ns->pl
		825
		826	player *pl = ns->pl;
		827
824	/* This is to synthesize how the data would be stored if it	828	/* This is to synthesize how the data would be stored if it
825	* was normally entered. A bit of a hack, and should be cleaned up	829	* was normally entered. A bit of a hack, and should be cleaned up
826	* once all the X11 code is removed from the server.	830	* once all the X11 code is removed from the server.
827	*	831	*
828	* We pass 13 to many of the functions because this way they	832	* We pass 13 to many of the functions because this way they
…		…
831	*/	835	*/
832	snprintf (pl->write_buf, sizeof (pl->write_buf), ":%s", buf);	836	snprintf (pl->write_buf, sizeof (pl->write_buf), ":%s", buf);
833		837
834	/* this avoids any hacking here */	838	/* this avoids any hacking here */
835		839
836	switch (pl->state)	840	switch (ns->state)
837	{	841	{
838	case ST_PLAYING:	842	case ST_PLAYING:
839	LOG (llevError, "Got reply message with ST_PLAYING input state\n");	843	LOG (llevError, "Got reply message with ST_PLAYING input state\n");
840	break;	844	break;
841		845
842	case ST_PLAY_AGAIN:
843	/* We can check this for return value (2==quit). Maybe we
844	* should, and do something appropriate?
845	*/
846	receive_play_again (pl->ob, buf[0]);
847	break;
848
849	case ST_ROLL_STAT:
850	key_roll_stat (pl->ob, buf[0]);
851	break;
852
853	case ST_CHANGE_CLASS:	846	case ST_CHANGE_CLASS:
854
855	key_change_class (pl->ob, buf[0]);	847	key_change_class (pl->ob, buf[0]);
856	break;	848	break;
857		849
858	case ST_CONFIRM_QUIT:	850	case ST_CONFIRM_QUIT:
859	key_confirm_quit (pl->ob, buf[0]);	851	key_confirm_quit (pl->ob, buf[0]);
860	break;	852	break;
861		853
862	case ST_CONFIGURE:
863	LOG (llevError, "In client input handling, but into configure state\n");
864	pl->state = ST_PLAYING;
865	break;
866
867	case ST_GET_NAME:
868	receive_player_name (pl->ob, 13);
869	break;
870
871	case ST_GET_PASSWORD:
872	case ST_CONFIRM_PASSWORD:
873	receive_player_password (pl->ob, 13);
874	break;
875
876	case ST_GET_PARTY_PASSWORD: /* Get password for party */	854	case ST_GET_PARTY_PASSWORD: /* Get password for party */
877	receive_party_password (pl->ob, 13);	855	receive_party_password (pl->ob, 13);
878	break;	856	break;
879		857
880	default:	858	default:
881	LOG (llevError, "Unknown input state: %d\n", pl->state);	859	LOG (llevError, "Unknown input state: %d\n", ns->state);
882	}	860	}
883	}	861	}
884		862
885	/**	863	/**
886	* Client tells its version. If there is a mismatch, we close the	864	* Client tells its version. If there is a mismatch, we close the
…		…
936	{	914	{
937	ns->sound = atoi (buf);	915	ns->sound = atoi (buf);
938	}	916	}
939		917
940	/** client wants the map resent */	918	/** client wants the map resent */
941
942	void	919	void
943	MapRedrawCmd (char buf, int len, player pl)	920	MapRedrawCmd (char buf, int len, player pl)
944	{	921	{
945	/* This function is currently disabled; just clearing the map state results in	922	/* This function is currently disabled; just clearing the map state results in
946	* display errors. It should clear the cache and send a newmap command.	923	* display errors. It should clear the cache and send a newmap command.
…		…
1033	esrv_update_stats (player *pl)	1010	esrv_update_stats (player *pl)
1034	{	1011	{
1035	char buf[MAX_BUF];	1012	char buf[MAX_BUF];
1036	uint16 flags;	1013	uint16 flags;
1037		1014
1038	packet sl;	1015	if (!pl->ns)
1039	sl << "stats ";	1016	return;
		1017
		1018	packet sl ("stats");
1040		1019
1041	if (pl->ob)	1020	if (pl->ob)
1042	{	1021	{
1043	AddIfShort (pl->last_stats.hp, pl->ob->stats.hp, CS_STAT_HP);	1022	AddIfShort (pl->last_stats.hp, pl->ob->stats.hp, CS_STAT_HP);
1044	AddIfShort (pl->last_stats.maxhp, pl->ob->stats.maxhp, CS_STAT_MAXHP);	1023	AddIfShort (pl->last_stats.maxhp, pl->ob->stats.maxhp, CS_STAT_MAXHP);
1045	AddIfShort (pl->last_stats.sp, pl->ob->stats.sp, CS_STAT_SP);	1024	AddIfShort (pl->last_stats.sp, pl->ob->stats.sp, CS_STAT_SP);
1046	AddIfShort (pl->last_stats.maxsp, pl->ob->stats.maxsp, CS_STAT_MAXSP);	1025	AddIfShort (pl->last_stats.maxsp, pl->ob->stats.maxsp, CS_STAT_MAXSP);
1047	AddIfShort (pl->last_stats.grace, pl->ob->stats.grace, CS_STAT_GRACE);	1026	AddIfShort (pl->last_stats.grace, pl->ob->stats.grace, CS_STAT_GRACE);
1048	AddIfShort (pl->last_stats.maxgrace, pl->ob->stats.maxgrace, CS_STAT_MAXGRACE);	1027	AddIfShort (pl->last_stats.maxgrace, pl->ob->stats.maxgrace, CS_STAT_MAXGRACE);
1049	AddIfShort (pl->last_stats.Str, pl->ob->stats.Str, CS_STAT_STR);	1028	AddIfShort (pl->last_stats.Str, pl->ob->stats.Str, CS_STAT_STR);
1050	AddIfShort (pl->last_stats.Int, pl->ob->stats.Int, CS_STAT_INT);
1051	AddIfShort (pl->last_stats.Pow, pl->ob->stats.Pow, CS_STAT_POW);
1052	AddIfShort (pl->last_stats.Wis, pl->ob->stats.Wis, CS_STAT_WIS);
1053	AddIfShort (pl->last_stats.Dex, pl->ob->stats.Dex, CS_STAT_DEX);	1029	AddIfShort (pl->last_stats.Dex, pl->ob->stats.Dex, CS_STAT_DEX);
1054	AddIfShort (pl->last_stats.Con, pl->ob->stats.Con, CS_STAT_CON);	1030	AddIfShort (pl->last_stats.Con, pl->ob->stats.Con, CS_STAT_CON);
		1031	AddIfShort (pl->last_stats.Int, pl->ob->stats.Int, CS_STAT_INT);
		1032	AddIfShort (pl->last_stats.Wis, pl->ob->stats.Wis, CS_STAT_WIS);
		1033	AddIfShort (pl->last_stats.Pow, pl->ob->stats.Pow, CS_STAT_POW);
1055	AddIfShort (pl->last_stats.Cha, pl->ob->stats.Cha, CS_STAT_CHA);	1034	AddIfShort (pl->last_stats.Cha, pl->ob->stats.Cha, CS_STAT_CHA);
1056	}	1035	}
1057		1036
1058	if (pl->socket->exp64)
1059	for (int s = 0; s < NUM_SKILLS; s++)	1037	for (int s = 0; s < NUM_SKILLS; s++)
1060	if (pl->last_skill_ob[s] && pl->last_skill_exp[s] != pl->last_skill_ob[s]->stats.exp)	1038	if (pl->last_skill_ob[s] && pl->last_skill_exp[s] != pl->last_skill_ob[s]->stats.exp)
1061	{	1039	{
1062	/* Always send along the level if exp changes. This is only	1040	/* Always send along the level if exp changes. This is only
1063	* 1 extra byte, but keeps processing simpler.	1041	* 1 extra byte, but keeps processing simpler.
1064	*/	1042	*/
1065	sl << uint8 (s + CS_STAT_SKILLINFO)	1043	sl << uint8 (s + CS_STAT_SKILLINFO)
1066	<< uint8 (pl->last_skill_ob[s]->level)	1044	<< uint8 (pl->last_skill_ob[s]->level)
1067	<< uint64 (pl->last_skill_ob[s]->stats.exp);	1045	<< uint64 (pl->last_skill_ob[s]->stats.exp);
1068		1046
1069	pl->last_skill_exp[s] = pl->last_skill_ob[s]->stats.exp;	1047	pl->last_skill_exp[s] = pl->last_skill_ob[s]->stats.exp;
1070	}	1048	}
1071		1049
1072	if (pl->socket->exp64)
1073	{ AddIfInt64 (pl->last_stats.exp, pl->ob->stats.exp, CS_STAT_EXP64) }	1050	AddIfInt64 (pl->last_stats.exp, pl->ob->stats.exp, CS_STAT_EXP64);
1074	else
1075	{ AddIfInt (pl->last_stats.exp, (int) pl->ob->stats.exp, CS_STAT_EXP) }
1076
1077	AddIfShort (pl->last_level, (char) pl->ob->level, CS_STAT_LEVEL);	1051	AddIfShort (pl->last_level, (char) pl->ob->level, CS_STAT_LEVEL);
1078	AddIfShort (pl->last_stats.wc, pl->ob->stats.wc, CS_STAT_WC);	1052	AddIfShort (pl->last_stats.wc, pl->ob->stats.wc, CS_STAT_WC);
1079	AddIfShort (pl->last_stats.ac, pl->ob->stats.ac, CS_STAT_AC);	1053	AddIfShort (pl->last_stats.ac, pl->ob->stats.ac, CS_STAT_AC);
1080	AddIfShort (pl->last_stats.dam, pl->ob->stats.dam, CS_STAT_DAM);	1054	AddIfShort (pl->last_stats.dam, pl->ob->stats.dam, CS_STAT_DAM);
1081	AddIfFloat (pl->last_speed, pl->ob->speed, CS_STAT_SPEED);	1055	AddIfFloat (pl->last_speed, pl->ob->speed, CS_STAT_SPEED);
…		…
1090	if (pl->run_on)	1064	if (pl->run_on)
1091	flags \|= SF_RUNON;	1065	flags \|= SF_RUNON;
1092		1066
1093	AddIfShort (pl->last_flags, flags, CS_STAT_FLAGS);	1067	AddIfShort (pl->last_flags, flags, CS_STAT_FLAGS);
1094		1068
1095	if (pl->socket->sc_version < 1025)	1069	if (pl->ns->sc_version < 1025)
1096	{ AddIfShort (pl->last_resist[ATNR_PHYSICAL], pl->ob->resist[ATNR_PHYSICAL], CS_STAT_ARMOUR) }	1070	{ AddIfShort (pl->last_resist[ATNR_PHYSICAL], pl->ob->resist[ATNR_PHYSICAL], CS_STAT_ARMOUR) }
1097	else	1071	else
1098	for (int i = 0; i < NROFATTACKS; i++)	1072	for (int i = 0; i < NROFATTACKS; i++)
1099	{	1073	{
1100	/* Skip ones we won't send */	1074	/* Skip ones we won't send */
…		…
1102	continue;	1076	continue;
1103		1077
1104	AddIfShort (pl->last_resist[i], pl->ob->resist[i], (char) atnr_cs_stat[i]);	1078	AddIfShort (pl->last_resist[i], pl->ob->resist[i], (char) atnr_cs_stat[i]);
1105	}	1079	}
1106		1080
1107	if (pl->socket->monitor_spells)	1081	if (pl->ns->monitor_spells)
1108	{	1082	{
1109	AddIfInt (pl->last_path_attuned, pl->ob->path_attuned, CS_STAT_SPELL_ATTUNE);	1083	AddIfInt (pl->last_path_attuned, pl->ob->path_attuned, CS_STAT_SPELL_ATTUNE);
1110	AddIfInt (pl->last_path_repelled, pl->ob->path_repelled, CS_STAT_SPELL_REPEL);	1084	AddIfInt (pl->last_path_repelled, pl->ob->path_repelled, CS_STAT_SPELL_REPEL);
1111	AddIfInt (pl->last_path_denied, pl->ob->path_denied, CS_STAT_SPELL_DENY);	1085	AddIfInt (pl->last_path_denied, pl->ob->path_denied, CS_STAT_SPELL_DENY);
1112	}	1086	}
1113		1087
1114	rangetostring (pl->ob, buf); /* we want use the new fire & run system in new client */	1088	rangetostring (pl->ob, buf); /* we want use the new fire & run system in new client */
1115	AddIfString (pl->socket->stats.range, buf, CS_STAT_RANGE);	1089	AddIfString (pl->ns->stats.range, buf, CS_STAT_RANGE);
1116	set_title (pl->ob, buf);	1090	set_title (pl->ob, buf);
1117	AddIfString (pl->socket->stats.title, buf, CS_STAT_TITLE);	1091	AddIfString (pl->ns->stats.title, buf, CS_STAT_TITLE);
1118		1092
1119	/* Only send it away if we have some actual data */	1093	/* Only send it away if we have some actual data */
1120	if (sl.length () > 6)	1094	if (sl.length () > 6)
1121	pl->socket->send_packet (sl);	1095	pl->ns->send_packet (sl);
1122	}	1096	}
1123		1097
1124	/**	1098	/**
1125	* Tells the client that here is a player it should start using.	1099	* Tells the client that here is a player it should start using.
1126	*/	1100	*/
1127	void	1101	void
1128	esrv_new_player (player *pl, uint32 weight)	1102	esrv_new_player (player *pl, uint32 weight)
1129	{	1103	{
1130	pl->last_weight = weight;	1104	pl->last_weight = weight;
1131		1105
1132	packet sl;	1106	packet sl ("player");
1133	sl << "player ";
1134		1107
1135	sl << uint32 (pl->ob->count)	1108	sl << uint32 (pl->ob->count)
1136	<< uint32 (weight)	1109	<< uint32 (weight)
1137	<< uint32 (pl->ob->face->number)	1110	<< uint32 (pl->ob->face->number)
1138	<< data8 (pl->ob->name);	1111	<< data8 (pl->ob->name);
1139		1112
1140	pl->socket->send_packet (sl);	1113	pl->ns->send_packet (sl);
1141	SET_FLAG (pl->ob, FLAG_CLIENT_SENT);	1114	SET_FLAG (pl->ob, FLAG_CLIENT_SENT);
1142	}	1115	}
1143		1116
1144	/**	1117	/**
1145	* Need to send an animation sequence to the client.	1118	* Need to send an animation sequence to the client.
…		…
1159	{	1132	{
1160	LOG (llevError, "esrv_send_anim (%d) out of bounds??\n", anim_num);	1133	LOG (llevError, "esrv_send_anim (%d) out of bounds??\n", anim_num);
1161	return;	1134	return;
1162	}	1135	}
1163		1136
1164	packet sl;	1137	packet sl ("anim");
1165		1138
1166	sl << "anim "
1167	<< uint16 (anim_num)	1139	sl << uint16 (anim_num)
1168	<< uint16 (0); /* flags - not used right now */	1140	<< uint16 (0); /* flags - not used right now */
1169		1141
1170	/* Build up the list of faces. Also, send any information (ie, the	1142	/* Build up the list of faces. Also, send any information (ie, the
1171	* the face itself) down to the client.	1143	* the face itself) down to the client.
1172	*/	1144	*/
…		…
1533	ob = GET_MAP_FACE_OBJ (mp, mx, my, layer);	1505	ob = GET_MAP_FACE_OBJ (mp, mx, my, layer);
1534		1506
1535	/* If there is no object for this space, or if the face for the object	1507	/* If there is no object for this space, or if the face for the object
1536	* is the blank face, set the smoothlevel to zero.	1508	* is the blank face, set the smoothlevel to zero.
1537	*/	1509	*/
1538	if (!ob \|\| ob->face == blank_face \|\| MAP_NOSMOOTH (mp))	1510	if (!ob \|\| ob->face == blank_face)
1539	smoothlevel = 0;	1511	smoothlevel = 0;
1540	else	1512	else
1541	{	1513	{
1542	smoothlevel = ob->smoothlevel;	1514	smoothlevel = ob->smoothlevel;
1543	if (smoothlevel && !(ns.faces_sent[ob->face->number] & NS_FACESENT_SMOOTH))	1515	if (smoothlevel && !(ns.faces_sent[ob->face->number] & NS_FACESENT_SMOOTH))
…		…
1593	* we need 2 bytes for coordinates and 2 bytes for faces, such a trade off	1565	* we need 2 bytes for coordinates and 2 bytes for faces, such a trade off
1594	* maps no sense. Instead, we actually really only use 12 bits for coordinates,	1566	* maps no sense. Instead, we actually really only use 12 bits for coordinates,
1595	* and use the other 4 bits for other informatiion. For full documentation	1567	* and use the other 4 bits for other informatiion. For full documentation
1596	* of what we send, see the doc/Protocol file.	1568	* of what we send, see the doc/Protocol file.
1597	* I will describe internally what we do:	1569	* I will describe internally what we do:
1598	* the socket->lastmap shows how the map last looked when sent to the client.	1570	* the ns->lastmap shows how the map last looked when sent to the client.
1599	* in the lastmap structure, there is a cells array, which is set to the	1571	* in the lastmap structure, there is a cells array, which is set to the
1600	* maximum viewable size (As set in config.h).	1572	* maximum viewable size (As set in config.h).
1601	* in the cells, there are faces and a count value.	1573	* in the cells, there are faces and a count value.
1602	* we use the count value to hold the darkness value. If -1, then this space	1574	* we use the count value to hold the darkness value. If -1, then this space
1603	* is not viewable.	1575	* is not viewable.
…		…
1614	uint8 eentrysize;	1586	uint8 eentrysize;
1615	uint16 ewhatstart, ewhatflag;	1587	uint16 ewhatstart, ewhatflag;
1616	uint8 extendedinfos;	1588	uint8 extendedinfos;
1617	maptile *m;	1589	maptile *m;
1618		1590
1619	client &socket = *pl->contr->socket;	1591	client &socket = *pl->contr->ns;
		1592
		1593	if (!pl->active ())
		1594	return;
1620		1595
1621	check_map_change (pl->contr);	1596	check_map_change (pl->contr);
1622		1597
1623	packet sl;	1598	packet sl (socket.mapmode == Map1Cmd ? "map1" : "map1a");
1624	packet esl;	1599	packet esl;
1625		1600
1626	sl << (socket.mapmode == Map1Cmd ? "map1 " : "map1a ");
1627	startlen = sl.length ();	1601	startlen = sl.length ();
1628		1602
1629	/Extendedmapinfo structure initialisation /	1603	/Extendedmapinfo structure initialisation /
1630	if (socket.ext_mapinfos)	1604	if (socket.ext_mapinfos)
1631	{	1605	{
…		…
1675	for (y = pl->y - socket.mapy / 2; y < max_y; y++, ay++)	1649	for (y = pl->y - socket.mapy / 2; y < max_y; y++, ay++)
1676	{	1650	{
1677	ax = 0;	1651	ax = 0;
1678	for (x = pl->x - socket.mapx / 2; x < max_x; x++, ax++)	1652	for (x = pl->x - socket.mapx / 2; x < max_x; x++, ax++)
1679	{	1653	{
1680
1681	emask = mask = (ax & 0x3f) << 10 \| (ay & 0x3f) << 4;	1654	emask = mask = (ax & 0x3f) << 10 \| (ay & 0x3f) << 4;
1682		1655
1683	/* If this space is out of the normal viewable area, we only check	1656	/* If this space is out of the normal viewable area, we only check
1684	* the heads value ax or ay will only be greater than what	1657	* the heads value ax or ay will only be greater than what
1685	* the client wants if using the map1a command - this is because	1658	* the client wants if using the map1a command - this is because
…		…
1747	map_clearcell (&lastcell, 0, 0, 0, -1);	1720	map_clearcell (&lastcell, 0, 0, 0, -1);
1748	}	1721	}
1749	}	1722	}
1750	else if (d > 3)	1723	else if (d > 3)
1751	{	1724	{
		1725	m->touch ();
		1726
1752	int need_send = 0, count;	1727	int need_send = 0, count;
1753		1728
1754	/* This block deals with spaces that are not visible for whatever	1729	/* This block deals with spaces that are not visible for whatever
1755	* reason. Still may need to send the head for this space.	1730	* reason. Still may need to send the head for this space.
1756	*/	1731	*/
…		…
1789	else	1764	else
1790	sl.reset (oldlen);	1765	sl.reset (oldlen);
1791	}	1766	}
1792	else	1767	else
1793	{	1768	{
		1769	m->touch ();
		1770
1794	/* In this block, the space is visible or there are head objects	1771	/* In this block, the space is visible or there are head objects
1795	* we need to send.	1772	* we need to send.
1796	*/	1773	*/
1797		1774
1798	/* Rather than try to figure out what everything that we might	1775	/* Rather than try to figure out what everything that we might
…		…
2015	if (pm == NULL \|\| pm->in_memory != MAP_IN_MEMORY)	1992	if (pm == NULL \|\| pm->in_memory != MAP_IN_MEMORY)
2016	return;	1993	return;
2017		1994
2018	memset (&newmap, 0, sizeof (struct Map));	1995	memset (&newmap, 0, sizeof (struct Map));
2019		1996
2020	for (j = (pl->y - pl->contr->socket->mapy / 2); j < (pl->y + (pl->contr->socket->mapy + 1) / 2); j++)	1997	for (j = (pl->y - pl->contr->ns->mapy / 2); j < (pl->y + (pl->contr->ns->mapy + 1) / 2); j++)
2021	{
2022	for (i = (pl->x - pl->contr->socket->mapx / 2); i < (pl->x + (pl->contr->socket->mapx + 1) / 2); i++)	1998	for (i = (pl->x - pl->contr->ns->mapx / 2); i < (pl->x + (pl->contr->ns->mapx + 1) / 2); i++)
2023	{	1999	{
2024	ax = i;	2000	ax = i;
2025	ay = j;	2001	ay = j;
2026	m = pm;	2002	m = pm;
2027	mflags = get_map_flags (m, &m, ax, ay, &ax, &ay);	2003	mflags = get_map_flags (m, &m, ax, ay, &ax, &ay);
2028		2004
2029	if (mflags & P_OUT_OF_MAP)	2005	if (mflags & P_OUT_OF_MAP)
2030	continue;	2006	continue;
2031		2007
2032	if (mflags & P_NEED_UPDATE)
2033	update_position (m, ax, ay);
2034
2035	/* If a map is visible to the player, we don't want to swap it out	2008	/* If a map is visible to the player, we don't want to swap it out
2036	* just to reload it. This should really call something like	2009	* just to reload it. This should really call something like
2037	* swap_map, but this is much more efficient and 'good enough'	2010	* swap_map, but this is much more efficient and 'good enough'
2038	*/	2011	*/
2039	if (mflags & P_NEW_MAP)	2012	if (mflags & P_NEW_MAP)
2040	m->timeout = 50;	2013	m->timeout = 50;
2041	}	2014	}
2042	}	2015
2043	/* do LOS after calls to update_position */	2016	/* do LOS after calls to update_position */
2044	if (pl->contr->do_los)	2017	if (pl->contr->do_los)
2045	{	2018	{
2046	update_los (pl);	2019	update_los (pl);
2047	pl->contr->do_los = 0;	2020	pl->contr->do_los = 0;
…		…
2062		2035
2063	/*****************************************************************************/	2036	/*****************************************************************************/
2064	void	2037	void
2065	send_plugin_custom_message (object pl, char buf)	2038	send_plugin_custom_message (object pl, char buf)
2066	{	2039	{
2067	pl->contr->socket->send_packet (buf);	2040	pl->contr->ns->send_packet (buf);
2068	}	2041	}
2069		2042
2070	/**	2043	/**
2071	* This sends the skill number to name mapping. We ignore	2044	* This sends the skill number to name mapping. We ignore
2072	* the params - we always send the same info no matter what.	2045	* the params - we always send the same info no matter what.
…		…
2117	* it then sends an updspell packet for each spell that has changed in this way	2090	* it then sends an updspell packet for each spell that has changed in this way
2118	*/	2091	*/
2119	void	2092	void
2120	esrv_update_spells (player *pl)	2093	esrv_update_spells (player *pl)
2121	{	2094	{
		2095	if (!pl->ns)
		2096	return;
		2097
2122	if (!pl->socket->monitor_spells)	2098	if (!pl->ns->monitor_spells)
2123	return;	2099	return;
2124		2100
2125	for (object *spell = pl->ob->inv; spell; spell = spell->below)	2101	for (object *spell = pl->ob->inv; spell; spell = spell->below)
2126	{	2102	{
2127	if (spell->type == SPELL)	2103	if (spell->type == SPELL)
…		…
2157		2133
2158	if (flags & UPD_SP_MANA ) sl << uint16 (spell->last_sp);	2134	if (flags & UPD_SP_MANA ) sl << uint16 (spell->last_sp);
2159	if (flags & UPD_SP_GRACE ) sl << uint16 (spell->last_grace);	2135	if (flags & UPD_SP_GRACE ) sl << uint16 (spell->last_grace);
2160	if (flags & UPD_SP_DAMAGE) sl << uint16 (spell->last_eat);	2136	if (flags & UPD_SP_DAMAGE) sl << uint16 (spell->last_eat);
2161		2137
2162	pl->socket->send_packet (sl);	2138	pl->ns->send_packet (sl);
2163	}	2139	}
2164	}	2140	}
2165	}	2141	}
2166	}	2142	}
2167		2143
2168	void	2144	void
2169	esrv_remove_spell (player pl, object spell)	2145	esrv_remove_spell (player pl, object spell)
2170	{	2146	{
2171	if (!pl->socket->monitor_spells)	2147	if (!pl->ns->monitor_spells)
2172	return;	2148	return;
2173		2149
2174	if (!pl \|\| !spell \|\| spell->env != pl->ob)	2150	if (!pl \|\| !spell \|\| spell->env != pl->ob)
2175	{	2151	{
2176	LOG (llevError, "Invalid call to esrv_remove_spell");	2152	LOG (llevError, "Invalid call to esrv_remove_spell");
2177	return;	2153	return;
2178	}	2154	}
2179		2155
2180	packet sl;	2156	packet sl ("delspell");
2181		2157
2182	sl << "delspell "
2183	<< uint32 (spell->count);	2158	sl << uint32 (spell->count);
2184		2159
2185	pl->socket->send_packet (sl);	2160	pl->ns->send_packet (sl);
2186	}	2161	}
2187		2162
2188	/* appends the spell spell to the Socklist we will send the data to. /	2163	/* appends the spell spell to the Socklist we will send the data to. /
2189	static void	2164	static void
2190	append_spell (player pl, packet &sl, object spell)	2165	append_spell (player pl, packet &sl, object spell)
…		…
2238	{	2213	{
2239	LOG (llevError, "esrv_add_spells, tried to add a spell to a NULL player");	2214	LOG (llevError, "esrv_add_spells, tried to add a spell to a NULL player");
2240	return;	2215	return;
2241	}	2216	}
2242		2217
2243	if (!pl->socket->monitor_spells)	2218	if (!pl->ns->monitor_spells)
2244	return;	2219	return;
2245		2220
2246	packet sl;	2221	packet sl ("addspell");
2247	sl << "addspell ";
2248		2222
2249	if (!spell)	2223	if (!spell)
2250	{	2224	{
2251	for (spell = pl->ob->inv; spell != NULL; spell = spell->below)	2225	for (spell = pl->ob->inv; spell != NULL; spell = spell->below)
2252	{	2226	{
…		…
2266	if (spell->type != SPELL)	2240	if (spell->type != SPELL)
2267	continue;	2241	continue;
2268		2242
2269	if (sl.length () >= (MAXSOCKBUF - (26 + strlen (spell->name) + (spell->msg ? strlen (spell->msg) : 0))))	2243	if (sl.length () >= (MAXSOCKBUF - (26 + strlen (spell->name) + (spell->msg ? strlen (spell->msg) : 0))))
2270	{	2244	{
2271	pl->socket->send_packet (sl);	2245	pl->ns->send_packet (sl);
2272		2246
2273	sl.reset ();	2247	sl.reset ();
2274	sl << "addspell ";	2248	sl << "addspell ";
2275	}	2249	}
2276		2250
…		…
2290	LOG (llevError, "Buffer overflow in esrv_add_spells!\n");	2264	LOG (llevError, "Buffer overflow in esrv_add_spells!\n");
2291	fatal (0);	2265	fatal (0);
2292	}	2266	}
2293		2267
2294	/* finally, we can send the packet */	2268	/* finally, we can send the packet */
2295	pl->socket->send_packet (sl);	2269	pl->ns->send_packet (sl);
2296	}	2270	}
2297		2271

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Comparing deliantra/server/socket/request.C (file contents): Revision 1.46 by root, Tue Dec 19 05:12:52 2006 UTC vs. Revision 1.58 by root, Thu Jan 4 16:19:32 2007 UTC

Diff Legend

Comparing deliantra/server/socket/request.C (file contents):
Revision 1.46 by root, Tue Dec 19 05:12:52 2006 UTC vs.
Revision 1.58 by root, Thu Jan 4 16:19:32 2007 UTC