source: trunk/ETSI-Testsuites/ETSI_auto_IOT/adapter/src/Capture/GenericCapture.cpp

/**
 * @file GenericCapture.cpp
 * @author Tomas Urban
 * @version 0.3
 * @date 23/07/2009
 */
#include "GenericCapture.h"
#include "Logger/Logger.h"

GenericCapture::GenericCapture() :
        m_pDispatch(0)
{
        m_startPoint.tv_sec = 0;
        m_startPoint.tv_usec = 0;
        m_offset.tv_sec = 0;
        m_offset.tv_usec = 0;
        m_timestamp.tv_sec = 0;
        m_timestamp.tv_usec = 0;
}

GenericCapture::~GenericCapture(void)
{
        
}

void GenericCapture::UpdateTimestamp()
{
        m_timestamp.tv_sec = m_startPoint.tv_sec + m_offset.tv_sec;
        m_timestamp.tv_usec = m_startPoint.tv_usec + m_offset.tv_usec;
        int nSec = m_timestamp.tv_usec / 1000000;
        if (nSec > 0)
        {
                m_timestamp.tv_sec += nSec;
                m_timestamp.tv_usec -= nSec * 1000000;
        }
}

void GenericCapture::SetStartPoint(struct timeval timestamp)
{
        m_startPoint = timestamp;
        UpdateTimestamp();
}

void GenericCapture::SetStartOffset(struct timeval offset) 
{ 
        m_offset = offset;
        UpdateTimestamp();
}

void GenericCapture::ProcessCapturedData(CapturedData * pData)
{
        if (!m_pDispatch)
                return;
        timeval msgTime = pData->GetTimestamp();
        if (msgTime.tv_sec > m_timestamp.tv_sec ||
                msgTime.tv_sec == m_timestamp.tv_sec && msgTime.tv_usec >= m_timestamp.tv_usec)
        {
                pData->SetCaptureType(GetCaptureType());
                m_pDispatch->DispatchData(pData);
        }
        else
                Logger::Instance().LogDebug("Captured message discarded (older than start point)");
}

bool GenericCapture::SetCaptureFile(const std::string sFile) 
{ 
        return sFile.length() == 0; 
}