volprocchainexec.h

Go to the documentation of this file.

#pragma once

/*+
________________________________________________________________________

 (C) dGB Beheer B.V.; (LICENSE) http://opendtect.org/OpendTect_license.txt
 Author:        K. Tingdahl
 Date:          October 2006
________________________________________________________________________


-*/

#include "volumeprocessingmod.h"
#include "volprocchain.h"
#include "executor.h"


namespace VolProc
{

mExpClass(VolumeProcessing) ChainExecutor : public Executor
{ mODTextTranslationClass(ChainExecutor);
public:
                                ChainExecutor(Chain&);
                                ~ChainExecutor();

    bool                        setCalculationScope(const TrcKeySampling&,
                                                    const StepInterval<int>&);
    od_int64                    computeMaximumMemoryUsage(const TrcKeySampling&,
                                                const StepInterval<int>&);
    bool                        areSamplesIndependent() const;
    bool                        needsFullVolume() const;

    const RegularSeisDataPack*  getOutput() const;
    RegularSeisDataPack*        getOutput();
    uiString                    errMsg() const;

    virtual int                 nextStep();
    virtual od_int64            nrDone() const;
    virtual od_int64            totalNr() const;
    virtual uiString            message() const;
    virtual uiString            nrDoneText() const;
    virtual void                controlWork(Control);

    static uiString             sGetStepErrMsg();

private:

    class Epoch
    {
    public:
                                Epoch(const ChainExecutor&);
                                ~Epoch()                { delete &taskgroup_; }

        void                    addStep(Step* s)        { steps_ += s; }
        const ObjectSet<Step>&  getSteps() const        { return steps_; }

        bool                    updateInputs();
        bool                    doPrepare(ProgressMeter* progmeter=0);
        void                    releaseData();
        Task&                   getTask()               { return taskgroup_; }

        bool                    needsStepOutput(Step::ID) const;
        RegularSeisDataPack*    getOutput() const;

    private:

        BufferString            errmsg_;
        const ChainExecutor&    chainexec_;
        TaskGroup&              taskgroup_;
        ObjectSet<Step>         steps_;

    };

    bool                        scheduleWork();
    void                        releaseMemory();
    int                         computeLatestEpoch(Step::ID) const;
    void                        computeComputationScope(Step::ID stepid,
                                    TrcKeySampling& stepoutputhrg,
                                    StepInterval<int>& stepoutputzrg ) const;
    Step::ID                    getChainOutputStepID() const;
    Step::OutputSlotID          getChainOutputSlotID() const;


    Epoch*                      curepoch_;
    bool                        isok_;
    Chain&                      chain_;
    TrcKeySampling              outputhrg_;
    StepInterval<int>           outputzrg_;
    mutable uiString            errmsg_;
    ObjectSet<Step>             scheduledsteps_;
    ObjectSet<Epoch>            epochs_;
    Chain::Web                  web_;
    int                         totalnrepochs_;

    RefMan<RegularSeisDataPack> outputdp_;

};

} // namespace VolProc