seisimporter.h

Go to the documentation of this file.

#pragma once
 
/*+
________________________________________________________________________
 
 (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_;
 
};