/*
 * Copyright 2001-2006, Haiku.
 * Distributed under the terms of the MIT License.
 *
 * Authors:
 *              DarkWyrm <bpmagic@columbus.rr.com>
 *              Pahtz <pahtz@yahoo.com.au>
 *              Axel Dörfler, axeld@pinc-software.de
 */
#ifndef _LINK_RECEIVER_H
#define _LINK_RECEIVER_H


#include <AffineTransform.h>
#include <OS.h>


class BGradient;
class BString;
class BRegion;
class BShape;


namespace BPrivate {

class LinkReceiver {
        public:
                LinkReceiver(port_id port);
                virtual ~LinkReceiver(void);

                void SetPort(port_id port);
                port_id Port(void) const { return fReceivePort; }

                status_t GetNextMessage(int32& code, bigtime_t timeout = B_INFINITE_TIMEOUT);
                bool HasMessages() const;
                bool NeedsReply() const;
                int32 Code() const;

                virtual status_t Read(void* data, ssize_t size);
                status_t ReadString(char** _string, size_t* _length = NULL);
                status_t ReadString(BString& string, size_t* _length = NULL);
                status_t ReadString(char* buffer, size_t bufferSize);
                status_t ReadRegion(BRegion* region);
                status_t ReadShape(BShape* shape);
                status_t ReadGradient(BGradient** gradient);
                status_t ReadAffineTransform(BAffineTransform *transform)
                        { return Read(&transform->sx, sizeof(double) * 6); }

                template <class Type> status_t Read(Type *data)
                        { return Read(data, sizeof(Type)); }

        protected:
                virtual status_t ReadFromPort(bigtime_t timeout);
                virtual status_t AdjustReplyBuffer(bigtime_t timeout);
                void ResetBuffer();

                port_id fReceivePort;

                char*   fRecvBuffer;
                int32   fRecvPosition;  //current read position
                int32   fRecvStart;     //start of current message
                int32   fRecvBufferSize;

                int32   fDataSize;      //size of data in recv buffer
                int32   fReplySize;     //size of current reply message

                status_t fReadError;    //Read failed for current message
};

}       // namespace BPrivate

#endif  // _LINK_RECEIVER_H