aboutsummaryrefslogtreecommitdiff
path: root/src/shared/Database/SqlDelayThread.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/shared/Database/SqlDelayThread.h')
-rw-r--r--src/shared/Database/SqlDelayThread.h8
1 files changed, 0 insertions, 8 deletions
diff --git a/src/shared/Database/SqlDelayThread.h b/src/shared/Database/SqlDelayThread.h
index 3c24d3525b7..422b01ac650 100644
--- a/src/shared/Database/SqlDelayThread.h
+++ b/src/shared/Database/SqlDelayThread.h
@@ -17,34 +17,26 @@
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
-
#ifndef __SQLDELAYTHREAD_H
#define __SQLDELAYTHREAD_H
-
#include "ace/Thread_Mutex.h"
#include "LockedQueue.h"
#include "Threading.h"
-
class Database;
class SqlOperation;
-
class SqlDelayThread : public ACE_Based::Runnable
{
typedef ACE_Based::LockedQueue<SqlOperation*, ACE_Thread_Mutex> SqlQueue;
-
private:
SqlQueue m_sqlQueue; ///< Queue of SQL statements
Database* m_dbEngine; ///< Pointer to used Database engine
volatile bool m_running;
-
SqlDelayThread();
public:
SqlDelayThread(Database* db);
-
///< Put sql statement to delay queue
bool Delay(SqlOperation* sql) { m_sqlQueue.add(sql); return true; }
-
virtual void Stop(); ///< Stop event
virtual void run(); ///< Main Thread loop
};