segyresorter.h

Go to the documentation of this file.

#pragma once

/*+
________________________________________________________________________

 (C) dGB Beheer B.V.; (LICENSE) http://opendtect.org/OpendTect_license.txt
 Author:        Bert
 Date:          Jul 2008
________________________________________________________________________

-*/

#include "seisposkey.h"
#include "executor.h"
#include "ranges.h"
#include "dbkey.h"
#include "strmdata.h"
#include "bufstringset.h"
namespace Pos           { class Filter; }
namespace PosInfo       { class CubeData; class CubeDataPos; }


namespace SEGY
{
class DirectDef;
class FileDataSet;
class DirectReader;

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

    mExpClass(Seis) Setup
    {
    public:

                        Setup(Seis::GeomType gt,const DBKey&,
                              const char* outputfnm);

        mDefSetupMemb(Seis::GeomType,geom)
        mDefSetupMemb(DBKey,inpkey)
        mDefSetupMemb(BufferString,outfnm)
        mDefSetupMemb(int,newfileeach)
        mDefSetupMemb(bool,inlnames)

        Interval<int>   getInlRg(int,const PosInfo::CubeData&) const;
        BufferString    getFileName(const Interval<int>&) const;

        mutable int     curfnr_;

    };

                        ReSorter(const Setup&,const char* linename=0);
                        ~ReSorter();

    void                setFilter(const Pos::Filter&);

    uiString            message() const { return msg_; }
    uiString            nrDoneText() const      { return tr("Traces handled"); }
    od_int64            nrDone() const          { return nrdone_; }
    od_int64            totalNr() const         { return totnr_; }
    int                 nextStep();

    const DirectDef&    dDef() const;
    const FileDataSet&  fds() const;

protected:

    const Setup         setup_;

    SEGY::DirectReader* drdr_;
    uiString            msg_;
    od_int64            nrdone_;
    od_int64            totnr_;
    StreamData          sdout_;
    Interval<int>       curinlrg_;
    bool                needwritefilehdrs_;

    ObjectSet<StreamData> inpsds_;
    TypeSet<int>        fidxs_;
    BufferStringSet     inpfnms_;

    unsigned char       hdrbuf_[3600];
    unsigned char*      trcbuf_;
    od_int64            trcbytes_;

    TypeSet<BinID>      binids_;
    PosInfo::CubeDataPos& cdp_;
    Pos::Filter*        posfilt_;

    int                 fillBinIDs();
    int                 wrapUp();
    bool                getCurPos(BinID&);
    bool                toNext();
    bool                getNext(const BinID&,int&,int&) const;
    bool                createOutput(const BinID&);
    bool                openOutputFile();
    int                 ensureFileOpen(int);
    bool                readData(int,int);
    bool                writeData();

};

} // namespace