seiswrite.h

Go to the documentation of this file.

#ifndef seiswrite_h
#define seiswrite_h

/*+
________________________________________________________________________

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

-*/


#include "seismod.h"
#include "seisstor.h"
#include "fixedstring.h"
#include "linekey.h"
#include "uistring.h"
class SeisTrc;
class SeisPSWriter;
class Seis2DLinePutter;
namespace Threads { class ConditionVar; }
namespace PosInfo { class Line2DData; }


mExpClass(Seis) SeisTrcWriter : public SeisStoreAccess
{ mODTextTranslationClass(SeisTrcWriter)
public:

                        SeisTrcWriter(const IOObj*,
                                      const GeomIDProvider* r=0);
                        SeisTrcWriter(const char*,bool is_2d,bool is_ps);
                        ~SeisTrcWriter();
    virtual bool        close();

    bool                prepareWork(const SeisTrc&);
    virtual bool        put(const SeisTrc&);
    int                 nrWritten() const               { return nrwritten_; }

    bool                isMultiComp() const;
    bool                isMultiConn() const;
    IOPar&              auxPars()                       { return auxpars_; }

    Seis2DLinePutter*   linePutter()                    { return putter_; }
    const Seis2DLinePutter* linePutter() const          { return putter_; }

    SeisPSWriter*       psWriter()                      { return pswriter_; }
    const SeisPSWriter* psWriter() const                { return pswriter_; }

                        // 2D only
    const GeomIDProvider* geomIDProvider() const        { return gidp_; }
    void                setGeomIDProvider(const GeomIDProvider*);
    void                setSelData(Seis::SelData*);
    void                setAttrib( const char* a )      { attribnm_ = a; }
    void                setDataType( const char* dt )   { datatype_ = dt; }

    void                setCrFrom( const char* str )    { crfrom_ = str; }
    void                setCrUserInfo( const char* str ) { crusrinfo_ = str; }
    void                setComponentNames(const BufferStringSet&);

protected:

    bool                prepared_;
    int                 nrtrcs_;
    int                 nrwritten_;
    SeisTrc&            worktrc_;
    int                 firstns_;
    SamplingData<float> firstsampling_;
    IOPar&              auxpars_;

    void                init();
    void                startWork();

    // PS only
    SeisPSWriter*       pswriter_;

    // 3D only
    Conn*               crConn(int,bool);
    bool                ensureRightConn(const SeisTrc&,bool);
    bool                start3DWrite(Conn*,const SeisTrc&);

    // 2D only
    BufferString        attribnm_;
    Seis2DLinePutter*   putter_;
    PosInfo::Line2DData* linedata_;
    TypeSet<int>        spnrs_;
    Pos::GeomID         prevgeomid_;
    const GeomIDProvider* gidp_;
    BufferString        datatype_;
    bool                next2DLine();
    bool                put2D(const SeisTrc&);

    BufferString        crfrom_;
    BufferString        crusrinfo_;
    BufferStringSet     compnames_;

};


mExpClass(Seis) SeisSequentialWriter
{ mODTextTranslationClass(SeisSequentialWriter);
public:
                        SeisSequentialWriter( SeisTrcWriter*, int buffsize=-1 );
                        ~SeisSequentialWriter();
    bool                announceTrace(const BinID&);
    bool                submitTrace( SeisTrc*, bool waitforbuffer=true );
    bool                submitGather( ObjectSet<SeisTrc>&,
                                      bool waitforbuffer=true );
    bool                finishWrite();
    uiString            errMsg() const { return errmsg_; }

protected:

    bool                        iterateBuffer(bool waitforbuffer);
    void                        reportWrite(const char*);
    friend class                SeisSequentialWriterTask;

    SeisTrcWriter*              writer_;
    TypeSet<BinID>              announcedtraces_;
    Threads::ConditionVar&      lock_;
    ObjectSet<SeisTrc>          outputs_;
    const int                   maxbuffersize_;

    BinID                       latestbid_;

    int                         queueid_;
    uiString                    errmsg_;

};


#endif