seisimporter.h

Go to the documentation of this file.

#ifndef seisimporter_h
#define seisimporter_h

/*+
________________________________________________________________________

 (C) dGB Beheer B.V.; (LICENSE) http://opendtect.org/OpendTect_license.txt
 Author:        A.H. Bril
 Date:          Nov 2006
 RCS:           $Id$
________________________________________________________________________

-*/

#include "seismod.h"
#include "seistype.h"
#include "executor.h"
#include "bufstring.h"
class IOObj;
class Scaler;
class SeisTrc;
class SeisTrcBuf;
class BinIDSorting;
class SeisTrcReader;
class SeisTrcWriter;
class SeisResampler;
class BinIDSortingAnalyser;
namespace Seis { class SelData; }

mExpClass(Seis) SeisImporter : public Executor
{ mODTextTranslationClass(SeisImporter);
public:

    mStruct(Seis) Reader
    {
        virtual                 ~Reader()                       {}

        virtual const char*     name() const                    = 0;
        virtual const char*     implName() const                = 0;
        virtual bool            fetch(SeisTrc&)                 = 0;
        virtual int             totalNr() const                 { return -1; }

        uiString                errmsg_;
    };


                        SeisImporter(Reader*,SeisTrcWriter&,Seis::GeomType);
    virtual             ~SeisImporter();

    uiString            uiMessage() const;
    od_int64            nrDone() const;
    uiString            uiNrDoneText() const;
    od_int64            totalNr() const;
    int                 nextStep();

    int                 nrSkipped() const       { return nrskipped_; }
    Reader&             reader()                { return *rdr_; }
    SeisTrcWriter&      writer()                { return wrr_; }

protected:

    enum State                  { ReadBuf, WriteBuf, ReadWrite };

    Reader*                     rdr_;
    SeisTrcWriter&              wrr_;
    int                         queueid_;
    int                         maxqueuesize_;
    Threads::ConditionVar&      lock_;
    SeisTrcBuf&                 buf_;
    SeisTrc&                    trc_;
    BinID&                      prevbid_;
    int                         sort2ddir_;
    BinIDSorting*               sorting_;
    BinIDSortingAnalyser*       sortanal_;
    Seis::GeomType              geomtype_;
    State                       state_;
    int                         nrread_;
    int                         nrwritten_;
    int                         nrskipped_;

    bool                        sortingOk(const SeisTrc&);
    int                         doWrite(SeisTrc&);
    int                         readIntoBuf();

    friend                      class SeisImporterWriterTask;
    void                        reportWrite(const uiString&);

    mutable uiString            errmsg_;
    mutable uiString            hndlmsg_;
};


mExpClass(Seis) SeisStdImporterReader : public SeisImporter::Reader
{ mODTextTranslationClass(SeisStdImporterReader);
public:
                        SeisStdImporterReader(const IOObj&,const char* nm);
                        ~SeisStdImporterReader();

    SeisTrcReader&      reader()                { return rdr_; }

    const char*         name() const            { return name_; }
    const char*         implName() const;
    bool                fetch(SeisTrc&);

    void                removeNull( bool yn )   { remnull_ = yn; }
    void                setResampler(SeisResampler*);   
    void                setScaler(Scaler*);             
    void                setSelData(Seis::SelData*);     

    int                 totalNr() const;

protected:

    const BufferString  name_;
    SeisTrcReader&      rdr_;
    bool                remnull_;
    SeisResampler*      resampler_;
    Scaler*             scaler_;

};


#endif