本文整理汇总了C++中RFIFOP函数的典型用法代码示例。如果您正苦于以下问题：C++ RFIFOP函数的具体用法？C++ RFIFOP怎么用？C++ RFIFOP使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了RFIFOP函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C++代码示例。
示例1: intif_parse_WisMessage
// Wisp/Page reception
static
int intif_parse_WisMessage (int fd)
{ // rewritten by [Yor]
struct map_session_data *sd;
int i;
if (battle_config.etc_log)
printf
("intif_parse_wismessage: id: %d, from: %s, to: %s, message: '%s'\n",
RFIFOL (fd, 4), RFIFOP (fd, 8), RFIFOP (fd, 32), RFIFOP (fd,
56));
sd = map_nick2sd ((const char *)RFIFOP (fd, 32)); // Searching destination player
if (sd != NULL && strcmp (sd->status.name, (const char *)RFIFOP (fd, 32)) == 0)
{ // exactly same name (inter-server have checked the name before)
// if player ignore all
if (sd->ignoreAll == 1)
intif_wis_replay (RFIFOL (fd, 4), 2); // flag: 0: success to send wisper, 1: target character is not loged in?, 2: ignored by target
else
{
const char *wisp_source = (const char *)RFIFOP (fd, 8); // speed up
// if player ignore the source character
for (i = 0; i < (sizeof (sd->ignore) / sizeof (sd->ignore[0]));
i++)
if (strcmp (sd->ignore[i].name, wisp_source) == 0)
{
intif_wis_replay (RFIFOL (fd, 4), 2); // flag: 0: success to send wisper, 1: target character is not loged in?, 2: ignored by target
break;
}
// if source player not found in ignore list
if (i == (sizeof (sd->ignore) / sizeof (sd->ignore[0])))
{
clif_wis_message (sd->fd, (const char *)RFIFOP (fd, 8), (const char *)RFIFOP (fd, 56),
RFIFOW (fd, 2) - 56);
intif_wis_replay (RFIFOL (fd, 4), 0); // flag: 0: success to send wisper, 1: target character is not loged in?, 2: ignored by target
}
}
}
else
intif_wis_replay (RFIFOL (fd, 4), 1); // flag: 0: success to send wisper, 1: target character is not loged in?, 2: ignored by target
return 0;
}
开发者ID:Cloudxtreme，项目名称:tmwa，代码行数:42，代码来源:intif.cpp
示例2: inter_party_parse_frommap
// map server からの通信
// ・１パケットのみ解析すること
// ・パケット長データはinter.cにセットしておくこと
// ・パケット長チェックや、RFIFOSKIPは呼び出し元で行われるので行ってはならない
// ・エラーなら0(false)、そうでないなら1(true)をかえさなければならない
int inter_party_parse_frommap(int fd)
{
switch(RFIFOW(fd,0)){
case 0x3020: mapif_parse_CreateParty(fd,RFIFOL(fd,2),(char*)RFIFOP(fd,6),(char*)RFIFOP(fd,30),(char*)RFIFOP(fd,54),RFIFOW(fd,70), RFIFOB(fd,72), RFIFOB(fd,73)); break;
case 0x3021: mapif_parse_PartyInfo(fd,RFIFOL(fd,2)); break;
case 0x3022: mapif_parse_PartyAddMember(fd,RFIFOL(fd,2),RFIFOL(fd,6),(char*)RFIFOP(fd,10),(char*)RFIFOP(fd,34),RFIFOW(fd,50)); break;
case 0x3023: mapif_parse_PartyChangeOption(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOW(fd,10),RFIFOW(fd,12)); break;
case 0x3024: mapif_parse_PartyLeave(fd,RFIFOL(fd,2),RFIFOL(fd,6)); break;
case 0x3025: mapif_parse_PartyChangeMap(fd,RFIFOL(fd,2),RFIFOL(fd,6),(char*)RFIFOP(fd,10),RFIFOB(fd,26),RFIFOW(fd,27)); break;
case 0x3026: mapif_parse_BreakParty(fd,RFIFOL(fd,2)); break;
case 0x3027: mapif_parse_PartyMessage(fd,RFIFOL(fd,4),RFIFOL(fd,8),(char*)RFIFOP(fd,12),RFIFOW(fd,2)-12); break;
case 0x3028: mapif_parse_PartyCheck(fd,RFIFOL(fd,2),RFIFOL(fd,6),(char*)RFIFOP(fd,10)); break;
default:
return 0;
}
return 1;
}
开发者ID:AxlSckay，项目名称:Ragnarok-OldTimes，代码行数:22，代码来源:int_party.c
示例3: mapif_parse_SaveGuildStorage
int mapif_parse_SaveGuildStorage(int fd)
{
int guild_exist=1;
int guild_id;
int len;
RFIFOHEAD(fd);
guild_id=RFIFOL(fd,8);
len=RFIFOW(fd,2);
if(sizeof(struct guild_storage)!=len-12) {
ShowError("inter storage: data size error %d %d\n",sizeof(struct guild_storage),len-12);
}
else {
#if 0 // Again, innodb key checks make the check pointless
// Check if guild exists, I may write a function for this later, coz I use it several times.
//printf("- Check if guild %d exists\n",g->guild_id);
sprintf(tmp_sql, "SELECT count(*) FROM `%s` WHERE `guild_id`='%d'",guild_db, guild_id);
if(mysql_query(&mysql_handle, tmp_sql) ) {
ShowSQL("DB error - %s\n",mysql_error(&mysql_handle));
ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql);
}
sql_res = mysql_store_result(&mysql_handle) ;
if (sql_res!=NULL && mysql_num_rows(sql_res)>0) {
sql_row = mysql_fetch_row(sql_res);
guild_exist = atoi (sql_row[0]);
//printf("- Check if guild %d exists : %s\n",g->guild_id,((guild_exist==0)?"No":"Yes"));
}
mysql_free_result(sql_res) ; //resource free
#endif
if(guild_exist==1) {
memcpy(guild_storage_pt,RFIFOP(fd,12),sizeof(struct guild_storage));
guild_storage_tosql(guild_id,guild_storage_pt);
mapif_save_guild_storage_ack(fd,RFIFOL(fd,4),guild_id,0);
}
else
mapif_save_guild_storage_ack(fd,RFIFOL(fd,4),guild_id,1);
}
return 0;
}
开发者ID:mleo1，项目名称:Ragnarok-OldTimes，代码行数:38，代码来源:int_storage.c
示例4: intif_parse_GuildMemberInfoChanged
// ギルドメンバ情報変更通知
static
int intif_parse_GuildMemberInfoChanged (int fd)
{
int type = RFIFOW (fd, 16), guild_id = RFIFOL (fd, 4);
int account_id = RFIFOL (fd, 8), char_id = RFIFOL (fd, 12);
void *data = RFIFOP (fd, 18);
struct guild *g = guild_search (guild_id);
int idx, dd = *((int *) data);
if (g == NULL)
return 0;
idx = guild_getindex (g, account_id, char_id);
switch (type)
{
case GMI_POSITION:
g->member[idx].position = dd;
guild_memberposition_changed (g, idx, dd);
break;
case GMI_EXP:
g->member[idx].exp = dd;
break;
}
return 0;
}
开发者ID:Cloudxtreme，项目名称:tmwa，代码行数:24，代码来源:intif.cpp
示例5: mapif_parse_Mail_receiver_check
static void mapif_parse_Mail_receiver_check(int fd) {
char name[NAME_LENGTH], esc_name[NAME_LENGTH * 2 + 1];
uint32 char_id = 0;
uint16 class_ = 0, base_level = 0;
safestrncpy(name, (char *)RFIFOP(fd,6), NAME_LENGTH);
// Try to find the Dest Char by Name
Sql_EscapeStringLen(sql_handle, esc_name, name, strnlen(name, NAME_LENGTH));
if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `char_id`,`class`,`base_level` FROM `%s` WHERE `name` = '%s'", char_db, esc_name) )
Sql_ShowDebug(sql_handle);
else if( SQL_SUCCESS == Sql_NextRow(sql_handle) ) {
char *data;
Sql_GetData(sql_handle, 0, &data, NULL); char_id = atoi(data);
Sql_GetData(sql_handle, 1, &data, NULL); class_ = atoi(data);
Sql_GetData(sql_handle, 2, &data, NULL); base_level = atoi(data);
}
Sql_FreeResult(sql_handle);
mapif_Mail_receiver_send(fd, RFIFOL(fd,2), char_id, class_, base_level, name);
}
开发者ID:exneval，项目名称:trunk，代码行数:23，代码来源:int_mail.c
示例6: intif_parse_GuildInfo
// ギルド情報
static
int intif_parse_GuildInfo (int fd)
{
if (RFIFOW (fd, 2) == 8)
{
if (battle_config.error_log)
printf ("intif: guild noinfo %d\n", RFIFOL (fd, 4));
guild_recv_noinfo (RFIFOL (fd, 4));
return 0;
}
// if(battle_config.etc_log)
// printf("intif: guild info %d\n",RFIFOL(fd,4));
if (RFIFOW (fd, 2) != sizeof (struct guild) + 4)
{
if (battle_config.error_log)
printf ("intif: guild info : data size error\n %d %d %d",
RFIFOL (fd, 4), RFIFOW (fd, 2),
sizeof (struct guild) + 4);
}
guild_recv_info ((struct guild *) RFIFOP (fd, 4));
return 0;
}
开发者ID:Cloudxtreme，项目名称:tmwa，代码行数:24，代码来源:intif.cpp
示例7: mapif_parse_Mail_send
static void mapif_parse_Mail_send(int fd)
{
struct mail_message msg;
char esc_name[NAME_LENGTH*2+1];
int account_id = 0;
if(RFIFOW(fd,2) != 8 + sizeof(struct mail_message))
return;
account_id = RFIFOL(fd,4);
memcpy(&msg, RFIFOP(fd,8), sizeof(struct mail_message));
// Try to find the Dest Char by Name
SQL->EscapeStringLen(sql_handle, esc_name, msg.dest_name, strnlen(msg.dest_name, NAME_LENGTH));
if ( SQL_ERROR == SQL->Query(sql_handle, "SELECT `account_id`, `char_id` FROM `%s` WHERE `name` = '%s'", char_db, esc_name) )
Sql_ShowDebug(sql_handle);
else
if ( SQL_SUCCESS == SQL->NextRow(sql_handle) )
{
char *data;
SQL->GetData(sql_handle, 0, &data, NULL);
if (atoi(data) != account_id)
{ // Cannot send mail to char in the same account
SQL->GetData(sql_handle, 1, &data, NULL);
msg.dest_id = atoi(data);
}
}
SQL->FreeResult(sql_handle);
msg.status = MAIL_NEW;
if( msg.dest_id > 0 )
msg.id = mail_savemessage(&msg);
mapif_Mail_send(fd, &msg); // notify sender
mapif_Mail_new(&msg); // notify recipient
}
开发者ID:Alexalvesgyn，项目名称:Cronus，代码行数:36，代码来源:int_mail.c
示例8: intif_parse_GuildBasicInfoChanged
// ギルド基本情報変更通知
static
int intif_parse_GuildBasicInfoChanged (int fd)
{
int type = RFIFOW (fd, 8), guild_id = RFIFOL (fd, 4);
void *data = RFIFOP (fd, 10);
struct guild *g = guild_search (guild_id);
short dw = *((short *) data);
int dd = *((int *) data);
if (g == NULL)
return 0;
switch (type)
{
case GBI_EXP:
g->exp = dd;
break;
case GBI_GUILDLV:
g->guild_lv = dw;
break;
case GBI_SKILLPOINT:
g->skill_point = dd;
break;
}
return 0;
}
开发者ID:Cloudxtreme，项目名称:tmwa，代码行数:25，代码来源:intif.cpp
示例9: intif_parse_GuildCastleAllDataLoad
// ギルド城データ一括受信(初期化時)
static
int intif_parse_GuildCastleAllDataLoad (int fd)
{
return guild_castlealldataload (RFIFOW (fd, 2),
(struct guild_castle *) RFIFOP (fd, 4));
}
开发者ID:Cloudxtreme，项目名称:tmwa，代码行数:7，代码来源:intif.cpp
示例10: intif_parse_GuildNotice
// ギルド告知変更通知
static
int intif_parse_GuildNotice (int fd)
{
guild_notice_changed (RFIFOL (fd, 2), (const char *)RFIFOP (fd, 6), (const char *)RFIFOP (fd, 66));
return 0;
}
开发者ID:Cloudxtreme，项目名称:tmwa，代码行数:7，代码来源:intif.cpp
示例11: inter_homunculus_parse_frommap
/*==========================================
* Inter Packets
*------------------------------------------*/
int inter_homunculus_parse_frommap(int fd)
{
unsigned short cmd = RFIFOW(fd,0);
switch( cmd )
{
case 0x3090: mapif_parse_homunculus_create(fd, (int)RFIFOW(fd,2), (int)RFIFOL(fd,4), (struct s_homunculus*)RFIFOP(fd,8)); break;
case 0x3091: mapif_parse_homunculus_load (fd, (int)RFIFOL(fd,2), (int)RFIFOL(fd,6)); break;
case 0x3092: mapif_parse_homunculus_save (fd, (int)RFIFOW(fd,2), (int)RFIFOL(fd,4), (struct s_homunculus*)RFIFOP(fd,8)); break;
case 0x3093: mapif_parse_homunculus_delete(fd, (int)RFIFOL(fd,2)); break;
case 0x3094: mapif_parse_homunculus_rename(fd, (int)RFIFOL(fd,2), (int)RFIFOL(fd,6), (char*)RFIFOP(fd,10)); break;
default:
return 0;
}
return 1;
}
开发者ID:Jefte-Netyul，项目名称:Radices，代码行数:19，代码来源:int_homun.c
示例12: mapif_parse_accinfo
/* [Dekamaster/Nightroad] */
void mapif_parse_accinfo(int fd) {
int u_fd = RFIFOL(fd,2), aid = RFIFOL(fd,6), castergroup = RFIFOL(fd,10);
char query[NAME_LENGTH], query_esq[NAME_LENGTH*2+1];
int account_id;
char *data;
safestrncpy(query, (char*) RFIFOP(fd,14), NAME_LENGTH);
SQL->EscapeString(sql_handle, query_esq, query);
account_id = atoi(query);
if (account_id < START_ACCOUNT_NUM) { // is string
if ( SQL_ERROR == SQL->Query(sql_handle, "SELECT `account_id`,`name`,`class`,`base_level`,`job_level`,`online` FROM `%s` WHERE `name` LIKE '%s' LIMIT 10", char_db, query_esq)
|| SQL->NumRows(sql_handle) == 0 ) {
if( SQL->NumRows(sql_handle) == 0 ) {
inter_msg_to_fd(fd, u_fd, aid, "No matches were found for your criteria, '%s'",query);
} else {
Sql_ShowDebug(sql_handle);
inter_msg_to_fd(fd, u_fd, aid, "An error occured, bother your admin about it.");
}
SQL->FreeResult(sql_handle);
return;
} else {
if( SQL->NumRows(sql_handle) == 1 ) {//we found a perfect match
SQL->NextRow(sql_handle);
SQL->GetData(sql_handle, 0, &data, NULL); account_id = atoi(data);
SQL->FreeResult(sql_handle);
} else {// more than one, listing... [Dekamaster/Nightroad]
inter_msg_to_fd(fd, u_fd, aid, "Your query returned the following %d results, please be more specific...",(int)SQL->NumRows(sql_handle));
while ( SQL_SUCCESS == SQL->NextRow(sql_handle) ) {
int class_;
short base_level, job_level, online;
char name[NAME_LENGTH];
SQL->GetData(sql_handle, 0, &data, NULL); account_id = atoi(data);
SQL->GetData(sql_handle, 1, &data, NULL); safestrncpy(name, data, sizeof(name));
SQL->GetData(sql_handle, 2, &data, NULL); class_ = atoi(data);
SQL->GetData(sql_handle, 3, &data, NULL); base_level = atoi(data);
SQL->GetData(sql_handle, 4, &data, NULL); job_level = atoi(data);
SQL->GetData(sql_handle, 5, &data, NULL); online = atoi(data);
inter_msg_to_fd(fd, u_fd, aid, "[AID: %d] %s | %s | Level: %d/%d | %s", account_id, name, job_name(class_), base_level, job_level, online?"Online":"Offline");
}
SQL->FreeResult(sql_handle);
return;
}
}
}
/* it will only get here if we have a single match */
if( account_id ) {
char userid[NAME_LENGTH], user_pass[NAME_LENGTH], email[40], last_ip[20], lastlogin[30], pin_code[5], birthdate[11];
short level = -1;
int logincount = 0,state = 0;
// FIXME: No, this doesn't really look right. We can't, and shouldn't, access the login table from the char server.
if ( SQL_ERROR == SQL->Query(sql_handle, "SELECT `userid`, `user_pass`, `email`, `last_ip`, `group_id`, `lastlogin`, `logincount`, `state`,`pincode`,`birthdate` FROM `login` WHERE `account_id` = '%d' LIMIT 1", account_id)
|| SQL->NumRows(sql_handle) == 0 ) {
if( SQL->NumRows(sql_handle) == 0 ) {
inter_msg_to_fd(fd, u_fd, aid, "No account with ID '%d' was found.", account_id );
} else {
inter_msg_to_fd(fd, u_fd, aid, "An error occured, bother your admin about it.");
Sql_ShowDebug(sql_handle);
}
} else {
SQL->NextRow(sql_handle);
SQL->GetData(sql_handle, 0, &data, NULL); safestrncpy(userid, data, sizeof(userid));
SQL->GetData(sql_handle, 1, &data, NULL); safestrncpy(user_pass, data, sizeof(user_pass));
SQL->GetData(sql_handle, 2, &data, NULL); safestrncpy(email, data, sizeof(email));
SQL->GetData(sql_handle, 3, &data, NULL); safestrncpy(last_ip, data, sizeof(last_ip));
SQL->GetData(sql_handle, 4, &data, NULL); level = atoi(data);
SQL->GetData(sql_handle, 5, &data, NULL); safestrncpy(lastlogin, data, sizeof(lastlogin));
SQL->GetData(sql_handle, 6, &data, NULL); logincount = atoi(data);
SQL->GetData(sql_handle, 7, &data, NULL); state = atoi(data);
SQL->GetData(sql_handle, 8, &data, NULL); safestrncpy(pin_code, data, sizeof(pin_code));
SQL->GetData(sql_handle, 9, &data, NULL); safestrncpy(birthdate, data, sizeof(birthdate));
}
SQL->FreeResult(sql_handle);
if (level == -1)
return;
inter_msg_to_fd(fd, u_fd, aid, "-- Account %d --", account_id );
inter_msg_to_fd(fd, u_fd, aid, "User: %s | GM Group: %d | State: %d", userid, level, state );
if (level < castergroup) { /* only show pass if your gm level is greater than the one you're searching for */
if( strlen(pin_code) )
inter_msg_to_fd(fd, u_fd, aid, "Password: %s (PIN:%s)", user_pass, pin_code );
else
inter_msg_to_fd(fd, u_fd, aid, "Password: %s", user_pass );
}
inter_msg_to_fd(fd, u_fd, aid, "Account e-mail: %s | Birthdate: %s", email, birthdate);
inter_msg_to_fd(fd, u_fd, aid, "Last IP: %s (%s)", last_ip, geoip_getcountry(str2ip(last_ip)) );
inter_msg_to_fd(fd, u_fd, aid, "This user has logged %d times, the last time were at %s", logincount, lastlogin );
inter_msg_to_fd(fd, u_fd, aid, "-- Character Details --" );
//.........这里部分代码省略.........
开发者ID:BlazingSpear，项目名称:Hercules，代码行数:101，代码来源:inter.c
示例13: mapif_parse_WisRequest
// Wisp/page request to send
int mapif_parse_WisRequest(int fd)
{
struct WisData* wd;
static int wisid = 0;
char name[NAME_LENGTH];
char esc_name[NAME_LENGTH*2+1];// escaped name
char* data;
size_t len;
if ( fd <= 0 ) {return 0;} // check if we have a valid fd
if (RFIFOW(fd,2)-52 >= sizeof(wd->msg)) {
ShowWarning("inter: Wis message size too long.\n");
return 0;
} else if (RFIFOW(fd,2)-52 <= 0) { // normaly, impossible, but who knows...
ShowError("inter: Wis message doesn't exist.\n");
return 0;
}
safestrncpy(name, (char*)RFIFOP(fd,28), NAME_LENGTH); //Received name may be too large and not contain \0! [Skotlex]
SQL->EscapeStringLen(sql_handle, esc_name, name, strnlen(name, NAME_LENGTH));
if( SQL_ERROR == SQL->Query(sql_handle, "SELECT `name` FROM `%s` WHERE `name`='%s'", char_db, esc_name) )
Sql_ShowDebug(sql_handle);
// search if character exists before to ask all map-servers
if( SQL_SUCCESS != SQL->NextRow(sql_handle) )
{
unsigned char buf[27];
WBUFW(buf, 0) = 0x3802;
memcpy(WBUFP(buf, 2), RFIFOP(fd, 4), NAME_LENGTH);
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
{// Character exists. So, ask all map-servers
// to be sure of the correct name, rewrite it
SQL->GetData(sql_handle, 0, &data, &len);
memset(name, 0, NAME_LENGTH);
memcpy(name, data, min(len, NAME_LENGTH));
// if source is destination, don't ask other servers.
if( strncmp((const char*)RFIFOP(fd,4), name, NAME_LENGTH) == 0 )
{
uint8 buf[27];
WBUFW(buf, 0) = 0x3802;
memcpy(WBUFP(buf, 2), RFIFOP(fd, 4), NAME_LENGTH);
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), NAME_LENGTH);
memcpy(wd->dst, RFIFOP(fd,28), NAME_LENGTH);
memcpy(wd->msg, RFIFOP(fd,52), wd->len);
wd->tick = timer->gettick();
idb_put(wis_db, wd->id, wd);
mapif_wis_message(wd);
}
}
SQL->FreeResult(sql_handle);
return 0;
}
开发者ID:BlazingSpear，项目名称:Hercules，代码行数:74，代码来源:inter.c
示例14: mapif_parse_SavePet
int mapif_parse_SavePet(int fd)
{
RFIFOHEAD(fd);
mapif->save_pet(fd, RFIFOL(fd, 4), RFIFOP(fd, 8));
return 0;
}
开发者ID:Barruch，项目名称:Hercules，代码行数:6，代码来源:int_pet.c
示例15: intif_parse_LoadGuildStorage
static
int intif_parse_LoadGuildStorage (int fd)
{
struct guild_storage *gstor;
struct map_session_data *sd;
int guild_id;
guild_id = RFIFOL (fd, 8);
if (guild_id > 0)
{
gstor = guild2storage (guild_id);
if (!gstor)
{
if (battle_config.error_log)
printf
("intif_parse_LoadGuildStorage: error guild_id %d not exist\n",
guild_id);
return 1;
}
if (RFIFOW (fd, 2) - 12 != sizeof (struct guild_storage))
{
gstor->storage_status = 0;
if (battle_config.error_log)
printf
("intif_parse_LoadGuildStorage: data size error %d %d\n",
RFIFOW (fd, 2) - 12, sizeof (struct guild_storage));
return 1;
}
sd = map_id2sd (RFIFOL (fd, 4));
if (sd == NULL)
{
if (battle_config.error_log)
printf ("intif_parse_LoadGuildStorage: user not found %d\n",
RFIFOL (fd, 4));
return 1;
}
if (gstor->storage_status == 1)
{ // Already open.. lets ignore this update
if (battle_config.error_log)
printf
("intif_parse_LoadGuildStorage: storage received for a client already open (User %d:%d)\n",
sd->status.account_id, sd->status.char_id);
return 1;
}
if (gstor->dirty)
{ // Already have storage, and it has been modified and not saved yet! Exploit! [Skotlex]
if (battle_config.error_log)
printf
("intif_parse_LoadGuildStorage: received storage for an already modified non-saved storage! (User %d:%d)\n",
sd->status.account_id, sd->status.char_id);
return 1;
}
if (battle_config.save_log)
printf ("intif_open_guild_storage: %d\n", RFIFOL (fd, 4));
memcpy (gstor, RFIFOP (fd, 12), sizeof (struct guild_storage));
gstor->storage_status = 1;
sd->state.storage_flag = 2;
clif_guildstorageitemlist (sd, gstor);
clif_guildstorageequiplist (sd, gstor);
clif_updateguildstorageamount (sd, gstor);
}
return 0;
}
开发者ID:Cloudxtreme，项目名称:tmwa，代码行数:63，代码来源:intif.cpp
示例16: mapif_parse_WisRequest
// Wisp/page request to send
int mapif_parse_WisRequest(int fd) {
struct WisData* wd;
static int wisid = 0;
char name[NAME_LENGTH], t_name[NAME_LENGTH*2]; //Needs space to allocate names with escaped chars [Skotlex]
if ( fd <= 0 ) {return 0;} // check if we have a valid fd
if (RFIFOW(fd,2)-52 >= sizeof(wd->msg)) {
ShowWarning("inter: Wis message size too long.\n");
return 0;
} else if (RFIFOW(fd,2)-52 <= 0) { // normaly, impossible, but who knows...
ShowError("inter: Wis message doesn't exist.\n");
return 0;
}
memcpy(name, RFIFOP(fd,28), NAME_LENGTH); //Received name may be too large and not contain \0! [Skotlex]
name[NAME_LENGTH-1]= '\0';
sprintf (tmp_sql, "SELECT `name` FROM `%s` WHERE `name`='%s'",
char_db, jstrescapecpy(t_name, name));
if(mysql_query(&mysql_handle, tmp_sql) ) {
ShowSQL("DB error - %s\n",mysql_error(&mysql_handle));
ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql);
}
sql_res = mysql_store_result(&mysql_handle);
// search if character exists before to ask all map-servers
if (!(sql_row = mysql_fetch_row(sql_res))) {
unsigned char buf[27];
WBUFW(buf, 0) = 0x3802;
memcpy(WBUFP(buf, 2), RFIFOP(fd, 4), NAME_LENGTH);
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(name, 0, NAME_LENGTH);
strncpy(name, sql_row[0], NAME_LENGTH);
// if source is destination, don't ask other servers.
if (strcmp((char*)RFIFOP(fd,4),name) == 0) {
unsigned char buf[27];
WBUFW(buf, 0) = 0x3802;
memcpy(WBUFP(buf, 2), RFIFOP(fd, 4), NAME_LENGTH);
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), NAME_LENGTH);
memcpy(wd->dst, RFIFOP(fd,28), NAME_LENGTH);
memcpy(wd->msg, RFIFOP(fd,52), wd->len);
wd->tick = gettick();
numdb_insert(wis_db, wd->id, wd);
mapif_wis_message(wd);
}
}
//Freeing ... O.o
if(sql_res){
mysql_free_result(sql_res);
}
return 0;
}
开发者ID:AxlSckay，项目名称:Ragnarok-OldTimes，代码行数:71，代码来源:inter.c
示例17: intif_parse
//-----------------------------------------------------------------
// inter serverからの通信
// エラーがあれば0(false)を返すこと
// パケットが処理できれば1,パケット長が足りなければ2を返すこと
int intif_parse (int fd)
{
int packet_len;
int cmd = RFIFOW (fd, 0);
// パケットのID確認
if (cmd < 0x3800
|| cmd >=
0x3800 + (sizeof (packet_len_table) / sizeof (packet_len_table[0]))
|| packet_len_table[cmd - 0x3800] == 0)
{
return 0;
}
// パケットの長さ確認
packet_len = packet_len_table[cmd - 0x3800];
if (packet_len == -1)
{
if (RFIFOREST (fd) < 4)
return 2;
packet_len = RFIFOW (fd, 2);
}
// if(battle_config.etc_log)
// printf("intif_parse %d %x %d %d\n",fd,cmd,packet_len,RFIFOREST(fd));
if (RFIFOREST (fd) < packet_len)
{
return 2;
}
// 処理分岐
switch (cmd)
{
case 0x3800:
clif_GMmessage (NULL, (const char *)RFIFOP (fd, 4), packet_len - 4, 0);
break;
case 0x3801:
intif_parse_WisMessage (fd);
break;
case 0x3802:
intif_parse_WisEnd (fd);
break;
case 0x3803:
mapif_parse_WisToGM (fd);
break;
case 0x3804:
intif_parse_AccountReg (fd);
break;
case 0x3810:
intif_parse_LoadStorage (fd);
break;
case 0x3811:
intif_parse_SaveStorage (fd);
break;
case 0x3818:
intif_parse_LoadGuildStorage (fd);
break;
case 0x3819:
intif_parse_SaveGuildStorage (fd);
break;
case 0x3820:
intif_parse_PartyCreated (fd);
break;
case 0x3821:
intif_parse_PartyInfo (fd);
break;
case 0x3822:
intif_parse_PartyMemberAdded (fd);
break;
case 0x3823:
intif_parse_PartyOptionChanged (fd);
break;
case 0x3824:
intif_parse_PartyMemberLeaved (fd);
break;
case 0x3825:
intif_parse_PartyMove (fd);
break;
case 0x3826:
intif_parse_PartyBroken (fd);
break;
case 0x3827:
intif_parse_PartyMessage (fd);
break;
case 0x3830:
intif_parse_GuildCreated (fd);
break;
case 0x3831:
intif_parse_GuildInfo (fd);
break;
case 0x3832:
intif_parse_GuildMemberAdded (fd);
break;
case 0x3834:
intif_parse_GuildMemberLeaved (fd);
break;
case 0x3835:
intif_parse_GuildMemberInfoShort (fd);
break;
case 0x3836:
//.........这里部分代码省略.........
开发者ID:Cloudxtreme，项目名称:tmwa，代码行数:101，代码来源:intif.cpp
示例18: mapif_parse_GMmessage
// GM message sending
int mapif_parse_GMmessage(int fd)
{
mapif_GMmessage(RFIFOP(fd, 8), RFIFOW(fd, 2), RFIFOL(fd, 4), fd);
return 0;
}
开发者ID:AxlSckay，项目名称:Ragnarok-OldTimes，代码行数:6，代码来源:inter.c
示例19: chrif_authok
/*==========================================
* Auth confirmation ack
*------------------------------------------*/
void chrif_authok(int fd) {
int account_id, group_id, char_id;
uint32 login_id1,login_id2;
time_t expiration_time;
struct mmo_charstatus* status;
struct auth_node *node;
bool changing_mapservers;
TBL_PC* sd;
//Check if both servers agree on the struct's size
if( RFIFOW(fd,2) - 25 != sizeof(struct mmo_charstatus) ) {
ShowError("chrif_authok: Data size mismatch! %d != %d\n", RFIFOW(fd,2) - 25, sizeof(struct mmo_charstatus));
return;
}
account_id = RFIFOL(fd,4);
login_id1 = RFIFOL(fd,8);
login_id2 = RFIFOL(fd,12);
expiration_time = (time_t)(int32)RFIFOL(fd,16);
group_id = RFIFOL(fd,20);
changing_mapservers = (RFIFOB(fd,24));
status = (struct mmo_charstatus*)RFIFOP(fd,25);
char_id = status->char_id;
//Check if we don't already have player data in our server
//Causes problems if the currently connected player tries to quit or this data belongs to an already connected player which is trying to re-auth.
if ( ( sd = map_id2sd(account_id) ) != NULL )
return;
if ( ( node = chrif_search(account_id) ) == NULL )
return; // should not happen
if ( node->state != ST_LOGIN )
return; //character in logout phase, do not touch that data.
if ( node->sd == NULL ) {
/*
//When we receive double login info and the client has not connected yet,
//discard the older one and keep the new one.
chrif_auth_delete(node->account_id, node->char_id, ST_LOGIN);
*/
return; // should not happen
}
sd = node->sd;
if( runflag == MAPSERVER_ST_RUNNING &&
node->char_dat == NULL &&
node->account_id == account_id &&
node->char_id == char_id &&
node->login_id1 == login_id1 )
{ //Auth Ok
if (pc_authok(sd, login_id2, expiration_time, group_id, status, changing_mapservers))
return;
} else { //Auth Failed
pc_authfail(sd);
}
chrif_char_offline(sd); //Set him offline, the char server likely has it set as online already.
chrif_auth_delete(account_id, char_id, ST_LOGIN);
}
开发者ID:Shaktoh，项目名称:Hercules，代码行数:64，代码来源:chrif.c
示例20: chrif_parse
/*==========================================
*
*------------------------------------------*/
int chrif_parse(int fd) {
int packet_len, cmd;
// only process data from the char-server
if ( fd != char_fd ) {
ShowDebug("chrif_parse: Disconnecting invalid session #%d (is not the char-server)\n", fd);
do_close(fd);
return 0;
}
if ( session[fd]->flag.eof ) {
do_close(fd);
char_fd = -1;
chrif_on_disconnect();
return 0;
} else if ( session[fd]->flag.ping ) {/* we've reached stall time */
if( DIFF_TICK(last_tick, session[fd]->rdata_tick) > (stall_time * 2) ) {/* we can't wait any longer */
set_eof(fd);
return 0;
} else if( session[fd]->flag.ping != 2 ) { /* we haven't sent ping out yet */
chrif_keepalive(fd);
session[fd]->flag.ping = 2;
}
}
while ( RFIFOREST(fd) >= 2 ) {
cmd = RFIFOW(fd,0);
if (cmd < 0x2af8 || cmd >= 0x2af8 + ARRAYLENGTH(packet_len_table) || packet_len_table[cmd-0x2af8] == 0) {
int r = intif_parse(fd); // Passed on to the intif
if (r == 1) continue; // Treated in intif
if (r == 2) return 0; // Didn't have enough data (len==-1)
ShowWarning("chrif_parse: session #%d, intif_parse failed (unrecognized command 0x%.4x).\n", fd, cmd);
set_eof(fd);
return 0;
}
if ( ( packet_len = packet_len_table[cmd-0x2af8] ) == -1) { // dynamic-length packet, second WORD holds the length
if (RFIFOREST(fd) < 4)
return 0;
packet_len = RFIFOW(fd,2);
}
if ((int)RFIFOREST(fd) < packet_len)
return 0;
//ShowDebug("Received packet 0x%4x (%d bytes) from char-server (connection %d)\n", RFIFOW(fd,0), packet_len, fd);
switch(cmd) {
case 0x2af9: chrif_connectack(fd); break;
case 0x2afb: chrif_sendmapack(fd); break;
case 0x2afd: chrif_authok(fd); break;
case 0x2b00: map_setusers(RFIFOL(fd,2)); chrif_keepalive(fd); break;
case 0x2b03: clif->charselectok(RFIFOL(fd,2), RFIFOB(fd,6)); break;
case 0x2b04: chrif_recvmap(fd); break;
case 0x2b06: chrif_changemapserverack(RFIFOL(fd,2), RFIFOL(fd,6), RFIFOL(fd,10), RFIFOL(fd,14), RFIFOW(fd,18), RFIFOW(fd,20), RFIFOW(fd,22), RFIFOL(fd,24), RFIFOW(fd,28)); break;
case 0x2b09: map_addnickdb(RFIFOL(fd,2), (char*)RFIFOP(fd,6)); break;
case 0x2b0a: socket_datasync(fd, false); break;
case 0x2b0d: chrif_changedsex(fd); break;
case 0x2b0f: chrif_char_ask_name_answer(RFIFOL(fd,2), (char*)RFIFOP(fd,6), RFIFOW(fd,30), RFIFOW(fd,32)); break;
case 0x2b12: chrif_divorceack(RFIFOL(fd,2), RFIFOL(fd,6)); break;
case 0x2b14: chrif_accountban(fd); break;
case 0x2b1b: chrif_recvfamelist(fd); break;
case 0x2b1d: chrif_load_scdata(fd); break;
case 0x2b1e: chrif_update_ip(fd); break;
case 0x2b1f: chrif_disconnectplayer(fd); break;
case 0x2b20: chrif_removemap(fd); break;
case 0x2b21: chrif_save_ack(fd); break;
case 0x2b22: chrif_updatefamelist_ack(fd); break;
case 0x2b24: chrif_keepalive_ack(fd); break;
case 0x2b25: chrif_deadopt(RFIFOL(fd,2), RFIFOL(fd,6), RFIFOL(fd,10)); break;
case 0x2b27: chrif_authfail(fd); break;
default:
ShowError("chrif_parse : unknown packet (session #%d): 0x%x. Disconnecting.\n", fd, cmd);
set_eof(fd);
return 0;
}
if ( fd == char_fd ) //There's the slight chance we lost the connection during parse, in which case this would segfault if not checked [Skotlex]
RFIFOSKIP(fd, packet_len);
}
return 0;
}
开发者ID:Shaktoh，项目名称:Hercules，代码行数:87，代码来源:chrif.c
注：本文中的RFIFOP函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论