SOutputQBox.h

Go to the documentation of this file.

#ifndef SOUTPUT_QBOX_H
#define SOUTPUT_QBOX_H

#include "QBox.h"
#include "SControlQBox.h"

BOREALIS_NAMESPACE_BEGIN;

class SOutputQBox : public SControlQBox {

    friend class SOutputBoxState;

protected:
    void setupImpl() throw (AuroraException);
    void initImpl() throw (AuroraException);
    void runImpl(QBoxInvocation&) throw (AuroraException);
        
    // packing and unpacking states 
    void setPendingBoxState(ptr<AbstractBoxState> packed_box);
    ptr<AbstractBoxState> packState();
    void unpackState(ptr<AbstractBoxState> box_state);

private:

    void saveTuple(const Tuple& tuple);

    ptr<dynbuf> _last_tuple;
    bool _wait_for_last_redo;
    Timestamp _timestamp_to_wait_for;
    //int32 _id_to_wait_for;
    //bool _wait_for_punctuation;

    AURORA_DECLARE_QBOX(SOutputQBox, "soutput");

};

class SOutputBoxState : public AbstractBoxState
{
 public:
    SOutputBoxState() {}
    SOutputBoxState(dynbuf& tuple) 
        : _tuple(tuple.max_length()) 
    {
        // Make a copy of the buffer
        memcpy(_tuple.data(),tuple.data(),tuple.max_length());
    }
    ~SOutputBoxState() {}

    dynbuf getTuple() { return _tuple; }
    NMSTL_SERIAL_SUBCLASS(SOutputBoxState, AbstractBoxState, << _tuple);

 private:
    dynbuf _tuple;
};



BOREALIS_NAMESPACE_END;

#endif

---