---

unzipstreamer.cpp

Go to the documentation of this file.

//============================================================================= 
//
// XDFLengine library
//
//-----------------------------------------------------------------------------
//  FSGETSTREAMER.CPP
//-----------------------------------------------------------------------------
//=============================================================================

#   include "unzipstreamer.hpp"
#   include "flow/buffers/filebuffer.hpp"
#   include "processor/xmlprocessor.hpp"
#   include "processor/xmlflowcontext.hpp"

BEGIN_XDFLENGINE_NS

//=============================================================================
//  CLASS UnzipStreamer
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

// CONSTRUCTOR & DESTRUCTOR

    //_____________________________________________________________________
    //  UnzipStreamer
    //---------------------------------------------------------------------
    UnzipStreamer::UnzipStreamer( const XMLStreamerFactory* p_pParent, StreamerParams* p_pParameters, XMLFlowContext* p_pContext, XMLStreamConsumer* p_pOutput)
    :XMLStreamer( p_pParent, p_pParameters, p_pContext, p_pOutput)
    {
        DEBUG_CREATE(UnzipStreamer)
    }
    
    //_____________________________________________________________________
    //  ~UnzipStreamer
    //---------------------------------------------------------------------     
    UnzipStreamer::~UnzipStreamer()
    {   
        DEBUG_DEL(UnzipStreamer)
    }
    
// STREAM   

    //_____________________________________________________________________
    //  INITSTREAM
    //---------------------------------------------------------------------
    bool UnzipStreamer::initStream()
    {
        DEBUG_FUNC(UnzipStreamer::initStream)
        return true;
    }

    //_____________________________________________________________________
    //  WRITEDATA
    //---------------------------------------------------------------------
    void UnzipStreamer::writeData( const char*  p_pszData, unsigned int p_uiDataLen)
    {
        DEBUG_FUNC(UnzipStreamer::initStream)
    }

    //_____________________________________________________________________
    //  COMMITSTREAM
    //---------------------------------------------------------------------
    bool UnzipStreamer::commitStream(bool p_fFinal)
    {
        //---------------------------------------------------------------------
        XMLStreamBuffer*        l_pBufIn=0;
        const char*             l_pszFilePath;
        unsigned int            l_uiCopyBufferSize;
        //---------------------------------------------------------------------

        DEBUG_IN(UnzipStreamer::commitStream)

        PREP_CATCH_XML_FLOW_ERROR;

        WATCH_XML_FLOW_ERROR
        {
            if(p_fFinal)
            {
                // Get File Name
                l_pszFilePath =  getParamValue( m_pParameters, UNZIPSTREAMER_TARGET);
                l_uiCopyBufferSize = atoi( getParamValue(m_pParameters, UNZIPSTREAMER_STREAMDATA,"0"));
                l_pBufIn=new ZipBuffer(l_pszFilePath, true, l_uiCopyBufferSize);
                (*l_pBufIn) >> (*m_pOutput);
            }
        }
        CATCH_XML_FLOW_ERROR_RELEASE_AND_RETURN
        catch(...)
        {
            // Unknown error handling
            MAKE_XMLFLOW_EXCEPTION( ERRCODE_LOC_FSGETHANDLER + ERRCODE_CAUSE_FILE , "Error while reading file." , l_pszFilePath, "UnzipHandler::processXML","", false);         
        }
    RELEASE_AND_RETURN: 

        // Release
        delete l_pBufIn;

        DEBUG_OUT(UnzipStreamer::commitStream)
        ON_XML_FLOW_ERROR_THROW;

        return true;

        
            
    }

//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
//=============================================================================


//=============================================================================
//  CLASS UnzipStreamerFactory
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
    UnzipStreamerFactory::UnzipStreamerFactory()
    {
        logout.display_version( "ZLIB", "'zlib' general purpose compression library", ZLIB_VERSION, "Copyright (C) 1995-2002 Jean-loup Gailly and Mark Adler"); 
    }

    XMLStreamer* UnzipStreamerFactory::getStreamer(
        StreamerParams*         p_pParameters, 
        XMLFlowContext* p_pStreamContext, 
        XMLStreamConsumer*      p_pStreamConsumer) const
    {
        DEBUG_FUNC(UnzipStreamer::getStreamer)
        return (XMLStreamer*) new UnzipStreamer( this, p_pParameters, p_pStreamContext, p_pStreamConsumer);
    }

//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
//=============================================================================


END_XDFLENGINE_NS

---