summaryrefslogtreecommitdiff
path: root/storage/ndb/src/old_files/newtonapi/dba_process.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'storage/ndb/src/old_files/newtonapi/dba_process.cpp')
-rw-r--r--storage/ndb/src/old_files/newtonapi/dba_process.cpp123
1 files changed, 0 insertions, 123 deletions
diff --git a/storage/ndb/src/old_files/newtonapi/dba_process.cpp b/storage/ndb/src/old_files/newtonapi/dba_process.cpp
deleted file mode 100644
index ddb6e62f180..00000000000
--- a/storage/ndb/src/old_files/newtonapi/dba_process.cpp
+++ /dev/null
@@ -1,123 +0,0 @@
-/* Copyright (C) 2003 MySQL AB
-
- This program 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; either version 2 of the License, or
- (at your option) any later version.
-
- This program 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 this program; if not, write to the Free Software
- Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
-
-
-#include "dba_process.hpp"
-
-NewtonBatchProcess::NewtonBatchProcess(Ndb & ndb, NdbMutex & mutex) :
- theNdb(ndb),
- theMutex(mutex)
-{
- theThread = 0;
- startStopMutex = NdbMutex_Create();
-
- _running = false;
- _stop = false;
-}
-
-NewtonBatchProcess::~NewtonBatchProcess(){
- doStop(true);
-
- if(theThread != 0)
- NdbThread_Destroy(&theThread);
-
- if(startStopMutex != 0)
- NdbMutex_Destroy(startStopMutex);
- startStopMutex = 0;
-}
-
-extern "C"
-void*
-runNDB_C(void * _nbp){
- NewtonBatchProcess * nbp = (NewtonBatchProcess*)_nbp;
- nbp->_running = true;
- nbp->run();
- nbp->_running = false;
-
- /**
- * This sleep is to make sure that the transporter
- * send thread will come in and send any
- * signal buffers that this thread may have allocated.
- * If that doesn't happen an error will occur in OSE
- * when trying to restore a signal buffer allocated by a thread
- * that have been killed.
- */
- NdbSleep_MilliSleep(50);
- NdbThread_Exit(0);
- return 0;
-}
-
-void
-NewtonBatchProcess::doStart(){
- NdbMutex_Lock(startStopMutex);
- if(_running && !_stop){
- NdbMutex_Unlock(startStopMutex);
- return ;
- }
-
- while(_running){
- NdbMutex_Unlock(startStopMutex);
- NdbSleep_MilliSleep(200);
- NdbMutex_Lock(startStopMutex);
- }
-
- require(!_running);
- _stop = false;
-
- if(theThread != 0)
- NdbThread_Destroy(&theThread);
-
- theThread = NdbThread_Create(runNDB_C,
- (void**)this,
- 65535,
- "Newton_BP",
- NDB_THREAD_PRIO_LOWEST);
-
- NdbMutex_Unlock(startStopMutex);
-}
-
-void
-NewtonBatchProcess::doStop(bool wait){
- NdbMutex_Lock(startStopMutex);
- _stop = true;
-
- if(wait){
- while(_running){
- NdbSleep_MilliSleep(200);
- }
- }
- NdbMutex_Unlock(startStopMutex);
-}
-
-bool
-NewtonBatchProcess::isRunning() const {
- return _running;
-}
-
-bool
-NewtonBatchProcess::isStopping() const {
- return _stop;
-}
-
-void
-NewtonBatchProcess::run(){
- while(!_stop){
- NdbMutex_Lock(&theMutex);
- theNdb.sendPollNdb(0, 1, DBA__NBP_Force);
- NdbMutex_Unlock(&theMutex);
- NdbSleep_MilliSleep(DBA__NBP_Intervall);
- }
-}