mirror of
https://github.com/mangosfour/server.git
synced 2025-12-16 22:37:02 +00:00
[6882] Make corpse erase async.
This commit is contained in:
parent
4df03b8561
commit
e81af0b739
2 changed files with 42 additions and 39 deletions
|
|
@ -29,15 +29,11 @@
|
||||||
#include "ObjectDefines.h"
|
#include "ObjectDefines.h"
|
||||||
#include "Corpse.h"
|
#include "Corpse.h"
|
||||||
|
|
||||||
/// Handle periodic erase of corpses and bones
|
static void CorpsesEraseCallBack(QueryResult *result, bool bones)
|
||||||
static void CorpsesErase(bool bones,uint32 delay)
|
|
||||||
{
|
{
|
||||||
///- Get the list of eligible corpses/bones to be removed
|
if(!result)
|
||||||
//No SQL injection (uint32 and enum)
|
return;
|
||||||
QueryResult *result = CharacterDatabase.PQuery("SELECT guid,position_x,position_y,map,player FROM corpse WHERE UNIX_TIMESTAMP()-time > '%u' AND corpse_type %s '0'", delay, (bones ? "=" : "<>") );
|
|
||||||
|
|
||||||
if(result)
|
|
||||||
{
|
|
||||||
do
|
do
|
||||||
{
|
{
|
||||||
Field *fields = result->Fetch();
|
Field *fields = result->Fetch();
|
||||||
|
|
@ -71,7 +67,14 @@ static void CorpsesErase(bool bones,uint32 delay)
|
||||||
} while (result->NextRow());
|
} while (result->NextRow());
|
||||||
|
|
||||||
delete result;
|
delete result;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Handle periodic erase of corpses and bones
|
||||||
|
static void CorpsesErase(bool bones,uint32 delay)
|
||||||
|
{
|
||||||
|
///- Get the list of eligible corpses/bones to be removed
|
||||||
|
//No SQL injection (uint32 and enum)
|
||||||
|
CharacterDatabase.AsyncPQuery(&CorpsesEraseCallBack, bones, "SELECT guid,position_x,position_y,map,player FROM corpse WHERE UNIX_TIMESTAMP()-time > '%u' AND corpse_type %s '0'", delay, (bones ? "=" : "<>"));
|
||||||
}
|
}
|
||||||
|
|
||||||
/// not thread guarded variant for call from other thread
|
/// not thread guarded variant for call from other thread
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
#ifndef __REVISION_NR_H__
|
#ifndef __REVISION_NR_H__
|
||||||
#define __REVISION_NR_H__
|
#define __REVISION_NR_H__
|
||||||
#define REVISION_NR "6881"
|
#define REVISION_NR "6882"
|
||||||
#endif // __REVISION_NR_H__
|
#endif // __REVISION_NR_H__
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue