tools/sci/org.eclipse.ptp.sci/libsci/writerproc.hpp

#ifndef _PRAGMA_COPYRIGHT_
#define _PRAGMA_COPYRIGHT_
#pragma comment(copyright, "%Z% %I% %W% %D% %T%\0")
#endif /* _PRAGMA_COPYRIGHT_ */
/****************************************************************************

* Copyright (c) 2008, 2010 IBM Corporation.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0s
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html

 Classes: WriterProcessor

 Description: Properties of class 'WriterProcessor':
    input: a message queue
    output: a stream
    action: relay messages from the queue to the stream.
   
 Author: Nicole Nie, Tu HongJ

 History:
   Date     Who ID    Description
   -------- --- ---   -----------
   05/25/09 nieyy      Initial code (F156654)

****************************************************************************/

#ifndef _WRITERPROC_HPP
#define _WRITERPROC_HPP

#include "processor.hpp"

class Stream;
class MessageQueue;
class ReaderProcessor;

class WriterProcessor : public Processor 
{
    private:
        Stream              *outStream;
        ReaderProcessor     *peerProcessor;
        int                 recoverID;
        int                 notifyID;

        bool                recoverState;
        bool                releaseState;

    public:
        WriterProcessor(int hndl = -1);
        ~WriterProcessor();

        virtual Message * read();
        virtual void process(Message *msg);
        virtual void write(Message *msg);
        virtual void seize();
        virtual int recover();
        virtual void clean();

        void setInQueue(MessageQueue *queue);
        MessageQueue * getInQueue();
        void setOutStream(Stream *stream);
        void setPeerProcessor(ReaderProcessor *processor);
        ReaderProcessor *getPeerProcessor();

        bool getRecoverState() { return recoverState; }
        void setRecoverState(bool state) { recoverState = state; }
        bool getReleaseState() { return releaseState; }
        void setReleaseState(bool state) { releaseState = state; }
};

#endif