boardworkerthread.cpp

Go to the documentation of this file.

// Name:        BoardWorkerThread.cpp
// Purpose:     
// Author:      NDA
// Modified by: 
// Created:     11/24/05 15:04:29
// RCS-ID:      
// Copyright:   CAEN S.p.A. All rights reserved
// Licence:     

// Generated by DialogBlocks (unregistered), 11/24/05 15:04:29

#if defined(__GNUG__) && !defined(__APPLE__)
#pragma implementation "boardworkerthread.h"
#endif

// For compilers that support precompilation, includes "wx/wx.h".
#include "wx/wxprec.h"

#ifdef __BORLANDC__
#pragma hdrstop
#endif

#ifndef WX_PRECOMP
#include "wx/wx.h"
#endif
#include <wx/datetime.h>

#include "generic_board.h"
#include "physical_board_channel.h"
#include "boardworkerthread.h"
#include "appsettings.h"
extern "C" 
{
        #include "../include/CAENVMETool/cvt_v1724.h"
}

BoardWorkerThread::BoardWorkerThread(GenericBoard* parent)
{
        this->m_parent= parent;
}

BoardWorkerThread::~BoardWorkerThread(void)
{
}

wxThread::ExitCode BoardWorkerThread::Entry( void)
{
        const int SW_TRIGGER_INTERVAL_MSEC= 1;
        this->m_next_sw_trigger= wxDateTime::UNow();
        while( !this->TestDestroy())
        {
                UINT32 num_samples_read;
                UINT32 num_events;
                //
                // Get channels' samples

                // Refresh channels' data cache
                
                num_samples_read= num_events= 0;
                if( this->m_parent->ReadBoardData( &num_samples_read, &num_events))
                {
                        if( num_samples_read)
                        {
                                if( num_samples_read> (UINT32)this->m_parent->m_p_app_settings->m_max_log_X)
                                        num_samples_read= (UINT32)this->m_parent->m_p_app_settings->m_max_log_X;

                                for( size_t i= 0; ( i< this->m_parent->m_channel_array.GetCount())&& !this->TestDestroy(); i++)
                                {
                                        PhysicalBoardChannel *board_channel= ( PhysicalBoardChannel *)this->m_parent->m_channel_array[i];
                                        if( board_channel->ReadSamplesCache( num_samples_read))
                                        {
                                                if( this->m_parent->m_is_recording)
                                                        board_channel->RecordSamples( );
                                        }
                                        this->Sleep( 1);
                                }
                                if( num_samples_read&& this->m_parent->m_is_recording)
                                {
                                        for( size_t i= 0; ( i< this->m_parent->m_virtual_channel_array.GetCount())&& !this->TestDestroy(); i++)
                                        {
                                                VirtualBoardChannel *board_channel= ( VirtualBoardChannel *)this->m_parent->m_virtual_channel_array[i];
                                                board_channel->RecordSamples( );
                                                this->Sleep( 1);
                                        }
                                }
                        }
                }
                else
                {
                        num_samples_read= 0;
                }
                //
                // Software autoretrig.
                if( this->TestDestroy())
                        goto exit_point;
                if(( this->m_parent->m_p_app_settings->m_trigger_msk& (int)AppSettings::SW_AUTO_TRIGGER_MSK)&& !this->TestDestroy())
                {
                        if( wxDateTime::UNow()>= this->m_next_sw_trigger)
                        {
                                // Update next trigger timer
                                this->m_next_sw_trigger= wxDateTime::UNow().Add( wxTimeSpan( 0, 0, 0, SW_TRIGGER_INTERVAL_MSEC));

                                // Send SW retrigger
                                this->m_parent->WriteSoftwareTrigger( );
                        }
                }
                if( num_samples_read&& this->m_parent->ScopeRefresh)
                {
                        for( int i= 0; i< SCOPE_NUM_PANELS; i++)
                        {
                                ( this->m_parent->ScopeRefresh)( i, false);
                        }
                }

        }
exit_point:
    this->m_parent->m_thread_exited= true;
        return (wxThread::ExitCode)0;
}

---