From 1abe8b013e2b12bebe47f401105ecbf2b46d29fa Mon Sep 17 00:00:00 2001 From: skotlex Date: Thu, 13 Apr 2006 18:10:08 +0000 Subject: - Added an Info message when pinging the SQL servers. - Changed line terminators back to *nix on map.c because otherwise it's impossible to run a diff between the stable and trunk versions of the file. git-svn-id: https://rathena.svn.sourceforge.net/svnroot/rathena/trunk@6043 54d463be-8e91-2dee-dedb-b68131a5f0ec --- src/char_sql/inter.c | 1 + src/login_sql/login.c | 1 + src/map/chrif.c | 1 - src/map/map.c | 7824 ++++++++++++++++++++++++------------------------- src/map/npc.c | 1 - 5 files changed, 3914 insertions(+), 3914 deletions(-) (limited to 'src') diff --git a/src/char_sql/inter.c b/src/char_sql/inter.c index 38fd1f289..d7e13c7c2 100644 --- a/src/char_sql/inter.c +++ b/src/char_sql/inter.c @@ -309,6 +309,7 @@ int inter_log(char *fmt,...) */ int inter_sql_ping(int tid, unsigned int tick, int id, int data) { + ShowInfo("Pinging SQL server to keep connection alive...\n"); mysql_ping(&mysql_handle); if(char_gm_read) mysql_ping(&lmysql_handle); diff --git a/src/login_sql/login.c b/src/login_sql/login.c index 1ed41ca27..d5819434d 100644 --- a/src/login_sql/login.c +++ b/src/login_sql/login.c @@ -359,6 +359,7 @@ int e_mail_check(char *email) { */ int login_sql_ping(int tid, unsigned int tick, int id, int data) { + ShowInfo("Pinging SQL server to keep connection alive...\n"); mysql_ping(&mysql_handle); return 0; } diff --git a/src/map/chrif.c b/src/map/chrif.c index f46fe1beb..ce0d0b19b 100644 --- a/src/map/chrif.c +++ b/src/map/chrif.c @@ -144,7 +144,6 @@ void chrif_checkdefaultlogin(void) } } - /*========================================== * *------------------------------------------ diff --git a/src/map/map.c b/src/map/map.c index a1a517ec8..d749d26bf 100644 --- a/src/map/map.c +++ b/src/map/map.c @@ -1,3755 +1,3755 @@ -// Copyright (c) Athena Dev Teams - Licensed under GNU GPL -// For more information, see LICENCE in the main folder - -#include -#include -#include -#include -#ifdef _WIN32 -#include -#else -#include -#include -#endif -#include - -#include "../common/core.h" -#include "../common/timer.h" -#include "../common/grfio.h" -#include "../common/malloc.h" -#include "../common/socket.h" -#include "../common/showmsg.h" -#include "../common/version.h" -#include "../common/nullpo.h" - -#include "map.h" -#include "chrif.h" -#include "clif.h" -#include "intif.h" -#include "npc.h" -#include "pc.h" -#include "status.h" -#include "mob.h" -#include "chat.h" -#include "itemdb.h" -#include "storage.h" -#include "skill.h" -#include "trade.h" -#include "party.h" -#include "unit.h" -#include "battle.h" -#include "script.h" -#include "guild.h" -#include "pet.h" -#include "atcommand.h" -#include "charcommand.h" - -#include "log.h" - -#include "charsave.h" - -#include "irc.h" - -// maybe put basic macros to somewhere else -#define swap(a,b) ((a == b) || ((a ^= b), (b ^= a), (a ^= b))) - -#ifndef TXT_ONLY - -#include "mail.h" // mail system [Valaris] - -MYSQL mmysql_handle; -MYSQL_RES* sql_res ; -MYSQL_ROW sql_row ; -char tmp_sql[65535]=""; - -MYSQL logmysql_handle; //For the log database - fix by [Maeki] -MYSQL_RES* logsql_res ; -MYSQL_ROW logsql_row ; - -MYSQL mail_handle; // mail system [Valaris] -MYSQL_RES* mail_res ; -MYSQL_ROW mail_row ; - -int map_server_port = 3306; -char map_server_ip[16] = "127.0.0.1"; -char map_server_id[32] = "ragnarok"; -char map_server_pw[32] = "ragnarok"; -char map_server_db[32] = "ragnarok"; -char default_codepage[32] = ""; //Feature by irmin. -int db_use_sqldbs = 0; -int connection_ping_interval = 0; - -int login_server_port = 3306; -char login_server_ip[16] = "127.0.0.1"; -char login_server_id[32] = "ragnarok"; -char login_server_pw[32] = "ragnarok"; -char login_server_db[32] = "ragnarok"; - -char item_db_db[32] = "item_db"; -char item_db2_db[32] = "item_db2"; -char mob_db_db[32] = "mob_db"; -char mob_db2_db[32] = "mob_db2"; - -char login_db[32] = "login"; -char login_db_level[32] = "level"; -char login_db_account_id[32] = "account_id"; - -int log_db_port = 3306; -char log_db_ip[16] = "127.0.0.1"; -char log_db_id[32] = "ragnarok"; -char log_db_pw[32] = "ragnarok"; -char log_db[32] = "log"; - -int mail_server_port = 3306; -char mail_server_ip[16] = "127.0.0.1"; -char mail_server_id[32] = "ragnarok"; -char mail_server_pw[32] = "ragnarok"; -char mail_server_db[32] = "ragnarok"; -int mail_server_enable = 0; - -char gm_db[32] = "login"; -char gm_db_level[32] = "level"; -char gm_db_account_id[32] = "account_id"; - -int read_gm_interval = 600000; - -char char_db[32] = "char"; - -char mail_db[32] = "mail"; - -char charsql_host[40] = "localhost"; -int charsql_port = 3306; -char charsql_user[32] = "ragnarok"; -char charsql_pass[32] = "eAthena"; -char charsql_db[40] = "ragnarok"; -MYSQL charsql_handle; -MYSQL_RES* charsql_res; -MYSQL_ROW charsql_row; - -#endif /* not TXT_ONLY */ - -int lowest_gm_level = 1; - -// This param using for sending mainchat -// messages like whispers to this nick. [LuzZza] -char main_chat_nick[16] = "Main"; - -char *INTER_CONF_NAME; -char *LOG_CONF_NAME; -char *MAP_CONF_NAME; -char *BATTLE_CONF_FILENAME; -char *ATCOMMAND_CONF_FILENAME; -char *CHARCOMMAND_CONF_FILENAME; -char *SCRIPT_CONF_NAME; -char *MSG_CONF_NAME; -char *GRF_PATH_FILENAME; - -// ‹É—Í static‚Ń?ƒJƒ‹‚É?‚ß‚é -static struct dbt * id_db=NULL; -static struct dbt * pc_db=NULL; -static struct dbt * map_db=NULL; -static struct dbt * charid_db=NULL; - -static int map_users=0; -static struct block_list *objects[MAX_FLOORITEM]; -static int first_free_object_id=0,last_object_id=0; - -#define block_free_max 1048576 -struct block_list *block_free[block_free_max]; -static int block_free_count = 0, block_free_lock = 0; - -#define BL_LIST_MAX 1048576 -static struct block_list *bl_list[BL_LIST_MAX]; -static int bl_list_count = 0; - -static char afm_dir[1024] = ""; // [Valaris] - -struct map_data map[MAX_MAP_PER_SERVER]; -int map_num = 0; - -int map_port=0; - -int autosave_interval = DEFAULT_AUTOSAVE_INTERVAL; -int charsave_method = 0; //Default 'OLD' Save method (SQL ONLY!) [Sirius] -int agit_flag = 0; -int night_flag = 0; // 0=day, 1=night [Yor] -int kick_on_disconnect = 1; - -struct charid2nick { - char nick[NAME_LENGTH]; - int req_id; -}; - -// «Þ«Ã«×«­«ã«Ã«·«å××éÄ«Õ«é«°(map_athana.conf?ªÎread_map_from_cacheªÇò¦E) -// 0:××éĪ·ªÊª¤ 1:Þª?õêÜÁðí 2:?õêÜÁðí -int map_read_flag = READ_FROM_GAT; -char map_cache_file[256]="db/map.info"; // «Þ«Ã«×«­«ã«Ã«·«å«Õ«¡«¤«E£ - -char db_path[256] = "db"; -char motd_txt[256] = "conf/motd.txt"; -char help_txt[256] = "conf/help.txt"; -char help2_txt[256] = "conf/help2.txt"; -char charhelp_txt[256] = "conf/charhelp.txt"; - -char wisp_server_name[NAME_LENGTH] = "Server"; // can be modified in char-server configuration file - -int console = 0; -int enable_spy = 0; //To enable/disable @spy commands, which consume too much cpu time when sending packets. [Skotlex] - -static const int dirx[8]={0,-1,-1,-1,0,1,1,1}; -static const int diry[8]={1,1,0,-1,-1,-1,0,1}; - -/*========================================== - * ‘SmapŽI?Œv‚Å‚ÌÚ??Ý’è - * (charŽI‚©‚ç‘—‚ç‚ê‚Ä‚­‚é) - *------------------------------------------ - */ -void map_setusers(int fd) -{ - RFIFOHEAD(fd); - WFIFOHEAD(fd, 2); - - map_users = RFIFOL(fd,2); - // send some anser - WFIFOW(fd,0) = 0x2718; - WFIFOSET(fd,2); -} - -/*========================================== - * ‘SmapŽI?Œv‚Å‚ÌÚ??Žæ“¾ (/w‚Ö‚Ì?“š—p) - *------------------------------------------ - */ -int map_getusers(void) { - return map_users; -} - - -//Distance functions, taken from http://www.flipcode.com/articles/article_fastdistance.shtml -int check_distance(int dx, int dy, int distance) { - //In this case, we just do a square comparison. Add 1 tile grace for diagonal range checks. - return (dx*dx + dy*dy <= distance*distance + (dx&&dy?1:0)); -} - -unsigned int distance(int dx, int dy) { - unsigned int min, max; - - if ( dx < 0 ) dx = -dx; - if ( dy < 0 ) dy = -dy; - //There appears to be something wrong with the aproximation below when either dx/dy is 0! [Skotlex] - if ( dx == 0 ) return dy; - if ( dy == 0 ) return dx; - - if ( dx < dy ) - { - min = dx; - max = dy; - } else { - min = dy; - max = dx; - } - // coefficients equivalent to ( 123/128 * max ) and ( 51/128 * min ) - return ((( max << 8 ) + ( max << 3 ) - ( max << 4 ) - ( max << 1 ) + - ( min << 7 ) - ( min << 5 ) + ( min << 3 ) - ( min << 1 )) >> 8 ); -} - -// -// block휂̈À‘S«Šm•Û?— -// - -/*========================================== - * block‚ðfree‚·‚é‚Æ‚«free‚Ì?‚í‚è‚ÉŒÄ‚Ô - * ƒƒbƒN‚³‚ê‚Ä‚¢‚é‚Æ‚«‚̓oƒbƒtƒ@‚É‚½‚ß‚é - *------------------------------------------ - */ -int map_freeblock (struct block_list *bl) -{ - if (block_free_lock == 0 || block_free_count >= block_free_max) - { - aFree(bl); - bl = NULL; - if (block_free_count >= block_free_max) - if (battle_config.error_log) - ShowWarning("map_freeblock: too many free block! %d %d\n", - block_free_count, block_free_lock); - } else - block_free[block_free_count++] = bl; - - return block_free_lock; -} -/*========================================== - * block‚Ìfree‚ðˆêŽsI‚É‹ÖŽ~‚·‚é - *------------------------------------------ - */ -int map_freeblock_lock (void) -{ - return ++block_free_lock; -} - -/*========================================== - * block‚Ìfree‚̃ƒbƒN‚ð‰ðœ‚·‚é - * ‚±‚Ì‚Æ‚«AƒƒbƒN‚ªŠ®‘S‚É‚È‚­‚È‚é‚Æ - * ƒoƒbƒtƒ@‚É‚½‚Ü‚Á‚Ä‚¢‚½block‚ð‘S•”íœ - *------------------------------------------ - */ -int map_freeblock_unlock (void) -{ - if ((--block_free_lock) == 0) { - int i; - for (i = 0; i < block_free_count; i++) - { //Directly calling aFree shouldn't be a leak, as Free remembers the size the original pointed to memory was allocated with? [Skotlex] - aFree(block_free[i]); - block_free[i] = NULL; - } - block_free_count = 0; - } else if (block_free_lock < 0) { - if (battle_config.error_log) - ShowError("map_freeblock_unlock: lock count < 0 !\n"); - block_free_lock = 0; // ŽŸ‰ñˆÈ~‚̃ƒbƒN‚ÉŽxႪo‚Ä‚­‚é‚̂ŃŠƒZƒbƒg - } - - return block_free_lock; -} - -// map_freeblock_lock() ‚ðŒÄ‚ñ‚Å map_freeblock_unlock() ‚ðŒÄ‚΂Ȃ¢ -// ŠÖ”‚ª‚ ‚Á‚½‚Ì‚ÅA’èŠú“I‚Éblock_free_lock‚ðƒŠƒZƒbƒg‚·‚é‚悤‚É‚·‚éB -// ‚±‚ÌŠÖ”‚ÍAdo_timer() ‚̃gƒbƒvƒŒƒxƒ‹‚©‚çŒÄ‚΂ê‚é‚Ì‚ÅA -// block_free_lock ‚ð’¼Ú‚¢‚¶‚Á‚Ä‚àŽxá–³‚¢‚Í‚¸B - -int map_freeblock_timer (int tid, unsigned int tick, int id, int data) -{ - if (block_free_lock > 0) { - ShowError("map_freeblock_timer: block_free_lock(%d) is invalid.\n", block_free_lock); - block_free_lock = 1; - map_freeblock_unlock(); - } - - return 0; -} - -// -// block‰»?— -// -/*========================================== - * map[]‚Ìblock_list‚©‚ç?‚ª‚Á‚Ä‚¢‚éê‡‚É - * bl->prev‚Ébl_head‚̃AƒhƒŒƒX‚ð“ü‚ê‚Ä‚¨‚­ - *------------------------------------------ - */ -static struct block_list bl_head; - -#ifdef CELL_NOSTACK -/*========================================== - * These pair of functions update the counter of how many objects - * lie on a tile. - *------------------------------------------ - */ -void map_addblcell(struct block_list *bl) -{ - if(bl->m<0 || bl->x<0 || bl->x>=map[bl->m].xs - || bl->y<0 || bl->y>=map[bl->m].ys || !(bl->type&BL_CHAR)) - return; - map[bl->m].cell_bl[bl->x+bl->y*map[bl->m].xs]++; - return; -} - -void map_delblcell(struct block_list *bl) -{ - if(bl->m <0 || bl->x<0 || bl->x>=map[bl->m].xs - || bl->y<0 || bl->y>=map[bl->m].ys || !(bl->type&BL_CHAR)) - return; - map[bl->m].cell_bl[bl->x+bl->y*map[bl->m].xs]--; -} -#endif - -/*========================================== - * Adds a block to the map. - * If flag is 1, then the block was just added - * otherwise it is part of a transition. - *------------------------------------------ - */ -int map_addblock_sub (struct block_list *bl, int flag) -{ - int m, x, y, pos; - - nullpo_retr(0, bl); - - if (bl->prev != NULL) { - if(battle_config.error_log) - ShowError("map_addblock error : bl->prev != NULL\n"); - return 0; - } - - m = bl->m; - x = bl->x; - y = bl->y; - if (m < 0 || m >= map_num || - x < 0 || x >= map[m].xs || - y < 0 || y >= map[m].ys) - return 1; - -#ifdef CELL_NOSTACK - map_addblcell(bl); -#endif - - pos = x/BLOCK_SIZE+(y/BLOCK_SIZE)*map[m].bxs; - if (bl->type == BL_MOB) { - bl->next = map[m].block_mob[pos]; - bl->prev = &bl_head; - if (bl->next) bl->next->prev = bl; - map[m].block_mob[pos] = bl; - map[m].block_mob_count[pos]++; - } else { - bl->next = map[m].block[pos]; - bl->prev = &bl_head; - if (bl->next) bl->next->prev = bl; - map[m].block[pos] = bl; - map[m].block_count[pos]++; - if (bl->type == BL_PC && flag) - { - struct map_session_data* sd; - if (map[m].users++ == 0 && battle_config.dynamic_mobs) //Skotlex - map_spawnmobs(m); - sd = (struct map_session_data*)bl; - if (battle_config.pet_no_gvg && map_flag_gvg(m) && sd->pd) - { //Return the pet to egg. [Skotlex] - clif_displaymessage(sd->fd, "Pets are not allowed in Guild Wars."); - pet_menu(sd, 3); //Option 3 is return to egg. - } - } - } - - return 0; -} - -/*========================================== - * Removes a block from the map. - * If flag is 1, then the block is removed for good - * otherwise it is part of a transition. - *------------------------------------------ - */ -int map_delblock_sub (struct block_list *bl, int flag) -{ - int b; - nullpo_retr(0, bl); - - // ?‚Éblocklist‚©‚ç?‚¯‚Ä‚¢‚é - if (bl->prev == NULL) { - if (bl->next != NULL) { - // prev‚ªNULL‚Ånext‚ªNULL‚Å‚È‚¢‚Ì‚Í—L‚Á‚Ä‚Í‚È‚ç‚È‚¢ - if(battle_config.error_log) - ShowError("map_delblock error : bl->next!=NULL\n"); - } - return 0; - } - -#ifdef CELL_NOSTACK - map_delblcell(bl); -#endif - - b = bl->x/BLOCK_SIZE+(bl->y/BLOCK_SIZE)*map[bl->m].bxs; - - if (bl->type == BL_PC && flag) - if (--map[bl->m].users == 0 && battle_config.dynamic_mobs) //[Skotlex] - map_removemobs(bl->m); - - if (bl->next) - bl->next->prev = bl->prev; - if (bl->prev == &bl_head) { - // ƒŠƒXƒg‚Ì“ª‚È‚Ì‚ÅAmap[]‚Ìblock_list‚ðXV‚·‚é - if (bl->type == BL_MOB) { - map[bl->m].block_mob[b] = bl->next; - if ((map[bl->m].block_mob_count[b]--) < 0) - map[bl->m].block_mob_count[b] = 0; - } else { - map[bl->m].block[b] = bl->next; - if((map[bl->m].block_count[b]--) < 0) - map[bl->m].block_count[b] = 0; - } - } else { - bl->prev->next = bl->next; - } - bl->next = NULL; - bl->prev = NULL; - - return 0; -} - -/*========================================== - * Moves a block a x/y target position. [Skotlex] - * Pass flag as 1 to prevent doing skill_unit_move checks - * (which are executed by default on BL_CHAR types) - *------------------------------------------ - */ -int map_moveblock(struct block_list *bl, int x1, int y1, unsigned int tick) { - int x0 = bl->x, y0 = bl->y; - struct status_change *sc = NULL; - int moveblock = ( x0/BLOCK_SIZE != x1/BLOCK_SIZE || y0/BLOCK_SIZE != y1/BLOCK_SIZE); - - if (!bl->prev) { - //Block not in map, just update coordinates, but do naught else. - bl->x = x1; - bl->y = y1; - return 0; - } - //TODO: Perhaps some outs of bounds checking should be placed here? - if (bl->type&BL_CHAR) { - skill_unit_move(bl,tick,2); - sc = status_get_sc(bl); - if (sc && sc->count) { - if (sc->data[SC_CLOSECONFINE].timer != -1) - status_change_end(bl, SC_CLOSECONFINE, -1); - if (sc->data[SC_CLOSECONFINE2].timer != -1) - status_change_end(bl, SC_CLOSECONFINE2, -1); - } - } - if (moveblock) map_delblock_sub(bl,0); -#ifdef CELL_NOSTACK - else map_delblcell(bl); -#endif - bl->x = x1; - bl->y = y1; - if (moveblock) map_addblock_sub(bl,0); -#ifdef CELL_NOSTACK - else map_addblcell(bl); -#endif - if (bl->type&BL_CHAR) { - skill_unit_move(bl,tick,3); - if (sc) { - if (sc->option&OPTION_CLOAK) - skill_check_cloaking(bl); - if (sc->count) { - if (sc->data[SC_DANCING].timer != -1) { - //Cancel Moonlight Petals if moved from casting position. [Skotlex] - if (sc->data[SC_DANCING].val1 == CG_MOONLIT) - skill_stop_dancing(bl); - else - skill_unit_move_unit_group((struct skill_unit_group *)sc->data[SC_DANCING].val2, bl->m, x1-x0, y1-y0); - } - } - } - } - return 0; -} - -/*========================================== - * Žü?‚ÌPCl?‚ð?‚¦‚é (unused) - *------------------------------------------ - */ -int map_countnearpc (int m, int x, int y) -{ - int bx, by, c = 0; - struct block_list *bl=NULL; - - if (map[m].users == 0) - return 0; - for (by = y/BLOCK_SIZE-AREA_SIZE/BLOCK_SIZE-1; by<=y/BLOCK_SIZE+AREA_SIZE/BLOCK_SIZE+1; by++) { - if (by < 0 || by >= map[m].bys) - continue; - for (bx = x/BLOCK_SIZE-AREA_SIZE/BLOCK_SIZE-1; bx <= x/BLOCK_SIZE+AREA_SIZE/BLOCK_SIZE+1; bx++) { - if (bx < 0 || bx >= map[m].bxs) - continue; - bl = map[m].block[bx+by*map[m].bxs]; - while(bl) { - if (bl->type == BL_PC) - c++; - bl = bl->next; - } - } - } - - return c; -} - -/*========================================== - * Counts specified number of objects on given cell. - *------------------------------------------ - */ -int map_count_oncell(int m, int x, int y, int type) { - int bx,by; - struct block_list *bl=NULL; - int i,c; - int count = 0; - - if (x < 0 || y < 0 || (x >= map[m].xs) || (y >= map[m].ys)) - return 0; - bx = x/BLOCK_SIZE; - by = y/BLOCK_SIZE; - - if (type == 0 || type != BL_MOB) - { - bl = map[m].block[bx+by*map[m].bxs]; - c = map[m].block_count[bx+by*map[m].bxs]; - for(i=0;inext) - if(bl->x == x && bl->y == y && bl->type == (type?type:BL_PC)) count++; - } - - if (type == 0 || type == BL_MOB) - { - bl = map[m].block_mob[bx+by*map[m].bxs]; - c = map[m].block_mob_count[bx+by*map[m].bxs]; - for(i=0;inext){ - if(bl->x == x && bl->y == y) count++; - } - } - return count; -} -/* - * «»«E¾ªÎõÌôøªË̸ªÄª±ª¿«¹«­«Eæ«Ë«Ã«ÈªòÚ÷ª¹ - */ -struct skill_unit *map_find_skill_unit_oncell(struct block_list *target,int x,int y,int skill_id,struct skill_unit *out_unit) -{ - int m,bx,by; - struct block_list *bl; - int i,c; - struct skill_unit *unit; - m = target->m; - - if (x < 0 || y < 0 || (x >= map[m].xs) || (y >= map[m].ys)) - return NULL; - bx = x/BLOCK_SIZE; - by = y/BLOCK_SIZE; - - bl = map[m].block[bx+by*map[m].bxs]; - c = map[m].block_count[bx+by*map[m].bxs]; - for(i=0;inext){ - if (bl->x != x || bl->y != y || bl->type != BL_SKILL) - continue; - unit = (struct skill_unit *) bl; - if (unit==out_unit || !unit->alive || - !unit->group || unit->group->skill_id!=skill_id) - continue; - if (battle_check_target(&unit->bl,target,unit->group->target_flag)>0) - return unit; - } - return NULL; -} - -/*========================================== - * Adapted from foreachinarea for an easier invocation. [Skotlex] - *------------------------------------------ - */ - -int map_foreachinrange(int (*func)(struct block_list*,va_list),struct block_list *center, int range,int type,...) { - va_list ap; - int bx,by,m; - int returnCount =0; //total sum of returned values of func() [Skotlex] - struct block_list *bl=NULL; - int blockcount=bl_list_count,i,c; - int x0,x1,y0,y1; - m = center->m; - if (m < 0) - return 0; - va_start(ap,type); - x0 = center->x-range; - x1 = center->x+range; - y0 = center->y-range; - y1 = center->y+range; - - if (x0 < 0) x0 = 0; - if (y0 < 0) y0 = 0; - if (x1 >= map[m].xs) x1 = map[m].xs-1; - if (y1 >= map[m].ys) y1 = map[m].ys-1; - - if (type&~BL_MOB) - for (by = y0 / BLOCK_SIZE; by <= y1 / BLOCK_SIZE; by++) { - for(bx=x0/BLOCK_SIZE;bx<=x1/BLOCK_SIZE;bx++){ - bl = map[m].block[bx+by*map[m].bxs]; - c = map[m].block_count[bx+by*map[m].bxs]; - for(i=0;inext){ - if(bl && bl->type&type - && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 - //For speed purposes, it does not checks actual range by default. - //Feel free to uncomment if you want a more "exact" approach. -// && check_distance_bl(center, bl, range) - && bl_list_countnext){ - if(bl - && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 - && check_distance_bl(center, bl, range) - && bl_list_count=BL_LIST_MAX) { - if(battle_config.error_log) - ShowWarning("map_foreachinrange: block count too many!\n"); - } - - map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é - - for(i=blockcount;iprev) // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN - returnCount += func(bl_list[i],ap); - - map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é - - va_end(ap); - bl_list_count = blockcount; - return returnCount; //[Skotlex] -} - -/*========================================== - * map m (x0,y0)-(x1,y1)?‚Ì‘Sobj‚É?‚µ‚Ä - * func‚ðŒÄ‚Ô - * type!=0 ‚È‚ç‚»‚ÌŽí—Þ‚Ì‚Ý - *------------------------------------------ - */ -int map_foreachinarea(int (*func)(struct block_list*,va_list),int m,int x0,int y0,int x1,int y1,int type,...) { - va_list ap; - int bx,by; - int returnCount =0; //total sum of returned values of func() [Skotlex] - struct block_list *bl=NULL; - int blockcount=bl_list_count,i,c; - - if (m < 0) - return 0; - va_start(ap,type); - if (x1 < x0) - { //Swap range - bx = x0; - x0 = x1; - x1 = bx; - } - if (y1 < y0) - { - bx = y0; - y0 = y1; - y1 = bx; - } - if (x0 < 0) x0 = 0; - if (y0 < 0) y0 = 0; - if (x1 >= map[m].xs) x1 = map[m].xs-1; - if (y1 >= map[m].ys) y1 = map[m].ys-1; - - if (type&~BL_MOB) - for (by = y0 / BLOCK_SIZE; by <= y1 / BLOCK_SIZE; by++) { - for(bx=x0/BLOCK_SIZE;bx<=x1/BLOCK_SIZE;bx++){ - bl = map[m].block[bx+by*map[m].bxs]; - c = map[m].block_count[bx+by*map[m].bxs]; - for(i=0;inext){ - if(bl && bl->type&type && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 && bl_list_countnext){ - if(bl && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 && bl_list_count=BL_LIST_MAX) { - if(battle_config.error_log) - ShowWarning("map_foreachinarea: block count too many!\n"); - } - - map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é - - for(i=blockcount;iprev) // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN - returnCount += func(bl_list[i],ap); - - map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é - - va_end(ap); - bl_list_count = blockcount; - return returnCount; //[Skotlex] -} - -/*========================================== - * ‹éŒ`(x0,y0)-(x1,y1)‚ª(dx,dy)ˆÚ“®‚µ‚½ŽbÌ - * —̈æŠO‚É‚È‚é—̈æ(‹éŒ`‚©LŽšŒ`)?‚Ìobj‚É - * ?‚µ‚Äfunc‚ðŒÄ‚Ô - * - * dx,dy‚Í-1,0,1‚Ì‚Ý‚Æ‚·‚éi‚Ç‚ñ‚È’l‚Å‚à‚¢‚¢‚Á‚Û‚¢Hj - *------------------------------------------ - */ -int map_foreachinmovearea(int (*func)(struct block_list*,va_list),int m,int x0,int y0,int x1,int y1,int dx,int dy,int type,...) { - int bx,by; - int returnCount =0; //total sum of returned values of func() [Skotlex] - struct block_list *bl=NULL; - va_list ap; - int blockcount=bl_list_count,i,c; - - va_start(ap,type); - if (x1 < x0) - { //Swap range - bx = x0; - x0 = x1; - x1 = bx; - } - if (y1 < y0) - { - bx = y0; - y0 = y1; - y1 = bx; - } - if(dx==0 || dy==0){ - // ‹éŒ`—̈æ‚Ìê‡ - if(dx==0){ - if(dy<0){ - y0=y1+dy+1; - } else { - y1=y0+dy-1; - } - } else if(dy==0){ - if(dx<0){ - x0=x1+dx+1; - } else { - x1=x0+dx-1; - } - } - if(x0<0) x0=0; - if(y0<0) y0=0; - if(x1>=map[m].xs) x1=map[m].xs-1; - if(y1>=map[m].ys) y1=map[m].ys-1; - for(by=y0/BLOCK_SIZE;by<=y1/BLOCK_SIZE;by++){ - for(bx=x0/BLOCK_SIZE;bx<=x1/BLOCK_SIZE;bx++){ - if (type&~BL_MOB) { - bl = map[m].block[bx+by*map[m].bxs]; - c = map[m].block_count[bx+by*map[m].bxs]; - for(i=0;inext){ - if(bl && bl->type&type && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 && bl_list_countnext){ - if(bl && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 && bl_list_count=map[m].xs) x1=map[m].xs-1; - if(y1>=map[m].ys) y1=map[m].ys-1; - for(by=y0/BLOCK_SIZE;by<=y1/BLOCK_SIZE;by++){ - for(bx=x0/BLOCK_SIZE;bx<=x1/BLOCK_SIZE;bx++){ - if (type & ~BL_MOB) { - bl = map[m].block[bx+by*map[m].bxs]; - c = map[m].block_count[bx+by*map[m].bxs]; - for(i=0;inext){ - if(!bl || !(bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1)) - continue; - if(bl && bl->type&type && ((dx>0 && bl->xx>x1+dx) || - (dy>0 && bl->yy>y1+dy)) && - bl_list_countnext){ - if(!bl || !(bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1)) - continue; - if(bl && ((dx>0 && bl->xx>x1+dx) || - (dy>0 && bl->yy>y1+dy)) && - bl_list_count=BL_LIST_MAX) { - if(battle_config.error_log) - ShowWarning("map_foreachinmovearea: block count too many!\n"); - } - - map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é - - for(i=blockcount;iprev) { // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN - if (bl_list[i]->type == BL_PC - && session[((struct map_session_data *) bl_list[i])->fd] == NULL) - continue; - returnCount += func(bl_list[i],ap); - } - - map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é - - va_end(ap); - bl_list_count = blockcount; - return returnCount; -} - -// -- moonsoul (added map_foreachincell which is a rework of map_foreachinarea but -// which only checks the exact single x/y passed to it rather than an -// area radius - may be more useful in some instances) -// -int map_foreachincell(int (*func)(struct block_list*,va_list),int m,int x,int y,int type,...) { - int bx,by; - int returnCount =0; //total sum of returned values of func() [Skotlex] - struct block_list *bl=NULL; - va_list ap; - int blockcount=bl_list_count,i,c; - - va_start(ap,type); - - by=y/BLOCK_SIZE; - bx=x/BLOCK_SIZE; - - if(type&~BL_MOB) - { - bl = map[m].block[bx+by*map[m].bxs]; - c = map[m].block_count[bx+by*map[m].bxs]; - for(i=0;inext) - { - if(bl && bl->type&type && bl->x==x && bl->y==y && bl_list_countnext) - { - if(bl && bl->x==x && bl->y==y && bl_list_count=BL_LIST_MAX) { - if(battle_config.error_log) - ShowWarning("map_foreachincell: block count too many!\n"); - } - - map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é - - for(i=blockcount;iprev) // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN - returnCount += func(bl_list[i],ap); - - map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é - - va_end(ap); - bl_list_count = blockcount; - return returnCount; -} - -/*============================================================ -* For checking a path between two points (x0, y0) and (x1, y1) -*------------------------------------------------------------ - */ -int map_foreachinpath(int (*func)(struct block_list*,va_list),int m,int x0,int y0,int x1,int y1,int range,int type,...) -{ - int returnCount =0; //total sum of returned values of func() [Skotlex] -////////////////////////////////////////////////////////////// -// -// sharp shooting 3 [Skotlex] -// -////////////////////////////////////////////////////////////// -// problem: -// Same as Sharp Shooting 1. Hits all targets within range of -// the line. -// (t1,t2 t3 and t4 get hit) -// -// target 1 -// x t4 -// t2 -// t3 x -// x -// S -////////////////////////////////////////////////////////////// -// Methodology: -// My trigonometrics and math is a little rusty... so the approach I am writing -// here is basicly do a double for to check for all targets in the square that -// contains the initial and final positions (area range increased to match the -// radius given), then for each object to test, calculate the distance to the -// path and include it if the range fits and the target is in the line (0 mx1) - { - mx0+=range; - mx1-=range; - } else { - mx0-=range; - mx1+=range; - } - if (my0 > my1) - { - my0+=range; - my1-=range; - } else { - my0-=range; - my1+=range; - } - - //The two fors assume mx0 < mx1 && my0 < my1 - if (mx0 > mx1) - { - k = mx1; - mx1 = mx0; - mx0 = k; - } - if (my0 > my1) - { - k = my1; - my1 = my0; - my0 = k; - } - - if (mx0 < 0) mx0 = 0; - if (my0 < 0) my0 = 0; - if (mx1 >= map[m].xs) mx1 = map[m].xs-1; - if (my1 >= map[m].ys) my1 = map[m].ys-1; - - range*=range<<8; //Values are shifted later on for higher precision using int math. - magnitude2 = MAGNITUDE2(x0,y0, x1,y1); - if (magnitude2 < 1) //Same begin and ending point, can't trace path. - return 0; - - if (type & ~BL_MOB) - for (by = my0 / BLOCK_SIZE; by <= my1 / BLOCK_SIZE; by++) { - for(bx=mx0/BLOCK_SIZE;bx<=mx1/BLOCK_SIZE;bx++){ - bl = map[m].block[bx+by*map[m].bxs]; - c = map[m].block_count[bx+by*map[m].bxs]; - for(i=0;inext){ - if(bl && bl->type&type && bl_list_countx; - yi = bl->y; - - k = (xi-x0)*(x1-x0) + (yi-y0)*(y1-y0); - if (k < 0)// || k > magnitude2) //No check to see if it lies after the target's point. - continue; - - //All these shifts are to increase the precision of the intersection point and distance considering how it's - //int math. - k = (k<<4)/magnitude2; //k will be between 1~16 instead of 0~1 - xi<<=4; - yi<<=4; - xu= (x0<<4) +k*(x1-x0); - yu= (y0<<4) +k*(y1-y0); - k = MAGNITUDE2(xi, yi, xu, yu); - - //If all dot coordinates were <<4 the square of the magnitude is <<8 - if (k > range) - continue; - - bl_list[bl_list_count++]=bl; - } - } - } - } - if(type&BL_MOB) - for(by=my0/BLOCK_SIZE;by<=my1/BLOCK_SIZE;by++){ - for(bx=mx0/BLOCK_SIZE;bx<=mx1/BLOCK_SIZE;bx++){ - bl = map[m].block_mob[bx+by*map[m].bxs]; - c = map[m].block_mob_count[bx+by*map[m].bxs]; - for(i=0;inext){ - if(bl && bl_list_countx; - yi = bl->y; - k = (xi-x0)*(x1-x0) + (yi-y0)*(y1-y0); - if (k < 0)// || k > magnitude2) //No check to see if it lies after the target's point. - continue; - - k = (k<<4)/magnitude2; //k will be between 1~16 instead of 0~1 - xi<<=4; - yi<<=4; - xu= (x0<<4) +k*(x1-x0); - yu= (y0<<4) +k*(y1-y0); - k = MAGNITUDE2(xi, yi, xu, yu); - - //If all dot coordinates were <<4 the square of the magnitude is <<8 - if (k > range) - continue; - - bl_list[bl_list_count++]=bl; - } - } - } - } - - if(bl_list_count>=BL_LIST_MAX) { - if(battle_config.error_log) - ShowWarning("map_foreachinpath: block count too many!\n"); - } - - map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é - - for(i=blockcount;iprev) // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN - returnCount += func(bl_list[i],ap); - - map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é - - va_end(ap); - bl_list_count = blockcount; - return returnCount; //[Skotlex] - -} - -// Copy of map_foreachincell, but applied to the whole map. [Skotlex] -int map_foreachinmap(int (*func)(struct block_list*,va_list),int m,int type,...) { - int b, bsize; - int returnCount =0; //total sum of returned values of func() [Skotlex] - struct block_list *bl=NULL; - va_list ap; - int blockcount=bl_list_count,i,c; - - va_start(ap,type); - - bsize = map[m].bxs * map[m].bys; - if(type&~BL_MOB) - { - for(b=0;bnext) - { - if(bl && bl->type&type && bl_list_countnext) - { - if(bl && bl_list_count=BL_LIST_MAX) { - if(battle_config.error_log) - ShowWarning("map_foreachinmap: block count too many!\n"); - } - - map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é - - for(i=blockcount;iprev) // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN - returnCount += func(bl_list[i],ap); - - map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é - - va_end(ap); - bl_list_count = blockcount; - return returnCount; -} - -/*========================================== - * °ƒAƒCƒeƒ€‚âƒGƒtƒFƒNƒg—p‚̈êŽObjŠ„‚è?‚Ä - * object[]‚Ö‚Ì•Û‘¶‚Æid_db“o?‚Ü‚Å - * - * bl->id‚à‚±‚Ì’†‚Åݒ肵‚Ä–â‘è–³‚¢? - *------------------------------------------ - */ -int map_addobject(struct block_list *bl) { - int i; - if( bl == NULL ){ - ShowWarning("map_addobject nullpo?\n"); - return 0; - } - if(first_free_object_id<2 || first_free_object_id>=MAX_FLOORITEM) - first_free_object_id=2; - for(i=first_free_object_id;i=MAX_FLOORITEM){ - if(battle_config.error_log) - ShowWarning("no free object id\n"); - return 0; - } - first_free_object_id=i; - if(last_object_idid) - first_free_object_id=id; - - while(last_object_id>2 && objects[last_object_id]==NULL) - last_object_id--; - - return 0; -} - -/*========================================== - * ˆêŽObject‚̉ð•ú - * block_list‚©‚ç‚ÌíœAid_db‚©‚ç‚Ìíœ - * object data‚ÌfreeAobject[]‚Ö‚ÌNULL‘ã“ü - * - * add‚Æ‚Ì??«‚ª–³‚¢‚Ì‚ª?‚É‚È‚é - *------------------------------------------ - */ -int map_delobject(int id) { - struct block_list *obj = objects[id]; - - if(obj==NULL) - return 0; - - map_delobjectnofree(id); - map_freeblock(obj); - - return 0; -} - -/*========================================== - * ‘SˆêŽObj‘ŠŽè‚Éfunc‚ðŒÄ‚Ô - * - *------------------------------------------ - */ -void map_foreachobject(int (*func)(struct block_list*,va_list),int type,...) { - int i; - int blockcount=bl_list_count; - va_list ap; - - va_start(ap,type); - - for(i=2;i<=last_object_id;i++){ - if(objects[i]){ - if(!(objects[i]->type==type)) // Fixed [Lance] - continue; - if(bl_list_count>=BL_LIST_MAX) { - if(battle_config.error_log) - ShowWarning("map_foreachobject: too many blocks !\n"); - break; - } - bl_list[bl_list_count++]=objects[i]; - } - } - - map_freeblock_lock(); - - for(i=blockcount;iprev || bl_list[i]->next ) - func(bl_list[i],ap); - - map_freeblock_unlock(); - - va_end(ap); - bl_list_count = blockcount; -} - -/*========================================== - * °ƒAƒCƒeƒ€‚ðÁ‚· - * - * data==0‚ÌŽbÍtimer‚ÅÁ‚¦‚½Žê * data!=0‚ÌŽbÍE‚¤“™‚ÅÁ‚¦‚½ŽbÆ‚µ‚Ä“®ì - * - * ŒãŽÒ‚ÍAmap_clearflooritem(id)‚Ö - * map.h?‚Å#define‚µ‚Ä‚ ‚é - *------------------------------------------ - */ -int map_clearflooritem_timer(int tid,unsigned int tick,int id,int data) { - struct flooritem_data *fitem=NULL; - - fitem = (struct flooritem_data *)objects[id]; - if(fitem==NULL || fitem->bl.type!=BL_ITEM || (!data && fitem->cleartimer != tid)){ - if(battle_config.error_log) - ShowError("map_clearflooritem_timer : error\n"); - return 1; - } - if(data) - delete_timer(fitem->cleartimer,map_clearflooritem_timer); - else if(fitem->item_data.card[0] == (short)0xff00) - intif_delete_petdata( MakeDWord(fitem->item_data.card[1],fitem->item_data.card[2]) ); - clif_clearflooritem(fitem,0); - map_delobject(fitem->bl.id); - - return 0; -} - -/*========================================== - * (m,x,y) locates a random available free cell around the given coordinates - * to place an BL_ITEM object. Scan area is 9x9, returns 1 on success. - * x and y are modified with the target cell when successful. - *------------------------------------------ - */ -int map_searchrandfreecell(int m,int *x,int *y,int stack) { - int free_cell,i,j; - int free_cells[9][2]; - - for(free_cell=0,i=-1;i<=1;i++){ - if(i+*y<0 || i+*y>=map[m].ys) - continue; - for(j=-1;j<=1;j++){ - if(j+*x<0 || j+*x>=map[m].xs) - continue; - if(map_getcell(m,j+*x,i+*y,CELL_CHKNOPASS)) - continue; - //Avoid item stacking to prevent against exploits. [Skotlex] - if(stack && map_count_oncell(m,j+*x,i+*y, BL_ITEM) > stack) - continue; - free_cells[free_cell][0] = j+*x; - free_cells[free_cell++][1] = i+*y; - } - } - if(free_cell==0) - return 0; - free_cell = rand()%free_cell; - *x = free_cells[free_cell][0]; - *y = free_cells[free_cell][1]; - return 1; -} - +// Copyright (c) Athena Dev Teams - Licensed under GNU GPL +// For more information, see LICENCE in the main folder + +#include +#include +#include +#include +#ifdef _WIN32 +#include +#else +#include +#include +#endif +#include + +#include "../common/core.h" +#include "../common/timer.h" +#include "../common/grfio.h" +#include "../common/malloc.h" +#include "../common/socket.h" +#include "../common/showmsg.h" +#include "../common/version.h" +#include "../common/nullpo.h" + +#include "map.h" +#include "chrif.h" +#include "clif.h" +#include "intif.h" +#include "npc.h" +#include "pc.h" +#include "status.h" +#include "mob.h" +#include "chat.h" +#include "itemdb.h" +#include "storage.h" +#include "skill.h" +#include "trade.h" +#include "party.h" +#include "unit.h" +#include "battle.h" +#include "script.h" +#include "guild.h" +#include "pet.h" +#include "atcommand.h" +#include "charcommand.h" + +#include "log.h" + +#include "charsave.h" + +#include "irc.h" + +// maybe put basic macros to somewhere else +#define swap(a,b) ((a == b) || ((a ^= b), (b ^= a), (a ^= b))) + +#ifndef TXT_ONLY + +#include "mail.h" // mail system [Valaris] + +MYSQL mmysql_handle; +MYSQL_RES* sql_res ; +MYSQL_ROW sql_row ; +char tmp_sql[65535]=""; + +MYSQL logmysql_handle; //For the log database - fix by [Maeki] +MYSQL_RES* logsql_res ; +MYSQL_ROW logsql_row ; + +MYSQL mail_handle; // mail system [Valaris] +MYSQL_RES* mail_res ; +MYSQL_ROW mail_row ; + +int map_server_port = 3306; +char map_server_ip[16] = "127.0.0.1"; +char map_server_id[32] = "ragnarok"; +char map_server_pw[32] = "ragnarok"; +char map_server_db[32] = "ragnarok"; +char default_codepage[32] = ""; //Feature by irmin. +int db_use_sqldbs = 0; +int connection_ping_interval = 0; + +int login_server_port = 3306; +char login_server_ip[16] = "127.0.0.1"; +char login_server_id[32] = "ragnarok"; +char login_server_pw[32] = "ragnarok"; +char login_server_db[32] = "ragnarok"; + +char item_db_db[32] = "item_db"; +char item_db2_db[32] = "item_db2"; +char mob_db_db[32] = "mob_db"; +char mob_db2_db[32] = "mob_db2"; + +char login_db[32] = "login"; +char login_db_level[32] = "level"; +char login_db_account_id[32] = "account_id"; + +int log_db_port = 3306; +char log_db_ip[16] = "127.0.0.1"; +char log_db_id[32] = "ragnarok"; +char log_db_pw[32] = "ragnarok"; +char log_db[32] = "log"; + +int mail_server_port = 3306; +char mail_server_ip[16] = "127.0.0.1"; +char mail_server_id[32] = "ragnarok"; +char mail_server_pw[32] = "ragnarok"; +char mail_server_db[32] = "ragnarok"; +int mail_server_enable = 0; + +char gm_db[32] = "login"; +char gm_db_level[32] = "level"; +char gm_db_account_id[32] = "account_id"; + +int read_gm_interval = 600000; + +char char_db[32] = "char"; + +char mail_db[32] = "mail"; + +char charsql_host[40] = "localhost"; +int charsql_port = 3306; +char charsql_user[32] = "ragnarok"; +char charsql_pass[32] = "eAthena"; +char charsql_db[40] = "ragnarok"; +MYSQL charsql_handle; +MYSQL_RES* charsql_res; +MYSQL_ROW charsql_row; + +#endif /* not TXT_ONLY */ + +int lowest_gm_level = 1; + +// This param using for sending mainchat +// messages like whispers to this nick. [LuzZza] +char main_chat_nick[16] = "Main"; + +char *INTER_CONF_NAME; +char *LOG_CONF_NAME; +char *MAP_CONF_NAME; +char *BATTLE_CONF_FILENAME; +char *ATCOMMAND_CONF_FILENAME; +char *CHARCOMMAND_CONF_FILENAME; +char *SCRIPT_CONF_NAME; +char *MSG_CONF_NAME; +char *GRF_PATH_FILENAME; + +// ‹É—Í static‚Ń?ƒJƒ‹‚É?‚ß‚é +static struct dbt * id_db=NULL; +static struct dbt * pc_db=NULL; +static struct dbt * map_db=NULL; +static struct dbt * charid_db=NULL; + +static int map_users=0; +static struct block_list *objects[MAX_FLOORITEM]; +static int first_free_object_id=0,last_object_id=0; + +#define block_free_max 1048576 +struct block_list *block_free[block_free_max]; +static int block_free_count = 0, block_free_lock = 0; + +#define BL_LIST_MAX 1048576 +static struct block_list *bl_list[BL_LIST_MAX]; +static int bl_list_count = 0; + +static char afm_dir[1024] = ""; // [Valaris] + +struct map_data map[MAX_MAP_PER_SERVER]; +int map_num = 0; + +int map_port=0; + +int autosave_interval = DEFAULT_AUTOSAVE_INTERVAL; +int charsave_method = 0; //Default 'OLD' Save method (SQL ONLY!) [Sirius] +int agit_flag = 0; +int night_flag = 0; // 0=day, 1=night [Yor] +int kick_on_disconnect = 1; + +struct charid2nick { + char nick[NAME_LENGTH]; + int req_id; +}; + +// «Þ«Ã«×«­«ã«Ã«·«å××éÄ«Õ«é«°(map_athana.conf?ªÎread_map_from_cacheªÇò¦E) +// 0:××éĪ·ªÊª¤ 1:Þª?õêÜÁðí 2:?õêÜÁðí +int map_read_flag = READ_FROM_GAT; +char map_cache_file[256]="db/map.info"; // «Þ«Ã«×«­«ã«Ã«·«å«Õ«¡«¤«E£ + +char db_path[256] = "db"; +char motd_txt[256] = "conf/motd.txt"; +char help_txt[256] = "conf/help.txt"; +char help2_txt[256] = "conf/help2.txt"; +char charhelp_txt[256] = "conf/charhelp.txt"; + +char wisp_server_name[NAME_LENGTH] = "Server"; // can be modified in char-server configuration file + +int console = 0; +int enable_spy = 0; //To enable/disable @spy commands, which consume too much cpu time when sending packets. [Skotlex] + +static const int dirx[8]={0,-1,-1,-1,0,1,1,1}; +static const int diry[8]={1,1,0,-1,-1,-1,0,1}; + +/*========================================== + * ‘SmapŽI?Œv‚Å‚ÌÚ??Ý’è + * (charŽI‚©‚ç‘—‚ç‚ê‚Ä‚­‚é) + *------------------------------------------ + */ +void map_setusers(int fd) +{ + RFIFOHEAD(fd); + WFIFOHEAD(fd, 2); + + map_users = RFIFOL(fd,2); + // send some anser + WFIFOW(fd,0) = 0x2718; + WFIFOSET(fd,2); +} + +/*========================================== + * ‘SmapŽI?Œv‚Å‚ÌÚ??Žæ“¾ (/w‚Ö‚Ì?“š—p) + *------------------------------------------ + */ +int map_getusers(void) { + return map_users; +} + + +//Distance functions, taken from http://www.flipcode.com/articles/article_fastdistance.shtml +int check_distance(int dx, int dy, int distance) { + //In this case, we just do a square comparison. Add 1 tile grace for diagonal range checks. + return (dx*dx + dy*dy <= distance*distance + (dx&&dy?1:0)); +} + +unsigned int distance(int dx, int dy) { + unsigned int min, max; + + if ( dx < 0 ) dx = -dx; + if ( dy < 0 ) dy = -dy; + //There appears to be something wrong with the aproximation below when either dx/dy is 0! [Skotlex] + if ( dx == 0 ) return dy; + if ( dy == 0 ) return dx; + + if ( dx < dy ) + { + min = dx; + max = dy; + } else { + min = dy; + max = dx; + } + // coefficients equivalent to ( 123/128 * max ) and ( 51/128 * min ) + return ((( max << 8 ) + ( max << 3 ) - ( max << 4 ) - ( max << 1 ) + + ( min << 7 ) - ( min << 5 ) + ( min << 3 ) - ( min << 1 )) >> 8 ); +} + +// +// block휂̈À‘S«Šm•Û?— +// + +/*========================================== + * block‚ðfree‚·‚é‚Æ‚«free‚Ì?‚í‚è‚ÉŒÄ‚Ô + * ƒƒbƒN‚³‚ê‚Ä‚¢‚é‚Æ‚«‚̓oƒbƒtƒ@‚É‚½‚ß‚é + *------------------------------------------ + */ +int map_freeblock (struct block_list *bl) +{ + if (block_free_lock == 0 || block_free_count >= block_free_max) + { + aFree(bl); + bl = NULL; + if (block_free_count >= block_free_max) + if (battle_config.error_log) + ShowWarning("map_freeblock: too many free block! %d %d\n", + block_free_count, block_free_lock); + } else + block_free[block_free_count++] = bl; + + return block_free_lock; +} +/*========================================== + * block‚Ìfree‚ðˆêŽsI‚É‹ÖŽ~‚·‚é + *------------------------------------------ + */ +int map_freeblock_lock (void) +{ + return ++block_free_lock; +} + +/*========================================== + * block‚Ìfree‚̃ƒbƒN‚ð‰ðœ‚·‚é + * ‚±‚Ì‚Æ‚«AƒƒbƒN‚ªŠ®‘S‚É‚È‚­‚È‚é‚Æ + * ƒoƒbƒtƒ@‚É‚½‚Ü‚Á‚Ä‚¢‚½block‚ð‘S•”íœ + *------------------------------------------ + */ +int map_freeblock_unlock (void) +{ + if ((--block_free_lock) == 0) { + int i; + for (i = 0; i < block_free_count; i++) + { //Directly calling aFree shouldn't be a leak, as Free remembers the size the original pointed to memory was allocated with? [Skotlex] + aFree(block_free[i]); + block_free[i] = NULL; + } + block_free_count = 0; + } else if (block_free_lock < 0) { + if (battle_config.error_log) + ShowError("map_freeblock_unlock: lock count < 0 !\n"); + block_free_lock = 0; // ŽŸ‰ñˆÈ~‚̃ƒbƒN‚ÉŽxႪo‚Ä‚­‚é‚̂ŃŠƒZƒbƒg + } + + return block_free_lock; +} + +// map_freeblock_lock() ‚ðŒÄ‚ñ‚Å map_freeblock_unlock() ‚ðŒÄ‚΂Ȃ¢ +// ŠÖ”‚ª‚ ‚Á‚½‚Ì‚ÅA’èŠú“I‚Éblock_free_lock‚ðƒŠƒZƒbƒg‚·‚é‚悤‚É‚·‚éB +// ‚±‚ÌŠÖ”‚ÍAdo_timer() ‚̃gƒbƒvƒŒƒxƒ‹‚©‚çŒÄ‚΂ê‚é‚Ì‚ÅA +// block_free_lock ‚ð’¼Ú‚¢‚¶‚Á‚Ä‚àŽxá–³‚¢‚Í‚¸B + +int map_freeblock_timer (int tid, unsigned int tick, int id, int data) +{ + if (block_free_lock > 0) { + ShowError("map_freeblock_timer: block_free_lock(%d) is invalid.\n", block_free_lock); + block_free_lock = 1; + map_freeblock_unlock(); + } + + return 0; +} + +// +// block‰»?— +// +/*========================================== + * map[]‚Ìblock_list‚©‚ç?‚ª‚Á‚Ä‚¢‚éê‡‚É + * bl->prev‚Ébl_head‚̃AƒhƒŒƒX‚ð“ü‚ê‚Ä‚¨‚­ + *------------------------------------------ + */ +static struct block_list bl_head; + +#ifdef CELL_NOSTACK +/*========================================== + * These pair of functions update the counter of how many objects + * lie on a tile. + *------------------------------------------ + */ +void map_addblcell(struct block_list *bl) +{ + if(bl->m<0 || bl->x<0 || bl->x>=map[bl->m].xs + || bl->y<0 || bl->y>=map[bl->m].ys || !(bl->type&BL_CHAR)) + return; + map[bl->m].cell_bl[bl->x+bl->y*map[bl->m].xs]++; + return; +} + +void map_delblcell(struct block_list *bl) +{ + if(bl->m <0 || bl->x<0 || bl->x>=map[bl->m].xs + || bl->y<0 || bl->y>=map[bl->m].ys || !(bl->type&BL_CHAR)) + return; + map[bl->m].cell_bl[bl->x+bl->y*map[bl->m].xs]--; +} +#endif + +/*========================================== + * Adds a block to the map. + * If flag is 1, then the block was just added + * otherwise it is part of a transition. + *------------------------------------------ + */ +int map_addblock_sub (struct block_list *bl, int flag) +{ + int m, x, y, pos; + + nullpo_retr(0, bl); + + if (bl->prev != NULL) { + if(battle_config.error_log) + ShowError("map_addblock error : bl->prev != NULL\n"); + return 0; + } + + m = bl->m; + x = bl->x; + y = bl->y; + if (m < 0 || m >= map_num || + x < 0 || x >= map[m].xs || + y < 0 || y >= map[m].ys) + return 1; + +#ifdef CELL_NOSTACK + map_addblcell(bl); +#endif + + pos = x/BLOCK_SIZE+(y/BLOCK_SIZE)*map[m].bxs; + if (bl->type == BL_MOB) { + bl->next = map[m].block_mob[pos]; + bl->prev = &bl_head; + if (bl->next) bl->next->prev = bl; + map[m].block_mob[pos] = bl; + map[m].block_mob_count[pos]++; + } else { + bl->next = map[m].block[pos]; + bl->prev = &bl_head; + if (bl->next) bl->next->prev = bl; + map[m].block[pos] = bl; + map[m].block_count[pos]++; + if (bl->type == BL_PC && flag) + { + struct map_session_data* sd; + if (map[m].users++ == 0 && battle_config.dynamic_mobs) //Skotlex + map_spawnmobs(m); + sd = (struct map_session_data*)bl; + if (battle_config.pet_no_gvg && map_flag_gvg(m) && sd->pd) + { //Return the pet to egg. [Skotlex] + clif_displaymessage(sd->fd, "Pets are not allowed in Guild Wars."); + pet_menu(sd, 3); //Option 3 is return to egg. + } + } + } + + return 0; +} + +/*========================================== + * Removes a block from the map. + * If flag is 1, then the block is removed for good + * otherwise it is part of a transition. + *------------------------------------------ + */ +int map_delblock_sub (struct block_list *bl, int flag) +{ + int b; + nullpo_retr(0, bl); + + // ?‚Éblocklist‚©‚ç?‚¯‚Ä‚¢‚é + if (bl->prev == NULL) { + if (bl->next != NULL) { + // prev‚ªNULL‚Ånext‚ªNULL‚Å‚È‚¢‚Ì‚Í—L‚Á‚Ä‚Í‚È‚ç‚È‚¢ + if(battle_config.error_log) + ShowError("map_delblock error : bl->next!=NULL\n"); + } + return 0; + } + +#ifdef CELL_NOSTACK + map_delblcell(bl); +#endif + + b = bl->x/BLOCK_SIZE+(bl->y/BLOCK_SIZE)*map[bl->m].bxs; + + if (bl->type == BL_PC && flag) + if (--map[bl->m].users == 0 && battle_config.dynamic_mobs) //[Skotlex] + map_removemobs(bl->m); + + if (bl->next) + bl->next->prev = bl->prev; + if (bl->prev == &bl_head) { + // ƒŠƒXƒg‚Ì“ª‚È‚Ì‚ÅAmap[]‚Ìblock_list‚ðXV‚·‚é + if (bl->type == BL_MOB) { + map[bl->m].block_mob[b] = bl->next; + if ((map[bl->m].block_mob_count[b]--) < 0) + map[bl->m].block_mob_count[b] = 0; + } else { + map[bl->m].block[b] = bl->next; + if((map[bl->m].block_count[b]--) < 0) + map[bl->m].block_count[b] = 0; + } + } else { + bl->prev->next = bl->next; + } + bl->next = NULL; + bl->prev = NULL; + + return 0; +} + +/*========================================== + * Moves a block a x/y target position. [Skotlex] + * Pass flag as 1 to prevent doing skill_unit_move checks + * (which are executed by default on BL_CHAR types) + *------------------------------------------ + */ +int map_moveblock(struct block_list *bl, int x1, int y1, unsigned int tick) { + int x0 = bl->x, y0 = bl->y; + struct status_change *sc = NULL; + int moveblock = ( x0/BLOCK_SIZE != x1/BLOCK_SIZE || y0/BLOCK_SIZE != y1/BLOCK_SIZE); + + if (!bl->prev) { + //Block not in map, just update coordinates, but do naught else. + bl->x = x1; + bl->y = y1; + return 0; + } + //TODO: Perhaps some outs of bounds checking should be placed here? + if (bl->type&BL_CHAR) { + skill_unit_move(bl,tick,2); + sc = status_get_sc(bl); + if (sc && sc->count) { + if (sc->data[SC_CLOSECONFINE].timer != -1) + status_change_end(bl, SC_CLOSECONFINE, -1); + if (sc->data[SC_CLOSECONFINE2].timer != -1) + status_change_end(bl, SC_CLOSECONFINE2, -1); + } + } + if (moveblock) map_delblock_sub(bl,0); +#ifdef CELL_NOSTACK + else map_delblcell(bl); +#endif + bl->x = x1; + bl->y = y1; + if (moveblock) map_addblock_sub(bl,0); +#ifdef CELL_NOSTACK + else map_addblcell(bl); +#endif + if (bl->type&BL_CHAR) { + skill_unit_move(bl,tick,3); + if (sc) { + if (sc->option&OPTION_CLOAK) + skill_check_cloaking(bl); + if (sc->count) { + if (sc->data[SC_DANCING].timer != -1) { + //Cancel Moonlight Petals if moved from casting position. [Skotlex] + if (sc->data[SC_DANCING].val1 == CG_MOONLIT) + skill_stop_dancing(bl); + else + skill_unit_move_unit_group((struct skill_unit_group *)sc->data[SC_DANCING].val2, bl->m, x1-x0, y1-y0); + } + } + } + } + return 0; +} + +/*========================================== + * Žü?‚ÌPCl?‚ð?‚¦‚é (unused) + *------------------------------------------ + */ +int map_countnearpc (int m, int x, int y) +{ + int bx, by, c = 0; + struct block_list *bl=NULL; + + if (map[m].users == 0) + return 0; + for (by = y/BLOCK_SIZE-AREA_SIZE/BLOCK_SIZE-1; by<=y/BLOCK_SIZE+AREA_SIZE/BLOCK_SIZE+1; by++) { + if (by < 0 || by >= map[m].bys) + continue; + for (bx = x/BLOCK_SIZE-AREA_SIZE/BLOCK_SIZE-1; bx <= x/BLOCK_SIZE+AREA_SIZE/BLOCK_SIZE+1; bx++) { + if (bx < 0 || bx >= map[m].bxs) + continue; + bl = map[m].block[bx+by*map[m].bxs]; + while(bl) { + if (bl->type == BL_PC) + c++; + bl = bl->next; + } + } + } + + return c; +} + +/*========================================== + * Counts specified number of objects on given cell. + *------------------------------------------ + */ +int map_count_oncell(int m, int x, int y, int type) { + int bx,by; + struct block_list *bl=NULL; + int i,c; + int count = 0; + + if (x < 0 || y < 0 || (x >= map[m].xs) || (y >= map[m].ys)) + return 0; + bx = x/BLOCK_SIZE; + by = y/BLOCK_SIZE; + + if (type == 0 || type != BL_MOB) + { + bl = map[m].block[bx+by*map[m].bxs]; + c = map[m].block_count[bx+by*map[m].bxs]; + for(i=0;inext) + if(bl->x == x && bl->y == y && bl->type == (type?type:BL_PC)) count++; + } + + if (type == 0 || type == BL_MOB) + { + bl = map[m].block_mob[bx+by*map[m].bxs]; + c = map[m].block_mob_count[bx+by*map[m].bxs]; + for(i=0;inext){ + if(bl->x == x && bl->y == y) count++; + } + } + return count; +} +/* + * «»«E¾ªÎõÌôøªË̸ªÄª±ª¿«¹«­«Eæ«Ë«Ã«ÈªòÚ÷ª¹ + */ +struct skill_unit *map_find_skill_unit_oncell(struct block_list *target,int x,int y,int skill_id,struct skill_unit *out_unit) +{ + int m,bx,by; + struct block_list *bl; + int i,c; + struct skill_unit *unit; + m = target->m; + + if (x < 0 || y < 0 || (x >= map[m].xs) || (y >= map[m].ys)) + return NULL; + bx = x/BLOCK_SIZE; + by = y/BLOCK_SIZE; + + bl = map[m].block[bx+by*map[m].bxs]; + c = map[m].block_count[bx+by*map[m].bxs]; + for(i=0;inext){ + if (bl->x != x || bl->y != y || bl->type != BL_SKILL) + continue; + unit = (struct skill_unit *) bl; + if (unit==out_unit || !unit->alive || + !unit->group || unit->group->skill_id!=skill_id) + continue; + if (battle_check_target(&unit->bl,target,unit->group->target_flag)>0) + return unit; + } + return NULL; +} + +/*========================================== + * Adapted from foreachinarea for an easier invocation. [Skotlex] + *------------------------------------------ + */ + +int map_foreachinrange(int (*func)(struct block_list*,va_list),struct block_list *center, int range,int type,...) { + va_list ap; + int bx,by,m; + int returnCount =0; //total sum of returned values of func() [Skotlex] + struct block_list *bl=NULL; + int blockcount=bl_list_count,i,c; + int x0,x1,y0,y1; + m = center->m; + if (m < 0) + return 0; + va_start(ap,type); + x0 = center->x-range; + x1 = center->x+range; + y0 = center->y-range; + y1 = center->y+range; + + if (x0 < 0) x0 = 0; + if (y0 < 0) y0 = 0; + if (x1 >= map[m].xs) x1 = map[m].xs-1; + if (y1 >= map[m].ys) y1 = map[m].ys-1; + + if (type&~BL_MOB) + for (by = y0 / BLOCK_SIZE; by <= y1 / BLOCK_SIZE; by++) { + for(bx=x0/BLOCK_SIZE;bx<=x1/BLOCK_SIZE;bx++){ + bl = map[m].block[bx+by*map[m].bxs]; + c = map[m].block_count[bx+by*map[m].bxs]; + for(i=0;inext){ + if(bl && bl->type&type + && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 + //For speed purposes, it does not checks actual range by default. + //Feel free to uncomment if you want a more "exact" approach. +// && check_distance_bl(center, bl, range) + && bl_list_countnext){ + if(bl + && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 + && check_distance_bl(center, bl, range) + && bl_list_count=BL_LIST_MAX) { + if(battle_config.error_log) + ShowWarning("map_foreachinrange: block count too many!\n"); + } + + map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é + + for(i=blockcount;iprev) // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN + returnCount += func(bl_list[i],ap); + + map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é + + va_end(ap); + bl_list_count = blockcount; + return returnCount; //[Skotlex] +} + +/*========================================== + * map m (x0,y0)-(x1,y1)?‚Ì‘Sobj‚É?‚µ‚Ä + * func‚ðŒÄ‚Ô + * type!=0 ‚È‚ç‚»‚ÌŽí—Þ‚Ì‚Ý + *------------------------------------------ + */ +int map_foreachinarea(int (*func)(struct block_list*,va_list),int m,int x0,int y0,int x1,int y1,int type,...) { + va_list ap; + int bx,by; + int returnCount =0; //total sum of returned values of func() [Skotlex] + struct block_list *bl=NULL; + int blockcount=bl_list_count,i,c; + + if (m < 0) + return 0; + va_start(ap,type); + if (x1 < x0) + { //Swap range + bx = x0; + x0 = x1; + x1 = bx; + } + if (y1 < y0) + { + bx = y0; + y0 = y1; + y1 = bx; + } + if (x0 < 0) x0 = 0; + if (y0 < 0) y0 = 0; + if (x1 >= map[m].xs) x1 = map[m].xs-1; + if (y1 >= map[m].ys) y1 = map[m].ys-1; + + if (type&~BL_MOB) + for (by = y0 / BLOCK_SIZE; by <= y1 / BLOCK_SIZE; by++) { + for(bx=x0/BLOCK_SIZE;bx<=x1/BLOCK_SIZE;bx++){ + bl = map[m].block[bx+by*map[m].bxs]; + c = map[m].block_count[bx+by*map[m].bxs]; + for(i=0;inext){ + if(bl && bl->type&type && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 && bl_list_countnext){ + if(bl && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 && bl_list_count=BL_LIST_MAX) { + if(battle_config.error_log) + ShowWarning("map_foreachinarea: block count too many!\n"); + } + + map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é + + for(i=blockcount;iprev) // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN + returnCount += func(bl_list[i],ap); + + map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é + + va_end(ap); + bl_list_count = blockcount; + return returnCount; //[Skotlex] +} + +/*========================================== + * ‹éŒ`(x0,y0)-(x1,y1)‚ª(dx,dy)ˆÚ“®‚µ‚½ŽbÌ + * —̈æŠO‚É‚È‚é—̈æ(‹éŒ`‚©LŽšŒ`)?‚Ìobj‚É + * ?‚µ‚Äfunc‚ðŒÄ‚Ô + * + * dx,dy‚Í-1,0,1‚Ì‚Ý‚Æ‚·‚éi‚Ç‚ñ‚È’l‚Å‚à‚¢‚¢‚Á‚Û‚¢Hj + *------------------------------------------ + */ +int map_foreachinmovearea(int (*func)(struct block_list*,va_list),int m,int x0,int y0,int x1,int y1,int dx,int dy,int type,...) { + int bx,by; + int returnCount =0; //total sum of returned values of func() [Skotlex] + struct block_list *bl=NULL; + va_list ap; + int blockcount=bl_list_count,i,c; + + va_start(ap,type); + if (x1 < x0) + { //Swap range + bx = x0; + x0 = x1; + x1 = bx; + } + if (y1 < y0) + { + bx = y0; + y0 = y1; + y1 = bx; + } + if(dx==0 || dy==0){ + // ‹éŒ`—̈æ‚Ìê‡ + if(dx==0){ + if(dy<0){ + y0=y1+dy+1; + } else { + y1=y0+dy-1; + } + } else if(dy==0){ + if(dx<0){ + x0=x1+dx+1; + } else { + x1=x0+dx-1; + } + } + if(x0<0) x0=0; + if(y0<0) y0=0; + if(x1>=map[m].xs) x1=map[m].xs-1; + if(y1>=map[m].ys) y1=map[m].ys-1; + for(by=y0/BLOCK_SIZE;by<=y1/BLOCK_SIZE;by++){ + for(bx=x0/BLOCK_SIZE;bx<=x1/BLOCK_SIZE;bx++){ + if (type&~BL_MOB) { + bl = map[m].block[bx+by*map[m].bxs]; + c = map[m].block_count[bx+by*map[m].bxs]; + for(i=0;inext){ + if(bl && bl->type&type && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 && bl_list_countnext){ + if(bl && bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1 && bl_list_count=map[m].xs) x1=map[m].xs-1; + if(y1>=map[m].ys) y1=map[m].ys-1; + for(by=y0/BLOCK_SIZE;by<=y1/BLOCK_SIZE;by++){ + for(bx=x0/BLOCK_SIZE;bx<=x1/BLOCK_SIZE;bx++){ + if (type & ~BL_MOB) { + bl = map[m].block[bx+by*map[m].bxs]; + c = map[m].block_count[bx+by*map[m].bxs]; + for(i=0;inext){ + if(!bl || !(bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1)) + continue; + if(bl && bl->type&type && ((dx>0 && bl->xx>x1+dx) || + (dy>0 && bl->yy>y1+dy)) && + bl_list_countnext){ + if(!bl || !(bl->x>=x0 && bl->x<=x1 && bl->y>=y0 && bl->y<=y1)) + continue; + if(bl && ((dx>0 && bl->xx>x1+dx) || + (dy>0 && bl->yy>y1+dy)) && + bl_list_count=BL_LIST_MAX) { + if(battle_config.error_log) + ShowWarning("map_foreachinmovearea: block count too many!\n"); + } + + map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é + + for(i=blockcount;iprev) { // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN + if (bl_list[i]->type == BL_PC + && session[((struct map_session_data *) bl_list[i])->fd] == NULL) + continue; + returnCount += func(bl_list[i],ap); + } + + map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é + + va_end(ap); + bl_list_count = blockcount; + return returnCount; +} + +// -- moonsoul (added map_foreachincell which is a rework of map_foreachinarea but +// which only checks the exact single x/y passed to it rather than an +// area radius - may be more useful in some instances) +// +int map_foreachincell(int (*func)(struct block_list*,va_list),int m,int x,int y,int type,...) { + int bx,by; + int returnCount =0; //total sum of returned values of func() [Skotlex] + struct block_list *bl=NULL; + va_list ap; + int blockcount=bl_list_count,i,c; + + va_start(ap,type); + + by=y/BLOCK_SIZE; + bx=x/BLOCK_SIZE; + + if(type&~BL_MOB) + { + bl = map[m].block[bx+by*map[m].bxs]; + c = map[m].block_count[bx+by*map[m].bxs]; + for(i=0;inext) + { + if(bl && bl->type&type && bl->x==x && bl->y==y && bl_list_countnext) + { + if(bl && bl->x==x && bl->y==y && bl_list_count=BL_LIST_MAX) { + if(battle_config.error_log) + ShowWarning("map_foreachincell: block count too many!\n"); + } + + map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é + + for(i=blockcount;iprev) // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN + returnCount += func(bl_list[i],ap); + + map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é + + va_end(ap); + bl_list_count = blockcount; + return returnCount; +} + +/*============================================================ +* For checking a path between two points (x0, y0) and (x1, y1) +*------------------------------------------------------------ + */ +int map_foreachinpath(int (*func)(struct block_list*,va_list),int m,int x0,int y0,int x1,int y1,int range,int type,...) +{ + int returnCount =0; //total sum of returned values of func() [Skotlex] +////////////////////////////////////////////////////////////// +// +// sharp shooting 3 [Skotlex] +// +////////////////////////////////////////////////////////////// +// problem: +// Same as Sharp Shooting 1. Hits all targets within range of +// the line. +// (t1,t2 t3 and t4 get hit) +// +// target 1 +// x t4 +// t2 +// t3 x +// x +// S +////////////////////////////////////////////////////////////// +// Methodology: +// My trigonometrics and math is a little rusty... so the approach I am writing +// here is basicly do a double for to check for all targets in the square that +// contains the initial and final positions (area range increased to match the +// radius given), then for each object to test, calculate the distance to the +// path and include it if the range fits and the target is in the line (0 mx1) + { + mx0+=range; + mx1-=range; + } else { + mx0-=range; + mx1+=range; + } + if (my0 > my1) + { + my0+=range; + my1-=range; + } else { + my0-=range; + my1+=range; + } + + //The two fors assume mx0 < mx1 && my0 < my1 + if (mx0 > mx1) + { + k = mx1; + mx1 = mx0; + mx0 = k; + } + if (my0 > my1) + { + k = my1; + my1 = my0; + my0 = k; + } + + if (mx0 < 0) mx0 = 0; + if (my0 < 0) my0 = 0; + if (mx1 >= map[m].xs) mx1 = map[m].xs-1; + if (my1 >= map[m].ys) my1 = map[m].ys-1; + + range*=range<<8; //Values are shifted later on for higher precision using int math. + magnitude2 = MAGNITUDE2(x0,y0, x1,y1); + if (magnitude2 < 1) //Same begin and ending point, can't trace path. + return 0; + + if (type & ~BL_MOB) + for (by = my0 / BLOCK_SIZE; by <= my1 / BLOCK_SIZE; by++) { + for(bx=mx0/BLOCK_SIZE;bx<=mx1/BLOCK_SIZE;bx++){ + bl = map[m].block[bx+by*map[m].bxs]; + c = map[m].block_count[bx+by*map[m].bxs]; + for(i=0;inext){ + if(bl && bl->type&type && bl_list_countx; + yi = bl->y; + + k = (xi-x0)*(x1-x0) + (yi-y0)*(y1-y0); + if (k < 0)// || k > magnitude2) //No check to see if it lies after the target's point. + continue; + + //All these shifts are to increase the precision of the intersection point and distance considering how it's + //int math. + k = (k<<4)/magnitude2; //k will be between 1~16 instead of 0~1 + xi<<=4; + yi<<=4; + xu= (x0<<4) +k*(x1-x0); + yu= (y0<<4) +k*(y1-y0); + k = MAGNITUDE2(xi, yi, xu, yu); + + //If all dot coordinates were <<4 the square of the magnitude is <<8 + if (k > range) + continue; + + bl_list[bl_list_count++]=bl; + } + } + } + } + if(type&BL_MOB) + for(by=my0/BLOCK_SIZE;by<=my1/BLOCK_SIZE;by++){ + for(bx=mx0/BLOCK_SIZE;bx<=mx1/BLOCK_SIZE;bx++){ + bl = map[m].block_mob[bx+by*map[m].bxs]; + c = map[m].block_mob_count[bx+by*map[m].bxs]; + for(i=0;inext){ + if(bl && bl_list_countx; + yi = bl->y; + k = (xi-x0)*(x1-x0) + (yi-y0)*(y1-y0); + if (k < 0)// || k > magnitude2) //No check to see if it lies after the target's point. + continue; + + k = (k<<4)/magnitude2; //k will be between 1~16 instead of 0~1 + xi<<=4; + yi<<=4; + xu= (x0<<4) +k*(x1-x0); + yu= (y0<<4) +k*(y1-y0); + k = MAGNITUDE2(xi, yi, xu, yu); + + //If all dot coordinates were <<4 the square of the magnitude is <<8 + if (k > range) + continue; + + bl_list[bl_list_count++]=bl; + } + } + } + } + + if(bl_list_count>=BL_LIST_MAX) { + if(battle_config.error_log) + ShowWarning("map_foreachinpath: block count too many!\n"); + } + + map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é + + for(i=blockcount;iprev) // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN + returnCount += func(bl_list[i],ap); + + map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é + + va_end(ap); + bl_list_count = blockcount; + return returnCount; //[Skotlex] + +} + +// Copy of map_foreachincell, but applied to the whole map. [Skotlex] +int map_foreachinmap(int (*func)(struct block_list*,va_list),int m,int type,...) { + int b, bsize; + int returnCount =0; //total sum of returned values of func() [Skotlex] + struct block_list *bl=NULL; + va_list ap; + int blockcount=bl_list_count,i,c; + + va_start(ap,type); + + bsize = map[m].bxs * map[m].bys; + if(type&~BL_MOB) + { + for(b=0;bnext) + { + if(bl && bl->type&type && bl_list_countnext) + { + if(bl && bl_list_count=BL_LIST_MAX) { + if(battle_config.error_log) + ShowWarning("map_foreachinmap: block count too many!\n"); + } + + map_freeblock_lock(); // ƒƒ‚ƒŠ‚©‚ç‚̉ð•ú‚ð‹ÖŽ~‚·‚é + + for(i=blockcount;iprev) // —L?‚©‚Ç‚¤‚©ƒ`ƒFƒbƒN + returnCount += func(bl_list[i],ap); + + map_freeblock_unlock(); // ‰ð•ú‚ð‹–‰Â‚·‚é + + va_end(ap); + bl_list_count = blockcount; + return returnCount; +} + +/*========================================== + * °ƒAƒCƒeƒ€‚âƒGƒtƒFƒNƒg—p‚̈êŽObjŠ„‚è?‚Ä + * object[]‚Ö‚Ì•Û‘¶‚Æid_db“o?‚Ü‚Å + * + * bl->id‚à‚±‚Ì’†‚Åݒ肵‚Ä–â‘è–³‚¢? + *------------------------------------------ + */ +int map_addobject(struct block_list *bl) { + int i; + if( bl == NULL ){ + ShowWarning("map_addobject nullpo?\n"); + return 0; + } + if(first_free_object_id<2 || first_free_object_id>=MAX_FLOORITEM) + first_free_object_id=2; + for(i=first_free_object_id;i=MAX_FLOORITEM){ + if(battle_config.error_log) + ShowWarning("no free object id\n"); + return 0; + } + first_free_object_id=i; + if(last_object_idid) + first_free_object_id=id; + + while(last_object_id>2 && objects[last_object_id]==NULL) + last_object_id--; + + return 0; +} + +/*========================================== + * ˆêŽObject‚̉ð•ú + * block_list‚©‚ç‚ÌíœAid_db‚©‚ç‚Ìíœ + * object data‚ÌfreeAobject[]‚Ö‚ÌNULL‘ã“ü + * + * add‚Æ‚Ì??«‚ª–³‚¢‚Ì‚ª?‚É‚È‚é + *------------------------------------------ + */ +int map_delobject(int id) { + struct block_list *obj = objects[id]; + + if(obj==NULL) + return 0; + + map_delobjectnofree(id); + map_freeblock(obj); + + return 0; +} + +/*========================================== + * ‘SˆêŽObj‘ŠŽè‚Éfunc‚ðŒÄ‚Ô + * + *------------------------------------------ + */ +void map_foreachobject(int (*func)(struct block_list*,va_list),int type,...) { + int i; + int blockcount=bl_list_count; + va_list ap; + + va_start(ap,type); + + for(i=2;i<=last_object_id;i++){ + if(objects[i]){ + if(!(objects[i]->type==type)) // Fixed [Lance] + continue; + if(bl_list_count>=BL_LIST_MAX) { + if(battle_config.error_log) + ShowWarning("map_foreachobject: too many blocks !\n"); + break; + } + bl_list[bl_list_count++]=objects[i]; + } + } + + map_freeblock_lock(); + + for(i=blockcount;iprev || bl_list[i]->next ) + func(bl_list[i],ap); + + map_freeblock_unlock(); + + va_end(ap); + bl_list_count = blockcount; +} + +/*========================================== + * °ƒAƒCƒeƒ€‚ðÁ‚· + * + * data==0‚ÌŽbÍtimer‚ÅÁ‚¦‚½Žê * data!=0‚ÌŽbÍE‚¤“™‚ÅÁ‚¦‚½ŽbÆ‚µ‚Ä“®ì + * + * ŒãŽÒ‚ÍAmap_clearflooritem(id)‚Ö + * map.h?‚Å#define‚µ‚Ä‚ ‚é + *------------------------------------------ + */ +int map_clearflooritem_timer(int tid,unsigned int tick,int id,int data) { + struct flooritem_data *fitem=NULL; + + fitem = (struct flooritem_data *)objects[id]; + if(fitem==NULL || fitem->bl.type!=BL_ITEM || (!data && fitem->cleartimer != tid)){ + if(battle_config.error_log) + ShowError("map_clearflooritem_timer : error\n"); + return 1; + } + if(data) + delete_timer(fitem->cleartimer,map_clearflooritem_timer); + else if(fitem->item_data.card[0] == (short)0xff00) + intif_delete_petdata( MakeDWord(fitem->item_data.card[1],fitem->item_data.card[2]) ); + clif_clearflooritem(fitem,0); + map_delobject(fitem->bl.id); + + return 0; +} + +/*========================================== + * (m,x,y) locates a random available free cell around the given coordinates + * to place an BL_ITEM object. Scan area is 9x9, returns 1 on success. + * x and y are modified with the target cell when successful. + *------------------------------------------ + */ +int map_searchrandfreecell(int m,int *x,int *y,int stack) { + int free_cell,i,j; + int free_cells[9][2]; + + for(free_cell=0,i=-1;i<=1;i++){ + if(i+*y<0 || i+*y>=map[m].ys) + continue; + for(j=-1;j<=1;j++){ + if(j+*x<0 || j+*x>=map[m].xs) + continue; + if(map_getcell(m,j+*x,i+*y,CELL_CHKNOPASS)) + continue; + //Avoid item stacking to prevent against exploits. [Skotlex] + if(stack && map_count_oncell(m,j+*x,i+*y, BL_ITEM) > stack) + continue; + free_cells[free_cell][0] = j+*x; + free_cells[free_cell++][1] = i+*y; + } + } + if(free_cell==0) + return 0; + free_cell = rand()%free_cell; + *x = free_cells[free_cell][0]; + *y = free_cells[free_cell][1]; + return 1; +} + static int map_count_sub(struct block_list *bl,va_list ap) { return 1; } -/*========================================== - * Locates a random spare cell around the object given, using range as max - * distance from that spot. Used for warping functions. Use range < 0 for - * whole map range. - * Returns 1 on success. when it fails and src is available, x/y are set to src's - * src can be null as long as flag&1 - * when ~flag&1, m is not needed. - * Flag values: - * &1 = random cell must be around given m,x,y, not around src - * &2 = the target should be able to walk to the target tile. - * &4 = there shouldn't be any players around the target tile (use the no_spawn_on_player setting) - *------------------------------------------ +/*========================================== + * Locates a random spare cell around the object given, using range as max + * distance from that spot. Used for warping functions. Use range < 0 for + * whole map range. + * Returns 1 on success. when it fails and src is available, x/y are set to src's + * src can be null as long as flag&1 + * when ~flag&1, m is not needed. + * Flag values: + * &1 = random cell must be around given m,x,y, not around src + * &2 = the target should be able to walk to the target tile. + * &4 = there shouldn't be any players around the target tile (use the no_spawn_on_player setting) + *------------------------------------------ + */ +int map_search_freecell(struct block_list *src, int m, short *x,short *y, int rx, int ry, int flag) { + int tries, spawn=0; + int bx, by; + int rx2 = 2*rx+1; + int ry2 = 2*ry+1; + + if (!src && (!(flag&1) || flag&2)) + { + ShowDebug("map_search_freecell: Incorrect usage! When src is NULL, flag has to be &1 and can't have &2\n"); + return 0; + } + + if (flag&1) { + bx = *x; + by = *y; + } else { + bx = src->x; + by = src->y; + m = src->m; + } + if (rx >= 0 && ry >= 0) { + tries = rx2*ry2; + if (tries > 50) tries = 50; + } else + tries = 100; + + while(tries--) { + *x = (rx >= 0)?(rand()%rx2-rx+bx):(rand()%(map[m].xs-2)+1); + *y = (ry >= 0)?(rand()%rx2-ry+by):(rand()%(map[m].ys-2)+1); + + if (map_getcell(m,*x,*y,CELL_CHKREACH)) + { + if(flag&2 && !unit_can_reach_pos(src, *x, *y, 1)) + continue; + if(flag&4 && spawn++ < battle_config.no_spawn_on_player && + map_foreachinarea(map_count_sub, m, + *x-AREA_SIZE, *y-AREA_SIZE, *x+AREA_SIZE, *y+AREA_SIZE, BL_PC) + ) + continue; + + return 1; + } + } + *x = bx; + *y = by; + return 0; +} + +/*========================================== + * (m,x,y)‚ð’†S‚É3x3ˆÈ?‚É°ƒAƒCƒeƒ€Ý’u + * + * item_data‚ÍamountˆÈŠO‚ðcopy‚·‚é + * type flag: &1 MVP item. &2 do stacking check. + *------------------------------------------ + */ +int map_addflooritem(struct item *item_data,int amount,int m,int x,int y,struct map_session_data *first_sd, + struct map_session_data *second_sd,struct map_session_data *third_sd,int type) { + int r; + unsigned int tick; + struct flooritem_data *fitem=NULL; + + nullpo_retr(0, item_data); + + if(!map_searchrandfreecell(m,&x,&y,type&2?1:0)) + return 0; + r=rand(); + + fitem = (struct flooritem_data *)aCalloc(1,sizeof(*fitem)); + fitem->bl.type=BL_ITEM; + fitem->bl.prev = fitem->bl.next = NULL; + fitem->bl.m=m; + fitem->bl.x=x; + fitem->bl.y=y; + fitem->bl.id = map_addobject(&fitem->bl); + if(fitem->bl.id==0){ + aFree(fitem); + return 0; + } + + tick = gettick(); + if(first_sd) { + fitem->first_get_id = first_sd->bl.id; + if(type&1) + fitem->first_get_tick = tick + battle_config.mvp_item_first_get_time; + else + fitem->first_get_tick = tick + battle_config.item_first_get_time; + } + if(second_sd) { + fitem->second_get_id = second_sd->bl.id; + if(type&1) + fitem->second_get_tick = tick + battle_config.mvp_item_first_get_time + battle_config.mvp_item_second_get_time; + else + fitem->second_get_tick = tick + battle_config.item_first_get_time + battle_config.item_second_get_time; + } + if(third_sd) { + fitem->third_get_id = third_sd->bl.id; + if(type&1) + fitem->third_get_tick = tick + battle_config.mvp_item_first_get_time + battle_config.mvp_item_second_get_time + battle_config.mvp_item_third_get_time; + else + fitem->third_get_tick = tick + battle_config.item_first_get_time + battle_config.item_second_get_time + battle_config.item_third_get_time; + } + + memcpy(&fitem->item_data,item_data,sizeof(*item_data)); + fitem->item_data.amount=amount; + fitem->subx=(r&3)*3+3; + fitem->suby=((r>>2)&3)*3+3; + fitem->cleartimer=add_timer(gettick()+battle_config.flooritem_lifetime,map_clearflooritem_timer,fitem->bl.id,0); + + map_addblock(&fitem->bl); + clif_dropflooritem(fitem); + + return fitem->bl.id; +} + +static void* create_charid2nick(DBKey key, va_list args) { + struct charid2nick *p; + p = (struct charid2nick *)aCallocA(1, sizeof (struct charid2nick)); + return p; +} +/*========================================== + * charid_db‚֒ljÁ(•ÔM‘Ò‚¿‚ª‚ ‚ê‚ΕÔM) + *------------------------------------------ + */ +void map_addchariddb(int charid, char *name) { + struct charid2nick *p; + int req = 0; + + p = idb_ensure(charid_db,charid,create_charid2nick); + req = p->req_id; + p->req_id = 0; + //We overwrite the nick anyway in case a different one arrived. + memcpy(p->nick, name, NAME_LENGTH); + + if (req) { + struct map_session_data *sd = map_id2sd(req); + if (sd) clif_solved_charname(sd,charid); + } +} + +/*========================================== + * charid_db‚֒ljÁi•ÔM—v‹‚Ì‚Ýj + *------------------------------------------ + */ +int map_reqchariddb(struct map_session_data * sd,int charid) { + struct charid2nick *p=NULL; + + nullpo_retr(0, sd); + + p = (struct charid2nick*)idb_get(charid_db,charid); + if(p) return 0; //Nothing to request, we already have the name! + p = (struct charid2nick *)aCalloc(1,sizeof(struct charid2nick)); + p->req_id=sd->bl.id; + idb_put(charid_db,charid,p); + return 0; +} + +/*========================================== + * id_db‚Öbl‚ð’ljÁ + *------------------------------------------ + */ +void map_addiddb(struct block_list *bl) { + nullpo_retv(bl); + + if (bl->type == BL_PC) + idb_put(pc_db,bl->id,bl); + idb_put(id_db,bl->id,bl); +} + +/*========================================== + * id_db‚©‚çbl‚ðíœ + *------------------------------------------ + */ +void map_deliddb(struct block_list *bl) { + nullpo_retv(bl); + + if (bl->type == BL_PC) + idb_remove(pc_db,bl->id); + idb_remove(id_db,bl->id); +} + +/*========================================== + * PC‚Ìquit?— map.c?•ª + * + * quit?—‚ÌŽå?‚ªˆá‚¤‚悤‚È?‚à‚µ‚Ä‚«‚½ + *------------------------------------------ + */ +int map_quit(struct map_session_data *sd) { + + //nullpo_retr(0, sd); //Utterly innecessary, all invokations to this function already have an SD non-null check. + //Learn to use proper coding and stop relying on nullpo_'s for safety :P [Skotlex] + + if(!sd->state.waitingdisconnect) { + if (sd->npc_timer_id != -1) //Cancel the event timer. + npc_timerevent_quit(sd); + if (sd->state.event_disconnect) { + if (script_config.event_script_type == 0) { + struct npc_data *npc; + if ((npc = npc_name2id(script_config.logout_event_name))) { + run_script(npc->u.scr.script,0,sd->bl.id,npc->bl.id); // PCLogoutNPC + ShowStatus("Event '"CL_WHITE"%s"CL_RESET"' executed.\n", script_config.logout_event_name); + } + } else { + ShowStatus("%d '"CL_WHITE"%s"CL_RESET"' events executed.\n", + npc_event_doall_id(script_config.logout_event_name, sd->bl.id), script_config.logout_event_name); + } + } + if (sd->pd) unit_free(&sd->pd->bl); + unit_free(&sd->bl); + pc_clean_skilltree(sd); + status_calc_pc(sd,4); + if(sd->pet.intimate > 0) + intif_save_petdata(sd->status.account_id,&sd->pet); + chrif_save(sd,1); + } else { //Try to free some data, without saving anything (this could be invoked on map server change. [Skotlex] + if (sd->bl.prev != NULL) + { //Remove from map... + unit_remove_map(&sd->bl, 0); + if (sd->pd && sd->pd->bl.prev != NULL) + unit_remove_map(&sd->pd->bl, 0); + } + } + if (sd->stack) { + script_free_stack(sd->stack); + sd->stack= NULL; + } + + //Do we really need to remove the name? + idb_remove(charid_db,sd->status.char_id); + idb_remove(id_db,sd->bl.id); + idb_remove(pc_db,sd->bl.id); + + if(sd->reg) + { //Double logout already freed pointer fix... [Skotlex] + aFree(sd->reg); + sd->reg = NULL; + sd->reg_num = 0; + } + if(sd->regstr) + { + aFree(sd->regstr); + sd->regstr = NULL; + sd->regstr_num = 0; + } + + if(!sd->fd) //There is no session connected, and as such socket.c won't free the data, we must do it. [Skotlex] + aFree(sd); + return 0; +} + +/*========================================== + * id”Ô?‚ÌPC‚ð’T‚·B‹‚È‚¯‚ê‚ÎNULL + *------------------------------------------ + */ +struct map_session_data * map_id2sd(int id) { +// Now using pc_db to handle all players, should be quicker than both previous methods at a small expense of more memory. [Skotlex] + if (id <= 0) return NULL; + return (struct map_session_data*)idb_get(pc_db,id); +} + +/*========================================== + * char_id”Ô?‚Ì–¼‘O‚ð’T‚· + *------------------------------------------ + */ +char * map_charid2nick(int id) { + struct charid2nick *p = (struct charid2nick*)idb_get(charid_db,id); + + if(p==NULL) + return NULL; + return p->nick; +} + +struct map_session_data * map_charid2sd(int id) { + int i, users; + struct map_session_data **all_sd; + + if (id <= 0) return 0; + + all_sd = map_getallusers(&users); + for(i = 0; i < users; i++) + if (all_sd[i] && all_sd[i]->status.char_id == id) + return all_sd[i]; + + return NULL; +} + +/*========================================== + * Search session data from a nick name + * (without sensitive case if necessary) + * return map_session_data pointer or NULL + *------------------------------------------ + */ +struct map_session_data * map_nick2sd(char *nick) { + int i, quantity=0, nicklen, users; + struct map_session_data *sd = NULL; + struct map_session_data *pl_sd = NULL, **pl_allsd; + + if (nick == NULL) + return NULL; + + nicklen = strlen(nick); + + pl_allsd = map_getallusers(&users); + + for (i = 0; i < users; i++) { + pl_sd = pl_allsd[i]; + // Without case sensitive check (increase the number of similar character names found) + if (strnicmp(pl_sd->status.name, nick, nicklen) == 0) { + // Strict comparison (if found, we finish the function immediatly with correct value) + if (strcmp(pl_sd->status.name, nick) == 0) + return pl_sd; + quantity++; + sd = pl_sd; + } + } + // Here, the exact character name is not found + // We return the found index of a similar account ONLY if there is 1 similar character + if (quantity == 1) + return sd; + + // Exact character name is not found and 0 or more than 1 similar characters have been found ==> we say not found + return NULL; +} + +/*========================================== + * id”Ô?‚Ì•¨‚ð’T‚· + * ˆêŽObject‚Ìꇂ͔z—ñ‚ðˆø‚­‚Ì‚Ý + *------------------------------------------ + */ +struct block_list * map_id2bl(int id) +{ + struct block_list *bl=NULL; + if(id >= 0 && id < sizeof(objects)/sizeof(objects[0])) + bl = objects[id]; + else + bl = idb_get(id_db,id); + + return bl; +} + +static int map_getallpc_sub(DBKey key,void * data,va_list ap) +{ + struct map_session_data *sd = (struct map_session_data*) data; + if (!sd->state.auth || sd->state.waitingdisconnect || sd->state.finalsave) + return 1; //Do not count in not-yet authenticated characters or ready to disconnect ones. + + return 0; +} + +/*========================================== + * Returns an array of all players in the server (includes non connected ones) [Skotlex] + * The int pointer given returns the count of elements in the array. + * If null is passed, it is requested that the memory be freed (for shutdown), and null is returned. + *------------------------------------------ + */ +struct map_session_data** map_getallusers(int *users) { + static struct map_session_data **all_sd=NULL; + static unsigned int all_count = 0; + + if (users == NULL) + { //Free up data + if (all_sd) aFree(all_sd); + all_sd = NULL; + return NULL; + } + + if (all_sd == NULL) + { //Init data + all_count = pc_db->size(pc_db); //This is the real number of chars in the db, better use this than the actual "online" count. + if (all_count < 1) + all_count = 10; //Allow room for at least 10 chars. + all_sd = aCalloc(all_count, sizeof(struct map_session_data*)); //it's actually just the size of a pointer. + } + + if (all_count < pc_db->size(pc_db)) + { + all_count = pc_db->size(pc_db)+10; //Give some room to prevent doing reallocs often. + all_sd = aRealloc(all_sd, all_count*sizeof(struct map_session_data*)); + } + *users = pc_db->getall(pc_db,(void**)all_sd,all_count,map_getallpc_sub); + if (*users > (signed int)all_count) //Which should be impossible... + *users = all_count; + return all_sd; +} + +/*========================================== + * id_db?‚Ì‘S‚Ä‚Éfunc‚ð?s + *------------------------------------------ + */ +int map_foreachiddb(int (*func)(DBKey,void*,va_list),...) { + va_list ap; + + va_start(ap,func); + id_db->foreach(id_db,func,ap); + va_end(ap); + return 0; +} + +/*========================================== + * map.npc‚֒ljÁ (warp“™‚̗̈掂¿‚Ì‚Ý) + *------------------------------------------ + */ +int map_addnpc(int m,struct npc_data *nd) { + int i; + if(m<0 || m>=map_num) + return -1; + for(i=0;in = i; + idb_put(id_db,nd->bl.id,nd); + + return i; +} + +void map_removenpc(void) { + int i,m,n=0; + + for(m=0;mbl,2); + map_delblock(&map[m].npc[i]->bl); + idb_remove(id_db,map[m].npc[i]->bl.id); + if(map[m].npc[i]->bl.subtype==SCRIPT) { + aFree(map[m].npc[i]->u.scr.script); + aFree(map[m].npc[i]->u.scr.label_list); + } + aFree(map[m].npc[i]); + map[m].npc[i] = NULL; + n++; + } + } + } + + ShowStatus("Successfully removed and freed from memory '"CL_WHITE"%d"CL_RESET"' NPCs.\n",n); +} + +/*========================================= + * Dynamic Mobs [Wizputer] + *----------------------------------------- + */ + +// allocates a struct when it there is place free in the cache, +// and returns NULL otherwise +// -- i'll just leave the old code in case it's needed ^^; +int map_addmobtolist(unsigned short m, struct spawn_data *spawn) +{ + size_t i; + for (i = 0; i < MAX_MOB_LIST_PER_MAP; i++) { + if (map[m].moblist[i] == NULL) { + map[m].moblist[i] = spawn; + return i; + } + } + return -1; +} + +void map_spawnmobs(int m) +{ + int i, k=0; + if (map[m].mob_delete_timer != -1) + { //Mobs have not been removed yet [Skotlex] + delete_timer(map[m].mob_delete_timer, map_removemobs_timer); + map[m].mob_delete_timer = -1; + return; + } + for(i=0; inum; + npc_parse_mob2(map[m].moblist[i],i); + } + + if (battle_config.etc_log && k > 0) + { + ShowStatus("Map %s: Spawned '"CL_WHITE"%d"CL_RESET"' mobs.\n",map[m].name, k); + } +} + +int mob_cache_cleanup_sub(struct block_list *bl, va_list ap) { + struct mob_data *md = (struct mob_data *)bl; + nullpo_retr(0, md); + + //When not to remove: + //Mob has the cached flag on 0 + if (!md->special_state.cached) + return 0; + if (!battle_config.mob_remove_damaged && + md->hp < md->db->max_hp) //don't use status_get_maxhp for speed (by the time you have to remove a mob, their status changes should have expired anyway) + return 0; //Do not remove damaged mobs. + + unit_free(&md->bl); + + return 1; +} + +int map_removemobs_timer(int tid, unsigned int tick, int id, int data) +{ + int k; + if (id < 0 || id >= MAX_MAP_PER_SERVER) + { //Incorrect map id! + if (battle_config.error_log) + ShowError("map_removemobs_timer error: timer %d points to invalid map %d\n",tid, id); + return 0; + } + if (map[id].mob_delete_timer != tid) + { //Incorrect timer call! + if (battle_config.error_log) + ShowError("map_removemobs_timer mismatch: %d != %d (map %s)\n",map[id].mob_delete_timer, tid, map[id].name); + return 0; + } + map[id].mob_delete_timer = -1; + if (map[id].users > 0) //Map not empty! + return 1; + k = map_foreachinmap(mob_cache_cleanup_sub, id, BL_MOB); + + if (battle_config.etc_log && k > 0) + ShowStatus("Map %s: Removed '"CL_WHITE"%d"CL_RESET"' mobs.\n",map[id].name, k); + + return 1; +} + +void map_removemobs(int m) +{ + if (map[m].mob_delete_timer != -1) + return; //Mobs are already scheduled for removal + + map[m].mob_delete_timer = add_timer(gettick()+battle_config.mob_remove_delay, map_removemobs_timer, m, 0); +} + +/*========================================== + * map–¼‚©‚çmap”Ô?‚Ö?Š· + *------------------------------------------ + */ +int map_mapname2mapid(char *name) { + unsigned short map_index; + map_index = mapindex_name2id(name); + if (!map_index) + return -1; + return map_mapindex2mapid(map_index); +} + +/*========================================== + * Returns the map of the given mapindex. [Skotlex] + *------------------------------------------ + */ +int map_mapindex2mapid(unsigned short mapindex) { + struct map_data *md=NULL; + + if (!mapindex) + return -1; + + md = (struct map_data*)uidb_get(map_db,(unsigned int)mapindex); + if(md==NULL || md->gat==NULL) + return -1; + return md->m; +} + +/*========================================== + * ‘¼ŽImap–¼‚©‚çip,port?Š· + *------------------------------------------ + */ +int map_mapname2ipport(unsigned short name,int *ip,int *port) { + struct map_data_other_server *mdos=NULL; + + mdos = (struct map_data_other_server*)uidb_get(map_db,(unsigned int)name); + if(mdos==NULL || mdos->gat) //If gat isn't null, this is a local map. + return -1; + *ip=mdos->ip; + *port=mdos->port; + return 0; +} + +/*========================================== + * Checks if both dirs point in the same direction. + *------------------------------------------ + */ +int map_check_dir(int s_dir,int t_dir) { + if(s_dir == t_dir) + return 0; + switch(s_dir) { + case 0: + if(t_dir == 7 || t_dir == 1 || t_dir == 0) + return 0; + break; + case 1: + if(t_dir == 0 || t_dir == 2 || t_dir == 1) + return 0; + break; + case 2: + if(t_dir == 1 || t_dir == 3 || t_dir == 2) + return 0; + break; + case 3: + if(t_dir == 2 || t_dir == 4 || t_dir == 3) + return 0; + break; + case 4: + if(t_dir == 3 || t_dir == 5 || t_dir == 4) + return 0; + break; + case 5: + if(t_dir == 4 || t_dir == 6 || t_dir == 5) + return 0; + break; + case 6: + if(t_dir == 5 || t_dir == 7 || t_dir == 6) + return 0; + break; + case 7: + if(t_dir == 6 || t_dir == 0 || t_dir == 7) + return 0; + break; + } + return 1; +} + +/*========================================== + * Returns the direction of the given cell in absolute relation to the char + * (regardless of where the char is facing) + *------------------------------------------ + */ +int map_calc_dir( struct block_list *src,int x,int y) { + int dir=0; + int dx,dy; + + nullpo_retr(0, src); + + dx=x-src->x; + dy=y-src->y; + if( dx==0 && dy==0 ){ // ”Þ‰ä‚Ìꊈê’v + dir=0; // ã + }else if( dx>=0 && dy>=0 ){ // •ûŒü“I‚ɉEã + dir=7; // ‰Eã + if( dx*2-1dy*2 ) dir=6; // ‰E + }else if( dx>=0 && dy<=0 ){ // •ûŒü“I‚ɉE‰º + dir=5; // ‰E‰º + if( dx*2-1<-dy ) dir=4; // ‰º + if( dx>-dy*2 ) dir=6; // ‰E + }else if( dx<=0 && dy<=0 ){ // •ûŒü“I‚ɶ‰º + dir=3; // ¶‰º + if( dx*2+1>dy ) dir=4; // ‰º + if( dxdy*2 ) dir=2; // ¶ + } + return dir; +} + +/*========================================== + * Randomizes target cell x,y to a random walkable cell that + * has the same distance from object as given coordinates do. [Skotlex] + *------------------------------------------ + */ +int map_random_dir(struct block_list *bl, short *x, short *y) { + struct walkpath_data wpd; + short xi = *x-bl->x; + short yi = *y-bl->y; + short i=0, j; + int dist2 = xi*xi + yi*yi; + short dist = (short)sqrt(dist2); + short segment; + + if (dist < 1) dist =1; + + do { + j = rand()%8; //Pick a random direction + segment = rand()%dist; //Pick a random interval from the whole vector in that direction + xi = bl->x + segment*dirx[j]; + segment = (short)sqrt(dist2 - segment*segment); //The complement of the previously picked segment + yi = bl->y + segment*diry[j]; + } while (( + map_getcell(bl->m,xi,yi,CELL_CHKNOPASS) || + path_search_real(&wpd,bl->m,bl->x,bl->y,xi,yi,1,CELL_CHKNOREACH) == -1) + && (++i)<100); + + if (i < 100) { + *x = xi; + *y = yi; + return 1; + } + return 0; +} +// gatŒn +/*========================================== + * (m,x,y)‚Ìó‘Ԃ𒲂ׂé + *------------------------------------------ + */ + +int map_getcell(int m,int x,int y,cell_t cellchk) +{ + return (m < 0 || m >= MAX_MAP_PER_SERVER) ? 0 : map_getcellp(&map[m],x,y,cellchk); +} + +int map_getcellp(struct map_data* m,int x,int y,cell_t cellchk) +{ + int type, type2; +#ifdef CELL_NOSTACK + int type3; +#endif + + nullpo_ret(m); + + if(x<0 || x>=m->xs-1 || y<0 || y>=m->ys-1) + { + if(cellchk==CELL_CHKNOPASS) return 1; + return 0; + } + type = m->gat[x+y*m->xs]; + type2 = m->cell[x+y*m->xs]; +#ifdef CELL_NOSTACK + type3 = m->cell_bl[x+y*m->xs]; +#endif + + switch(cellchk) + { + case CELL_CHKPASS: +#ifdef CELL_NOSTACK + if (type3 >= battle_config.cell_stack_limit) return 0; +#endif + case CELL_CHKREACH: + return (type!=1 && type!=5 && !(type2&(CELL_MOONLIT|CELL_ICEWALL))); + case CELL_CHKNOPASS: +#ifdef CELL_NOSTACK + if (type3 >= battle_config.cell_stack_limit) return 1; +#endif + case CELL_CHKNOREACH: + return (type==1 || type==5 || type2&(CELL_MOONLIT|CELL_ICEWALL)); + case CELL_CHKSTACK: +#ifdef CELL_NOSTACK + return (type3 >= battle_config.cell_stack_limit); +#else + return 0; +#endif + case CELL_CHKWALL: + return (type==1/* || type2&CELL_ICEWALL*/); //Uncomment to prevent sniping/casting through the icewall. [Skotlex] + case CELL_CHKWATER: + return (type==3); + case CELL_CHKGROUND: + return (type==5 || type2&CELL_ICEWALL); + case CELL_GETTYPE: + return type; + case CELL_GETCELLTYPE: + return type2; + case CELL_CHKNPC: + return (type2&CELL_NPC); + case CELL_CHKPNEUMA: + return (type2&CELL_PNEUMA); + case CELL_CHKSAFETYWALL: + return (type2&CELL_SAFETYWALL); + case CELL_CHKBASILICA: + return (type2&CELL_BASILICA); + case CELL_CHKLANDPROTECTOR: + return (type2&CELL_LANDPROTECTOR); + case CELL_CHKMOONLIT: + return (type2&CELL_MOONLIT); + case CELL_CHKREGEN: + return (type2&CELL_REGEN); + case CELL_CHKICEWALL: + return (type2&CELL_ICEWALL); + default: + return 0; + } +} + +/*========================================== + * (m,x,y)‚Ìó‘Ô‚ðÝ’è‚·‚é + *------------------------------------------ + */ +void map_setcell(int m,int x,int y,int cell) +{ + int j; + if(x<0 || x>=map[m].xs || y<0 || y>=map[m].ys) + return; + j=x+y*map[m].xs; + + switch (cell) { + case CELL_SETNPC: + map[m].cell[j] |= CELL_NPC; + break; + case CELL_CLRNPC: + map[m].cell[j] &= ~CELL_NPC; + break; + case CELL_SETICEWALL: + map[m].cell[j] |= CELL_ICEWALL; + break; + case CELL_CLRICEWALL: + map[m].cell[j] &= ~CELL_ICEWALL; + break; + case CELL_SETBASILICA: + map[m].cell[j] |= CELL_BASILICA; + break; + case CELL_CLRBASILICA: + map[m].cell[j] &= ~CELL_BASILICA; + break; + case CELL_SETPNEUMA: + map[m].cell[j] |= CELL_PNEUMA; + break; + case CELL_CLRPNEUMA: + map[m].cell[j] &= ~CELL_PNEUMA; + break; + case CELL_SETSAFETYWALL: + map[m].cell[j] |= CELL_SAFETYWALL; + break; + case CELL_CLRSAFETYWALL: + map[m].cell[j] &= ~CELL_SAFETYWALL; + break; + case CELL_SETMOONLIT: + map[m].cell[j] |= CELL_MOONLIT; + break; + case CELL_CLRMOONLIT: + map[m].cell[j] &= ~CELL_MOONLIT; + break; + case CELL_SETLANDPROTECTOR: + map[m].cell[j] |= CELL_LANDPROTECTOR; + break; + case CELL_CLRLANDPROTECTOR: + map[m].cell[j] &= ~CELL_LANDPROTECTOR; + break; + case CELL_SETREGEN: + map[m].cell[j] |= CELL_REGEN; + break; + default: + map[m].gat[j] = cell; + break; + } +} +static void* create_map_data_other_server(DBKey key, va_list args) { + struct map_data_other_server *mdos; + unsigned short mapindex = (unsigned short)key.ui; + mdos=(struct map_data_other_server *)aCalloc(1,sizeof(struct map_data_other_server)); + mdos->index = mapindex; + memcpy(mdos->name, mapindex_id2name(mapindex), MAP_NAME_LENGTH); + return mdos; +} +/*========================================== + * ‘¼ŽIŠÇ—‚̃}ƒbƒv‚ðdb‚ɒljÁ + *------------------------------------------ + */ +int map_setipport(unsigned short mapindex,unsigned long ip,int port) { + struct map_data_other_server *mdos=NULL; + + mdos=(struct map_data_other_server *)uidb_ensure(map_db,(unsigned int)mapindex, create_map_data_other_server); + + if(mdos->gat) //Local map,Do nothing. Give priority to our own local maps over ones from another server. [Skotlex] + return 0; + if(ip == clif_getip() && port == clif_getport()) { + //That's odd, we received info that we are the ones with this map, but... we don't have it. + ShowFatalError("map_setipport : received info that this map-server SHOULD have map '%s', but it is not loaded.\n",mapindex_id2name(mapindex)); + exit(1); + } + mdos->ip = ip; + mdos->port = port; + return 1; +} + +/*========================================== + * ‘¼ŽIŠÇ—‚̃}ƒbƒv‚ð‘S‚Äíœ + *------------------------------------------ + */ +int map_eraseallipport_sub(DBKey key,void *data,va_list va) { + struct map_data_other_server *mdos = (struct map_data_other_server*)data; + if(mdos->gat == NULL) { + db_remove(map_db,key); + aFree(mdos); + } + return 0; +} + +int map_eraseallipport(void) { + map_db->foreach(map_db,map_eraseallipport_sub); + return 1; +} + +/*========================================== + * ‘¼ŽIŠÇ—‚̃}ƒbƒv‚ðdb‚©‚çíœ + *------------------------------------------ + */ +int map_eraseipport(unsigned short mapindex,unsigned long ip,int port) +{ + struct map_data_other_server *mdos; +// unsigned char *p=(unsigned char *)&ip; + + mdos = uidb_get(map_db,(unsigned int)mapindex); + if(!mdos || mdos->gat) //Map either does not exists or is a local map. + return 0; + + if(mdos->ip==ip && mdos->port == port) { + uidb_remove(map_db,(unsigned int)mapindex); + aFree(mdos); + return 1; + } + return 0; +} + +// ‰Šú‰»Žü‚è +/*========================================== + * …ê‚‚³Ý’è + *------------------------------------------ + */ +//static struct waterlist_ { +// char mapname[MAP_NAME_LENGTH], clonemapname[MAP_NAME_LENGTH]; +//} *waterlist=NULL; + +#define NO_WATER 1000000 + +static int map_setwaterheight_sub(int m) { + char fn[256]; + char *gat; + int x,y; + int wh; + struct gat_1cell {float high[4]; int type;} *p = NULL; + + if (m < 0) + return 0; + wh = map[m].water_height; + + sprintf(fn,"data\\%s",mapindex_id2name(map[m].index)); + + // read & convert fn + // again, might not need to be unsigned char + gat = (char *) grfio_read (fn); + if (gat == NULL) + return 0; + + for (y = 0; y < map[m].ys; y++) { + p = (struct gat_1cell*)(gat+y*map[m].xs*20+14); + for (x = 0; x < map[m].xs; x++) { + if (wh != NO_WATER && p->type == 0) //Set water cell + map[m].gat[x+y*map[m].xs] = (p->high[0]>wh || p->high[1]>wh || p->high[2]>wh || p->high[3]>wh) ? 3 : 0; + else //Remove water cell + map[m].gat[x+y*map[m].xs] = p->type==3?0:p->type; + p++; + } + } + aFree(gat); + return 1; +} +int map_setwaterheight(int m, char *mapname, int height) { + if (height < 0) + height = NO_WATER; + map[m].water_height = height; + return map_setwaterheight_sub(m); +} + +/* map_readwaterheight + * Reads from the .rsw for each map + * Returns water height (or NO_WATER if file doesn't exist) + * or other error is encountered. + * This receives a map-name, and changes the extension to rsw if it isn't set already. + * assumed path for file is data/mapname.rsw + * Credits to LittleWolf + */ +int map_waterheight(char *mapname) { + char fn[256]; + char *rsw, *found; + float whtemp; + int wh; + + //Look up for clone map. + //if(waterlist){ + // int i; + // for(i=0;waterlist[i].mapname[0] && i < MAX_MAP_PER_SERVER;i++) + // if(strcmp(waterlist[i].mapname,mapname)==0) + // return map_waterheight(waterlist[i].clonemapname); + //} + //Look up for the rsw + sprintf(fn,"data\\%s",mapname); + + found = grfio_find_file(fn); + if(!strstr(found,"data\\")) + sprintf(fn,"data\\%s", found); + else + strcpy(fn, found); + + rsw = strstr(fn, "."); + if (rsw && strstr(fn, ".rsw") == NULL) + sprintf(rsw,".rsw"); + // read & convert fn + // again, might not need to be unsigned char + rsw = (char *) grfio_read (fn); + if (rsw) + { //Load water height from file + whtemp = *(float*)(rsw+166); + wh = (int) whtemp; + aFree(rsw); + return wh; + } + ShowWarning("Failed to find water level for (%s)\n", mapname, fn); + return NO_WATER; +} + +//static void map_readwater(char *watertxt) { +// char line[1024],w1[1024],w2[1024]; +// FILE *fp=NULL; +// int n=0; +// +// fp=fopen(watertxt,"r"); +// if(fp==NULL){ +// ShowError("file not found: %s\n",watertxt); +// return; +// } +// if(waterlist==NULL) +// waterlist = (struct waterlist_*)aCallocA(MAX_MAP_PER_SERVER,sizeof(*waterlist)); +// while(fgets(line,1020,fp) && n < MAX_MAP_PER_SERVER){ +// if(line[0] == '/' && line[1] == '/') +// continue; +// if(sscanf(line,"%s %s",w1,w2) < 2){ +// continue; +// } +// memcpy(waterlist[n].mapname,w1, MAP_NAME_LENGTH-1); +// memcpy(waterlist[n].clonemapname, w2, MAP_NAME_LENGTH-1); +// n++; +// } +// fclose(fp); +//} +/*========================================== +* ƒ}ƒbƒvƒLƒƒƒbƒVƒ…‚ɒljÁ‚·‚é +*===========================================*/ + +// ƒ}ƒbƒvƒLƒƒƒbƒVƒ…‚ÌÅ‘å’l +#define MAX_MAP_CACHE 768 + +//Šeƒ}ƒbƒv‚²‚Æ‚ÌŬŒÀî•ñ‚ð“ü‚ê‚é‚à‚ÌAREAD_FROM_BITMAP—p +struct map_cache_info { + char fn[32];//ƒtƒ@ƒCƒ‹–¼ + int xs,ys; //•‚Æ‚‚³ + int water_height; + int pos; // ƒf[ƒ^‚ª“ü‚ê‚Ä‚ ‚éêŠ + int compressed; // zilb’Ê‚¹‚é‚悤‚É‚·‚éˆ×‚Ì—\–ñ + int compressed_len; // zilb’Ê‚¹‚é‚悤‚É‚·‚éˆ×‚Ì—\–ñ +}; // 56 byte + +struct map_cache_head { + int sizeof_header; + int sizeof_map; + // ã‚Ì‚Q‚‰ü•Ï•s‰Â + int nmaps; // ƒ}ƒbƒv‚̌” + int filesize; +}; + +struct { + struct map_cache_head head; + struct map_cache_info *map; + FILE *fp; + int dirty; +} map_cache; + +static int map_cache_open(char *fn); +static void map_cache_close(void); +static int map_cache_read(struct map_data *m); +static int map_cache_write(struct map_data *m); + +static int map_cache_open(char *fn) +{ + if (map_cache.fp) + map_cache_close(); + map_cache.fp = fopen(fn, "r+b"); + if (map_cache.fp) { + fread(&map_cache.head,1,sizeof(struct map_cache_head),map_cache.fp); + fseek(map_cache.fp,0,SEEK_END); + if( + map_cache.head.sizeof_header == sizeof(struct map_cache_head) && + map_cache.head.sizeof_map == sizeof(struct map_cache_info) && + map_cache.head.filesize == ftell(map_cache.fp) + ) { + // ƒLƒƒƒbƒVƒ…“Ç‚ÝbݬŒ÷ + map_cache.map = (struct map_cache_info *) aMalloc(sizeof(struct map_cache_info) * map_cache.head.nmaps); + fseek(map_cache.fp,sizeof(struct map_cache_head),SEEK_SET); + fread(map_cache.map,sizeof(struct map_cache_info),map_cache.head.nmaps,map_cache.fp); + return 1; + } + fclose(map_cache.fp); + } + // “Ç‚ÝbÝ‚ÉŽ¸”s‚µ‚½‚Ì‚ÅV‹K‚É쬂·‚é + map_cache.fp = fopen(fn,"wb"); + if(map_cache.fp) { + memset(&map_cache.head,0,sizeof(struct map_cache_head)); + map_cache.map = (struct map_cache_info *) aCalloc(sizeof(struct map_cache_info),MAX_MAP_CACHE); + map_cache.head.nmaps = MAX_MAP_CACHE; + map_cache.head.sizeof_header = sizeof(struct map_cache_head); + map_cache.head.sizeof_map = sizeof(struct map_cache_info); + + map_cache.head.filesize = sizeof(struct map_cache_head); + map_cache.head.filesize += sizeof(struct map_cache_info) * map_cache.head.nmaps; + + map_cache.dirty = 1; + return 1; + } + return 0; +} + +static void map_cache_close(void) +{ + if(!map_cache.fp) { return; } + if(map_cache.dirty) { + fseek(map_cache.fp,0,SEEK_SET); + fwrite(&map_cache.head,1,sizeof(struct map_cache_head),map_cache.fp); + fwrite(map_cache.map,map_cache.head.nmaps,sizeof(struct map_cache_info),map_cache.fp); + } + fclose(map_cache.fp); + aFree(map_cache.map); + map_cache.fp = NULL; + return; +} + +int map_cache_read(struct map_data *m) +{ + int i; + if(!map_cache.fp) { return 0; } + for(i = 0;i < map_cache.head.nmaps ; i++) { + if(!strcmp(m->name,map_cache.map[i].fn)) { + if(map_cache.map[i].compressed == 0) { + // ”ñˆ³kƒtƒ@ƒCƒ‹ + int size = map_cache.map[i].xs * map_cache.map[i].ys; + m->xs = map_cache.map[i].xs; + m->ys = map_cache.map[i].ys; + m->water_height = map_cache.map[i].water_height; + m->gat = (unsigned char *)aCalloc(m->xs * m->ys,sizeof(unsigned char)); + fseek(map_cache.fp,map_cache.map[i].pos,SEEK_SET); + if(fread(m->gat,1,size,map_cache.fp) == size) { + // ¬Œ÷ + return 1; + } else { + // ‚È‚º‚©ƒtƒ@ƒCƒ‹Œã”¼‚ªŒ‡‚¯‚Ä‚é‚Ì‚Å“Ç‚Ý’¼‚µ + m->xs = 0; m->ys = 0; aFree(m->gat); m->gat = NULL; + return 0; + } + } else if(map_cache.map[i].compressed == 1) { + // ˆ³kƒtƒ‰ƒO=1 : zlib + unsigned char *buf; + unsigned long dest_len; + int size_compress = map_cache.map[i].compressed_len; + m->xs = map_cache.map[i].xs; + m->ys = map_cache.map[i].ys; + m->water_height = map_cache.map[i].water_height; + m->gat = (unsigned char *)aMalloc(m->xs * m->ys * sizeof(unsigned char)); + buf = (unsigned char*)aMalloc(size_compress); + fseek(map_cache.fp,map_cache.map[i].pos,SEEK_SET); + if(fread(buf,1,size_compress,map_cache.fp) != size_compress) { + // ‚È‚º‚©ƒtƒ@ƒCƒ‹Œã”¼‚ªŒ‡‚¯‚Ä‚é‚Ì‚Å“Ç‚Ý’¼‚µ + ShowError("fread error\n"); + aFree(m->gat); m->xs = 0; m->ys = 0; m->gat = NULL; + aFree(buf); + return 0; + } + dest_len = m->xs * m->ys; + decode_zip(m->gat,&dest_len,buf,size_compress); + if(dest_len != map_cache.map[i].xs * map_cache.map[i].ys) { + // ³í‚ɉ𓀂ªo—ˆ‚Ä‚È‚¢ + aFree(m->gat); m->xs = 0; m->ys = 0; m->gat = NULL; + aFree(buf); + return 0; + } + aFree(buf); + return 1; + } + } + } + return 0; +} + +static int map_cache_write(struct map_data *m) +{ + int i; + unsigned long len_new , len_old; + char *write_buf; + if(!map_cache.fp) { return 0; } + for(i = 0;i < map_cache.head.nmaps ; i++) { + if(!strcmp(m->name,map_cache.map[i].fn)) { + // “¯‚¶ƒGƒ“ƒgƒŠ[‚ª‚ ‚ê‚Îã‘‚« + if(map_cache.map[i].compressed == 0) { + len_old = map_cache.map[i].xs * map_cache.map[i].ys; + } else if(map_cache.map[i].compressed == 1) { + len_old = map_cache.map[i].compressed_len; + } else { + // ƒTƒ|[ƒg‚³‚ê‚Ä‚È‚¢Œ`Ž®‚È‚Ì‚Å’·‚³‚O + len_old = 0; + } + if(map_read_flag == 2) { + // ˆ³k•Û‘¶ + // ‚³‚·‚ª‚É‚Q”{‚É–c‚ê‚鎖‚Í‚È‚¢‚Æ‚¢‚¤Ž–‚Å + write_buf = (char *) aMalloc(m->xs * m->ys * 2); + len_new = m->xs * m->ys * 2; + encode_zip((unsigned char *) write_buf,&len_new,m->gat,m->xs * m->ys); + map_cache.map[i].compressed = 1; + map_cache.map[i].compressed_len = len_new; + } else { + len_new = m->xs * m->ys; + write_buf = (char *) m->gat; + map_cache.map[i].compressed = 0; + map_cache.map[i].compressed_len = 0; + } + if(len_new <= len_old) { + // ƒTƒCƒY‚ª“¯‚¶‚©¬‚³‚­‚È‚Á‚½‚Ì‚Åꊂ͕ςí‚ç‚È‚¢ + fseek(map_cache.fp,map_cache.map[i].pos,SEEK_SET); + fwrite(write_buf,1,len_new,map_cache.fp); + } else { + // V‚µ‚¢êŠ‚É“o˜^ + fseek(map_cache.fp,map_cache.head.filesize,SEEK_SET); + fwrite(write_buf,1,len_new,map_cache.fp); + map_cache.map[i].pos = map_cache.head.filesize; + map_cache.head.filesize += len_new; + } + map_cache.map[i].xs = m->xs; + map_cache.map[i].ys = m->ys; + map_cache.map[i].water_height = m->water_height; + map_cache.dirty = 1; + if(map_read_flag == 2) { + aFree(write_buf); + } + return 0; + } + } + // “¯‚¶ƒGƒ“ƒgƒŠ‚ª–³‚¯‚ê‚Α‚«bß‚éꊂð’T‚· + for(i = 0;i < map_cache.head.nmaps ; i++) { + if(map_cache.map[i].fn[0] == 0) { + // V‚µ‚¢êŠ‚É“o˜^ + if(map_read_flag == 2) { + write_buf = (char *) aMalloc(m->xs * m->ys * 2); + len_new = m->xs * m->ys * 2; + encode_zip((unsigned char *) write_buf,&len_new,m->gat,m->xs * m->ys); + map_cache.map[i].compressed = 1; + map_cache.map[i].compressed_len = len_new; + } else { + len_new = m->xs * m->ys; + write_buf = (char *) m->gat; + map_cache.map[i].compressed = 0; + map_cache.map[i].compressed_len = 0; + } + strncpy(map_cache.map[i].fn,m->name,sizeof(map_cache.map[0].fn)); + fseek(map_cache.fp,map_cache.head.filesize,SEEK_SET); + fwrite(write_buf,1,len_new,map_cache.fp); + map_cache.map[i].pos = map_cache.head.filesize; + map_cache.map[i].xs = m->xs; + map_cache.map[i].ys = m->ys; + map_cache.map[i].water_height = m->water_height; + map_cache.head.filesize += len_new; + map_cache.dirty = 1; + if(map_read_flag == 2) { + aFree(write_buf); + } + return 0; + } + } + // ‘‚«bß‚È‚©‚Á‚½ + return 1; +} + +/*========================================== + * ?‚Ý?‚Þmap‚ð’ljÁ‚·‚é + *------------------------------------------ + */ +int map_addmap(char *mapname) { + if (strcmpi(mapname,"clear")==0) { + map_num=0; + return 0; + } + + if (map_num >= MAX_MAP_PER_SERVER - 1) { + ShowError("Could not add map '" + CL_WHITE"%s"CL_RESET"', the limit of maps has been reached.\n",mapname); + return 1; + } + memcpy(map[map_num].name, mapname, MAP_NAME_LENGTH-1); + map_num++; + return 0; +} + +/*========================================== + * Removes the map in the index passed. + *------------------------------------------ + */ +static void map_delmapid(int id) +{ + ShowNotice("Removing map [ %s ] from maplist\n",map[id].name); + memmove(map+id, map+id+1, sizeof(map[0])*(map_num-id-1)); + map_num--; +} + +/*========================================== + * ?‚Ý?‚Þmap‚ð휂·‚é + *------------------------------------------ + */ +int map_delmap(char *mapname) { + + int i; + + if (strcmpi(mapname, "all") == 0) { + map_num = 0; + return 0; + } + + for(i = 0; i < map_num; i++) { + if (strcmp(map[i].name, mapname) == 0) { + map_delmapid(i); + return 1; + } + } + return 0; +} + +//////////////////////////////////////////////// + +/* + Advanced Fusion Maps Support + (c) 2003-2004, The Fusion Project + - AlexKreuz + + The following code has been provided by me for eAthena + under the GNU GPL. It provides Advanced Fusion + Map, the map format desgined by me for Fusion, support + for the eAthena emulator. + + I understand that because it is under the GPL + that other emulators may very well use this code in their + GNU project as well. + + The AFM map format was not originally a part of the GNU + GPL. It originated from scratch by my own hand. I understand + that distributing this code to read the AFM maps with eAthena + causes the GPL to apply to this code. But the actual AFM + maps are STILL copyrighted to the Fusion Project. By choosing + + In exchange for that 'act of faith' I ask for the following. + + A) Give credit where it is due. If you use this code, do not + place your name on the changelog. Credit should be given + to AlexKreuz. + B) As an act of courtesy, ask me and let me know that you are putting + AFM support in your project. You will have my blessings if you do. + C) Use the code in its entirety INCLUDING the copyright message. + Although the code provided may now be GPL, the AFM maps are not + and so I ask you to display the copyright message on the STARTUP + SCREEN as I have done here. (refer to core.c) + "Advanced Fusion Maps (c) 2003-2004 The Fusion Project" + + Without this copyright, you are NOT entitled to bundle or distribute + the AFM maps at all. On top of that, your "support" for AFM maps + becomes just as shady as your "support" for Gravity GRF files. + + The bottom line is this. I know that there are those of you who + would like to use this code but aren't going to want to provide the + proper credit. I know this because I speak frome experience. If + you are one of those people who is going to try to get around my + requests, then save your breath because I don't want to hear it. + + I have zero faith in GPL and I know and accept that if you choose to + not display the copyright for the AFMs then there is absolutely nothing + I can do about it. I am not about to start a legal battle over something + this silly. + + Provide the proper credit because you believe in the GPL. If you choose + not to and would rather argue about it, consider the GPL failed. + + October 18th, 2004 + - AlexKreuz + - The Fusion Project + */ +static int map_loadafm (struct map_data *m, char *fn) +{ + // check if .afm file exists + FILE *afm_file = fopen(fn, "r"); + if (afm_file != NULL) { + int x,y,xs,ys; + char afm_line[65535]; + int afm_size[2]; + char *str; + + str = fgets(afm_line, sizeof(afm_line)-1, afm_file); + str = fgets(afm_line, sizeof(afm_line)-1, afm_file); + str = fgets(afm_line, sizeof(afm_line)-1, afm_file); + sscanf(str , "%d%d", &afm_size[0], &afm_size[1]); + + xs = m->xs = afm_size[0]; + ys = m->ys = afm_size[1]; + m->water_height = map_waterheight(m->name); + + m->gat = (unsigned char*)aCallocA(xs * ys, 1); + + for (y = 0; y < ys; y++) { + str = fgets(afm_line, sizeof(afm_line)-1, afm_file); + for (x = 0; x < xs; x++) + m->gat[x+y*xs] = str[x]-48; + } + + fclose(afm_file); + return 1; + } + + return 0; +} +/*================================== + * .AFM format + *---------------------------------- + */ +int map_readafm (struct map_data *m) +{ + char afm_name[256] = ""; + char fn[256], *p; + + // convert map name to .afm + if(!strstr(m->name, ".afm")) { + // check if it's necessary to replace the extension - speeds up loading a bit + strncpy(afm_name, m->name, strlen(m->name) - 4); + strcat(afm_name, ".afm"); + } + + sprintf(fn, "%s\\%s", afm_dir, afm_name); + for (p = &fn[0]; *p != 0; p++) + if (*p == '\\') *p = '/'; // * At the time of Unix + + return map_loadafm(m, fn); +} +/*================================== + * .AF2 format + *---------------------------------- + */ +int map_readaf2 (struct map_data *m) +{ + FILE *af2_file; + char af2_name[256] = ""; + char fn[256], *p, *out; + + // convert map name to .af2 + p = out = m->name; + while ((p = strchr(p, '/')) != NULL) + out = ++p; + strncpy (af2_name, out, strlen(out)); + // grr, this is so troublesome >.< [celest] + p = strrchr (af2_name, '.'); + if (p) *p++ = 0; + strcat(af2_name, ".af2"); + sprintf(fn, "%s\\%s", afm_dir, af2_name); + for (p = &fn[0]; *p != 0; p++) + if (*p == '\\') *p = '/'; // * At the time of Unix + + // check if .af2 file exists + af2_file = fopen(fn, "r"); + if (af2_file != NULL) { + char out_file[256]; + + fclose(af2_file); + + // convert map name to .out + strncpy (out_file, out, strlen(out)); + p = strrchr (out_file, '.'); + if (p) *p++ = 0; + strcat(out_file, ".out"); + + // unzip .out file and use loadafm() + if (deflate_file(fn, out_file) && + map_loadafm(m, out_file)) + { + unlink (out_file); + return 1; + } + } + + return 0; +} + + +/*========================================== + * ƒ}ƒbƒv1–‡“Ç‚ÝbÝ + * ===================================================*/ +//static int map_readmap(int m,char *fn, char *alias, int *map_cache, int maxmap) { + +/*================================== + * .GAT format + *---------------------------------- + */ +int map_readgat (struct map_data *m) +{ + char fn[256], *pt; + char *gat; + int wh,x,y,xs,ys; + struct gat_1cell {float high[4]; int type;} *p = NULL; + + if (strstr(m->name,".gat") == NULL) + return 0; + + if ((pt = strstr(m->name,"<")) != NULL) { // [MouseJstr] + char buf[64]; + *pt++ = '\0'; + sprintf(buf,"data\\%s", pt); + m->alias = aStrdup(buf); + } + + sprintf(fn,"data\\%s",m->name); + + // read & convert fn + // again, might not need to be unsigned char + gat = (char *) grfio_read (fn); + if (gat == NULL) + return 0; + + xs = m->xs = *(int*)(gat+6); + ys = m->ys = *(int*)(gat+10); + m->gat = (unsigned char *)aCallocA(m->xs * m->ys, sizeof(unsigned char)); + + m->water_height = wh = map_waterheight(m->name); + for (y = 0; y < ys; y++) { + p = (struct gat_1cell*)(gat+y*xs*20+14); + for (x = 0; x < xs; x++) { + if (wh != NO_WATER && p->type == 0) + // …ê”»’è + m->gat[x+y*xs] = (p->high[0]>wh || p->high[1]>wh || p->high[2]>wh || p->high[3]>wh) ? 3 : 0; + else + m->gat[x+y*xs] = p->type; + p++; + } + } + + aFree(gat); + + return 1; +} + +////////////////////////////////////////////////////// + +static int map_cache_init (void); +static int map_readafm_init (void); +static int map_readaf2_init (void); +static int map_readgat_init (void); + +// Todo: Properly implement this system as plugins/safer code [Celest] +enum { + MAP_CACHE = 0, // jAthena map cache + MAP_AFM, // Advanced Fusion Map + MAP_AF2, // Advanced Fusion Map + MAP_GAT, // GRF map + MAP_MAXSOURCE +}; +// in descending order +int (*mapsource_init[MAP_MAXSOURCE])(void) = { + map_cache_init, + map_readafm_init, + map_readaf2_init, + map_readgat_init +}; +int (*mapsource_read[MAP_MAXSOURCE])(struct map_data *) = { + map_cache_read, + map_readafm, + map_readaf2, + map_readgat +}; +void (*mapsource_final[MAP_MAXSOURCE])(void) = { + map_cache_close, + NULL, + NULL, + NULL +}; + +static int map_cache_init (void) +{ + if (map_read_flag >= READ_FROM_BITMAP && map_cache_open(map_cache_file)) { + ShowMessage("[cache] "); + return 1; + } + + return 0; +} +static int map_readafm_init (void) +{ + ShowMessage("[afm] "); + return 1; +} +static int map_readaf2_init (void) +{ + // check if AFM loading is available, + // otherwise disable AF2 loading + if (mapsource_read[1] != NULL) { + ShowMessage("[af2] "); + return 1; + } + + return 0; +} +static int map_readgat_init (void) +{ + ShowMessage("[gat] "); + return 1; +} + +/*====================================== + * Initiate maps loading stage + *-------------------------------------- + */ +int map_readallmaps (void) +{ + // pre-loading stage + int i; + int maps_removed = 0; + int maps_cached = 0; + + ShowMessage(CL_GREEN"[Status]"CL_RESET": Loading Maps with... "CL_WHITE); + + for (i = 0; i < MAP_MAXSOURCE; i++) { + if (mapsource_init[i] && // check if source requires initialisation + mapsource_init[i]() == 0) // if init failed + { + // remove all loading methods associated with this source + mapsource_init[i] = NULL; + mapsource_read[i] = NULL; + mapsource_final[i] = NULL; + } + } + + ShowMessage(CL_RESET"\n"); + + // initiate map loading + for (i = 0; i < map_num; i++) + { + int success = 0; + static int lasti = -1; + static int last_time = -1; + int j = i*20/map_num; + + // show progress + if (map_num && //avoid map-server crashing if there are 0 maps + (j != lasti || last_time != time(0))) + { + char progress[21] = " "; + char c = '-'; + int k; + + lasti = j; + printf("\r"); + ShowStatus("Progress: ["); + for (k=0; k < j; k++) progress[k] = '#'; + printf(progress); + last_time = (int)time(0); + switch(last_time % 4) { + case 0: c='\\'; break; + case 1: c='|'; break; + case 2: c='/'; break; + case 3: c='-'; break; + } + printf("] Working: [%c]",c); + fflush(stdout); + } + + // pre-init some data + map[i].alias = NULL; + map[i].m = i; + memset (map[i].moblist, 0, sizeof(map[i].moblist)); //Initialize moblist [Skotlex] + map[i].mob_delete_timer = -1; //Initialize timer [Skotlex] + if (battle_config.pk_mode) + map[i].flag.pvp = 1; // make all maps pvp for pk_mode [Valaris] + + for (j = 0; j < MAP_MAXSOURCE; j++) + { + if (mapsource_read[j] && // check if map source is valid + mapsource_read[j](&map[i])) // check if map source is available + { + // successful, now initialise map + size_t size; + char *alias; + + if (map[i].alias && (alias = strstr(map[i].name, "<")) != NULL) { // alias has been set by one of the sources + *alias++ = '\0'; + } + if (map[i].alias) + map[i].index = mapindex_name2id(map[i].alias); + else + map[i].index = mapindex_name2id(map[i].name); + + if (!map[i].index) { + if (map[i].alias) + ShowWarning("Map %s (alias %s) is not in the map-index cache!\n", map[i].name, map[i].alias); + else + ShowWarning("Map %s is not in the map-index cache!\n", map[i].name); + success = 0; //Can't load a map that isn't in our cache. + if (map[i].gat) { + aFree(map[i].gat); + map[i].gat = NULL; + } + break; + } + if (uidb_get(map_db,(unsigned int)map[i].index) != NULL) { + ShowWarning("Map %s already loaded!\n", map[i].name); + success = 0; //Can't load a map already in the db + if (map[i].gat) { + aFree(map[i].gat); + map[i].gat = NULL; + } + break; + } + + map[i].cell = (unsigned char *)aCalloc(map[i].xs * map[i].ys, sizeof(unsigned char)); +#ifdef CELL_NOSTACK + map[i].cell_bl = (unsigned char *)aCalloc(map[i].xs * map[i].ys, sizeof(unsigned char)); +#endif + + map[i].bxs = (map[i].xs + BLOCK_SIZE - 1) / BLOCK_SIZE; + map[i].bys = (map[i].ys + BLOCK_SIZE - 1) / BLOCK_SIZE; + + size = map[i].bxs * map[i].bys * sizeof(struct block_list*); + map[i].block = (struct block_list**)aCalloc(size, 1); + map[i].block_mob = (struct block_list**)aCalloc(size, 1); + + size = map[i].bxs * map[i].bys * sizeof(int); + map[i].block_count = (int*)aCallocA(size, 1); + memset(map[i].block_count, 0, size); + + map[i].block_mob_count = (int*)aCallocA(size, 1); + memset(map[i].block_mob_count, 0, size); + + uidb_put(map_db, (unsigned int)map[i].index, &map[i]); + + // cache our map if necessary + if (j != MAP_CACHE && mapsource_read[MAP_CACHE] != NULL) { // map data is not cached yet + map_cache_write(&map[i]); + maps_cached++; + } + + // next map + success = 1; + break; + } + } + + // no sources have been found, so remove map from list + if (!success) { + map_delmapid(i); + maps_removed++; + i--; + } + } + + // unload map sources + for (i = 0; i < MAP_MAXSOURCE; i++) { + if (mapsource_final[i]) + mapsource_final[i](); + } + + // finished map loading + //aFree(waterlist); + printf("\r"); + ShowInfo("Successfully loaded '"CL_WHITE"%d"CL_RESET"' maps.%30s\n",map_num,""); + + if (maps_removed) + ShowNotice("Maps Removed: '"CL_WHITE"%d"CL_RESET"'\n",maps_removed); + if (maps_cached) + ShowNotice("Maps Added to Cache: '"CL_WHITE"%d"CL_RESET"'\n",maps_cached); + + return 0; +} + +//////////////////////////////////////////////////////////////////////// + +static int map_ip_set_ = 0; +static int char_ip_set_ = 0; +//static int bind_ip_set_ = 0; + +/*========================================== + * Console Command Parser [Wizputer] + *------------------------------------------ + */ +int parse_console(char *buf) { + char *type,*command,*map, *buf2; + int x = 0, y = 0; + int m, n; + struct map_session_data *sd; + + sd = (struct map_session_data*)aCalloc(sizeof(*sd), 1); + + sd->fd = 0; + strcpy( sd->status.name , "console"); + + type = (char *)aMallocA(64); + command = (char *)aMallocA(64); + map = (char *)aMallocA(64); + buf2 = (char *)aMallocA(72); + + memset(type,0,64); + memset(command,0,64); + memset(map,0,64); + memset(buf2,0,72); + + if ( ( n = sscanf(buf, "%[^:]:%[^:]:%99s %d %d[^\n]", type , command , map , &x , &y )) < 5 ) + if ( ( n = sscanf(buf, "%[^:]:%[^\n]", type , command )) < 2 ) + n = sscanf(buf,"%[^\n]",type); + + if ( n == 5 ) { + if (x <= 0) { + x = rand() % 399 + 1; + sd->bl.x = x; + } else { + sd->bl.x = x; + } + + if (y <= 0) { + y = rand() % 399 + 1; + sd->bl.y = y; + } else { + sd->bl.y = y; + } + + m = map_mapname2mapid(map); + if ( m >= 0 ) + sd->bl.m = m; + else { + ShowWarning("Console: Unknown map\n"); + goto end; + } + } + + ShowInfo("Type of command: %s || Command: %s || Map: %s Coords: %d %d\n",type,command,map,x,y); + + if ( strcmpi("admin",type) == 0 && n == 5 ) { + sprintf(buf2,"console: %s",command); + if( is_atcommand(sd->fd,sd,buf2,99) == AtCommand_None ) + printf("Console: not atcommand\n"); + } else if ( strcmpi("server",type) == 0 && n == 2 ) { + if ( strcmpi("shutdown", command) == 0 || strcmpi("exit",command) == 0 || strcmpi("quit",command) == 0 ) { + runflag = 0; + } + } else if ( strcmpi("help",type) == 0 ) { + ShowNotice("To use GM commands:\n"); + printf("admin:: \n"); + printf("You can use any GM command that doesn't require the GM.\n"); + printf("No using @item or @warp however you can use @charwarp\n"); + printf("The is for commands that need coords of the GM\n"); + printf("IE: @spawn\n"); + printf("To shutdown the server:\n"); + printf("server:shutdown\n"); + } + + end: + aFree(buf); + aFree(type); + aFree(command); + aFree(map); + aFree(buf2); + aFree(sd); + + return 0; +} + +/*========================================== + * Ý’èƒtƒ@ƒCƒ‹‚ð?‚Ý?‚Þ + *------------------------------------------ */ -int map_search_freecell(struct block_list *src, int m, short *x,short *y, int rx, int ry, int flag) { - int tries, spawn=0; - int bx, by; - int rx2 = 2*rx+1; - int ry2 = 2*ry+1; +int map_config_read(char *cfgName) { + char line[1024], w1[1024], w2[1024]; + FILE *fp; + struct hostent *h = NULL; - if (!src && (!(flag&1) || flag&2)) - { - ShowDebug("map_search_freecell: Incorrect usage! When src is NULL, flag has to be &1 and can't have &2\n"); - return 0; + fp = fopen(cfgName,"r"); + if (fp == NULL) { + ShowFatalError("Map configuration file not found at: %s\n", cfgName); + exit(1); + } + while(fgets(line, sizeof(line) -1, fp)) { + if (line[0] == '/' && line[1] == '/') + continue; + if (sscanf(line, "%[^:]: %[^\r\n]", w1, w2) == 2) { + if(strcmpi(w1,"timestamp_format")==0){ + strncpy(timestamp_format, w2, 20); + } else if(strcmpi(w1,"console_silent")==0){ + msg_silent = 0; //To always allow the next line to show up. + ShowInfo("Console Silent Setting: %d\n", atoi(w2)); + msg_silent = atoi(w2); + } else if (strcmpi(w1, "userid")==0){ + chrif_setuserid(w2); + } else if (strcmpi(w1, "passwd") == 0) { + chrif_setpasswd(w2); + } else if (strcmpi(w1, "char_ip") == 0) { + char_ip_set_ = 1; + h = gethostbyname (w2); + if(h != NULL) { + ShowInfo("Char Server IP Address : '"CL_WHITE"%s"CL_RESET"' -> '"CL_WHITE"%d.%d.%d.%d"CL_RESET"'.\n", w2, (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); + sprintf(w2,"%d.%d.%d.%d", (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); + } + chrif_setip(w2); + } else if (strcmpi(w1, "char_port") == 0) { + chrif_setport(atoi(w2)); + } else if (strcmpi(w1, "map_ip") == 0) { + map_ip_set_ = 1; + h = gethostbyname (w2); + if (h != NULL) { + ShowInfo("Map Server IP Address : '"CL_WHITE"%s"CL_RESET"' -> '"CL_WHITE"%d.%d.%d.%d"CL_RESET"'.\n", w2, (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); + sprintf(w2, "%d.%d.%d.%d", (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); + } + clif_setip(w2); + } else if (strcmpi(w1, "bind_ip") == 0) { + //bind_ip_set_ = 1; + h = gethostbyname (w2); + if (h != NULL) { + ShowInfo("Map Server IP Address : '"CL_WHITE"%s"CL_RESET"' -> '"CL_WHITE"%d.%d.%d.%d"CL_RESET"'.\n", w2, (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); + sprintf(w2, "%d.%d.%d.%d", (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); + } + clif_setbindip(w2); + } else if (strcmpi(w1, "map_port") == 0) { + clif_setport(atoi(w2)); + map_port = (atoi(w2)); + //} else if (strcmpi(w1, "water_height") == 0) { + // map_readwater(w2); + } else if (strcmpi(w1, "map") == 0) { + map_addmap(w2); + } else if (strcmpi(w1, "delmap") == 0) { + map_delmap(w2); + } else if (strcmpi(w1, "npc") == 0) { + npc_addsrcfile(w2); + } else if (strcmpi(w1, "delnpc") == 0) { + npc_delsrcfile(w2); + } else if (strcmpi(w1, "autosave_time") == 0) { + autosave_interval = atoi(w2) * 1000; + if (autosave_interval <= 0) + autosave_interval = DEFAULT_AUTOSAVE_INTERVAL; + } else if (strcmpi(w1, "motd_txt") == 0) { + strcpy(motd_txt, w2); + } else if (strcmpi(w1, "help_txt") == 0) { + strcpy(help_txt, w2); + } else if (strcmpi(w1, "help2_txt") == 0) { + strcpy(help2_txt, w2); + } else if (strcmpi(w1, "charhelp_txt") == 0) { + strcpy(charhelp_txt, w2); + } else if (strcmpi(w1, "mapreg_txt") == 0) { + strcpy(mapreg_txt, w2); + } else if(strcmpi(w1,"read_map_from_cache") == 0){ + if (atoi(w2) == 2) + map_read_flag = READ_FROM_BITMAP_COMPRESSED; + else if (atoi(w2) == 1) + map_read_flag = READ_FROM_BITMAP; + else + map_read_flag = READ_FROM_GAT; + } else if(strcmpi(w1,"map_cache_file") == 0) { + strncpy(map_cache_file,w2,255); + } else if(strcmpi(w1,"db_path") == 0) { + strncpy(db_path,w2,255); + } else if(strcmpi(w1,"afm_dir") == 0) { + strcpy(afm_dir, w2); + } else if (strcmpi(w1, "console") == 0) { + if(strcmpi(w2,"on") == 0 || strcmpi(w2,"yes") == 0 ) { + console = 1; + ShowNotice("Console Commands are enabled.\n"); + } + } else if (strcmpi(w1, "enable_spy") == 0) { + if(strcmpi(w2,"on") == 0 || strcmpi(w2,"yes") == 0 ) + enable_spy = 1; + else + enable_spy = 0; + } else if (strcmpi(w1, "import") == 0) { + map_config_read(w2); + } + } } + fclose(fp); - if (flag&1) { - bx = *x; - by = *y; - } else { - bx = src->x; - by = src->y; - m = src->m; + return 0; +} + +int inter_config_read(char *cfgName) +{ + int i; + char line[1024],w1[1024],w2[1024]; + FILE *fp; + + fp=fopen(cfgName,"r"); + if(fp==NULL){ + ShowError("File not found: '%s'.\n",cfgName); + return 1; } - if (rx >= 0 && ry >= 0) { - tries = rx2*ry2; - if (tries > 50) tries = 50; - } else - tries = 100; - - while(tries--) { - *x = (rx >= 0)?(rand()%rx2-rx+bx):(rand()%(map[m].xs-2)+1); - *y = (ry >= 0)?(rand()%rx2-ry+by):(rand()%(map[m].ys-2)+1); + while(fgets(line,1020,fp)){ + if(line[0] == '/' && line[1] == '/') + continue; + i=sscanf(line,"%[^:]: %[^\r\n]",w1,w2); + if(i!=2) + continue; + if(strcmpi(w1,"kick_on_disconnect")==0){ + kick_on_disconnect = battle_config_switch(w2); + } else if(strcmpi(w1,"party_share_level")==0){ + party_share_level = battle_config_switch(w2); + } else if(strcmpi(w1,"lowest_gm_level")==0){ + lowest_gm_level = atoi(w2); - if (map_getcell(m,*x,*y,CELL_CHKREACH)) - { - if(flag&2 && !unit_can_reach_pos(src, *x, *y, 1)) - continue; - if(flag&4 && spawn++ < battle_config.no_spawn_on_player && - map_foreachinarea(map_count_sub, m, - *x-AREA_SIZE, *y-AREA_SIZE, *x+AREA_SIZE, *y+AREA_SIZE, BL_PC) - ) - continue; - - return 1; + /* Main chat nick [LuzZza] */ + } else if(strcmpi(w1, "main_chat_nick")==0){ + strcpy(main_chat_nick, w2); + + #ifndef TXT_ONLY + } else if(strcmpi(w1,"charsave_method")==0){ + charsave_method = atoi(w2); //New char saving method. + } else if(strcmpi(w1,"item_db_db")==0){ + strcpy(item_db_db,w2); + } else if(strcmpi(w1,"mob_db_db")==0){ + strcpy(mob_db_db,w2); + } else if(strcmpi(w1,"item_db2_db")==0){ + strcpy(item_db2_db,w2); + } else if(strcmpi(w1,"mob_db2_db")==0){ + strcpy(mob_db2_db,w2); + } else if(strcmpi(w1,"login_db_level")==0){ + strcpy(login_db_level,w2); + } else if(strcmpi(w1,"login_db_account_id")==0){ + strcpy(login_db_account_id,w2); + } else if(strcmpi(w1,"login_db")==0){ + strcpy(login_db,w2); + } else if (strcmpi(w1, "char_db") == 0) { + strcpy(char_db, w2); + } else if(strcmpi(w1,"gm_db_level")==0){ + strcpy(gm_db_level,w2); + } else if(strcmpi(w1,"gm_db_account_id")==0){ + strcpy(gm_db_account_id,w2); + } else if(strcmpi(w1,"gm_db")==0){ + strcpy(gm_db,w2); + //Map Server SQL DB + } else if(strcmpi(w1,"map_server_ip")==0){ + strcpy(map_server_ip, w2); + } else if(strcmpi(w1,"map_server_port")==0){ + map_server_port=atoi(w2); + } else if(strcmpi(w1,"map_server_id")==0){ + strcpy(map_server_id, w2); + } else if(strcmpi(w1,"map_server_pw")==0){ + strcpy(map_server_pw, w2); + } else if(strcmpi(w1,"map_server_db")==0){ + strcpy(map_server_db, w2); + } else if(strcmpi(w1,"default_codepage")==0){ + strcpy(default_codepage, w2); + } else if(strcmpi(w1,"use_sql_db")==0){ + db_use_sqldbs = battle_config_switch(w2); + ShowStatus ("Using SQL dbs: %s\n",w2); + } else if(strcmpi(w1,"connection_ping_interval")==0) { + connection_ping_interval = battle_config_switch(w2); + //Login Server SQL DB + } else if(strcmpi(w1,"login_server_ip")==0){ + strcpy(login_server_ip, w2); + } else if(strcmpi(w1,"login_server_port")==0){ + login_server_port = atoi(w2); + } else if(strcmpi(w1,"login_server_id")==0){ + strcpy(login_server_id, w2); + } else if(strcmpi(w1,"login_server_pw")==0){ + strcpy(login_server_pw, w2); + } else if(strcmpi(w1,"login_server_db")==0){ + strcpy(login_server_db, w2); + } else if(strcmpi(w1,"read_gm_interval")==0){ + read_gm_interval = ( atoi(w2) * 60 * 1000 ); // Minutes multiplied by 60 secs per min by 1000 milliseconds per second + }else if(strcmpi(w1, "char_server_ip") == 0){ + strcpy(charsql_host, w2); + }else if(strcmpi(w1, "char_server_port") == 0){ + charsql_port = atoi(w2); + }else if(strcmpi(w1, "char_server_id") == 0){ + strcpy(charsql_user, w2); + }else if(strcmpi(w1, "char_server_pw") == 0){ + strcpy(charsql_pass, w2); + }else if(strcmpi(w1, "char_server_db") == 0){ + strcpy(charsql_db, w2); + } else if(strcmpi(w1,"log_db")==0) { + strcpy(log_db, w2); + } else if(strcmpi(w1,"log_db_ip")==0) { + strcpy(log_db_ip, w2); + } else if(strcmpi(w1,"log_db")==0) { + strcpy(log_db, w2); + } else if(strcmpi(w1,"log_db_id")==0) { + strcpy(log_db_id, w2); + } else if(strcmpi(w1,"log_db_pw")==0) { + strcpy(log_db_pw, w2); + } else if(strcmpi(w1,"log_db_port")==0) { + log_db_port = atoi(w2); + // Mail Server SQL + } else if(strcmpi(w1,"mail_server_enable")==0){ + mail_server_enable = battle_config_switch(w2); + ShowStatus ("Using Mail Server: %s\n",w2); + } else if(strcmpi(w1,"mail_server_ip")==0){ + strcpy(mail_server_ip, w2); + } else if(strcmpi(w1,"mail_server_port")==0){ + mail_server_port=atoi(w2); + } else if(strcmpi(w1,"mail_server_id")==0){ + strcpy(mail_server_id, w2); + } else if(strcmpi(w1,"mail_server_pw")==0){ + strcpy(mail_server_pw, w2); + } else if(strcmpi(w1,"mail_server_db")==0){ + strcpy(mail_server_db, w2); + } else if(strcmpi(w1,"mail_db")==0) { + strcpy(mail_db, w2); + #endif + //support the import command, just like any other config + } else if(strcmpi(w1,"import")==0){ + inter_config_read(w2); } } - *x = bx; - *y = by; + fclose(fp); + return 0; } -/*========================================== - * (m,x,y)‚ð’†S‚É3x3ˆÈ?‚É°ƒAƒCƒeƒ€Ý’u - * - * item_data‚ÍamountˆÈŠO‚ðcopy‚·‚é - * type flag: &1 MVP item. &2 do stacking check. - *------------------------------------------ - */ -int map_addflooritem(struct item *item_data,int amount,int m,int x,int y,struct map_session_data *first_sd, - struct map_session_data *second_sd,struct map_session_data *third_sd,int type) { - int r; - unsigned int tick; - struct flooritem_data *fitem=NULL; - - nullpo_retr(0, item_data); - - if(!map_searchrandfreecell(m,&x,&y,type&2?1:0)) - return 0; - r=rand(); - - fitem = (struct flooritem_data *)aCalloc(1,sizeof(*fitem)); - fitem->bl.type=BL_ITEM; - fitem->bl.prev = fitem->bl.next = NULL; - fitem->bl.m=m; - fitem->bl.x=x; - fitem->bl.y=y; - fitem->bl.id = map_addobject(&fitem->bl); - if(fitem->bl.id==0){ - aFree(fitem); - return 0; - } - - tick = gettick(); - if(first_sd) { - fitem->first_get_id = first_sd->bl.id; - if(type&1) - fitem->first_get_tick = tick + battle_config.mvp_item_first_get_time; - else - fitem->first_get_tick = tick + battle_config.item_first_get_time; - } - if(second_sd) { - fitem->second_get_id = second_sd->bl.id; - if(type&1) - fitem->second_get_tick = tick + battle_config.mvp_item_first_get_time + battle_config.mvp_item_second_get_time; - else - fitem->second_get_tick = tick + battle_config.item_first_get_time + battle_config.item_second_get_time; - } - if(third_sd) { - fitem->third_get_id = third_sd->bl.id; - if(type&1) - fitem->third_get_tick = tick + battle_config.mvp_item_first_get_time + battle_config.mvp_item_second_get_time + battle_config.mvp_item_third_get_time; - else - fitem->third_get_tick = tick + battle_config.item_first_get_time + battle_config.item_second_get_time + battle_config.item_third_get_time; - } - - memcpy(&fitem->item_data,item_data,sizeof(*item_data)); - fitem->item_data.amount=amount; - fitem->subx=(r&3)*3+3; - fitem->suby=((r>>2)&3)*3+3; - fitem->cleartimer=add_timer(gettick()+battle_config.flooritem_lifetime,map_clearflooritem_timer,fitem->bl.id,0); - - map_addblock(&fitem->bl); - clif_dropflooritem(fitem); - - return fitem->bl.id; -} - -static void* create_charid2nick(DBKey key, va_list args) { - struct charid2nick *p; - p = (struct charid2nick *)aCallocA(1, sizeof (struct charid2nick)); - return p; -} -/*========================================== - * charid_db‚֒ljÁ(•ÔM‘Ò‚¿‚ª‚ ‚ê‚ΕÔM) - *------------------------------------------ - */ -void map_addchariddb(int charid, char *name) { - struct charid2nick *p; - int req = 0; - - p = idb_ensure(charid_db,charid,create_charid2nick); - req = p->req_id; - p->req_id = 0; - //We overwrite the nick anyway in case a different one arrived. - memcpy(p->nick, name, NAME_LENGTH); - - if (req) { - struct map_session_data *sd = map_id2sd(req); - if (sd) clif_solved_charname(sd,charid); - } -} - -/*========================================== - * charid_db‚֒ljÁi•ÔM—v‹‚Ì‚Ýj - *------------------------------------------ - */ -int map_reqchariddb(struct map_session_data * sd,int charid) { - struct charid2nick *p=NULL; - - nullpo_retr(0, sd); - - p = (struct charid2nick*)idb_get(charid_db,charid); - if(p) return 0; //Nothing to request, we already have the name! - p = (struct charid2nick *)aCalloc(1,sizeof(struct charid2nick)); - p->req_id=sd->bl.id; - idb_put(charid_db,charid,p); - return 0; -} - -/*========================================== - * id_db‚Öbl‚ð’ljÁ - *------------------------------------------ - */ -void map_addiddb(struct block_list *bl) { - nullpo_retv(bl); - - if (bl->type == BL_PC) - idb_put(pc_db,bl->id,bl); - idb_put(id_db,bl->id,bl); -} - -/*========================================== - * id_db‚©‚çbl‚ðíœ - *------------------------------------------ - */ -void map_deliddb(struct block_list *bl) { - nullpo_retv(bl); - - if (bl->type == BL_PC) - idb_remove(pc_db,bl->id); - idb_remove(id_db,bl->id); -} - -/*========================================== - * PC‚Ìquit?— map.c?•ª - * - * quit?—‚ÌŽå?‚ªˆá‚¤‚悤‚È?‚à‚µ‚Ä‚«‚½ - *------------------------------------------ - */ -int map_quit(struct map_session_data *sd) { +#ifndef TXT_ONLY +/*======================================= + * MySQL Init + *--------------------------------------- + */ - //nullpo_retr(0, sd); //Utterly innecessary, all invokations to this function already have an SD non-null check. - //Learn to use proper coding and stop relying on nullpo_'s for safety :P [Skotlex] +int map_sql_init(void){ - if(!sd->state.waitingdisconnect) { - if (sd->npc_timer_id != -1) //Cancel the event timer. - npc_timerevent_quit(sd); - if (sd->state.event_disconnect) { - if (script_config.event_script_type == 0) { - struct npc_data *npc; - if ((npc = npc_name2id(script_config.logout_event_name))) { - run_script(npc->u.scr.script,0,sd->bl.id,npc->bl.id); // PCLogoutNPC - ShowStatus("Event '"CL_WHITE"%s"CL_RESET"' executed.\n", script_config.logout_event_name); - } - } else { - ShowStatus("%d '"CL_WHITE"%s"CL_RESET"' events executed.\n", - npc_event_doall_id(script_config.logout_event_name, sd->bl.id), script_config.logout_event_name); + mysql_init(&mmysql_handle); + + //DB connection start + ShowInfo("Connecting to the Map DB Server....\n"); + if(!mysql_real_connect(&mmysql_handle, map_server_ip, map_server_id, map_server_pw, + map_server_db ,map_server_port, (char *)NULL, 0)) { + //pointer check + ShowSQL("DB error - %s\n",mysql_error(&mmysql_handle)); + exit(1); + } + else { + ShowStatus("connect success! (Map Server Connection)\n"); + } + + if(mail_server_enable) { // mail system [Valaris] + mysql_init(&mail_handle); + ShowInfo("Connecting to the Mail DB Server....\n"); + if(!mysql_real_connect(&mail_handle, mail_server_ip, mail_server_id, mail_server_pw, + mail_server_db ,mail_server_port, (char *)NULL, 0)) { + ShowSQL("DB error - %s\n",mysql_error(&mail_handle)); + exit(1); + } + if( strlen(default_codepage) > 0 ) { + sprintf( tmp_sql, "SET NAMES %s", default_codepage ); + if (mysql_query(&mail_handle, tmp_sql)) { + ShowSQL("DB error - %s\n",mysql_error(&mail_handle)); + ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } - if (sd->pd) unit_free(&sd->pd->bl); - unit_free(&sd->bl); - pc_clean_skilltree(sd); - status_calc_pc(sd,4); - if(sd->pet.intimate > 0) - intif_save_petdata(sd->status.account_id,&sd->pet); - chrif_save(sd,1); - } else { //Try to free some data, without saving anything (this could be invoked on map server change. [Skotlex] - if (sd->bl.prev != NULL) - { //Remove from map... - unit_remove_map(&sd->bl, 0); - if (sd->pd && sd->pd->bl.prev != NULL) - unit_remove_map(&sd->pd->bl, 0); + } + if( strlen(default_codepage) > 0 ) { + sprintf( tmp_sql, "SET NAMES %s", default_codepage ); + if (mysql_query(&mmysql_handle, tmp_sql)) { + ShowSQL("DB error - %s\n",mysql_error(&mmysql_handle)); + ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } - if (sd->stack) { - script_free_stack(sd->stack); - sd->stack= NULL; + return 0; +} + +int map_sql_close(void){ + mysql_close(&mmysql_handle); + ShowStatus("Close Map DB Connection....\n"); + + if (log_config.sql_logs) +//Updating this if each time there's a log_config addition is too much of a hassle. [Skotlex] + /*&& (log_config.branch || log_config.drop || log_config.mvpdrop || + log_config.present || log_config.produce || log_config.refine || log_config.trade))*/ + { + mysql_close(&logmysql_handle); + ShowStatus("Close Log DB Connection....\n"); } - //Do we really need to remove the name? - idb_remove(charid_db,sd->status.char_id); - idb_remove(id_db,sd->bl.id); - idb_remove(pc_db,sd->bl.id); + return 0; +} - if(sd->reg) - { //Double logout already freed pointer fix... [Skotlex] - aFree(sd->reg); - sd->reg = NULL; - sd->reg_num = 0; +int log_sql_init(void){ + + mysql_init(&logmysql_handle); + + //DB connection start + ShowInfo(""CL_WHITE"[SQL]"CL_RESET": Connecting to the Log Database "CL_WHITE"%s"CL_RESET" At "CL_WHITE"%s"CL_RESET"...\n",log_db,log_db_ip); + if(!mysql_real_connect(&logmysql_handle, log_db_ip, log_db_id, log_db_pw, + log_db ,log_db_port, (char *)NULL, 0)) { + //pointer check + ShowSQL("DB error - %s\n",mysql_error(&logmysql_handle)); + exit(1); } - if(sd->regstr) - { - aFree(sd->regstr); - sd->regstr = NULL; - sd->regstr_num = 0; + + ShowStatus(""CL_WHITE"[SQL]"CL_RESET": Successfully '"CL_GREEN"connected"CL_RESET"' to Database '"CL_WHITE"%s"CL_RESET"'.\n", log_db); + if( strlen(default_codepage) > 0 ) { + sprintf( tmp_sql, "SET NAMES %s", default_codepage ); + if (mysql_query(&logmysql_handle, tmp_sql)) { + ShowSQL("DB error - %s\n",mysql_error(&logmysql_handle)); + ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); + } } + return 0; +} +#endif /* not TXT_ONLY */ - if(!sd->fd) //There is no session connected, and as such socket.c won't free the data, we must do it. [Skotlex] - aFree(sd); +int map_db_final(DBKey k,void *d,va_list ap) +{ + struct map_data_other_server *mdos = (struct map_data_other_server*)d; + if(mdos && mdos->gat == NULL) + aFree(mdos); + return 0; +} +int nick_db_final(void *k,void *d,va_list ap) +{ + char *p = (char *) d; + if (p) aFree(p); return 0; } +int cleanup_sub(struct block_list *bl, va_list ap) { + nullpo_retr(0, bl); + + switch(bl->type) { + case BL_PC: + map_quit((struct map_session_data *) bl); + break; + case BL_NPC: + npc_unload((struct npc_data *)bl); + break; + case BL_MOB: + unit_free(bl); + break; + case BL_PET: + //There is no need for this, the pet is removed together with the player. [Skotlex] + break; + case BL_ITEM: + map_clearflooritem(bl->id); + break; + case BL_SKILL: + skill_delunit((struct skill_unit *) bl); + break; + } + + return 1; +} -/*========================================== - * id”Ô?‚ÌPC‚ð’T‚·B‹‚È‚¯‚ê‚ÎNULL - *------------------------------------------ - */ -struct map_session_data * map_id2sd(int id) { -// Now using pc_db to handle all players, should be quicker than both previous methods at a small expense of more memory. [Skotlex] - if (id <= 0) return NULL; - return (struct map_session_data*)idb_get(pc_db,id); -} - -/*========================================== - * char_id”Ô?‚Ì–¼‘O‚ð’T‚· - *------------------------------------------ - */ -char * map_charid2nick(int id) { - struct charid2nick *p = (struct charid2nick*)idb_get(charid_db,id); - - if(p==NULL) - return NULL; - return p->nick; -} - -struct map_session_data * map_charid2sd(int id) { - int i, users; - struct map_session_data **all_sd; - - if (id <= 0) return 0; - - all_sd = map_getallusers(&users); - for(i = 0; i < users; i++) - if (all_sd[i] && all_sd[i]->status.char_id == id) - return all_sd[i]; - - return NULL; -} - -/*========================================== - * Search session data from a nick name - * (without sensitive case if necessary) - * return map_session_data pointer or NULL - *------------------------------------------ - */ -struct map_session_data * map_nick2sd(char *nick) { - int i, quantity=0, nicklen, users; - struct map_session_data *sd = NULL; - struct map_session_data *pl_sd = NULL, **pl_allsd; - - if (nick == NULL) - return NULL; - - nicklen = strlen(nick); - - pl_allsd = map_getallusers(&users); - - for (i = 0; i < users; i++) { - pl_sd = pl_allsd[i]; - // Without case sensitive check (increase the number of similar character names found) - if (strnicmp(pl_sd->status.name, nick, nicklen) == 0) { - // Strict comparison (if found, we finish the function immediatly with correct value) - if (strcmp(pl_sd->status.name, nick) == 0) - return pl_sd; - quantity++; - sd = pl_sd; - } - } - // Here, the exact character name is not found - // We return the found index of a similar account ONLY if there is 1 similar character - if (quantity == 1) - return sd; - - // Exact character name is not found and 0 or more than 1 similar characters have been found ==> we say not found - return NULL; -} - -/*========================================== - * id”Ô?‚Ì•¨‚ð’T‚· - * ˆêŽObject‚Ìꇂ͔z—ñ‚ðˆø‚­‚Ì‚Ý - *------------------------------------------ - */ -struct block_list * map_id2bl(int id) -{ - struct block_list *bl=NULL; - if(id >= 0 && id < sizeof(objects)/sizeof(objects[0])) - bl = objects[id]; - else - bl = idb_get(id_db,id); - - return bl; -} - -static int map_getallpc_sub(DBKey key,void * data,va_list ap) -{ - struct map_session_data *sd = (struct map_session_data*) data; - if (!sd->state.auth || sd->state.waitingdisconnect || sd->state.finalsave) - return 1; //Do not count in not-yet authenticated characters or ready to disconnect ones. - - return 0; -} - -/*========================================== - * Returns an array of all players in the server (includes non connected ones) [Skotlex] - * The int pointer given returns the count of elements in the array. - * If null is passed, it is requested that the memory be freed (for shutdown), and null is returned. - *------------------------------------------ - */ -struct map_session_data** map_getallusers(int *users) { - static struct map_session_data **all_sd=NULL; - static unsigned int all_count = 0; - - if (users == NULL) - { //Free up data - if (all_sd) aFree(all_sd); - all_sd = NULL; - return NULL; - } - - if (all_sd == NULL) - { //Init data - all_count = pc_db->size(pc_db); //This is the real number of chars in the db, better use this than the actual "online" count. - if (all_count < 1) - all_count = 10; //Allow room for at least 10 chars. - all_sd = aCalloc(all_count, sizeof(struct map_session_data*)); //it's actually just the size of a pointer. - } - - if (all_count < pc_db->size(pc_db)) - { - all_count = pc_db->size(pc_db)+10; //Give some room to prevent doing reallocs often. - all_sd = aRealloc(all_sd, all_count*sizeof(struct map_session_data*)); - } - *users = pc_db->getall(pc_db,(void**)all_sd,all_count,map_getallpc_sub); - if (*users > (signed int)all_count) //Which should be impossible... - *users = all_count; - return all_sd; -} - -/*========================================== - * id_db?‚Ì‘S‚Ä‚Éfunc‚ð?s - *------------------------------------------ - */ -int map_foreachiddb(int (*func)(DBKey,void*,va_list),...) { - va_list ap; - - va_start(ap,func); - id_db->foreach(id_db,func,ap); - va_end(ap); - return 0; -} - -/*========================================== - * map.npc‚֒ljÁ (warp“™‚̗̈掂¿‚Ì‚Ý) - *------------------------------------------ - */ -int map_addnpc(int m,struct npc_data *nd) { - int i; - if(m<0 || m>=map_num) - return -1; - for(i=0;in = i; - idb_put(id_db,nd->bl.id,nd); - - return i; -} - -void map_removenpc(void) { - int i,m,n=0; - - for(m=0;mbl,2); - map_delblock(&map[m].npc[i]->bl); - idb_remove(id_db,map[m].npc[i]->bl.id); - if(map[m].npc[i]->bl.subtype==SCRIPT) { - aFree(map[m].npc[i]->u.scr.script); - aFree(map[m].npc[i]->u.scr.label_list); - } - aFree(map[m].npc[i]); - map[m].npc[i] = NULL; - n++; - } - } - } - - ShowStatus("Successfully removed and freed from memory '"CL_WHITE"%d"CL_RESET"' NPCs.\n",n); -} - -/*========================================= - * Dynamic Mobs [Wizputer] - *----------------------------------------- - */ - -// allocates a struct when it there is place free in the cache, -// and returns NULL otherwise -// -- i'll just leave the old code in case it's needed ^^; -int map_addmobtolist(unsigned short m, struct spawn_data *spawn) -{ - size_t i; - for (i = 0; i < MAX_MOB_LIST_PER_MAP; i++) { - if (map[m].moblist[i] == NULL) { - map[m].moblist[i] = spawn; - return i; - } - } - return -1; -} - -void map_spawnmobs(int m) -{ - int i, k=0; - if (map[m].mob_delete_timer != -1) - { //Mobs have not been removed yet [Skotlex] - delete_timer(map[m].mob_delete_timer, map_removemobs_timer); - map[m].mob_delete_timer = -1; - return; - } - for(i=0; inum; - npc_parse_mob2(map[m].moblist[i],i); - } - - if (battle_config.etc_log && k > 0) - { - ShowStatus("Map %s: Spawned '"CL_WHITE"%d"CL_RESET"' mobs.\n",map[m].name, k); - } -} - -int mob_cache_cleanup_sub(struct block_list *bl, va_list ap) { - struct mob_data *md = (struct mob_data *)bl; - nullpo_retr(0, md); - - //When not to remove: - //Mob has the cached flag on 0 - if (!md->special_state.cached) - return 0; - if (!battle_config.mob_remove_damaged && - md->hp < md->db->max_hp) //don't use status_get_maxhp for speed (by the time you have to remove a mob, their status changes should have expired anyway) - return 0; //Do not remove damaged mobs. - - unit_free(&md->bl); - - return 1; -} - -int map_removemobs_timer(int tid, unsigned int tick, int id, int data) -{ - int k; - if (id < 0 || id >= MAX_MAP_PER_SERVER) - { //Incorrect map id! - if (battle_config.error_log) - ShowError("map_removemobs_timer error: timer %d points to invalid map %d\n",tid, id); - return 0; - } - if (map[id].mob_delete_timer != tid) - { //Incorrect timer call! - if (battle_config.error_log) - ShowError("map_removemobs_timer mismatch: %d != %d (map %s)\n",map[id].mob_delete_timer, tid, map[id].name); - return 0; - } - map[id].mob_delete_timer = -1; - if (map[id].users > 0) //Map not empty! - return 1; - k = map_foreachinmap(mob_cache_cleanup_sub, id, BL_MOB); - - if (battle_config.etc_log && k > 0) - ShowStatus("Map %s: Removed '"CL_WHITE"%d"CL_RESET"' mobs.\n",map[id].name, k); - - return 1; -} - -void map_removemobs(int m) -{ - if (map[m].mob_delete_timer != -1) - return; //Mobs are already scheduled for removal - - map[m].mob_delete_timer = add_timer(gettick()+battle_config.mob_remove_delay, map_removemobs_timer, m, 0); -} - -/*========================================== - * map–¼‚©‚çmap”Ô?‚Ö?Š· - *------------------------------------------ - */ -int map_mapname2mapid(char *name) { - unsigned short map_index; - map_index = mapindex_name2id(name); - if (!map_index) - return -1; - return map_mapindex2mapid(map_index); -} - -/*========================================== - * Returns the map of the given mapindex. [Skotlex] - *------------------------------------------ - */ -int map_mapindex2mapid(unsigned short mapindex) { - struct map_data *md=NULL; - - if (!mapindex) - return -1; - - md = (struct map_data*)uidb_get(map_db,(unsigned int)mapindex); - if(md==NULL || md->gat==NULL) - return -1; - return md->m; -} - -/*========================================== - * ‘¼ŽImap–¼‚©‚çip,port?Š· - *------------------------------------------ - */ -int map_mapname2ipport(unsigned short name,int *ip,int *port) { - struct map_data_other_server *mdos=NULL; - - mdos = (struct map_data_other_server*)uidb_get(map_db,(unsigned int)name); - if(mdos==NULL || mdos->gat) //If gat isn't null, this is a local map. - return -1; - *ip=mdos->ip; - *port=mdos->port; - return 0; -} - -/*========================================== - * Checks if both dirs point in the same direction. - *------------------------------------------ - */ -int map_check_dir(int s_dir,int t_dir) { - if(s_dir == t_dir) - return 0; - switch(s_dir) { - case 0: - if(t_dir == 7 || t_dir == 1 || t_dir == 0) - return 0; - break; - case 1: - if(t_dir == 0 || t_dir == 2 || t_dir == 1) - return 0; - break; - case 2: - if(t_dir == 1 || t_dir == 3 || t_dir == 2) - return 0; - break; - case 3: - if(t_dir == 2 || t_dir == 4 || t_dir == 3) - return 0; - break; - case 4: - if(t_dir == 3 || t_dir == 5 || t_dir == 4) - return 0; - break; - case 5: - if(t_dir == 4 || t_dir == 6 || t_dir == 5) - return 0; - break; - case 6: - if(t_dir == 5 || t_dir == 7 || t_dir == 6) - return 0; - break; - case 7: - if(t_dir == 6 || t_dir == 0 || t_dir == 7) - return 0; - break; - } - return 1; -} - -/*========================================== - * Returns the direction of the given cell in absolute relation to the char - * (regardless of where the char is facing) - *------------------------------------------ - */ -int map_calc_dir( struct block_list *src,int x,int y) { - int dir=0; - int dx,dy; - - nullpo_retr(0, src); - - dx=x-src->x; - dy=y-src->y; - if( dx==0 && dy==0 ){ // ”Þ‰ä‚Ìꊈê’v - dir=0; // ã - }else if( dx>=0 && dy>=0 ){ // •ûŒü“I‚ɉEã - dir=7; // ‰Eã - if( dx*2-1dy*2 ) dir=6; // ‰E - }else if( dx>=0 && dy<=0 ){ // •ûŒü“I‚ɉE‰º - dir=5; // ‰E‰º - if( dx*2-1<-dy ) dir=4; // ‰º - if( dx>-dy*2 ) dir=6; // ‰E - }else if( dx<=0 && dy<=0 ){ // •ûŒü“I‚ɶ‰º - dir=3; // ¶‰º - if( dx*2+1>dy ) dir=4; // ‰º - if( dxdy*2 ) dir=2; // ¶ - } - return dir; -} - -/*========================================== - * Randomizes target cell x,y to a random walkable cell that - * has the same distance from object as given coordinates do. [Skotlex] - *------------------------------------------ - */ -int map_random_dir(struct block_list *bl, short *x, short *y) { - struct walkpath_data wpd; - short xi = *x-bl->x; - short yi = *y-bl->y; - short i=0, j; - int dist2 = xi*xi + yi*yi; - short dist = (short)sqrt(dist2); - short segment; - - if (dist < 1) dist =1; - - do { - j = rand()%8; //Pick a random direction - segment = rand()%dist; //Pick a random interval from the whole vector in that direction - xi = bl->x + segment*dirx[j]; - segment = (short)sqrt(dist2 - segment*segment); //The complement of the previously picked segment - yi = bl->y + segment*diry[j]; - } while (( - map_getcell(bl->m,xi,yi,CELL_CHKNOPASS) || - path_search_real(&wpd,bl->m,bl->x,bl->y,xi,yi,1,CELL_CHKNOREACH) == -1) - && (++i)<100); - - if (i < 100) { - *x = xi; - *y = yi; - return 1; - } - return 0; -} -// gatŒn -/*========================================== - * (m,x,y)‚Ìó‘Ԃ𒲂ׂé - *------------------------------------------ - */ - -int map_getcell(int m,int x,int y,cell_t cellchk) -{ - return (m < 0 || m >= MAX_MAP_PER_SERVER) ? 0 : map_getcellp(&map[m],x,y,cellchk); -} - -int map_getcellp(struct map_data* m,int x,int y,cell_t cellchk) -{ - int type, type2; -#ifdef CELL_NOSTACK - int type3; -#endif - - nullpo_ret(m); - - if(x<0 || x>=m->xs-1 || y<0 || y>=m->ys-1) - { - if(cellchk==CELL_CHKNOPASS) return 1; - return 0; - } - type = m->gat[x+y*m->xs]; - type2 = m->cell[x+y*m->xs]; -#ifdef CELL_NOSTACK - type3 = m->cell_bl[x+y*m->xs]; -#endif - - switch(cellchk) - { - case CELL_CHKPASS: -#ifdef CELL_NOSTACK - if (type3 >= battle_config.cell_stack_limit) return 0; -#endif - case CELL_CHKREACH: - return (type!=1 && type!=5 && !(type2&(CELL_MOONLIT|CELL_ICEWALL))); - case CELL_CHKNOPASS: -#ifdef CELL_NOSTACK - if (type3 >= battle_config.cell_stack_limit) return 1; -#endif - case CELL_CHKNOREACH: - return (type==1 || type==5 || type2&(CELL_MOONLIT|CELL_ICEWALL)); - case CELL_CHKSTACK: -#ifdef CELL_NOSTACK - return (type3 >= battle_config.cell_stack_limit); -#else - return 0; -#endif - case CELL_CHKWALL: - return (type==1/* || type2&CELL_ICEWALL*/); //Uncomment to prevent sniping/casting through the icewall. [Skotlex] - case CELL_CHKWATER: - return (type==3); - case CELL_CHKGROUND: - return (type==5 || type2&CELL_ICEWALL); - case CELL_GETTYPE: - return type; - case CELL_GETCELLTYPE: - return type2; - case CELL_CHKNPC: - return (type2&CELL_NPC); - case CELL_CHKPNEUMA: - return (type2&CELL_PNEUMA); - case CELL_CHKSAFETYWALL: - return (type2&CELL_SAFETYWALL); - case CELL_CHKBASILICA: - return (type2&CELL_BASILICA); - case CELL_CHKLANDPROTECTOR: - return (type2&CELL_LANDPROTECTOR); - case CELL_CHKMOONLIT: - return (type2&CELL_MOONLIT); - case CELL_CHKREGEN: - return (type2&CELL_REGEN); - case CELL_CHKICEWALL: - return (type2&CELL_ICEWALL); - default: - return 0; - } -} - -/*========================================== - * (m,x,y)‚Ìó‘Ô‚ðÝ’è‚·‚é - *------------------------------------------ - */ -void map_setcell(int m,int x,int y,int cell) -{ - int j; - if(x<0 || x>=map[m].xs || y<0 || y>=map[m].ys) - return; - j=x+y*map[m].xs; - - switch (cell) { - case CELL_SETNPC: - map[m].cell[j] |= CELL_NPC; - break; - case CELL_CLRNPC: - map[m].cell[j] &= ~CELL_NPC; - break; - case CELL_SETICEWALL: - map[m].cell[j] |= CELL_ICEWALL; - break; - case CELL_CLRICEWALL: - map[m].cell[j] &= ~CELL_ICEWALL; - break; - case CELL_SETBASILICA: - map[m].cell[j] |= CELL_BASILICA; - break; - case CELL_CLRBASILICA: - map[m].cell[j] &= ~CELL_BASILICA; - break; - case CELL_SETPNEUMA: - map[m].cell[j] |= CELL_PNEUMA; - break; - case CELL_CLRPNEUMA: - map[m].cell[j] &= ~CELL_PNEUMA; - break; - case CELL_SETSAFETYWALL: - map[m].cell[j] |= CELL_SAFETYWALL; - break; - case CELL_CLRSAFETYWALL: - map[m].cell[j] &= ~CELL_SAFETYWALL; - break; - case CELL_SETMOONLIT: - map[m].cell[j] |= CELL_MOONLIT; - break; - case CELL_CLRMOONLIT: - map[m].cell[j] &= ~CELL_MOONLIT; - break; - case CELL_SETLANDPROTECTOR: - map[m].cell[j] |= CELL_LANDPROTECTOR; - break; - case CELL_CLRLANDPROTECTOR: - map[m].cell[j] &= ~CELL_LANDPROTECTOR; - break; - case CELL_SETREGEN: - map[m].cell[j] |= CELL_REGEN; - break; - default: - map[m].gat[j] = cell; - break; - } -} -static void* create_map_data_other_server(DBKey key, va_list args) { - struct map_data_other_server *mdos; - unsigned short mapindex = (unsigned short)key.ui; - mdos=(struct map_data_other_server *)aCalloc(1,sizeof(struct map_data_other_server)); - mdos->index = mapindex; - memcpy(mdos->name, mapindex_id2name(mapindex), MAP_NAME_LENGTH); - return mdos; -} -/*========================================== - * ‘¼ŽIŠÇ—‚̃}ƒbƒv‚ðdb‚ɒljÁ - *------------------------------------------ - */ -int map_setipport(unsigned short mapindex,unsigned long ip,int port) { - struct map_data_other_server *mdos=NULL; - - mdos=(struct map_data_other_server *)uidb_ensure(map_db,(unsigned int)mapindex, create_map_data_other_server); - - if(mdos->gat) //Local map,Do nothing. Give priority to our own local maps over ones from another server. [Skotlex] - return 0; - if(ip == clif_getip() && port == clif_getport()) { - //That's odd, we received info that we are the ones with this map, but... we don't have it. - ShowFatalError("map_setipport : received info that this map-server SHOULD have map '%s', but it is not loaded.\n",mapindex_id2name(mapindex)); - exit(1); - } - mdos->ip = ip; - mdos->port = port; - return 1; -} - -/*========================================== - * ‘¼ŽIŠÇ—‚̃}ƒbƒv‚ð‘S‚Äíœ - *------------------------------------------ - */ -int map_eraseallipport_sub(DBKey key,void *data,va_list va) { - struct map_data_other_server *mdos = (struct map_data_other_server*)data; - if(mdos->gat == NULL) { - db_remove(map_db,key); - aFree(mdos); - } - return 0; -} - -int map_eraseallipport(void) { - map_db->foreach(map_db,map_eraseallipport_sub); - return 1; -} - -/*========================================== - * ‘¼ŽIŠÇ—‚̃}ƒbƒv‚ðdb‚©‚çíœ - *------------------------------------------ - */ -int map_eraseipport(unsigned short mapindex,unsigned long ip,int port) -{ - struct map_data_other_server *mdos; -// unsigned char *p=(unsigned char *)&ip; - - mdos = uidb_get(map_db,(unsigned int)mapindex); - if(!mdos || mdos->gat) //Map either does not exists or is a local map. - return 0; - - if(mdos->ip==ip && mdos->port == port) { - uidb_remove(map_db,(unsigned int)mapindex); - aFree(mdos); - return 1; - } - return 0; -} - -// ‰Šú‰»Žü‚è -/*========================================== - * …ê‚‚³Ý’è - *------------------------------------------ - */ -//static struct waterlist_ { -// char mapname[MAP_NAME_LENGTH], clonemapname[MAP_NAME_LENGTH]; -//} *waterlist=NULL; - -#define NO_WATER 1000000 - -static int map_setwaterheight_sub(int m) { - char fn[256]; - char *gat; - int x,y; - int wh; - struct gat_1cell {float high[4]; int type;} *p = NULL; - - if (m < 0) - return 0; - wh = map[m].water_height; - - sprintf(fn,"data\\%s",mapindex_id2name(map[m].index)); - - // read & convert fn - // again, might not need to be unsigned char - gat = (char *) grfio_read (fn); - if (gat == NULL) - return 0; - - for (y = 0; y < map[m].ys; y++) { - p = (struct gat_1cell*)(gat+y*map[m].xs*20+14); - for (x = 0; x < map[m].xs; x++) { - if (wh != NO_WATER && p->type == 0) //Set water cell - map[m].gat[x+y*map[m].xs] = (p->high[0]>wh || p->high[1]>wh || p->high[2]>wh || p->high[3]>wh) ? 3 : 0; - else //Remove water cell - map[m].gat[x+y*map[m].xs] = p->type==3?0:p->type; - p++; - } - } - aFree(gat); - return 1; -} -int map_setwaterheight(int m, char *mapname, int height) { - if (height < 0) - height = NO_WATER; - map[m].water_height = height; - return map_setwaterheight_sub(m); -} - -/* map_readwaterheight - * Reads from the .rsw for each map - * Returns water height (or NO_WATER if file doesn't exist) - * or other error is encountered. - * This receives a map-name, and changes the extension to rsw if it isn't set already. - * assumed path for file is data/mapname.rsw - * Credits to LittleWolf - */ -int map_waterheight(char *mapname) { - char fn[256]; - char *rsw, *found; - float whtemp; - int wh; - - //Look up for clone map. - //if(waterlist){ - // int i; - // for(i=0;waterlist[i].mapname[0] && i < MAX_MAP_PER_SERVER;i++) - // if(strcmp(waterlist[i].mapname,mapname)==0) - // return map_waterheight(waterlist[i].clonemapname); - //} - //Look up for the rsw - sprintf(fn,"data\\%s",mapname); - - found = grfio_find_file(fn); - if(!strstr(found,"data\\")) - sprintf(fn,"data\\%s", found); - else - strcpy(fn, found); - - rsw = strstr(fn, "."); - if (rsw && strstr(fn, ".rsw") == NULL) - sprintf(rsw,".rsw"); - // read & convert fn - // again, might not need to be unsigned char - rsw = (char *) grfio_read (fn); - if (rsw) - { //Load water height from file - whtemp = *(float*)(rsw+166); - wh = (int) whtemp; - aFree(rsw); - return wh; - } - ShowWarning("Failed to find water level for (%s)\n", mapname, fn); - return NO_WATER; -} - -//static void map_readwater(char *watertxt) { -// char line[1024],w1[1024],w2[1024]; -// FILE *fp=NULL; -// int n=0; -// -// fp=fopen(watertxt,"r"); -// if(fp==NULL){ -// ShowError("file not found: %s\n",watertxt); -// return; -// } -// if(waterlist==NULL) -// waterlist = (struct waterlist_*)aCallocA(MAX_MAP_PER_SERVER,sizeof(*waterlist)); -// while(fgets(line,1020,fp) && n < MAX_MAP_PER_SERVER){ -// if(line[0] == '/' && line[1] == '/') -// continue; -// if(sscanf(line,"%s %s",w1,w2) < 2){ -// continue; -// } -// memcpy(waterlist[n].mapname,w1, MAP_NAME_LENGTH-1); -// memcpy(waterlist[n].clonemapname, w2, MAP_NAME_LENGTH-1); -// n++; -// } -// fclose(fp); -//} -/*========================================== -* ƒ}ƒbƒvƒLƒƒƒbƒVƒ…‚ɒljÁ‚·‚é -*===========================================*/ - -// ƒ}ƒbƒvƒLƒƒƒbƒVƒ…‚ÌÅ‘å’l -#define MAX_MAP_CACHE 768 - -//Šeƒ}ƒbƒv‚²‚Æ‚ÌŬŒÀî•ñ‚ð“ü‚ê‚é‚à‚ÌAREAD_FROM_BITMAP—p -struct map_cache_info { - char fn[32];//ƒtƒ@ƒCƒ‹–¼ - int xs,ys; //•‚Æ‚‚³ - int water_height; - int pos; // ƒf[ƒ^‚ª“ü‚ê‚Ä‚ ‚éêŠ - int compressed; // zilb’Ê‚¹‚é‚悤‚É‚·‚éˆ×‚Ì—\–ñ - int compressed_len; // zilb’Ê‚¹‚é‚悤‚É‚·‚éˆ×‚Ì—\–ñ -}; // 56 byte - -struct map_cache_head { - int sizeof_header; - int sizeof_map; - // ã‚Ì‚Q‚‰ü•Ï•s‰Â - int nmaps; // ƒ}ƒbƒv‚̌” - int filesize; -}; - -struct { - struct map_cache_head head; - struct map_cache_info *map; - FILE *fp; - int dirty; -} map_cache; - -static int map_cache_open(char *fn); -static void map_cache_close(void); -static int map_cache_read(struct map_data *m); -static int map_cache_write(struct map_data *m); - -static int map_cache_open(char *fn) -{ - if (map_cache.fp) - map_cache_close(); - map_cache.fp = fopen(fn, "r+b"); - if (map_cache.fp) { - fread(&map_cache.head,1,sizeof(struct map_cache_head),map_cache.fp); - fseek(map_cache.fp,0,SEEK_END); - if( - map_cache.head.sizeof_header == sizeof(struct map_cache_head) && - map_cache.head.sizeof_map == sizeof(struct map_cache_info) && - map_cache.head.filesize == ftell(map_cache.fp) - ) { - // ƒLƒƒƒbƒVƒ…“Ç‚ÝbݬŒ÷ - map_cache.map = (struct map_cache_info *) aMalloc(sizeof(struct map_cache_info) * map_cache.head.nmaps); - fseek(map_cache.fp,sizeof(struct map_cache_head),SEEK_SET); - fread(map_cache.map,sizeof(struct map_cache_info),map_cache.head.nmaps,map_cache.fp); - return 1; - } - fclose(map_cache.fp); - } - // “Ç‚ÝbÝ‚ÉŽ¸”s‚µ‚½‚Ì‚ÅV‹K‚É쬂·‚é - map_cache.fp = fopen(fn,"wb"); - if(map_cache.fp) { - memset(&map_cache.head,0,sizeof(struct map_cache_head)); - map_cache.map = (struct map_cache_info *) aCalloc(sizeof(struct map_cache_info),MAX_MAP_CACHE); - map_cache.head.nmaps = MAX_MAP_CACHE; - map_cache.head.sizeof_header = sizeof(struct map_cache_head); - map_cache.head.sizeof_map = sizeof(struct map_cache_info); - - map_cache.head.filesize = sizeof(struct map_cache_head); - map_cache.head.filesize += sizeof(struct map_cache_info) * map_cache.head.nmaps; - - map_cache.dirty = 1; - return 1; - } - return 0; -} - -static void map_cache_close(void) -{ - if(!map_cache.fp) { return; } - if(map_cache.dirty) { - fseek(map_cache.fp,0,SEEK_SET); - fwrite(&map_cache.head,1,sizeof(struct map_cache_head),map_cache.fp); - fwrite(map_cache.map,map_cache.head.nmaps,sizeof(struct map_cache_info),map_cache.fp); - } - fclose(map_cache.fp); - aFree(map_cache.map); - map_cache.fp = NULL; - return; -} - -int map_cache_read(struct map_data *m) -{ - int i; - if(!map_cache.fp) { return 0; } - for(i = 0;i < map_cache.head.nmaps ; i++) { - if(!strcmp(m->name,map_cache.map[i].fn)) { - if(map_cache.map[i].compressed == 0) { - // ”ñˆ³kƒtƒ@ƒCƒ‹ - int size = map_cache.map[i].xs * map_cache.map[i].ys; - m->xs = map_cache.map[i].xs; - m->ys = map_cache.map[i].ys; - m->water_height = map_cache.map[i].water_height; - m->gat = (unsigned char *)aCalloc(m->xs * m->ys,sizeof(unsigned char)); - fseek(map_cache.fp,map_cache.map[i].pos,SEEK_SET); - if(fread(m->gat,1,size,map_cache.fp) == size) { - // ¬Œ÷ - return 1; - } else { - // ‚È‚º‚©ƒtƒ@ƒCƒ‹Œã”¼‚ªŒ‡‚¯‚Ä‚é‚Ì‚Å“Ç‚Ý’¼‚µ - m->xs = 0; m->ys = 0; aFree(m->gat); m->gat = NULL; - return 0; - } - } else if(map_cache.map[i].compressed == 1) { - // ˆ³kƒtƒ‰ƒO=1 : zlib - unsigned char *buf; - unsigned long dest_len; - int size_compress = map_cache.map[i].compressed_len; - m->xs = map_cache.map[i].xs; - m->ys = map_cache.map[i].ys; - m->water_height = map_cache.map[i].water_height; - m->gat = (unsigned char *)aMalloc(m->xs * m->ys * sizeof(unsigned char)); - buf = (unsigned char*)aMalloc(size_compress); - fseek(map_cache.fp,map_cache.map[i].pos,SEEK_SET); - if(fread(buf,1,size_compress,map_cache.fp) != size_compress) { - // ‚È‚º‚©ƒtƒ@ƒCƒ‹Œã”¼‚ªŒ‡‚¯‚Ä‚é‚Ì‚Å“Ç‚Ý’¼‚µ - ShowError("fread error\n"); - aFree(m->gat); m->xs = 0; m->ys = 0; m->gat = NULL; - aFree(buf); - return 0; - } - dest_len = m->xs * m->ys; - decode_zip(m->gat,&dest_len,buf,size_compress); - if(dest_len != map_cache.map[i].xs * map_cache.map[i].ys) { - // ³í‚ɉ𓀂ªo—ˆ‚Ä‚È‚¢ - aFree(m->gat); m->xs = 0; m->ys = 0; m->gat = NULL; - aFree(buf); - return 0; - } - aFree(buf); - return 1; - } - } - } - return 0; -} - -static int map_cache_write(struct map_data *m) -{ - int i; - unsigned long len_new , len_old; - char *write_buf; - if(!map_cache.fp) { return 0; } - for(i = 0;i < map_cache.head.nmaps ; i++) { - if(!strcmp(m->name,map_cache.map[i].fn)) { - // “¯‚¶ƒGƒ“ƒgƒŠ[‚ª‚ ‚ê‚Îã‘‚« - if(map_cache.map[i].compressed == 0) { - len_old = map_cache.map[i].xs * map_cache.map[i].ys; - } else if(map_cache.map[i].compressed == 1) { - len_old = map_cache.map[i].compressed_len; - } else { - // ƒTƒ|[ƒg‚³‚ê‚Ä‚È‚¢Œ`Ž®‚È‚Ì‚Å’·‚³‚O - len_old = 0; - } - if(map_read_flag == 2) { - // ˆ³k•Û‘¶ - // ‚³‚·‚ª‚É‚Q”{‚É–c‚ê‚鎖‚Í‚È‚¢‚Æ‚¢‚¤Ž–‚Å - write_buf = (char *) aMalloc(m->xs * m->ys * 2); - len_new = m->xs * m->ys * 2; - encode_zip((unsigned char *) write_buf,&len_new,m->gat,m->xs * m->ys); - map_cache.map[i].compressed = 1; - map_cache.map[i].compressed_len = len_new; - } else { - len_new = m->xs * m->ys; - write_buf = (char *) m->gat; - map_cache.map[i].compressed = 0; - map_cache.map[i].compressed_len = 0; - } - if(len_new <= len_old) { - // ƒTƒCƒY‚ª“¯‚¶‚©¬‚³‚­‚È‚Á‚½‚Ì‚Åꊂ͕ςí‚ç‚È‚¢ - fseek(map_cache.fp,map_cache.map[i].pos,SEEK_SET); - fwrite(write_buf,1,len_new,map_cache.fp); - } else { - // V‚µ‚¢êŠ‚É“o˜^ - fseek(map_cache.fp,map_cache.head.filesize,SEEK_SET); - fwrite(write_buf,1,len_new,map_cache.fp); - map_cache.map[i].pos = map_cache.head.filesize; - map_cache.head.filesize += len_new; - } - map_cache.map[i].xs = m->xs; - map_cache.map[i].ys = m->ys; - map_cache.map[i].water_height = m->water_height; - map_cache.dirty = 1; - if(map_read_flag == 2) { - aFree(write_buf); - } - return 0; - } - } - // “¯‚¶ƒGƒ“ƒgƒŠ‚ª–³‚¯‚ê‚Α‚«bß‚éꊂð’T‚· - for(i = 0;i < map_cache.head.nmaps ; i++) { - if(map_cache.map[i].fn[0] == 0) { - // V‚µ‚¢êŠ‚É“o˜^ - if(map_read_flag == 2) { - write_buf = (char *) aMalloc(m->xs * m->ys * 2); - len_new = m->xs * m->ys * 2; - encode_zip((unsigned char *) write_buf,&len_new,m->gat,m->xs * m->ys); - map_cache.map[i].compressed = 1; - map_cache.map[i].compressed_len = len_new; - } else { - len_new = m->xs * m->ys; - write_buf = (char *) m->gat; - map_cache.map[i].compressed = 0; - map_cache.map[i].compressed_len = 0; - } - strncpy(map_cache.map[i].fn,m->name,sizeof(map_cache.map[0].fn)); - fseek(map_cache.fp,map_cache.head.filesize,SEEK_SET); - fwrite(write_buf,1,len_new,map_cache.fp); - map_cache.map[i].pos = map_cache.head.filesize; - map_cache.map[i].xs = m->xs; - map_cache.map[i].ys = m->ys; - map_cache.map[i].water_height = m->water_height; - map_cache.head.filesize += len_new; - map_cache.dirty = 1; - if(map_read_flag == 2) { - aFree(write_buf); - } - return 0; - } - } - // ‘‚«bß‚È‚©‚Á‚½ - return 1; -} - -/*========================================== - * ?‚Ý?‚Þmap‚ð’ljÁ‚·‚é - *------------------------------------------ - */ -int map_addmap(char *mapname) { - if (strcmpi(mapname,"clear")==0) { - map_num=0; - return 0; - } - - if (map_num >= MAX_MAP_PER_SERVER - 1) { - ShowError("Could not add map '" - CL_WHITE"%s"CL_RESET"', the limit of maps has been reached.\n",mapname); - return 1; - } - memcpy(map[map_num].name, mapname, MAP_NAME_LENGTH-1); - map_num++; - return 0; -} - -/*========================================== - * Removes the map in the index passed. - *------------------------------------------ - */ -static void map_delmapid(int id) -{ - ShowNotice("Removing map [ %s ] from maplist\n",map[id].name); - memmove(map+id, map+id+1, sizeof(map[0])*(map_num-id-1)); - map_num--; -} - -/*========================================== - * ?‚Ý?‚Þmap‚ð휂·‚é - *------------------------------------------ - */ -int map_delmap(char *mapname) { - - int i; - - if (strcmpi(mapname, "all") == 0) { - map_num = 0; - return 0; - } - - for(i = 0; i < map_num; i++) { - if (strcmp(map[i].name, mapname) == 0) { - map_delmapid(i); - return 1; - } - } - return 0; -} - -//////////////////////////////////////////////// - -/* - Advanced Fusion Maps Support - (c) 2003-2004, The Fusion Project - - AlexKreuz - - The following code has been provided by me for eAthena - under the GNU GPL. It provides Advanced Fusion - Map, the map format desgined by me for Fusion, support - for the eAthena emulator. - - I understand that because it is under the GPL - that other emulators may very well use this code in their - GNU project as well. - - The AFM map format was not originally a part of the GNU - GPL. It originated from scratch by my own hand. I understand - that distributing this code to read the AFM maps with eAthena - causes the GPL to apply to this code. But the actual AFM - maps are STILL copyrighted to the Fusion Project. By choosing - - In exchange for that 'act of faith' I ask for the following. - - A) Give credit where it is due. If you use this code, do not - place your name on the changelog. Credit should be given - to AlexKreuz. - B) As an act of courtesy, ask me and let me know that you are putting - AFM support in your project. You will have my blessings if you do. - C) Use the code in its entirety INCLUDING the copyright message. - Although the code provided may now be GPL, the AFM maps are not - and so I ask you to display the copyright message on the STARTUP - SCREEN as I have done here. (refer to core.c) - "Advanced Fusion Maps (c) 2003-2004 The Fusion Project" - - Without this copyright, you are NOT entitled to bundle or distribute - the AFM maps at all. On top of that, your "support" for AFM maps - becomes just as shady as your "support" for Gravity GRF files. - - The bottom line is this. I know that there are those of you who - would like to use this code but aren't going to want to provide the - proper credit. I know this because I speak frome experience. If - you are one of those people who is going to try to get around my - requests, then save your breath because I don't want to hear it. - - I have zero faith in GPL and I know and accept that if you choose to - not display the copyright for the AFMs then there is absolutely nothing - I can do about it. I am not about to start a legal battle over something - this silly. - - Provide the proper credit because you believe in the GPL. If you choose - not to and would rather argue about it, consider the GPL failed. - - October 18th, 2004 - - AlexKreuz - - The Fusion Project - */ -static int map_loadafm (struct map_data *m, char *fn) -{ - // check if .afm file exists - FILE *afm_file = fopen(fn, "r"); - if (afm_file != NULL) { - int x,y,xs,ys; - char afm_line[65535]; - int afm_size[2]; - char *str; - - str = fgets(afm_line, sizeof(afm_line)-1, afm_file); - str = fgets(afm_line, sizeof(afm_line)-1, afm_file); - str = fgets(afm_line, sizeof(afm_line)-1, afm_file); - sscanf(str , "%d%d", &afm_size[0], &afm_size[1]); - - xs = m->xs = afm_size[0]; - ys = m->ys = afm_size[1]; - m->water_height = map_waterheight(m->name); - - m->gat = (unsigned char*)aCallocA(xs * ys, 1); - - for (y = 0; y < ys; y++) { - str = fgets(afm_line, sizeof(afm_line)-1, afm_file); - for (x = 0; x < xs; x++) - m->gat[x+y*xs] = str[x]-48; - } - - fclose(afm_file); - return 1; - } - - return 0; -} -/*================================== - * .AFM format - *---------------------------------- - */ -int map_readafm (struct map_data *m) -{ - char afm_name[256] = ""; - char fn[256], *p; - - // convert map name to .afm - if(!strstr(m->name, ".afm")) { - // check if it's necessary to replace the extension - speeds up loading a bit - strncpy(afm_name, m->name, strlen(m->name) - 4); - strcat(afm_name, ".afm"); - } - - sprintf(fn, "%s\\%s", afm_dir, afm_name); - for (p = &fn[0]; *p != 0; p++) - if (*p == '\\') *p = '/'; // * At the time of Unix - - return map_loadafm(m, fn); -} -/*================================== - * .AF2 format - *---------------------------------- - */ -int map_readaf2 (struct map_data *m) -{ - FILE *af2_file; - char af2_name[256] = ""; - char fn[256], *p, *out; - - // convert map name to .af2 - p = out = m->name; - while ((p = strchr(p, '/')) != NULL) - out = ++p; - strncpy (af2_name, out, strlen(out)); - // grr, this is so troublesome >.< [celest] - p = strrchr (af2_name, '.'); - if (p) *p++ = 0; - strcat(af2_name, ".af2"); - sprintf(fn, "%s\\%s", afm_dir, af2_name); - for (p = &fn[0]; *p != 0; p++) - if (*p == '\\') *p = '/'; // * At the time of Unix - - // check if .af2 file exists - af2_file = fopen(fn, "r"); - if (af2_file != NULL) { - char out_file[256]; - - fclose(af2_file); - - // convert map name to .out - strncpy (out_file, out, strlen(out)); - p = strrchr (out_file, '.'); - if (p) *p++ = 0; - strcat(out_file, ".out"); - - // unzip .out file and use loadafm() - if (deflate_file(fn, out_file) && - map_loadafm(m, out_file)) - { - unlink (out_file); - return 1; - } - } - - return 0; -} - - -/*========================================== - * ƒ}ƒbƒv1–‡“Ç‚ÝbÝ - * ===================================================*/ -//static int map_readmap(int m,char *fn, char *alias, int *map_cache, int maxmap) { - -/*================================== - * .GAT format - *---------------------------------- - */ -int map_readgat (struct map_data *m) -{ - char fn[256], *pt; - char *gat; - int wh,x,y,xs,ys; - struct gat_1cell {float high[4]; int type;} *p = NULL; - - if (strstr(m->name,".gat") == NULL) - return 0; - - if ((pt = strstr(m->name,"<")) != NULL) { // [MouseJstr] - char buf[64]; - *pt++ = '\0'; - sprintf(buf,"data\\%s", pt); - m->alias = aStrdup(buf); - } - - sprintf(fn,"data\\%s",m->name); - - // read & convert fn - // again, might not need to be unsigned char - gat = (char *) grfio_read (fn); - if (gat == NULL) - return 0; - - xs = m->xs = *(int*)(gat+6); - ys = m->ys = *(int*)(gat+10); - m->gat = (unsigned char *)aCallocA(m->xs * m->ys, sizeof(unsigned char)); - - m->water_height = wh = map_waterheight(m->name); - for (y = 0; y < ys; y++) { - p = (struct gat_1cell*)(gat+y*xs*20+14); - for (x = 0; x < xs; x++) { - if (wh != NO_WATER && p->type == 0) - // …ê”»’è - m->gat[x+y*xs] = (p->high[0]>wh || p->high[1]>wh || p->high[2]>wh || p->high[3]>wh) ? 3 : 0; - else - m->gat[x+y*xs] = p->type; - p++; - } - } - - aFree(gat); - - return 1; -} - -////////////////////////////////////////////////////// - -static int map_cache_init (void); -static int map_readafm_init (void); -static int map_readaf2_init (void); -static int map_readgat_init (void); - -// Todo: Properly implement this system as plugins/safer code [Celest] -enum { - MAP_CACHE = 0, // jAthena map cache - MAP_AFM, // Advanced Fusion Map - MAP_AF2, // Advanced Fusion Map - MAP_GAT, // GRF map - MAP_MAXSOURCE -}; -// in descending order -int (*mapsource_init[MAP_MAXSOURCE])(void) = { - map_cache_init, - map_readafm_init, - map_readaf2_init, - map_readgat_init -}; -int (*mapsource_read[MAP_MAXSOURCE])(struct map_data *) = { - map_cache_read, - map_readafm, - map_readaf2, - map_readgat -}; -void (*mapsource_final[MAP_MAXSOURCE])(void) = { - map_cache_close, - NULL, - NULL, - NULL -}; - -static int map_cache_init (void) -{ - if (map_read_flag >= READ_FROM_BITMAP && map_cache_open(map_cache_file)) { - ShowMessage("[cache] "); - return 1; - } - - return 0; -} -static int map_readafm_init (void) -{ - ShowMessage("[afm] "); - return 1; -} -static int map_readaf2_init (void) -{ - // check if AFM loading is available, - // otherwise disable AF2 loading - if (mapsource_read[1] != NULL) { - ShowMessage("[af2] "); - return 1; - } - - return 0; -} -static int map_readgat_init (void) -{ - ShowMessage("[gat] "); - return 1; -} - -/*====================================== - * Initiate maps loading stage - *-------------------------------------- - */ -int map_readallmaps (void) -{ - // pre-loading stage - int i; - int maps_removed = 0; - int maps_cached = 0; - - ShowMessage(CL_GREEN"[Status]"CL_RESET": Loading Maps with... "CL_WHITE); - - for (i = 0; i < MAP_MAXSOURCE; i++) { - if (mapsource_init[i] && // check if source requires initialisation - mapsource_init[i]() == 0) // if init failed - { - // remove all loading methods associated with this source - mapsource_init[i] = NULL; - mapsource_read[i] = NULL; - mapsource_final[i] = NULL; - } - } - - ShowMessage(CL_RESET"\n"); - - // initiate map loading - for (i = 0; i < map_num; i++) - { - int success = 0; - static int lasti = -1; - static int last_time = -1; - int j = i*20/map_num; - - // show progress - if (map_num && //avoid map-server crashing if there are 0 maps - (j != lasti || last_time != time(0))) - { - char progress[21] = " "; - char c = '-'; - int k; - - lasti = j; - printf("\r"); - ShowStatus("Progress: ["); - for (k=0; k < j; k++) progress[k] = '#'; - printf(progress); - last_time = (int)time(0); - switch(last_time % 4) { - case 0: c='\\'; break; - case 1: c='|'; break; - case 2: c='/'; break; - case 3: c='-'; break; - } - printf("] Working: [%c]",c); - fflush(stdout); - } - - // pre-init some data - map[i].alias = NULL; - map[i].m = i; - memset (map[i].moblist, 0, sizeof(map[i].moblist)); //Initialize moblist [Skotlex] - map[i].mob_delete_timer = -1; //Initialize timer [Skotlex] - if (battle_config.pk_mode) - map[i].flag.pvp = 1; // make all maps pvp for pk_mode [Valaris] - - for (j = 0; j < MAP_MAXSOURCE; j++) - { - if (mapsource_read[j] && // check if map source is valid - mapsource_read[j](&map[i])) // check if map source is available - { - // successful, now initialise map - size_t size; - char *alias; - - if (map[i].alias && (alias = strstr(map[i].name, "<")) != NULL) { // alias has been set by one of the sources - *alias++ = '\0'; - } - if (map[i].alias) - map[i].index = mapindex_name2id(map[i].alias); - else - map[i].index = mapindex_name2id(map[i].name); - - if (!map[i].index) { - if (map[i].alias) - ShowWarning("Map %s (alias %s) is not in the map-index cache!\n", map[i].name, map[i].alias); - else - ShowWarning("Map %s is not in the map-index cache!\n", map[i].name); - success = 0; //Can't load a map that isn't in our cache. - if (map[i].gat) { - aFree(map[i].gat); - map[i].gat = NULL; - } - break; - } - if (uidb_get(map_db,(unsigned int)map[i].index) != NULL) { - ShowWarning("Map %s already loaded!\n", map[i].name); - success = 0; //Can't load a map already in the db - if (map[i].gat) { - aFree(map[i].gat); - map[i].gat = NULL; - } - break; - } - - map[i].cell = (unsigned char *)aCalloc(map[i].xs * map[i].ys, sizeof(unsigned char)); -#ifdef CELL_NOSTACK - map[i].cell_bl = (unsigned char *)aCalloc(map[i].xs * map[i].ys, sizeof(unsigned char)); -#endif - - map[i].bxs = (map[i].xs + BLOCK_SIZE - 1) / BLOCK_SIZE; - map[i].bys = (map[i].ys + BLOCK_SIZE - 1) / BLOCK_SIZE; - - size = map[i].bxs * map[i].bys * sizeof(struct block_list*); - map[i].block = (struct block_list**)aCalloc(size, 1); - map[i].block_mob = (struct block_list**)aCalloc(size, 1); - - size = map[i].bxs * map[i].bys * sizeof(int); - map[i].block_count = (int*)aCallocA(size, 1); - memset(map[i].block_count, 0, size); - - map[i].block_mob_count = (int*)aCallocA(size, 1); - memset(map[i].block_mob_count, 0, size); - - uidb_put(map_db, (unsigned int)map[i].index, &map[i]); - - // cache our map if necessary - if (j != MAP_CACHE && mapsource_read[MAP_CACHE] != NULL) { // map data is not cached yet - map_cache_write(&map[i]); - maps_cached++; - } - - // next map - success = 1; - break; - } - } - - // no sources have been found, so remove map from list - if (!success) { - map_delmapid(i); - maps_removed++; - i--; - } - } - - // unload map sources - for (i = 0; i < MAP_MAXSOURCE; i++) { - if (mapsource_final[i]) - mapsource_final[i](); - } - - // finished map loading - //aFree(waterlist); - printf("\r"); - ShowInfo("Successfully loaded '"CL_WHITE"%d"CL_RESET"' maps.%30s\n",map_num,""); - - if (maps_removed) - ShowNotice("Maps Removed: '"CL_WHITE"%d"CL_RESET"'\n",maps_removed); - if (maps_cached) - ShowNotice("Maps Added to Cache: '"CL_WHITE"%d"CL_RESET"'\n",maps_cached); - - return 0; -} - -//////////////////////////////////////////////////////////////////////// - -static int map_ip_set_ = 0; -static int char_ip_set_ = 0; -//static int bind_ip_set_ = 0; - -/*========================================== - * Console Command Parser [Wizputer] - *------------------------------------------ - */ -int parse_console(char *buf) { - char *type,*command,*map, *buf2; - int x = 0, y = 0; - int m, n; - struct map_session_data *sd; - - sd = (struct map_session_data*)aCalloc(sizeof(*sd), 1); - - sd->fd = 0; - strcpy( sd->status.name , "console"); - - type = (char *)aMallocA(64); - command = (char *)aMallocA(64); - map = (char *)aMallocA(64); - buf2 = (char *)aMallocA(72); - - memset(type,0,64); - memset(command,0,64); - memset(map,0,64); - memset(buf2,0,72); - - if ( ( n = sscanf(buf, "%[^:]:%[^:]:%99s %d %d[^\n]", type , command , map , &x , &y )) < 5 ) - if ( ( n = sscanf(buf, "%[^:]:%[^\n]", type , command )) < 2 ) - n = sscanf(buf,"%[^\n]",type); - - if ( n == 5 ) { - if (x <= 0) { - x = rand() % 399 + 1; - sd->bl.x = x; - } else { - sd->bl.x = x; - } - - if (y <= 0) { - y = rand() % 399 + 1; - sd->bl.y = y; - } else { - sd->bl.y = y; - } - - m = map_mapname2mapid(map); - if ( m >= 0 ) - sd->bl.m = m; - else { - ShowWarning("Console: Unknown map\n"); - goto end; - } - } - - ShowInfo("Type of command: %s || Command: %s || Map: %s Coords: %d %d\n",type,command,map,x,y); - - if ( strcmpi("admin",type) == 0 && n == 5 ) { - sprintf(buf2,"console: %s",command); - if( is_atcommand(sd->fd,sd,buf2,99) == AtCommand_None ) - printf("Console: not atcommand\n"); - } else if ( strcmpi("server",type) == 0 && n == 2 ) { - if ( strcmpi("shutdown", command) == 0 || strcmpi("exit",command) == 0 || strcmpi("quit",command) == 0 ) { - runflag = 0; - } - } else if ( strcmpi("help",type) == 0 ) { - ShowNotice("To use GM commands:\n"); - printf("admin:: \n"); - printf("You can use any GM command that doesn't require the GM.\n"); - printf("No using @item or @warp however you can use @charwarp\n"); - printf("The is for commands that need coords of the GM\n"); - printf("IE: @spawn\n"); - printf("To shutdown the server:\n"); - printf("server:shutdown\n"); - } - - end: - aFree(buf); - aFree(type); - aFree(command); - aFree(map); - aFree(buf2); - aFree(sd); - - return 0; -} - -/*========================================== - * Ý’èƒtƒ@ƒCƒ‹‚ð?‚Ý?‚Þ - *------------------------------------------ - */ -int map_config_read(char *cfgName) { - char line[1024], w1[1024], w2[1024]; - FILE *fp; - struct hostent *h = NULL; - - fp = fopen(cfgName,"r"); - if (fp == NULL) { - ShowFatalError("Map configuration file not found at: %s\n", cfgName); - exit(1); - } - while(fgets(line, sizeof(line) -1, fp)) { - if (line[0] == '/' && line[1] == '/') - continue; - if (sscanf(line, "%[^:]: %[^\r\n]", w1, w2) == 2) { - if(strcmpi(w1,"timestamp_format")==0){ - strncpy(timestamp_format, w2, 20); - } else if(strcmpi(w1,"console_silent")==0){ - msg_silent = 0; //To always allow the next line to show up. - ShowInfo("Console Silent Setting: %d\n", atoi(w2)); - msg_silent = atoi(w2); - } else if (strcmpi(w1, "userid")==0){ - chrif_setuserid(w2); - } else if (strcmpi(w1, "passwd") == 0) { - chrif_setpasswd(w2); - } else if (strcmpi(w1, "char_ip") == 0) { - char_ip_set_ = 1; - h = gethostbyname (w2); - if(h != NULL) { - ShowInfo("Char Server IP Address : '"CL_WHITE"%s"CL_RESET"' -> '"CL_WHITE"%d.%d.%d.%d"CL_RESET"'.\n", w2, (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); - sprintf(w2,"%d.%d.%d.%d", (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); - } - chrif_setip(w2); - } else if (strcmpi(w1, "char_port") == 0) { - chrif_setport(atoi(w2)); - } else if (strcmpi(w1, "map_ip") == 0) { - map_ip_set_ = 1; - h = gethostbyname (w2); - if (h != NULL) { - ShowInfo("Map Server IP Address : '"CL_WHITE"%s"CL_RESET"' -> '"CL_WHITE"%d.%d.%d.%d"CL_RESET"'.\n", w2, (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); - sprintf(w2, "%d.%d.%d.%d", (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); - } - clif_setip(w2); - } else if (strcmpi(w1, "bind_ip") == 0) { - //bind_ip_set_ = 1; - h = gethostbyname (w2); - if (h != NULL) { - ShowInfo("Map Server IP Address : '"CL_WHITE"%s"CL_RESET"' -> '"CL_WHITE"%d.%d.%d.%d"CL_RESET"'.\n", w2, (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); - sprintf(w2, "%d.%d.%d.%d", (unsigned char)h->h_addr[0], (unsigned char)h->h_addr[1], (unsigned char)h->h_addr[2], (unsigned char)h->h_addr[3]); - } - clif_setbindip(w2); - } else if (strcmpi(w1, "map_port") == 0) { - clif_setport(atoi(w2)); - map_port = (atoi(w2)); - //} else if (strcmpi(w1, "water_height") == 0) { - // map_readwater(w2); - } else if (strcmpi(w1, "map") == 0) { - map_addmap(w2); - } else if (strcmpi(w1, "delmap") == 0) { - map_delmap(w2); - } else if (strcmpi(w1, "npc") == 0) { - npc_addsrcfile(w2); - } else if (strcmpi(w1, "delnpc") == 0) { - npc_delsrcfile(w2); - } else if (strcmpi(w1, "autosave_time") == 0) { - autosave_interval = atoi(w2) * 1000; - if (autosave_interval <= 0) - autosave_interval = DEFAULT_AUTOSAVE_INTERVAL; - } else if (strcmpi(w1, "motd_txt") == 0) { - strcpy(motd_txt, w2); - } else if (strcmpi(w1, "help_txt") == 0) { - strcpy(help_txt, w2); - } else if (strcmpi(w1, "help2_txt") == 0) { - strcpy(help2_txt, w2); - } else if (strcmpi(w1, "charhelp_txt") == 0) { - strcpy(charhelp_txt, w2); - } else if (strcmpi(w1, "mapreg_txt") == 0) { - strcpy(mapreg_txt, w2); - } else if(strcmpi(w1,"read_map_from_cache") == 0){ - if (atoi(w2) == 2) - map_read_flag = READ_FROM_BITMAP_COMPRESSED; - else if (atoi(w2) == 1) - map_read_flag = READ_FROM_BITMAP; - else - map_read_flag = READ_FROM_GAT; - } else if(strcmpi(w1,"map_cache_file") == 0) { - strncpy(map_cache_file,w2,255); - } else if(strcmpi(w1,"db_path") == 0) { - strncpy(db_path,w2,255); - } else if(strcmpi(w1,"afm_dir") == 0) { - strcpy(afm_dir, w2); - } else if (strcmpi(w1, "console") == 0) { - if(strcmpi(w2,"on") == 0 || strcmpi(w2,"yes") == 0 ) { - console = 1; - ShowNotice("Console Commands are enabled.\n"); - } - } else if (strcmpi(w1, "enable_spy") == 0) { - if(strcmpi(w2,"on") == 0 || strcmpi(w2,"yes") == 0 ) - enable_spy = 1; - else - enable_spy = 0; - } else if (strcmpi(w1, "import") == 0) { - map_config_read(w2); - } - } - } - fclose(fp); - - return 0; -} - -int inter_config_read(char *cfgName) -{ - int i; - char line[1024],w1[1024],w2[1024]; - FILE *fp; - - fp=fopen(cfgName,"r"); - if(fp==NULL){ - ShowError("File not found: '%s'.\n",cfgName); - return 1; - } - while(fgets(line,1020,fp)){ - if(line[0] == '/' && line[1] == '/') - continue; - i=sscanf(line,"%[^:]: %[^\r\n]",w1,w2); - if(i!=2) - continue; - if(strcmpi(w1,"kick_on_disconnect")==0){ - kick_on_disconnect = battle_config_switch(w2); - } else if(strcmpi(w1,"party_share_level")==0){ - party_share_level = battle_config_switch(w2); - } else if(strcmpi(w1,"lowest_gm_level")==0){ - lowest_gm_level = atoi(w2); - - /* Main chat nick [LuzZza] */ - } else if(strcmpi(w1, "main_chat_nick")==0){ - strcpy(main_chat_nick, w2); - - #ifndef TXT_ONLY - } else if(strcmpi(w1,"charsave_method")==0){ - charsave_method = atoi(w2); //New char saving method. - } else if(strcmpi(w1,"item_db_db")==0){ - strcpy(item_db_db,w2); - } else if(strcmpi(w1,"mob_db_db")==0){ - strcpy(mob_db_db,w2); - } else if(strcmpi(w1,"item_db2_db")==0){ - strcpy(item_db2_db,w2); - } else if(strcmpi(w1,"mob_db2_db")==0){ - strcpy(mob_db2_db,w2); - } else if(strcmpi(w1,"login_db_level")==0){ - strcpy(login_db_level,w2); - } else if(strcmpi(w1,"login_db_account_id")==0){ - strcpy(login_db_account_id,w2); - } else if(strcmpi(w1,"login_db")==0){ - strcpy(login_db,w2); - } else if (strcmpi(w1, "char_db") == 0) { - strcpy(char_db, w2); - } else if(strcmpi(w1,"gm_db_level")==0){ - strcpy(gm_db_level,w2); - } else if(strcmpi(w1,"gm_db_account_id")==0){ - strcpy(gm_db_account_id,w2); - } else if(strcmpi(w1,"gm_db")==0){ - strcpy(gm_db,w2); - //Map Server SQL DB - } else if(strcmpi(w1,"map_server_ip")==0){ - strcpy(map_server_ip, w2); - } else if(strcmpi(w1,"map_server_port")==0){ - map_server_port=atoi(w2); - } else if(strcmpi(w1,"map_server_id")==0){ - strcpy(map_server_id, w2); - } else if(strcmpi(w1,"map_server_pw")==0){ - strcpy(map_server_pw, w2); - } else if(strcmpi(w1,"map_server_db")==0){ - strcpy(map_server_db, w2); - } else if(strcmpi(w1,"default_codepage")==0){ - strcpy(default_codepage, w2); - } else if(strcmpi(w1,"use_sql_db")==0){ - db_use_sqldbs = battle_config_switch(w2); - ShowStatus ("Using SQL dbs: %s\n",w2); - } else if(strcmpi(w1,"connection_ping_interval")==0) { - connection_ping_interval = battle_config_switch(w2); - //Login Server SQL DB - } else if(strcmpi(w1,"login_server_ip")==0){ - strcpy(login_server_ip, w2); - } else if(strcmpi(w1,"login_server_port")==0){ - login_server_port = atoi(w2); - } else if(strcmpi(w1,"login_server_id")==0){ - strcpy(login_server_id, w2); - } else if(strcmpi(w1,"login_server_pw")==0){ - strcpy(login_server_pw, w2); - } else if(strcmpi(w1,"login_server_db")==0){ - strcpy(login_server_db, w2); - } else if(strcmpi(w1,"read_gm_interval")==0){ - read_gm_interval = ( atoi(w2) * 60 * 1000 ); // Minutes multiplied by 60 secs per min by 1000 milliseconds per second - }else if(strcmpi(w1, "char_server_ip") == 0){ - strcpy(charsql_host, w2); - }else if(strcmpi(w1, "char_server_port") == 0){ - charsql_port = atoi(w2); - }else if(strcmpi(w1, "char_server_id") == 0){ - strcpy(charsql_user, w2); - }else if(strcmpi(w1, "char_server_pw") == 0){ - strcpy(charsql_pass, w2); - }else if(strcmpi(w1, "char_server_db") == 0){ - strcpy(charsql_db, w2); - } else if(strcmpi(w1,"log_db")==0) { - strcpy(log_db, w2); - } else if(strcmpi(w1,"log_db_ip")==0) { - strcpy(log_db_ip, w2); - } else if(strcmpi(w1,"log_db")==0) { - strcpy(log_db, w2); - } else if(strcmpi(w1,"log_db_id")==0) { - strcpy(log_db_id, w2); - } else if(strcmpi(w1,"log_db_pw")==0) { - strcpy(log_db_pw, w2); - } else if(strcmpi(w1,"log_db_port")==0) { - log_db_port = atoi(w2); - // Mail Server SQL - } else if(strcmpi(w1,"mail_server_enable")==0){ - mail_server_enable = battle_config_switch(w2); - ShowStatus ("Using Mail Server: %s\n",w2); - } else if(strcmpi(w1,"mail_server_ip")==0){ - strcpy(mail_server_ip, w2); - } else if(strcmpi(w1,"mail_server_port")==0){ - mail_server_port=atoi(w2); - } else if(strcmpi(w1,"mail_server_id")==0){ - strcpy(mail_server_id, w2); - } else if(strcmpi(w1,"mail_server_pw")==0){ - strcpy(mail_server_pw, w2); - } else if(strcmpi(w1,"mail_server_db")==0){ - strcpy(mail_server_db, w2); - } else if(strcmpi(w1,"mail_db")==0) { - strcpy(mail_db, w2); - #endif - //support the import command, just like any other config - } else if(strcmpi(w1,"import")==0){ - inter_config_read(w2); - } - } - fclose(fp); - - return 0; -} - -#ifndef TXT_ONLY -/*======================================= - * MySQL Init - *--------------------------------------- - */ - -int map_sql_init(void){ - - mysql_init(&mmysql_handle); - - //DB connection start - ShowInfo("Connecting to the Map DB Server....\n"); - if(!mysql_real_connect(&mmysql_handle, map_server_ip, map_server_id, map_server_pw, - map_server_db ,map_server_port, (char *)NULL, 0)) { - //pointer check - ShowSQL("DB error - %s\n",mysql_error(&mmysql_handle)); - exit(1); - } - else { - ShowStatus("connect success! (Map Server Connection)\n"); - } - - if(mail_server_enable) { // mail system [Valaris] - mysql_init(&mail_handle); - ShowInfo("Connecting to the Mail DB Server....\n"); - if(!mysql_real_connect(&mail_handle, mail_server_ip, mail_server_id, mail_server_pw, - mail_server_db ,mail_server_port, (char *)NULL, 0)) { - ShowSQL("DB error - %s\n",mysql_error(&mail_handle)); - exit(1); - } - if( strlen(default_codepage) > 0 ) { - sprintf( tmp_sql, "SET NAMES %s", default_codepage ); - if (mysql_query(&mail_handle, tmp_sql)) { - ShowSQL("DB error - %s\n",mysql_error(&mail_handle)); - ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); - } - } - } - if( strlen(default_codepage) > 0 ) { - sprintf( tmp_sql, "SET NAMES %s", default_codepage ); - if (mysql_query(&mmysql_handle, tmp_sql)) { - ShowSQL("DB error - %s\n",mysql_error(&mmysql_handle)); - ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); - } - } - return 0; -} - -int map_sql_close(void){ - mysql_close(&mmysql_handle); - ShowStatus("Close Map DB Connection....\n"); - - if (log_config.sql_logs) -//Updating this if each time there's a log_config addition is too much of a hassle. [Skotlex] - /*&& (log_config.branch || log_config.drop || log_config.mvpdrop || - log_config.present || log_config.produce || log_config.refine || log_config.trade))*/ - { - mysql_close(&logmysql_handle); - ShowStatus("Close Log DB Connection....\n"); - } - - return 0; -} - -int log_sql_init(void){ - - mysql_init(&logmysql_handle); - - //DB connection start - ShowInfo(""CL_WHITE"[SQL]"CL_RESET": Connecting to the Log Database "CL_WHITE"%s"CL_RESET" At "CL_WHITE"%s"CL_RESET"...\n",log_db,log_db_ip); - if(!mysql_real_connect(&logmysql_handle, log_db_ip, log_db_id, log_db_pw, - log_db ,log_db_port, (char *)NULL, 0)) { - //pointer check - ShowSQL("DB error - %s\n",mysql_error(&logmysql_handle)); - exit(1); - } - - ShowStatus(""CL_WHITE"[SQL]"CL_RESET": Successfully '"CL_GREEN"connected"CL_RESET"' to Database '"CL_WHITE"%s"CL_RESET"'.\n", log_db); - if( strlen(default_codepage) > 0 ) { - sprintf( tmp_sql, "SET NAMES %s", default_codepage ); - if (mysql_query(&logmysql_handle, tmp_sql)) { - ShowSQL("DB error - %s\n",mysql_error(&logmysql_handle)); - ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); - } - } - return 0; -} -#endif /* not TXT_ONLY */ - -int map_db_final(DBKey k,void *d,va_list ap) -{ - struct map_data_other_server *mdos = (struct map_data_other_server*)d; - if(mdos && mdos->gat == NULL) - aFree(mdos); - return 0; -} -int nick_db_final(void *k,void *d,va_list ap) -{ - char *p = (char *) d; - if (p) aFree(p); - return 0; -} - -int cleanup_sub(struct block_list *bl, va_list ap) { - nullpo_retr(0, bl); - - switch(bl->type) { - case BL_PC: - map_quit((struct map_session_data *) bl); - break; - case BL_NPC: - npc_unload((struct npc_data *)bl); - break; - case BL_MOB: - unit_free(bl); - break; - case BL_PET: - //There is no need for this, the pet is removed together with the player. [Skotlex] - break; - case BL_ITEM: - map_clearflooritem(bl->id); - break; - case BL_SKILL: - skill_delunit((struct skill_unit *) bl); - break; - } - - return 1; -} - static int cleanup_db_sub(DBKey key,void *data,va_list va) { return cleanup_sub((struct block_list*)data, NULL); } -/*========================================== - * mapŽII—¹E— - *------------------------------------------ - */ -void do_final(void) { - int i, j; - struct map_session_data **pl_allsd; - - ShowStatus("Terminating...\n"); - - // we probably don't need the cache open at all times 'yet', so this is closed by mapsource_final [celest] - //map_cache_close(); - grfio_final(); - - for (i = 0; i < map_num; i++) - if (map[i].m >= 0) - map_foreachinmap(cleanup_sub, i, BL_ALL); - - //Scan any remaining players (between maps?) to kick them out. [Skotlex] - pl_allsd = map_getallusers(&j); - for (i = 0; i < j; i++) - map_quit(pl_allsd[i]); - - i = id_db->foreach(id_db,cleanup_db_sub); - chrif_char_reset_offline(); - chrif_flush_fifo(); - - do_final_atcommand(); - do_final_battle(); - do_final_chrif(); // ‚±‚Ì“à•”‚ŃLƒƒƒ‰‚ð‘S‚ÄØ’f‚·‚é - do_final_npc(); -// map_removenpc(); - do_final_script(); - do_final_itemdb(); - do_final_storage(); - do_final_guild(); - do_final_party(); - do_final_pc(); - do_final_pet(); - do_final_mob(); - do_final_msg(); - do_final_skill(); +/*========================================== + * mapŽII—¹E— + *------------------------------------------ + */ +void do_final(void) { + int i, j; + struct map_session_data **pl_allsd; + + ShowStatus("Terminating...\n"); + + // we probably don't need the cache open at all times 'yet', so this is closed by mapsource_final [celest] + //map_cache_close(); + grfio_final(); + + for (i = 0; i < map_num; i++) + if (map[i].m >= 0) + map_foreachinmap(cleanup_sub, i, BL_ALL); + + //Scan any remaining players (between maps?) to kick them out. [Skotlex] + pl_allsd = map_getallusers(&j); + for (i = 0; i < j; i++) + map_quit(pl_allsd[i]); + + i = id_db->foreach(id_db,cleanup_db_sub); + chrif_char_reset_offline(); + chrif_flush_fifo(); + + do_final_atcommand(); + do_final_battle(); + do_final_chrif(); // ‚±‚Ì“à•”‚ŃLƒƒƒ‰‚ð‘S‚ÄØ’f‚·‚é + do_final_npc(); +// map_removenpc(); + do_final_script(); + do_final_itemdb(); + do_final_storage(); + do_final_guild(); + do_final_party(); + do_final_pc(); + do_final_pet(); + do_final_mob(); + do_final_msg(); + do_final_skill(); do_final_unit(); - if(use_irc) - do_final_irc(); - - map_getallusers(NULL); //Clear the memory allocated for this array. - - map_db->destroy(map_db, map_db_final); - - for (i=0; idestroy(id_db, NULL); - pc_db->destroy(pc_db, NULL); - charid_db->destroy(charid_db, NULL); - -//#endif - -#ifndef TXT_ONLY - map_sql_close(); - if(charsave_method) - charsql_db_init(0); //Connecting to chardb -#endif /* not TXT_ONLY */ - ShowStatus("Successfully terminated.\n"); -} - -/*====================================================== - * Map-Server Version Screen [MC Cameri] - *------------------------------------------------------ - */ -void map_helpscreen(int flag) { // by MC Cameri - puts("Usage: map-server [options]"); - puts("Options:"); - puts(CL_WHITE" Commands\t\t\tDescription"CL_RESET); - puts("-----------------------------------------------------------------------------"); - puts(" --help, --h, --?, /? Displays this help screen"); - puts(" --map-config Load map-server configuration from "); - puts(" --battle-config Load battle configuration from "); - puts(" --atcommand-config Load atcommand configuration from "); - puts(" --charcommand-config Load charcommand configuration from "); - puts(" --script-config Load script configuration from "); - puts(" --msg-config Load message configuration from "); - puts(" --grf-path-file Load grf path file configuration from "); - puts(" --sql-config Load inter-server configuration from "); - puts(" (SQL Only)"); - puts(" --log-config Load logging configuration from "); - puts(" (SQL Only)"); - puts(" --version, --v, -v, /v Displays the server's version"); - puts("\n"); - if (flag) exit(1); -} - -/*====================================================== - * Map-Server Version Screen [MC Cameri] - *------------------------------------------------------ - */ -void map_versionscreen(int flag) { - printf("CL_WHITE" "eAthena version %d.%02d.%02d, Athena Mod version %d" CL_RESET"\n", - ATHENA_MAJOR_VERSION, ATHENA_MINOR_VERSION, ATHENA_REVISION, - ATHENA_MOD_VERSION); - puts(CL_GREEN "Website/Forum:" CL_RESET "\thttp://eathena.deltaanime.net/"); - puts(CL_GREEN "Download URL:" CL_RESET "\thttp://eathena.systeminplace.net/"); - puts(CL_GREEN "IRC Channel:" CL_RESET "\tirc://irc.deltaanime.net/#athena"); - puts("\nOpen " CL_WHITE "readme.html" CL_RESET " for more information."); - if (ATHENA_RELEASE_FLAG) ShowNotice("This version is not for release.\n"); - if (flag) exit(1); -} - + if(use_irc) + do_final_irc(); + + map_getallusers(NULL); //Clear the memory allocated for this array. + + map_db->destroy(map_db, map_db_final); + + for (i=0; idestroy(id_db, NULL); + pc_db->destroy(pc_db, NULL); + charid_db->destroy(charid_db, NULL); + +//#endif + +#ifndef TXT_ONLY + map_sql_close(); + if(charsave_method) + charsql_db_init(0); //Connecting to chardb +#endif /* not TXT_ONLY */ + ShowStatus("Successfully terminated.\n"); +} + +/*====================================================== + * Map-Server Version Screen [MC Cameri] + *------------------------------------------------------ + */ +void map_helpscreen(int flag) { // by MC Cameri + puts("Usage: map-server [options]"); + puts("Options:"); + puts(CL_WHITE" Commands\t\t\tDescription"CL_RESET); + puts("-----------------------------------------------------------------------------"); + puts(" --help, --h, --?, /? Displays this help screen"); + puts(" --map-config Load map-server configuration from "); + puts(" --battle-config Load battle configuration from "); + puts(" --atcommand-config Load atcommand configuration from "); + puts(" --charcommand-config Load charcommand configuration from "); + puts(" --script-config Load script configuration from "); + puts(" --msg-config Load message configuration from "); + puts(" --grf-path-file Load grf path file configuration from "); + puts(" --sql-config Load inter-server configuration from "); + puts(" (SQL Only)"); + puts(" --log-config Load logging configuration from "); + puts(" (SQL Only)"); + puts(" --version, --v, -v, /v Displays the server's version"); + puts("\n"); + if (flag) exit(1); +} + +/*====================================================== + * Map-Server Version Screen [MC Cameri] + *------------------------------------------------------ + */ +void map_versionscreen(int flag) { + printf("CL_WHITE" "eAthena version %d.%02d.%02d, Athena Mod version %d" CL_RESET"\n", + ATHENA_MAJOR_VERSION, ATHENA_MINOR_VERSION, ATHENA_REVISION, + ATHENA_MOD_VERSION); + puts(CL_GREEN "Website/Forum:" CL_RESET "\thttp://eathena.deltaanime.net/"); + puts(CL_GREEN "Download URL:" CL_RESET "\thttp://eathena.systeminplace.net/"); + puts(CL_GREEN "IRC Channel:" CL_RESET "\tirc://irc.deltaanime.net/#athena"); + puts("\nOpen " CL_WHITE "readme.html" CL_RESET " for more information."); + if (ATHENA_RELEASE_FLAG) ShowNotice("This version is not for release.\n"); + if (flag) exit(1); +} + #ifndef TXT_ONLY -/*====================================================== +/*====================================================== * Does a mysql_ping to all connection handles. [Skotlex] - *------------------------------------------------------ - */ + *------------------------------------------------------ + */ int map_sql_ping(int tid, unsigned int tick, int id, int data) { + ShowInfo("Pinging SQL server to keep connection alive...\n"); mysql_ping(&mmysql_handle); if (log_config.sql_logs) mysql_ping(&logmysql_handle); @@ -3759,212 +3759,212 @@ int map_sql_ping(int tid, unsigned int tick, int id, int data) } #endif -/*====================================================== - * Map-Server Init and Command-line Arguments [Valaris] - *------------------------------------------------------ - */ -void set_server_type(void) -{ - SERVER_TYPE = ATHENA_SERVER_MAP; -} -int do_init(int argc, char *argv[]) { - int i; - -#ifdef GCOLLECT - GC_enable_incremental(); -#endif - - INTER_CONF_NAME="conf/inter_athena.conf"; - LOG_CONF_NAME="conf/log_athena.conf"; - MAP_CONF_NAME = "conf/map_athena.conf"; - BATTLE_CONF_FILENAME = "conf/battle_athena.conf"; - ATCOMMAND_CONF_FILENAME = "conf/atcommand_athena.conf"; - CHARCOMMAND_CONF_FILENAME = "conf/charcommand_athena.conf"; - SCRIPT_CONF_NAME = "conf/script_athena.conf"; - MSG_CONF_NAME = "conf/msg_athena.conf"; - GRF_PATH_FILENAME = "conf/grf-files.txt"; - - chrif_connected = 0; - - srand(gettick()); - - for (i = 1; i < argc ; i++) { - if (strcmp(argv[i], "--help") == 0 || strcmp(argv[i], "--h") == 0 || strcmp(argv[i], "--?") == 0 || strcmp(argv[i], "/?") == 0) - map_helpscreen(1); - else if (strcmp(argv[i], "--version") == 0 || strcmp(argv[i], "--v") == 0 || strcmp(argv[i], "-v") == 0 || strcmp(argv[i], "/v") == 0) - map_versionscreen(1); - else if (strcmp(argv[i], "--map_config") == 0 || strcmp(argv[i], "--map-config") == 0) - MAP_CONF_NAME=argv[i+1]; - else if (strcmp(argv[i],"--battle_config") == 0 || strcmp(argv[i],"--battle-config") == 0) - BATTLE_CONF_FILENAME = argv[i+1]; - else if (strcmp(argv[i],"--atcommand_config") == 0 || strcmp(argv[i],"--atcommand-config") == 0) - ATCOMMAND_CONF_FILENAME = argv[i+1]; - else if (strcmp(argv[i],"--charcommand_config") == 0 || strcmp(argv[i],"--charcommand-config") == 0) - CHARCOMMAND_CONF_FILENAME = argv[i+1]; - else if (strcmp(argv[i],"--script_config") == 0 || strcmp(argv[i],"--script-config") == 0) - SCRIPT_CONF_NAME = argv[i+1]; - else if (strcmp(argv[i],"--msg_config") == 0 || strcmp(argv[i],"--msg-config") == 0) - MSG_CONF_NAME = argv[i+1]; - else if (strcmp(argv[i],"--grf_path_file") == 0 || strcmp(argv[i],"--grf-path-file") == 0) - GRF_PATH_FILENAME = argv[i+1]; -#ifndef TXT_ONLY - else if (strcmp(argv[i],"--inter_config") == 0 || strcmp(argv[i],"--inter-config") == 0) - INTER_CONF_NAME = argv[i+1]; -#endif - else if (strcmp(argv[i],"--log_config") == 0 || strcmp(argv[i],"--log-config") == 0) - LOG_CONF_NAME = argv[i+1]; - else if (strcmp(argv[i],"--run_once") == 0) // close the map-server as soon as its done.. for testing [Celest] - runflag = 0; - } - - map_config_read(MAP_CONF_NAME); - irc_read_conf(IRC_CONF); // [Zido] - chrif_checkdefaultlogin(); - - if ((naddr_ == 0) && (map_ip_set_ == 0 || char_ip_set_ == 0)) { - ShowError("\nUnable to determine your IP address... please edit the map_athena.conf file and set it.\n"); - ShowError("(127.0.0.1 is valid if you have no network interface)\n"); - } - - if (map_ip_set_ == 0 || char_ip_set_ == 0) { - // The map server should know what IP address it is running on - // - MouseJstr - int localaddr = ntohl(addr_[0]); - unsigned char *ptr = (unsigned char *) &localaddr; - char buf[16]; - sprintf(buf, "%d.%d.%d.%d", ptr[0], ptr[1], ptr[2], ptr[3]);; - if (naddr_ != 1) - ShowNotice("Multiple interfaces detected.. using %s as our IP address\n", buf); - else - ShowInfo("Defaulting to %s as our IP address\n", buf); - if (map_ip_set_ == 0) - clif_setip(buf); - if (char_ip_set_ == 0) - chrif_setip(buf); - if (ptr[0] == 192 && ptr[1] == 168) - ShowNotice("\nFirewall detected.. \n edit subnet_athena.conf and map_athena.conf\n\n"); - } - - if (SHOW_DEBUG_MSG) - ShowNotice("Server running in '"CL_WHITE"Debug Mode"CL_RESET"'.\n"); - - - battle_config_read(BATTLE_CONF_FILENAME); - msg_config_read(MSG_CONF_NAME); - atcommand_config_read(ATCOMMAND_CONF_FILENAME); - charcommand_config_read(CHARCOMMAND_CONF_FILENAME); - script_config_read(SCRIPT_CONF_NAME); - inter_config_read(INTER_CONF_NAME); - log_config_read(LOG_CONF_NAME); - - id_db = db_alloc(__FILE__,__LINE__,DB_INT,DB_OPT_BASE,sizeof(int)); - pc_db = db_alloc(__FILE__,__LINE__,DB_INT,DB_OPT_BASE,sizeof(int)); //Added for reliable map_id2sd() use. [Skotlex] - map_db = db_alloc(__FILE__,__LINE__,DB_UINT,DB_OPT_BASE,sizeof(int)); - charid_db = db_alloc(__FILE__,__LINE__,DB_INT,DB_OPT_RELEASE_DATA,sizeof(int)); -#ifndef TXT_ONLY - map_sql_init(); - if(charsave_method) - charsql_db_init(1); //Connecting to chardb -#endif /* not TXT_ONLY */ - - mapindex_init(); - grfio_init(GRF_PATH_FILENAME); - - map_readallmaps(); - - add_timer_func_list(map_freeblock_timer, "map_freeblock_timer"); - add_timer_func_list(map_clearflooritem_timer, "map_clearflooritem_timer"); - add_timer_func_list(map_removemobs_timer, "map_removemobs_timer"); - add_timer_interval(gettick()+1000, map_freeblock_timer, 0, 0, 60*1000); - - if(use_irc) - do_init_irc(); - do_init_atcommand(); - do_init_battle(); - do_init_chrif(); - do_init_clif(); - do_init_script(); - do_init_itemdb(); - do_init_mob(); // npc‚̉Šú‰»E‚Åmob_spawn‚µ‚ÄAmob_db‚ð?Æ‚·‚é‚Ì‚Åinit_npc‚æ‚èæ - do_init_pc(); - do_init_status(); - do_init_party(); - do_init_guild(); - do_init_storage(); - do_init_skill(); - do_init_pet(); - do_init_npc(); +/*====================================================== + * Map-Server Init and Command-line Arguments [Valaris] + *------------------------------------------------------ + */ +void set_server_type(void) +{ + SERVER_TYPE = ATHENA_SERVER_MAP; +} +int do_init(int argc, char *argv[]) { + int i; + +#ifdef GCOLLECT + GC_enable_incremental(); +#endif + + INTER_CONF_NAME="conf/inter_athena.conf"; + LOG_CONF_NAME="conf/log_athena.conf"; + MAP_CONF_NAME = "conf/map_athena.conf"; + BATTLE_CONF_FILENAME = "conf/battle_athena.conf"; + ATCOMMAND_CONF_FILENAME = "conf/atcommand_athena.conf"; + CHARCOMMAND_CONF_FILENAME = "conf/charcommand_athena.conf"; + SCRIPT_CONF_NAME = "conf/script_athena.conf"; + MSG_CONF_NAME = "conf/msg_athena.conf"; + GRF_PATH_FILENAME = "conf/grf-files.txt"; + + chrif_connected = 0; + + srand(gettick()); + + for (i = 1; i < argc ; i++) { + if (strcmp(argv[i], "--help") == 0 || strcmp(argv[i], "--h") == 0 || strcmp(argv[i], "--?") == 0 || strcmp(argv[i], "/?") == 0) + map_helpscreen(1); + else if (strcmp(argv[i], "--version") == 0 || strcmp(argv[i], "--v") == 0 || strcmp(argv[i], "-v") == 0 || strcmp(argv[i], "/v") == 0) + map_versionscreen(1); + else if (strcmp(argv[i], "--map_config") == 0 || strcmp(argv[i], "--map-config") == 0) + MAP_CONF_NAME=argv[i+1]; + else if (strcmp(argv[i],"--battle_config") == 0 || strcmp(argv[i],"--battle-config") == 0) + BATTLE_CONF_FILENAME = argv[i+1]; + else if (strcmp(argv[i],"--atcommand_config") == 0 || strcmp(argv[i],"--atcommand-config") == 0) + ATCOMMAND_CONF_FILENAME = argv[i+1]; + else if (strcmp(argv[i],"--charcommand_config") == 0 || strcmp(argv[i],"--charcommand-config") == 0) + CHARCOMMAND_CONF_FILENAME = argv[i+1]; + else if (strcmp(argv[i],"--script_config") == 0 || strcmp(argv[i],"--script-config") == 0) + SCRIPT_CONF_NAME = argv[i+1]; + else if (strcmp(argv[i],"--msg_config") == 0 || strcmp(argv[i],"--msg-config") == 0) + MSG_CONF_NAME = argv[i+1]; + else if (strcmp(argv[i],"--grf_path_file") == 0 || strcmp(argv[i],"--grf-path-file") == 0) + GRF_PATH_FILENAME = argv[i+1]; +#ifndef TXT_ONLY + else if (strcmp(argv[i],"--inter_config") == 0 || strcmp(argv[i],"--inter-config") == 0) + INTER_CONF_NAME = argv[i+1]; +#endif + else if (strcmp(argv[i],"--log_config") == 0 || strcmp(argv[i],"--log-config") == 0) + LOG_CONF_NAME = argv[i+1]; + else if (strcmp(argv[i],"--run_once") == 0) // close the map-server as soon as its done.. for testing [Celest] + runflag = 0; + } + + map_config_read(MAP_CONF_NAME); + irc_read_conf(IRC_CONF); // [Zido] + chrif_checkdefaultlogin(); + + if ((naddr_ == 0) && (map_ip_set_ == 0 || char_ip_set_ == 0)) { + ShowError("\nUnable to determine your IP address... please edit the map_athena.conf file and set it.\n"); + ShowError("(127.0.0.1 is valid if you have no network interface)\n"); + } + + if (map_ip_set_ == 0 || char_ip_set_ == 0) { + // The map server should know what IP address it is running on + // - MouseJstr + int localaddr = ntohl(addr_[0]); + unsigned char *ptr = (unsigned char *) &localaddr; + char buf[16]; + sprintf(buf, "%d.%d.%d.%d", ptr[0], ptr[1], ptr[2], ptr[3]);; + if (naddr_ != 1) + ShowNotice("Multiple interfaces detected.. using %s as our IP address\n", buf); + else + ShowInfo("Defaulting to %s as our IP address\n", buf); + if (map_ip_set_ == 0) + clif_setip(buf); + if (char_ip_set_ == 0) + chrif_setip(buf); + if (ptr[0] == 192 && ptr[1] == 168) + ShowNotice("\nFirewall detected.. \n edit subnet_athena.conf and map_athena.conf\n\n"); + } + + if (SHOW_DEBUG_MSG) + ShowNotice("Server running in '"CL_WHITE"Debug Mode"CL_RESET"'.\n"); + + + battle_config_read(BATTLE_CONF_FILENAME); + msg_config_read(MSG_CONF_NAME); + atcommand_config_read(ATCOMMAND_CONF_FILENAME); + charcommand_config_read(CHARCOMMAND_CONF_FILENAME); + script_config_read(SCRIPT_CONF_NAME); + inter_config_read(INTER_CONF_NAME); + log_config_read(LOG_CONF_NAME); + + id_db = db_alloc(__FILE__,__LINE__,DB_INT,DB_OPT_BASE,sizeof(int)); + pc_db = db_alloc(__FILE__,__LINE__,DB_INT,DB_OPT_BASE,sizeof(int)); //Added for reliable map_id2sd() use. [Skotlex] + map_db = db_alloc(__FILE__,__LINE__,DB_UINT,DB_OPT_BASE,sizeof(int)); + charid_db = db_alloc(__FILE__,__LINE__,DB_INT,DB_OPT_RELEASE_DATA,sizeof(int)); +#ifndef TXT_ONLY + map_sql_init(); + if(charsave_method) + charsql_db_init(1); //Connecting to chardb +#endif /* not TXT_ONLY */ + + mapindex_init(); + grfio_init(GRF_PATH_FILENAME); + + map_readallmaps(); + + add_timer_func_list(map_freeblock_timer, "map_freeblock_timer"); + add_timer_func_list(map_clearflooritem_timer, "map_clearflooritem_timer"); + add_timer_func_list(map_removemobs_timer, "map_removemobs_timer"); + add_timer_interval(gettick()+1000, map_freeblock_timer, 0, 0, 60*1000); + + if(use_irc) + do_init_irc(); + do_init_atcommand(); + do_init_battle(); + do_init_chrif(); + do_init_clif(); + do_init_script(); + do_init_itemdb(); + do_init_mob(); // npc‚̉Šú‰»E‚Åmob_spawn‚µ‚ÄAmob_db‚ð?Æ‚·‚é‚Ì‚Åinit_npc‚æ‚èæ + do_init_pc(); + do_init_status(); + do_init_party(); + do_init_guild(); + do_init_storage(); + do_init_skill(); + do_init_pet(); + do_init_npc(); do_init_unit(); -#ifndef TXT_ONLY /* mail system [Valaris] */ - if(mail_server_enable) - do_init_mail(); - - if (log_config.sql_logs) - { - log_sql_init(); - } +#ifndef TXT_ONLY /* mail system [Valaris] */ + if(mail_server_enable) + do_init_mail(); + + if (log_config.sql_logs) + { + log_sql_init(); + } if (connection_ping_interval) { - add_timer_func_list(map_sql_ping, "map_sql_ping"); + add_timer_func_list(map_sql_ping, "map_sql_ping"); add_timer_interval(gettick()+connection_ping_interval*60*1000, map_sql_ping, 0, 0, connection_ping_interval*60*1000); } -#endif /* not TXT_ONLY */ - - npc_event_do_oninit(); // npc‚ÌOnInitƒCƒxƒ“ƒg?s - - if ( console ) { - set_defaultconsoleparse(parse_console); - start_console(); - } - - if (battle_config.pk_mode == 1) - ShowNotice("Server is running on '"CL_WHITE"PK Mode"CL_RESET"'.\n"); - - ShowStatus("Server is '"CL_GREEN"ready"CL_RESET"' and listening on port '"CL_WHITE"%d"CL_RESET"'.\n\n", map_port); - - return 0; -} - -int compare_item(struct item *a, struct item *b) { - - if (a->nameid == b->nameid && - a->identify == b->identify && - a->refine == b->refine && - a->attribute == b->attribute) - { - int i; - for (i = 0; i < MAX_SLOTS && (a->card[i] == b->card[i]); i++); - return (i == MAX_SLOTS); - } - return 0; -} - -#ifndef TXT_ONLY -int charsql_db_init(int method){ - - if(method == 1){ //'INIT / START' - ShowInfo("Connecting to 'character' Database... "); - mysql_init(&charsql_handle); - - if(!mysql_real_connect(&charsql_handle, charsql_host, charsql_user, charsql_pass, charsql_db, charsql_port, (char *)NULL, 0)){ - ShowSQL("DB error - %s\n",mysql_error(&charsql_handle)); - exit(1); - }else{ - printf("success.\n"); - if( strlen(default_codepage) > 0 ) { - sprintf( tmp_sql, "SET NAMES %s", default_codepage ); - if (mysql_query(&charsql_handle, tmp_sql)) { - ShowSQL("DB error - %s\n",mysql_error(&charsql_handle)); - ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); - } - } - } - }else if(method == 0){ //'FINAL' / Shutdown - ShowInfo("Closing 'character' Database connection ... "); - mysql_close(&charsql_handle); - printf("done.\n"); - } - return 0; -} -#endif +#endif /* not TXT_ONLY */ + + npc_event_do_oninit(); // npc‚ÌOnInitƒCƒxƒ“ƒg?s + + if ( console ) { + set_defaultconsoleparse(parse_console); + start_console(); + } + + if (battle_config.pk_mode == 1) + ShowNotice("Server is running on '"CL_WHITE"PK Mode"CL_RESET"'.\n"); + + ShowStatus("Server is '"CL_GREEN"ready"CL_RESET"' and listening on port '"CL_WHITE"%d"CL_RESET"'.\n\n", map_port); + + return 0; +} + +int compare_item(struct item *a, struct item *b) { + + if (a->nameid == b->nameid && + a->identify == b->identify && + a->refine == b->refine && + a->attribute == b->attribute) + { + int i; + for (i = 0; i < MAX_SLOTS && (a->card[i] == b->card[i]); i++); + return (i == MAX_SLOTS); + } + return 0; +} + +#ifndef TXT_ONLY +int charsql_db_init(int method){ + + if(method == 1){ //'INIT / START' + ShowInfo("Connecting to 'character' Database... "); + mysql_init(&charsql_handle); + + if(!mysql_real_connect(&charsql_handle, charsql_host, charsql_user, charsql_pass, charsql_db, charsql_port, (char *)NULL, 0)){ + ShowSQL("DB error - %s\n",mysql_error(&charsql_handle)); + exit(1); + }else{ + printf("success.\n"); + if( strlen(default_codepage) > 0 ) { + sprintf( tmp_sql, "SET NAMES %s", default_codepage ); + if (mysql_query(&charsql_handle, tmp_sql)) { + ShowSQL("DB error - %s\n",mysql_error(&charsql_handle)); + ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); + } + } + } + }else if(method == 0){ //'FINAL' / Shutdown + ShowInfo("Closing 'character' Database connection ... "); + mysql_close(&charsql_handle); + printf("done.\n"); + } + return 0; +} +#endif diff --git a/src/map/npc.c b/src/map/npc.c index cfe3a31a6..e50e78fa5 100644 --- a/src/map/npc.c +++ b/src/map/npc.c @@ -2785,4 +2785,3 @@ int npc_changename(const char *name, const char *newname, short look){ npc_enable(newname,1); return 0; } - -- cgit v1.2.3-70-g09d2