diff options
Diffstat (limited to 'comm/MsgStream.h')
-rw-r--r-- | comm/MsgStream.h | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/comm/MsgStream.h b/comm/MsgStream.h index 7660ae8..d3e613e 100644 --- a/comm/MsgStream.h +++ b/comm/MsgStream.h @@ -16,35 +16,35 @@ #define MsgStream_H_ #include "BufStream.h" -class UchMessage; +class IvlMessage; -class UchMsgStream : public UchBufStream { +class IvlMsgStream : public IvlBufStream { protected: enum STATE { WAITING, GOT_TYPE, GOT_LENGTH, DONE}; enum TYPE { MSG = 1, ASK, ANS, SYNC, ASYNC, OK }; STATE State; bool BufferedMessages; - UchMsgBuffer Buffered; + IvlMsgBuffer Buffered; bool WaitingReply; int InLength; byte InType; - UchMessage* Process (UchMsgBuffer&, bool); - UchMsgStream (const UchMsgStream&); - void WriteMsg (UchMessage&); - bool ReadMsg (UchMessage&); + IvlMessage* Process (IvlMsgBuffer&, bool); + IvlMsgStream (const IvlMsgStream&); + void WriteMsg (IvlMessage&); + bool ReadMsg (IvlMessage&); public: - UchMsgStream (UchAddress* = 0, UchAddress* = 0); - ~UchMsgStream (); + IvlMsgStream (IvlAddress* = 0, IvlAddress* = 0); + ~IvlMsgStream (); void HandleRead (); -virtual UchMessage* DecodeMessage (UchMsgBuffer&); -virtual UchMessage* DecodeAnswer (UchMsgBuffer&); - void Send (UchMessage&, bool = false); - UchMessage* Ask (UchMessage&); - void Reply (UchMessage&); - void Send (UchMsgBuffer&, bool = false); +virtual IvlMessage* DecodeMessage (IvlMsgBuffer&); +virtual IvlMessage* DecodeAnswer (IvlMsgBuffer&); + void Send (IvlMessage&, bool = false); + IvlMessage* Ask (IvlMessage&); + void Reply (IvlMessage&); + void Send (IvlMsgBuffer&, bool = false); }; #endif /* MsgStream_H_ */ |