aboutsummaryrefslogtreecommitdiff
path: root/src/reader.hh
blob: 7db1ca7010b2e4ba705699636e60358639b2e446 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
#ifndef TIBIA_READER_HH_
#define TIBIA_READER_HH_ 1

#include "common.hh"

struct TPlayerData;

typedef void TRefreshSectorFunction(int SectorX, int SectorY, int SectorZ,
									const uint8 *Data, int Size);
typedef void TSendMailsFunction(TPlayerData *PlayerData);

enum TReaderThreadOrderType: int {
	READER_ORDER_TERMINATE		= 0,
	READER_ORDER_LOADSECTOR		= 1,
	READER_ORDER_LOADCHARACTER	= 2,
};

enum TReaderThreadReplyType: int {
	READER_REPLY_SECTORDATA		= 0,
	READER_REPLY_CHARACTERDATA	= 1,
};

struct TReaderThreadOrder {
	TReaderThreadOrderType OrderType;
	int SectorX;
	int SectorY;
	int SectorZ;
	uint32 CharacterID;
};

struct TReaderThreadReply {
	TReaderThreadReplyType ReplyType;
	int SectorX;
	int SectorY;
	int SectorZ;
	uint8 *Data;
	int Size;
};

void InitReaderBuffers(void);
void InsertOrder(TReaderThreadOrderType OrderType,
		int SectorX, int SectorY, int SectorZ, uint32 CharacterID);
void GetOrder(TReaderThreadOrder *Order);
void TerminateReaderOrder(void);
void LoadSectorOrder(int SectorX, int SectorY, int SectorZ);
void LoadCharacterOrder(uint32 CharacterID);
void ProcessLoadSectorOrder(int SectorX, int SectorY, int SectorZ);
void ProcessLoadCharacterOrder(uint32 CharacterID);
int ReaderThreadLoop(void *Unused);

void InsertReply(TReaderThreadReplyType ReplyType,
		int SectorX, int SectorY, int SectorZ, uint8 *Data, int Size);
bool GetReply(TReaderThreadReply *Reply);
void SectorReply(int SectorX, int SectorY, int SectorZ, uint8 *Data, int Size);
void CharacterReply(uint32 CharacterID);
void ProcessSectorReply(TRefreshSectorFunction *RefreshSector,
		int SectorX, int SectorY, int SectorZ, uint8 *Data, int Size);
void ProcessCharacterReply(TSendMailsFunction *SendMails, uint32 CharacterID);
void ProcessReaderThreadReplies(TRefreshSectorFunction *RefreshSector, TSendMailsFunction *SendMails);

void InitReader(void);
void ExitReader(void);

#endif //TIBIA_READER_HH