OregonCore  revision be9e804-git
Your Favourite TBC server
SqlDelayThread.h
Go to the documentation of this file.
1 /*
2  * This file is part of the OregonCore Project. See AUTHORS file for Copyright information
3  *
4  * This program is free software; you can redistribute it and/or modify it
5  * under the terms of the GNU General Public License as published by the
6  * Free Software Foundation; either version 2 of the License, or (at your
7  * option) any later version.
8  *
9  * This program is distributed in the hope that it will be useful, but WITHOUT
10  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11  * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
12  * more details.
13  *
14  * You should have received a copy of the GNU General Public License along
15  * with this program. If not, see <https://www.gnu.org/licenses/>.
16  */
17 
18 #ifndef __SQLDELAYTHREAD_H
19 #define __SQLDELAYTHREAD_H
20 
21 #include "ace/Thread_Mutex.h"
22 #include "ace/Activation_Queue.h"
23 #include "Threading.h"
24 
25 class Database;
26 class SqlOperation;
27 
29 {
30  typedef ACE_Activation_Queue SqlQueue;
31 
32  private:
33  SqlQueue m_sqlQueue; // Queue of SQL statements
34  Database* m_dbEngine; // Pointer to used Database engine
35  volatile bool m_running;
36 
38  public:
40 
41  // Put sql statement to delay queue
42  bool Delay(SqlOperation* sql);
43 
44  void Stop(); // Stop event
45  void run() override; // Main Thread loop
46 };
47 #endif //__SQLDELAYTHREAD_H
48 
void run() override
Database * m_dbEngine
volatile bool m_running
SqlQueue m_sqlQueue
ACE_Activation_Queue SqlQueue
bool Delay(SqlOperation *sql)