src/main/hashcheckerthread.cpp

   1 /***************************************************************************
   2  *                                                                         *
   3  *   Copyright (C) 2006 David Brodsky                                      *
   4  *                                                                         *
   5  *   This program is free software; you can redistribute it and/or         *
   6  *   modify it under the terms of the GNU General Public License as        *
   7  *   published by the Free Software Foundation and appearing               *
   8  *   in the file LICENSE.GPL included in the packaging of this file.       *
   9  *                                                                         *
  10  *   This program is distributed in the hope that it will be useful,       *
  11  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  12  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU      *
  13  *   General Public License for more details.                              *
  14  *                                                                         *
  15  ***************************************************************************/
  16
  17 #include <tairon/core/mutex.h>
  18
  19 #include "hashcheckerthread.h"
  20
  21 #include "hashchecker.h"
  22
  23 namespace Tairent
  24 {
  25
  26 namespace Main
  27 {
  28
  29 HashCheckerThread *HashCheckerThread::hashCheckerThread = 0;
  30
  31 /* {{{ HashCheckerThread::HashCheckerThread() */
  32 HashCheckerThread::HashCheckerThread() : Tairon::Core::Thread("hash"), exit(false)
  33 {
  34         deletingMutex = new Tairon::Core::Mutex();
  35         hashCheckerThread = this;
  36 }
  37 /* }}} */
  38
  39 /* {{{ HashCheckerThread::~HashCheckerThread() */
  40 HashCheckerThread::~HashCheckerThread()
  41 {
  42         delete deletingMutex;
  43         hashCheckerThread = 0;
  44 }
  45 /* }}} */
  46
  47 /* {{{ HashCheckerThread::addCheckerToDelete(HashChecker *) */
  48 void HashCheckerThread::addCheckerToDelete(HashChecker *checker)
  49 {
  50         deletingMutex->lock();
  51         toDelete.push_back(checker);
  52         deletingMutex->unlock();
  53 }
  54 /* }}} */
  55
  56 /* {{{ HashCheckerThread::run() */
  57 void *HashCheckerThread::run()
  58 {
  59         while (!exit) {
  60                 waitAndCallFunctors(1, 0);
  61                 deletingMutex->lock();
  62                 for (std::list<HashChecker *>::const_iterator it = toDelete.begin(); it != toDelete.end(); ++it)
  63                         delete *it;
  64                 toDelete.clear();
  65                 deletingMutex->unlock();
  66         }
  67
  68         return 0;
  69 }
  70 /* }}} */
  71
  72 }; // namespace Main
  73
  74 }; // namespace Tairent
  75
  76 // vim: ai sw=4 ts=4 noet fdm=marker