summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorrubidium <rubidium@openttd.org>2010-12-05 14:41:34 +0000
committerrubidium <rubidium@openttd.org>2010-12-05 14:41:34 +0000
commit085c693289a9e132c53145997a91f28d2aa35c58 (patch)
treec9987ccd7aa06923c50cec7a3adfc7acd3410df0 /src
parent5ff58155d1106fb6169cbcd7ee8da5b915f91e4e (diff)
downloadopenttd-085c693289a9e132c53145997a91f28d2aa35c58.tar.xz
(svn r21395) -Codechange: move the save and load filter's interface to a header
Diffstat (limited to 'src')
-rw-r--r--src/saveload/saveload.cpp127
-rw-r--r--src/saveload/saveload.h2
-rw-r--r--src/saveload/saveload_filter.h107
3 files changed, 143 insertions, 93 deletions
diff --git a/src/saveload/saveload.cpp b/src/saveload/saveload.cpp
index 635d05072..d196dd3fd 100644
--- a/src/saveload/saveload.cpp
+++ b/src/saveload/saveload.cpp
@@ -46,6 +46,7 @@
#include "table/strings.h"
#include "saveload_internal.h"
+#include "saveload_filter.h"
/*
* Previous savegame versions, the trunk revision where they were
@@ -246,43 +247,6 @@ enum NeedLength {
/** Save in chunks of 128 KiB. */
static const size_t MEMORY_CHUNK_SIZE = 128 * 1024;
-/** Interface for filtering a savegame till it is loaded. */
-struct LoadFilter {
- /** Chained to the (savegame) filters. */
- LoadFilter *chain;
-
- /**
- * Initialise this filter.
- * @param chain The next filter in this chain.
- */
- LoadFilter(LoadFilter *chain) : chain(chain)
- {
- }
-
- /** Make sure the writers are properly closed. */
- virtual ~LoadFilter()
- {
- delete this->chain;
- }
-
- /**
- * Read a given number of bytes from the savegame.
- * @param buf The bytes to read.
- * @param len The number of bytes to read.
- * @return The number of actually read bytes.
- */
- virtual size_t Read(byte *buf, size_t len) = 0;
-
- /**
- * Reset this filter to read from the beginning of the file.
- */
- virtual void Reset()
- {
- this->chain->Reset();
- }
-};
-
-
/** A buffer for reading (and buffering) savegame data. */
struct ReadBuffer {
byte buf[MEMORY_CHUNK_SIZE]; ///< Buffer we're going to read from.
@@ -324,62 +288,6 @@ struct ReadBuffer {
};
-/**
- * Instantiator for a load filter.
- * @param chain The next filter in this chain.
- * @tparam T The type of load filter to create.
- */
-template <typename T> LoadFilter *CreateLoadFilter(LoadFilter *chain)
-{
- return new T(chain);
-}
-
-/** Interface for filtering a savegame till it is written. */
-struct SaveFilter {
- /** Chained to the (savegame) filters. */
- SaveFilter *chain;
-
- /**
- * Initialise this filter.
- * @param chain The next filter in this chain.
- */
- SaveFilter(SaveFilter *chain) : chain(chain)
- {
- }
-
- /** Make sure the writers are properly closed. */
- virtual ~SaveFilter()
- {
- delete this->chain;
- }
-
- /**
- * Write a given number of bytes into the savegame.
- * @param buf The bytes to write.
- * @param len The number of bytes to write.
- */
- virtual void Write(byte *buf, size_t len) = 0;
-
- /**
- * Prepare everything to finish writing the savegame.
- */
- virtual void Finish()
- {
- if (this->chain != NULL) this->chain->Finish();
- }
-};
-
-/**
- * Instantiator for a save filter.
- * @param chain The next filter in this chain.
- * @param compression_level The requested level of compression.
- * @tparam T The type of save filter to create.
- */
-template <typename T> SaveFilter *CreateSaveFilter(SaveFilter *chain, byte compression_level)
-{
- return new T(chain, compression_level);
-}
-
/** Container for dumping the savegame (quickly) to memory. */
struct MemoryDumper {
AutoFreeSmallVector<byte *, 16> blocks; ///< Buffer with blocks of allocated memory.
@@ -2518,6 +2426,23 @@ static SaveOrLoadResult DoSave(SaveFilter *writer, bool threaded)
}
/**
+ * Save the game using a (writer) filter.
+ * @param writer The filter to write the savegame to.
+ * @param threaded Whether to try to perform the saving asynchroniously.
+ * @return Return the result of the action. #SL_OK or #SL_ERROR
+ */
+SaveOrLoadResult SaveWithFilter(SaveFilter *writer, bool threaded)
+{
+ try {
+ _sl.action = SLA_SAVE;
+ return DoSave(writer, threaded);
+ } catch (...) {
+ ClearSaveLoadState();
+ return SL_ERROR;
+ }
+}
+
+/**
* Actually perform the loading of a "non-old" savegame.
* @param reader The filter to read the savegame from.
* @param load_check Whether to perform the checking ("preview") or actually load the game.
@@ -2660,6 +2585,22 @@ static SaveOrLoadResult DoLoad(LoadFilter *reader, bool load_check)
}
/**
+ * Load the game using a (reader) filter.
+ * @param reader The filter to read the savegame from.
+ * @return Return the result of the action. #SL_OK or #SL_REINIT ("unload" the game)
+ */
+SaveOrLoadResult LoadWithFilter(LoadFilter *reader)
+{
+ try {
+ _sl.action = SLA_LOAD;
+ return DoLoad(reader, false);
+ } catch (...) {
+ ClearSaveLoadState();
+ return SL_REINIT;
+ }
+}
+
+/**
* Main Save or Load function where the high-level saveload functions are
* handled. It opens the savegame, selects format and checks versions
* @param filename The name of the savegame being created/loaded
diff --git a/src/saveload/saveload.h b/src/saveload/saveload.h
index ddf6b6dc5..f9d191467 100644
--- a/src/saveload/saveload.h
+++ b/src/saveload/saveload.h
@@ -55,6 +55,8 @@ SaveOrLoadResult SaveOrLoad(const char *filename, int mode, Subdirectory sb, boo
void WaitTillSaved();
void DoExitSave();
+SaveOrLoadResult SaveWithFilter(struct SaveFilter *writer, bool threaded);
+SaveOrLoadResult LoadWithFilter(struct LoadFilter *reader);
typedef void ChunkSaveLoadProc();
typedef void AutolengthProc(void *arg);
diff --git a/src/saveload/saveload_filter.h b/src/saveload/saveload_filter.h
new file mode 100644
index 000000000..0cb5c8695
--- /dev/null
+++ b/src/saveload/saveload_filter.h
@@ -0,0 +1,107 @@
+/* $Id$ */
+
+/*
+ * This file is part of OpenTTD.
+ * OpenTTD is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, version 2.
+ * OpenTTD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+ * See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with OpenTTD. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+/** @file saveload_filter.h Declaration of filters used for saving and loading savegames. */
+
+#ifndef SAVELOAD_FILTER_H
+#define SAVELOAD_FILTER_H
+
+/** Interface for filtering a savegame till it is loaded. */
+struct LoadFilter {
+ /** Chained to the (savegame) filters. */
+ LoadFilter *chain;
+
+ /**
+ * Initialise this filter.
+ * @param chain The next filter in this chain.
+ */
+ LoadFilter(LoadFilter *chain) : chain(chain)
+ {
+ }
+
+ /** Make sure the writers are properly closed. */
+ virtual ~LoadFilter()
+ {
+ delete this->chain;
+ }
+
+ /**
+ * Read a given number of bytes from the savegame.
+ * @param buf The bytes to read.
+ * @param len The number of bytes to read.
+ * @return The number of actually read bytes.
+ */
+ virtual size_t Read(byte *buf, size_t len) = 0;
+
+ /**
+ * Reset this filter to read from the beginning of the file.
+ */
+ virtual void Reset()
+ {
+ this->chain->Reset();
+ }
+};
+
+/**
+ * Instantiator for a load filter.
+ * @param chain The next filter in this chain.
+ * @tparam T The type of load filter to create.
+ */
+template <typename T> LoadFilter *CreateLoadFilter(LoadFilter *chain)
+{
+ return new T(chain);
+}
+
+/** Interface for filtering a savegame till it is written. */
+struct SaveFilter {
+ /** Chained to the (savegame) filters. */
+ SaveFilter *chain;
+
+ /**
+ * Initialise this filter.
+ * @param chain The next filter in this chain.
+ */
+ SaveFilter(SaveFilter *chain) : chain(chain)
+ {
+ }
+
+ /** Make sure the writers are properly closed. */
+ virtual ~SaveFilter()
+ {
+ delete this->chain;
+ }
+
+ /**
+ * Write a given number of bytes into the savegame.
+ * @param buf The bytes to write.
+ * @param len The number of bytes to write.
+ */
+ virtual void Write(byte *buf, size_t len) = 0;
+
+ /**
+ * Prepare everything to finish writing the savegame.
+ */
+ virtual void Finish()
+ {
+ if (this->chain != NULL) this->chain->Finish();
+ }
+};
+
+/**
+ * Instantiator for a save filter.
+ * @param chain The next filter in this chain.
+ * @param compression_level The requested level of compression.
+ * @tparam T The type of save filter to create.
+ */
+template <typename T> SaveFilter *CreateSaveFilter(SaveFilter *chain, byte compression_level)
+{
+ return new T(chain, compression_level);
+}
+
+#endif /* SAVELOAD_FILTER_H */