1 files changed, 60 insertions, 0 deletions
diff --git a/src/game-server/accountconnection.hpp b/src/game-server/accountconnection.hpp
index 2c63e17c..22c422a7 100644
--- a/src/game-server/accountconnection.hpp
+++ b/src/game-server/accountconnection.hpp
@@ -22,16 +22,39 @@
 #ifndef _TMW_ACCOUNTCONNECTION_H_
 #define _TMW_ACCOUNTCONNECTION_H_
 
+#include "net/messageout.hpp"
 #include "net/connection.hpp"
 
 class Character;
 
+/** \fn void AccountConnection::syncChanges(bool force = false)
+ *
+ *  The gameserver holds a buffer with all changes made by a character. The
+ *  changes are added at the time they occur. When the buffer reaches one of
+ *  the following limits, the buffer is sent to the account server and applied
+ *  to the database.
+ *
+ *  The sync buffer is sent when:
+ *  - forced by any process (param force = true)
+ *  - every 10 seconds
+ *  - buffer reaches size of 1kb (defined in #SYNC_BUFFER_SIZE)
+ *  - buffer holds more then 20 messages (defined in #SYNC_BUFFER_LIMIT)
+ */
+#define SYNC_BUFFER_SIZE    1024   /**< maximum size of sync buffer in bytes. */
+#define SYNC_BUFFER_LIMIT     20   /**< maximum number of messages in sync buffer. */
+
 /**
  * A connection to the account server.
  */
 class AccountConnection : public Connection
 {
     public:
+
+        /**
+        * Destructor
+        */
+        ~AccountConnection();
+
         /**
          * Initializes a connection to the account server described in the
          * configuration file. Registers the maps known by MapManager.
@@ -84,12 +107,49 @@ class AccountConnection : public Connection
          */
         void changeAccountLevel(Character *, int);
 
+        /**
+         * Sends all changed player data to the account server to minimize
+         * dataloss due to failure of one server component.
+         *
+         * @param force Send changes even if buffer hasn't reached its size
+         *              or message limit. (used to send in timed schedules)
+         */
+        void syncChanges(bool force = false);
+
+        /**
+         * Write a modification message about character points to the sync buffer.
+         *
+         * @param CharId      ID of the character
+         * @param CharPoints  Number of character points left for the character
+         * @param CorrPoints  Number of correction points left for the character
+         * @param AttribId    ID of the modified attribute
+         * @param AttribValue New value of the modified attribute
+         */
+        void updateCharacterPoints(const int CharId, const int CharPoints,
+                                   const int CorrPoints, const int AttribId,
+                                   const int AttribValue);
+
+
+        /**
+         * Write a modification message about character skills to the sync buffer.
+         * @param CharId      ID of the character
+         * @param SkillId     ID of the skill
+         * @param SkillValue  new skill points
+         */
+        void updateExperience(const int CharId, const int SkillId,
+                              const int SkillValue);
+
     protected:
         /**
          * Processes server messages.
          */
         virtual void processMessage(MessageIn &);
 
+    private:
+
+        MessageOut* mSyncBuffer;     /**< Message buffer to store sync data. */
+        int mSyncMessages;           /**< Number of messages in the sync buffer. */
+
 };
 
 extern AccountConnection *accountHandler;