Commit 54555e91 authored by mercury233's avatar mercury233

define replay_mode constant

parent 9e00a5b1
...@@ -23,7 +23,7 @@ Replay::~Replay() { ...@@ -23,7 +23,7 @@ Replay::~Replay() {
} }
void Replay::BeginRecord() { void Replay::BeginRecord() {
#ifdef YGOPRO_SERVER_MODE #ifdef YGOPRO_SERVER_MODE
if(replay_mode & 0x1) { if(replay_mode & REPLAY_MODE_SAVE_IN_SERVER) {
#endif #endif
if(!FileSystem::IsDirExists(L"./replay") && !FileSystem::MakeDir(L"./replay")) if(!FileSystem::IsDirExists(L"./replay") && !FileSystem::MakeDir(L"./replay"))
return; return;
...@@ -72,7 +72,7 @@ void Replay::BeginRecord() { ...@@ -72,7 +72,7 @@ void Replay::BeginRecord() {
void Replay::WriteHeader(ReplayHeader& header) { void Replay::WriteHeader(ReplayHeader& header) {
pheader = header; pheader = header;
#ifdef YGOPRO_SERVER_MODE #ifdef YGOPRO_SERVER_MODE
if(!(replay_mode & 0x1)) return; if(!(replay_mode & REPLAY_MODE_SAVE_IN_SERVER)) return;
#endif #endif
#ifdef _WIN32 #ifdef _WIN32
DWORD size; DWORD size;
...@@ -90,7 +90,7 @@ void Replay::WriteData(const void* data, int length, bool flush) { ...@@ -90,7 +90,7 @@ void Replay::WriteData(const void* data, int length, bool flush) {
memcpy(pdata, data, length); memcpy(pdata, data, length);
pdata += length; pdata += length;
#ifdef YGOPRO_SERVER_MODE #ifdef YGOPRO_SERVER_MODE
if(!(replay_mode & 0x1)) return; if(!(replay_mode & REPLAY_MODE_SAVE_IN_SERVER)) return;
#endif #endif
#ifdef _WIN32 #ifdef _WIN32
DWORD size; DWORD size;
...@@ -109,7 +109,7 @@ void Replay::WriteInt32(int data, bool flush) { ...@@ -109,7 +109,7 @@ void Replay::WriteInt32(int data, bool flush) {
*((int*)(pdata)) = data; *((int*)(pdata)) = data;
pdata += 4; pdata += 4;
#ifdef YGOPRO_SERVER_MODE #ifdef YGOPRO_SERVER_MODE
if(!(replay_mode & 0x1)) return; if(!(replay_mode & REPLAY_MODE_SAVE_IN_SERVER)) return;
#endif #endif
#ifdef _WIN32 #ifdef _WIN32
DWORD size; DWORD size;
...@@ -128,7 +128,7 @@ void Replay::WriteInt16(short data, bool flush) { ...@@ -128,7 +128,7 @@ void Replay::WriteInt16(short data, bool flush) {
*((short*)(pdata)) = data; *((short*)(pdata)) = data;
pdata += 2; pdata += 2;
#ifdef YGOPRO_SERVER_MODE #ifdef YGOPRO_SERVER_MODE
if(!(replay_mode & 0x1)) return; if(!(replay_mode & REPLAY_MODE_SAVE_IN_SERVER)) return;
#endif #endif
#ifdef _WIN32 #ifdef _WIN32
DWORD size; DWORD size;
...@@ -147,7 +147,7 @@ void Replay::WriteInt8(char data, bool flush) { ...@@ -147,7 +147,7 @@ void Replay::WriteInt8(char data, bool flush) {
*pdata = data; *pdata = data;
pdata++; pdata++;
#ifdef YGOPRO_SERVER_MODE #ifdef YGOPRO_SERVER_MODE
if(!(replay_mode & 0x1)) return; if(!(replay_mode & REPLAY_MODE_SAVE_IN_SERVER)) return;
#endif #endif
#ifdef _WIN32 #ifdef _WIN32
DWORD size; DWORD size;
...@@ -162,7 +162,7 @@ void Replay::Flush() { ...@@ -162,7 +162,7 @@ void Replay::Flush() {
if(!is_recording) if(!is_recording)
return; return;
#ifdef YGOPRO_SERVER_MODE #ifdef YGOPRO_SERVER_MODE
if(!(replay_mode & 0x1)) return; if(!(replay_mode & REPLAY_MODE_SAVE_IN_SERVER)) return;
#endif #endif
#ifdef _WIN32 #ifdef _WIN32
#else #else
...@@ -173,7 +173,7 @@ void Replay::EndRecord() { ...@@ -173,7 +173,7 @@ void Replay::EndRecord() {
if(!is_recording) if(!is_recording)
return; return;
#ifdef YGOPRO_SERVER_MODE #ifdef YGOPRO_SERVER_MODE
if(replay_mode & 0x1) { if(replay_mode & REPLAY_MODE_SAVE_IN_SERVER) {
#endif #endif
#ifdef _WIN32 #ifdef _WIN32
CloseHandle(recording_fp); CloseHandle(recording_fp);
......
...@@ -17,6 +17,11 @@ namespace ygo { ...@@ -17,6 +17,11 @@ namespace ygo {
#define MAX_REPLAY_SIZE 0x20000 #define MAX_REPLAY_SIZE 0x20000
#define MAX_COMP_SIZE 0x2000 #define MAX_COMP_SIZE 0x2000
#ifdef YGOPRO_SERVER_MODE
#define REPLAY_MODE_SAVE_IN_SERVER 0x1
#define REPLAY_MODE_WATCHER_NO_SEND 0x2
#endif // YGOPRO_SERVER_MODE
struct ReplayHeader { struct ReplayHeader {
unsigned int id; unsigned int id;
unsigned int version; unsigned int version;
......
...@@ -1798,7 +1798,7 @@ void SingleDuel::EndDuel() { ...@@ -1798,7 +1798,7 @@ void SingleDuel::EndDuel() {
NetServer::SendBufferToPlayer(players[0], STOC_REPLAY, replaybuf, sizeof(ReplayHeader) + last_replay.comp_size); NetServer::SendBufferToPlayer(players[0], STOC_REPLAY, replaybuf, sizeof(ReplayHeader) + last_replay.comp_size);
NetServer::ReSendToPlayer(players[1]); NetServer::ReSendToPlayer(players[1]);
#ifdef YGOPRO_SERVER_MODE #ifdef YGOPRO_SERVER_MODE
if(!(replay_mode & 0x2)) { if(!(replay_mode & REPLAY_MODE_WATCHER_NO_SEND)) {
for(auto oit = observers.begin(); oit != observers.end(); ++oit) for(auto oit = observers.begin(); oit != observers.end(); ++oit)
NetServer::ReSendToPlayer(*oit); NetServer::ReSendToPlayer(*oit);
NetServer::ReSendToPlayers(cache_recorder, replay_recorder); NetServer::ReSendToPlayers(cache_recorder, replay_recorder);
......
...@@ -1867,7 +1867,7 @@ void TagDuel::EndDuel() { ...@@ -1867,7 +1867,7 @@ void TagDuel::EndDuel() {
NetServer::ReSendToPlayer(players[2]); NetServer::ReSendToPlayer(players[2]);
NetServer::ReSendToPlayer(players[3]); NetServer::ReSendToPlayer(players[3]);
#ifdef YGOPRO_SERVER_MODE #ifdef YGOPRO_SERVER_MODE
if(!(replay_mode & 0x2)) { if(!(replay_mode & REPLAY_MODE_WATCHER_NO_SEND)) {
for(auto oit = observers.begin(); oit != observers.end(); ++oit) for(auto oit = observers.begin(); oit != observers.end(); ++oit)
NetServer::ReSendToPlayer(*oit); NetServer::ReSendToPlayer(*oit);
NetServer::ReSendToPlayers(cache_recorder, replay_recorder); NetServer::ReSendToPlayers(cache_recorder, replay_recorder);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment