customdb_samples/customdbsample_extended/linux/schedule_thread.cpp

/* IBM Source Code */
/* (C) Copyright IBM Corp. 2009, 2012 */
/* Licensed Materials - Property of IBM */
/* US Government Users Restricted Rights - Use duplication or disclosure restricted by GSA Schedule Contract with IBM Corp. */
 
#include "dca/dca_base.h"
 
#include "../mythreads.h"
 
using namespace dca;
 
struct ScheduleThreadData
{
        const DcaInstance* pDcaInstance;
        volatile bool shutdown;
        volatile bool *errorSignal;
 
        ScheduleThreadData()
                : pDcaInstance(NULL)
                , shutdown(false)
                , errorSignal(NULL)
        {
        }
};
 
static ScheduleThreadData S_scheduleThreadData;
 
static void* ScheduleThreadWorkerFunction( void* pThreadData )
{
        const ScheduleThreadData* pScheduleThreadData = (ScheduleThreadData*)pThreadData;
 
        try {
                bool error = false;
                while( !error && !pScheduleThreadData->shutdown ) {
                        FunctionResult fr = pScheduleThreadData->pDcaInstance->schedule();
                        if( !fr ) {
                                error = true;
                                break;
                        }
 
                        // sleep for 1 minute - avoid busy loop
                        for (size_t k=0; k<60 && !pScheduleThreadData->shutdown; ++k)
                                mySleep( 1000 ); 
 
                }
        }
        catch(...) {}   
 
        pthread_exit(0);
}
 
static pthread_t S_hScheduleThread = 0;
 
void createScheduleThread( const DcaInstance& aDcaInstance, volatile bool *errorSignal )
{
        S_scheduleThreadData.pDcaInstance = &aDcaInstance;
        S_scheduleThreadData.errorSignal = errorSignal;
 
        pthread_create(&S_hScheduleThread, NULL, ScheduleThreadWorkerFunction, (void*)&S_scheduleThreadData);
}
 
void shutdownScheduleThread()
{
        S_scheduleThreadData.shutdown = true;
        pthread_join(S_hScheduleThread, NULL);
}