00001 /* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*- 00002 * vim:expandtab:shiftwidth=2:tabstop=2:smarttab: 00003 * 00004 * Copyright (C) 2011 David Shrewsbury 00005 * 00006 * This program is free software; you can redistribute it and/or modify 00007 * it under the terms of the GNU General Public License as published by 00008 * the Free Software Foundation; either version 2 of the License, or 00009 * (at your option) any later version. 00010 * 00011 * This program is distributed in the hope that it will be useful, 00012 * but WITHOUT ANY WARRANTY; without even the implied warranty of 00013 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 00014 * GNU General Public License for more details. 00015 * 00016 * You should have received a copy of the GNU General Public License 00017 * along with this program; if not, write to the Free Software 00018 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA 00019 */ 00020 00021 #include <config.h> 00022 #include <plugin/slave/queue_thread.h> 00023 #include <drizzled/internal/my_pthread.h> 00024 #include <boost/thread.hpp> 00025 00026 using namespace drizzled; 00027 00028 namespace slave 00029 { 00030 00031 void QueueThread::run(void) 00032 { 00033 boost::posix_time::seconds duration(getSleepInterval()); 00034 00035 /* thread setup needed to do things like create a Session */ 00036 internal::my_thread_init(); 00037 boost::this_thread::at_thread_exit(&internal::my_thread_end); 00038 00039 if (not init()) 00040 return; 00041 00042 while (1) 00043 { 00044 { 00045 /* This uninterruptable block processes the message queue */ 00046 boost::this_thread::disable_interruption di; 00047 00048 if (not process()) 00049 { 00050 shutdown(); 00051 return; 00052 } 00053 } 00054 00055 /* Interruptable only when not doing work (aka, sleeping) */ 00056 try 00057 { 00058 boost::this_thread::sleep(duration); 00059 } 00060 catch (boost::thread_interrupted &) 00061 { 00062 return; 00063 } 00064 } 00065 } 00066 00067 } /* namespace slave */