summaryrefslogtreecommitdiff
path: root/src/char/inter.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/char/inter.c')
-rw-r--r--src/char/inter.c635
1 files changed, 0 insertions, 635 deletions
diff --git a/src/char/inter.c b/src/char/inter.c
deleted file mode 100644
index e886bf6..0000000
--- a/src/char/inter.c
+++ /dev/null
@@ -1,635 +0,0 @@
-// $Id: inter.c,v 1.1.1.1 2004/09/10 17:26:51 MagicalTux Exp $
-#include "../common/mmo.h"
-#include "char.h"
-#include "../common/socket.h"
-#include "../common/timer.h"
-#include "../common/db.h"
-#include <string.h>
-#include <stdlib.h>
-
-#include "inter.h"
-#include "int_party.h"
-#include "int_guild.h"
-#include "int_storage.h"
-#include "../common/lock.h"
-
-#define WISDATA_TTL (60*1000) // Existence time of Wisp/page data (60 seconds)
- // that is the waiting time of answers of all map-servers
-#define WISDELLIST_MAX 256 // Number of elements of Wisp/page data deletion list
-
-char inter_log_filename[1024] = "log/inter.log";
-
-char accreg_txt[1024] = "save/accreg.txt";
-static struct dbt *accreg_db = NULL;
-
-struct accreg
-{
- int account_id, reg_num;
- struct global_reg reg[ACCOUNT_REG_NUM];
-};
-
-int party_share_level = 10;
-
-// 送信パケット長リスト
-int inter_send_packet_length[] = {
- -1, -1, 27, -1, -1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- -1, 7, 0, 0, 0, 0, 0, 0, -1, 11, 0, 0, 0, 0, 0, 0,
- 35, -1, 11, 15, 34, 29, 7, -1, 0, 0, 0, 0, 0, 0, 0, 0,
- 10, -1, 15, 0, 79, 19, 7, -1, 0, -1, -1, -1, 14, 67, 186, -1,
- 9, 9, -1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 11, -1, 7, 3, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
-};
-
-// 受信パケット長リスト
-int inter_recv_packet_length[] = {
- -1, -1, 7, -1, -1, 6, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 6, -1, 0, 0, 0, 0, 0, 0, 10, -1, 0, 0, 0, 0, 0, 0,
- 72, 6, 52, 14, 10, 29, 6, -1, 34, 0, 0, 0, 0, 0, 0, 0,
- -1, 6, -1, 0, 55, 19, 6, -1, 14, -1, -1, -1, 14, 19, 186, -1,
- 5, 9, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 48, 14, -1, 6, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
-};
-
-struct WisData
-{
- int id, fd, count, len;
- unsigned long tick;
- unsigned char src[24], dst[24], msg[1024];
-};
-static struct dbt *wis_db = NULL;
-static int wis_dellist[WISDELLIST_MAX], wis_delnum;
-
-//--------------------------------------------------------
-
-// アカウント変数を文字列へ変換
-int inter_accreg_tostr (char *str, struct accreg *reg)
-{
- int j;
- char *p = str;
-
- p += sprintf (p, "%d\t", reg->account_id);
- for (j = 0; j < reg->reg_num; j++)
- {
- p += sprintf (p, "%s,%d ", reg->reg[j].str, reg->reg[j].value);
- }
-
- return 0;
-}
-
-// アカウント変数を文字列から変換
-int inter_accreg_fromstr (const char *str, struct accreg *reg)
-{
- int j, v, n;
- char buf[128];
- const char *p = str;
-
- if (sscanf (p, "%d\t%n", &reg->account_id, &n) != 1
- || reg->account_id <= 0)
- return 1;
-
- for (j = 0, p += n; j < ACCOUNT_REG_NUM; j++, p += n)
- {
- if (sscanf (p, "%[^,],%d %n", buf, &v, &n) != 2)
- break;
- memcpy (reg->reg[j].str, buf, 32);
- reg->reg[j].value = v;
- }
- reg->reg_num = j;
-
- return 0;
-}
-
-// アカウント変数の読み込み
-int inter_accreg_init (void)
-{
- char line[8192];
- FILE *fp;
- int c = 0;
- struct accreg *reg;
-
- accreg_db = numdb_init ();
-
- if ((fp = fopen_ (accreg_txt, "r")) == NULL)
- return 1;
- while (fgets (line, sizeof (line) - 1, fp))
- {
- line[sizeof (line) - 1] = '\0';
- CREATE (reg, struct accreg, 1);
- if (inter_accreg_fromstr (line, reg) == 0 && reg->account_id > 0)
- {
- numdb_insert (accreg_db, reg->account_id, reg);
- }
- else
- {
- printf ("inter: accreg: broken data [%s] line %d\n", accreg_txt,
- c);
- free (reg);
- }
- c++;
- }
- fclose_ (fp);
-// printf("inter: %s read done (%d)\n", accreg_txt, c);
-
- return 0;
-}
-
-// アカウント変数のセーブ用
-void inter_accreg_save_sub (db_key_t key, db_val_t data, va_list ap)
-{
- char line[8192];
- FILE *fp;
- struct accreg *reg = (struct accreg *) data;
-
- if (reg->reg_num > 0)
- {
- inter_accreg_tostr (line, reg);
- fp = va_arg (ap, FILE *);
- fprintf (fp, "%s\n", line);
- }
-}
-
-// アカウント変数のセーブ
-int inter_accreg_save (void)
-{
- FILE *fp;
- int lock;
-
- if ((fp = lock_fopen (accreg_txt, &lock)) == NULL)
- {
- printf ("int_accreg: cant write [%s] !!! data is lost !!!\n",
- accreg_txt);
- return 1;
- }
- numdb_foreach (accreg_db, inter_accreg_save_sub, fp);
- lock_fclose (fp, accreg_txt, &lock);
-// printf("inter: %s saved.\n", accreg_txt);
-
- return 0;
-}
-
-//--------------------------------------------------------
-
-/*==========================================
- * 設定ファイルを読み込む
- *------------------------------------------
- */
-int inter_config_read (const char *cfgName)
-{
- char line[1024], w1[1024], w2[1024];
- FILE *fp;
-
- fp = fopen_ (cfgName, "r");
- if (fp == NULL)
- {
- printf ("file not found: %s\n", cfgName);
- return 1;
- }
- while (fgets (line, sizeof (line) - 1, fp))
- {
- if (line[0] == '/' && line[1] == '/')
- continue;
- line[sizeof (line) - 1] = '\0';
-
- if (sscanf (line, "%[^:]: %[^\r\n]", w1, w2) != 2)
- continue;
-
- if (strcasecmp (w1, "storage_txt") == 0)
- {
- strncpy (storage_txt, w2, sizeof (storage_txt));
- }
- else if (strcasecmp (w1, "party_txt") == 0)
- {
- strncpy (party_txt, w2, sizeof (party_txt));
- }
- else if (strcasecmp (w1, "guild_txt") == 0)
- {
- strncpy (guild_txt, w2, sizeof (guild_txt));
- }
- else if (strcasecmp (w1, "castle_txt") == 0)
- {
- strncpy (castle_txt, w2, sizeof (castle_txt));
- }
- else if (strcasecmp (w1, "accreg_txt") == 0)
- {
- strncpy (accreg_txt, w2, sizeof (accreg_txt));
- }
- else if (strcasecmp (w1, "guild_storage_txt") == 0)
- {
- strncpy (guild_storage_txt, w2, sizeof (guild_storage_txt));
- }
- else if (strcasecmp (w1, "party_share_level") == 0)
- {
- party_share_level = atoi (w2);
- if (party_share_level < 0)
- party_share_level = 0;
- }
- else if (strcasecmp (w1, "inter_log_filename") == 0)
- {
- strncpy (inter_log_filename, w2, sizeof (inter_log_filename));
- }
- else if (strcasecmp (w1, "import") == 0)
- {
- inter_config_read (w2);
- }
- }
- fclose_ (fp);
-
- return 0;
-}
-
-// ログ書き出し
-int inter_log (char *fmt, ...)
-{
- FILE *logfp;
- va_list ap;
-
- va_start (ap, fmt);
- logfp = fopen_ (inter_log_filename, "a");
- if (logfp)
- {
- vfprintf (logfp, fmt, ap);
- fclose_ (logfp);
- }
- va_end (ap);
-
- return 0;
-}
-
-// セーブ
-int inter_save (void)
-{
- inter_party_save ();
- inter_guild_save ();
- inter_storage_save ();
- inter_guild_storage_save ();
- inter_accreg_save ();
-
- return 0;
-}
-
-// 初期化
-int inter_init (const char *file)
-{
- inter_config_read (file);
-
- wis_db = numdb_init ();
-
- inter_party_init ();
- inter_guild_init ();
- inter_storage_init ();
- inter_accreg_init ();
-
- return 0;
-}
-
-// マップサーバー接続
-int inter_mapif_init (int fd)
-{
- inter_guild_mapif_init (fd);
-
- return 0;
-}
-
-//--------------------------------------------------------
-// sended packets to map-server
-
-// GMメッセージ送信
-int mapif_GMmessage (unsigned char *mes, int len)
-{
- unsigned char buf[len];
-
- WBUFW (buf, 0) = 0x3800;
- WBUFW (buf, 2) = len;
- memcpy (WBUFP (buf, 4), mes, len - 4);
- mapif_sendall (buf, len);
-// printf("inter server: GM:%d %s\n", len, mes);
-
- return 0;
-}
-
-// Wisp/page transmission to all map-server
-int mapif_wis_message (struct WisData *wd)
-{
- unsigned char buf[56 + wd->len];
-
- WBUFW (buf, 0) = 0x3801;
- WBUFW (buf, 2) = 56 + wd->len;
- WBUFL (buf, 4) = wd->id;
- memcpy (WBUFP (buf, 8), wd->src, 24);
- memcpy (WBUFP (buf, 32), wd->dst, 24);
- memcpy (WBUFP (buf, 56), wd->msg, wd->len);
- wd->count = mapif_sendall (buf, WBUFW (buf, 2));
-
- return 0;
-}
-
-// Wisp/page transmission result to map-server
-int mapif_wis_end (struct WisData *wd, int flag)
-{
- unsigned char buf[27];
-
- WBUFW (buf, 0) = 0x3802;
- memcpy (WBUFP (buf, 2), wd->src, 24);
- WBUFB (buf, 26) = flag; // flag: 0: success to send wisper, 1: target character is not loged in?, 2: ignored by target
- mapif_send (wd->fd, buf, 27);
-// printf("inter server wis_end: flag: %d\n", flag);
-
- return 0;
-}
-
-// アカウント変数送信
-int mapif_account_reg (int fd, unsigned char *src)
-{
- unsigned char buf[WBUFW (src, 2)];
-
- memcpy (WBUFP (buf, 0), src, WBUFW (src, 2));
- WBUFW (buf, 0) = 0x3804;
- mapif_sendallwos (fd, buf, WBUFW (buf, 2));
-
- return 0;
-}
-
-// アカウント変数要求返信
-int mapif_account_reg_reply (int fd, int account_id)
-{
- struct accreg *reg = (struct accreg *)numdb_search (accreg_db, account_id);
-
- WFIFOW (fd, 0) = 0x3804;
- WFIFOL (fd, 4) = account_id;
- if (reg == NULL)
- {
- WFIFOW (fd, 2) = 8;
- }
- else
- {
- int j, p;
- for (j = 0, p = 8; j < reg->reg_num; j++, p += 36)
- {
- memcpy (WFIFOP (fd, p), reg->reg[j].str, 32);
- WFIFOL (fd, p + 32) = reg->reg[j].value;
- }
- WFIFOW (fd, 2) = p;
- }
- WFIFOSET (fd, WFIFOW (fd, 2));
-
- return 0;
-}
-
-//--------------------------------------------------------
-
-// Existence check of WISP data
-void check_ttl_wisdata_sub (db_key_t key, db_val_t data, va_list ap)
-{
- unsigned long tick;
- struct WisData *wd = (struct WisData *) data;
- tick = va_arg (ap, unsigned long);
-
- if (DIFF_TICK (tick, wd->tick) > WISDATA_TTL
- && wis_delnum < WISDELLIST_MAX)
- wis_dellist[wis_delnum++] = wd->id;
-}
-
-int check_ttl_wisdata (void)
-{
- unsigned long tick = gettick ();
- int i;
-
- do
- {
- wis_delnum = 0;
- numdb_foreach (wis_db, check_ttl_wisdata_sub, tick);
- for (i = 0; i < wis_delnum; i++)
- {
- struct WisData *wd = (struct WisData *)numdb_search (wis_db, wis_dellist[i]);
- printf ("inter: wis data id=%d time out : from %s to %s\n",
- wd->id, wd->src, wd->dst);
- // removed. not send information after a timeout. Just no answer for the player
- //mapif_wis_end(wd, 1); // flag: 0: success to send wisper, 1: target character is not loged in?, 2: ignored by target
- numdb_erase (wis_db, wd->id);
- free (wd);
- }
- }
- while (wis_delnum >= WISDELLIST_MAX);
-
- return 0;
-}
-
-//--------------------------------------------------------
-// received packets from map-server
-
-// GMメッセージ送信
-int mapif_parse_GMmessage (int fd)
-{
- mapif_GMmessage (RFIFOP (fd, 4), RFIFOW (fd, 2));
-
- return 0;
-}
-
-// Wisp/page request to send
-int mapif_parse_WisRequest (int fd)
-{
- struct WisData *wd;
- static int wisid = 0;
- int index;
-
- if (RFIFOW (fd, 2) - 52 >= sizeof (wd->msg))
- {
- printf ("inter: Wis message size too long.\n");
- return 0;
- }
- else if (RFIFOW (fd, 2) - 52 <= 0)
- { // normaly, impossible, but who knows...
- printf ("inter: Wis message doesn't exist.\n");
- return 0;
- }
-
- // search if character exists before to ask all map-servers
- if ((index = search_character_index (RFIFOP (fd, 28))) == -1)
- {
- unsigned char buf[27];
- WBUFW (buf, 0) = 0x3802;
- memcpy (WBUFP (buf, 2), RFIFOP (fd, 4), 24);
- WBUFB (buf, 26) = 1; // flag: 0: success to send wisper, 1: target character is not loged in?, 2: ignored by target
- mapif_send (fd, buf, 27);
- // Character exists. So, ask all map-servers
- }
- else
- {
- // to be sure of the correct name, rewrite it
- memset (RFIFOP (fd, 28), 0, 24);
- strncpy (RFIFOP (fd, 28), search_character_name (index), 24);
- // if source is destination, don't ask other servers.
- if (strcmp (RFIFOP (fd, 4), RFIFOP (fd, 28)) == 0)
- {
- unsigned char buf[27];
- WBUFW (buf, 0) = 0x3802;
- memcpy (WBUFP (buf, 2), RFIFOP (fd, 4), 24);
- WBUFB (buf, 26) = 1; // flag: 0: success to send wisper, 1: target character is not loged in?, 2: ignored by target
- mapif_send (fd, buf, 27);
- }
- else
- {
- CREATE (wd, struct WisData, 1);
-
- // Whether the failure of previous wisp/page transmission (timeout)
- check_ttl_wisdata ();
-
- wd->id = ++wisid;
- wd->fd = fd;
- wd->len = RFIFOW (fd, 2) - 52;
- memcpy (wd->src, RFIFOP (fd, 4), 24);
- memcpy (wd->dst, RFIFOP (fd, 28), 24);
- memcpy (wd->msg, RFIFOP (fd, 52), wd->len);
- wd->tick = gettick ();
- numdb_insert (wis_db, wd->id, wd);
- mapif_wis_message (wd);
- }
- }
-
- return 0;
-}
-
-// Wisp/page transmission result
-int mapif_parse_WisReply (int fd)
-{
- int id = RFIFOL (fd, 2), flag = RFIFOB (fd, 6);
- struct WisData *wd = (struct WisData *)numdb_search (wis_db, id);
-
- if (wd == NULL)
- return 0; // This wisp was probably suppress before, because it was timeout of because of target was found on another map-server
-
- if ((--wd->count) <= 0 || flag != 1)
- {
- mapif_wis_end (wd, flag); // flag: 0: success to send wisper, 1: target character is not loged in?, 2: ignored by target
- numdb_erase (wis_db, id);
- free (wd);
- }
-
- return 0;
-}
-
-// Received wisp message from map-server for ALL gm (just copy the message and resends it to ALL map-servers)
-int mapif_parse_WisToGM (int fd)
-{
- unsigned char buf[RFIFOW (fd, 2)]; // 0x3003/0x3803 <packet_len>.w <wispname>.24B <min_gm_level>.w <message>.?B
-
- memcpy (WBUFP (buf, 0), RFIFOP (fd, 0), RFIFOW (fd, 2));
- WBUFW (buf, 0) = 0x3803;
- mapif_sendall (buf, RFIFOW (fd, 2));
-
- return 0;
-}
-
-// アカウント変数保存要求
-int mapif_parse_AccReg (int fd)
-{
- int j, p;
- struct accreg *reg = (struct accreg*)numdb_search (accreg_db, (numdb_key_t)RFIFOL (fd, 4));
-
- if (reg == NULL)
- {
- CREATE (reg, struct accreg, 1);
- reg->account_id = RFIFOL (fd, 4);
- numdb_insert (accreg_db, (numdb_key_t)RFIFOL (fd, 4), reg);
- }
-
- for (j = 0, p = 8; j < ACCOUNT_REG_NUM && p < RFIFOW (fd, 2);
- j++, p += 36)
- {
- memcpy (reg->reg[j].str, RFIFOP (fd, p), 32);
- reg->reg[j].value = RFIFOL (fd, p + 32);
- }
- reg->reg_num = j;
-
- mapif_account_reg (fd, RFIFOP (fd, 0)); // 他のMAPサーバーに送信
-
- return 0;
-}
-
-// アカウント変数送信要求
-int mapif_parse_AccRegRequest (int fd)
-{
-// printf("mapif: accreg request\n");
- return mapif_account_reg_reply (fd, RFIFOL (fd, 2));
-}
-
-//--------------------------------------------------------
-
-// map server からの通信（１パケットのみ解析すること）
-// エラーなら0(false)、処理できたなら1、
-// パケット長が足りなければ2をかえさなければならない
-int inter_parse_frommap (int fd)
-{
- int cmd = RFIFOW (fd, 0);
- int len = 0;
-
- // inter鯖管轄かを調べる
- if (cmd < 0x3000
- || cmd >=
- 0x3000 +
- (sizeof (inter_recv_packet_length) /
- sizeof (inter_recv_packet_length[0])))
- return 0;
-
- // パケット長を調べる
- if ((len =
- inter_check_length (fd,
- inter_recv_packet_length[cmd - 0x3000])) == 0)
- return 2;
-
- switch (cmd)
- {
- case 0x3000:
- mapif_parse_GMmessage (fd);
- break;
- case 0x3001:
- mapif_parse_WisRequest (fd);
- break;
- case 0x3002:
- mapif_parse_WisReply (fd);
- break;
- case 0x3003:
- mapif_parse_WisToGM (fd);
- break;
- case 0x3004:
- mapif_parse_AccReg (fd);
- break;
- case 0x3005:
- mapif_parse_AccRegRequest (fd);
- break;
- default:
- if (inter_party_parse_frommap (fd))
- break;
- if (inter_guild_parse_frommap (fd))
- break;
- if (inter_storage_parse_frommap (fd))
- break;
- return 0;
- }
- RFIFOSKIP (fd, len);
-
- return 1;
-}
-
-// RFIFOのパケット長確認
-// 必要パケット長があればパケット長、まだ足りなければ0
-int inter_check_length (int fd, int length)
-{
- if (length == -1)
- { // 可変パケット長
- if (RFIFOREST (fd) < 4) // パケット長が未着
- return 0;
- length = RFIFOW (fd, 2);
- }
-
- if (RFIFOREST (fd) < length) // パケットが未着
- return 0;
-
- return length;
-}
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2025-04-27 15:44:19 +0000