JAUS++: jaus++/2.0/src/jaus/core/events/updateevent.cpp Source File

Go to the documentation of this file.
00001 
00002 
00003 
00004 
00005 
00006 
00007 
00008 
00009 
00010 
00011 
00012 
00013 
00014 
00015 
00016 
00017 
00018 
00019 
00020 
00021 
00022 
00023 
00024 
00025 
00026 
00027 
00028 
00029 
00030 
00031 
00032 
00033 
00034 
00035 
00036 
00037 
00038 
00039 
00040 #include "jaus/core/events/updateevent.h"
00041 #include "jaus/core/scaledinteger.h"
00042 #include "jaus/core/events/confirmeventrequest.h"
00043 #include "jaus/core/events/rejecteventrequest.h"
00044 
00045 using namespace JAUS;
00046 
00047 const double UpdateEvent::Limits::MaxUpdateRate = 1092.0;
00048 const double UpdateEvent::Limits::MinUpdateRate = 0.0;
00049 
00050 
00059 UpdateEvent::UpdateEvent(const Address& dest,
00060                          const Address& src) : Message(UPDATE_EVENT, dest, src)
00061 {
00062     mType = Events::EveryChange;
00063     mRequestID = 0;
00064     mEventID = 0;
00065     mRequestedPeriodicRate = 1;
00066     mQueryMessageCode = 0;
00067 }
00068 
00069 
00075 UpdateEvent::UpdateEvent(const UpdateEvent& message) : Message(UPDATE_EVENT)
00076 {
00077     mType = Events::EveryChange;
00078     mRequestID = 0;
00079     mEventID = 0;
00080     mRequestedPeriodicRate = 1;
00081     mQueryMessageCode = 0;
00082     *this = message;
00083 }
00084 
00085 
00091 UpdateEvent::~UpdateEvent()
00092 {
00093 
00094 }
00095 
00096 
00107 bool UpdateEvent::SetRequestedPeriodicRate(const double rate)
00108 {
00109     if(rate >= Limits::MinUpdateRate && rate <= Limits::MaxUpdateRate)
00110     {
00111         mRequestedPeriodicRate = rate;
00112         return true;
00113     }
00114     return false;
00115 }
00116 
00117 
00129 bool UpdateEvent::SetQueryMessage(const Message* queryMessage)
00130 {
00131     mQueryMessage.Clear();
00132     if(queryMessage && queryMessage->WriteMessageBody(mQueryMessage))
00133     {
00134         mQueryMessageCode = queryMessage->GetMessageCode();
00135         return true;
00136     }
00137     return false;
00138 }
00139 
00140 
00153 bool UpdateEvent::SetQueryMessage(const UShort messageCode,
00154                                   const Packet& queryPayload)
00155 {
00156     mQueryMessageCode = messageCode;
00157     mQueryMessage = queryPayload;
00158     return true;
00159 }
00160 
00161 
00180 bool UpdateEvent::IsResponseToMessage(const Message *requestingMessage) const
00181 {
00182     if(mSourceID == requestingMessage->GetDestinationID())
00183     {
00184         if(requestingMessage->GetMessageCode() == CONFIRM_EVENT_REQUEST)
00185         {
00186             const ConfirmEventRequest* original = dynamic_cast<const ConfirmEventRequest*>(requestingMessage);
00187             if(original && original->GetRequestID() == mRequestID)
00188             {
00189                 return true;
00190             }
00191         }
00192         else if(requestingMessage->GetMessageCode() == REJECT_EVENT_REQUEST)
00193         {
00194             const RejectEventRequest* original = dynamic_cast<const RejectEventRequest*>(requestingMessage);
00195             {
00196                 return true;
00197             }
00198         }
00199     }
00200     return false;
00201 }
00202 
00203 
00215 int UpdateEvent::WriteMessageBody(Packet& packet) const
00216 {
00217     int total = 0;
00218     int expected = BYTE_SIZE*3 + USHORT_SIZE + UINT_SIZE + USHORT_SIZE;
00219     total += packet.Write(mRequestID);
00220     total += packet.WriteByte((Byte)mType);
00221     total += ScaledInteger::Write(packet,
00222                                   mRequestedPeriodicRate,
00223                                   Limits::MaxUpdateRate,
00224                                   Limits::MinUpdateRate,
00225                                   ScaledInteger::UShort);
00226     total += packet.Write(mEventID);
00227     total += packet.Write( (UInt)(mQueryMessage.Size() + USHORT_SIZE ) );
00228     total += packet.Write( mQueryMessageCode );
00229     if(mQueryMessage.Size() > 0)
00230     {
00231         expected += mQueryMessage.Size();
00232         total += packet.Write(mQueryMessage);
00233     }
00234     return total == expected ? total : -1;
00235 }
00236 
00237 
00249 int UpdateEvent::ReadMessageBody(const Packet& packet) 
00250 {
00251     int total = 0;
00252     int expected = BYTE_SIZE*3 + USHORT_SIZE + UINT_SIZE + USHORT_SIZE;
00253     UInt payloadSize = 0;
00254     total += packet.Read(mRequestID);
00255     total += packet.Read((Byte &)mType);
00256     total += ScaledInteger::Read(packet,
00257                                   mRequestedPeriodicRate,
00258                                   Limits::MaxUpdateRate,
00259                                   Limits::MinUpdateRate,
00260                                   ScaledInteger::UShort);
00261     total += packet.Read(mEventID);
00262     total += packet.Read( payloadSize );    
00263     if(payloadSize >= USHORT_SIZE)
00264     {
00265         expected += payloadSize - USHORT_SIZE;
00266         total += packet.Read( mQueryMessageCode );
00267         total += packet.Read(mQueryMessage, payloadSize - USHORT_SIZE);
00268     }
00269     return total == expected ? total : -1;
00270 }
00271 
00272 
00278 void UpdateEvent::ClearMessageBody()
00279 {
00280     mType = Events::EveryChange;
00281     mRequestID = 0;
00282     mEventID = 0;
00283     mRequestedPeriodicRate = 1;
00284     mQueryMessageCode = 0;
00285     mQueryMessage.Clear();
00286 }
00287 
00288 
00294 UpdateEvent& UpdateEvent::operator =(const UpdateEvent& message)
00295 {
00296     if(this != &message)
00297     {
00298         CopyHeaderData(&message);
00299         mType = message.mType;
00300         mEventID = message.mEventID;
00301         mRequestID = message.mRequestID;
00302         mRequestedPeriodicRate = message.mRequestedPeriodicRate;
00303         mQueryMessageCode = message.mQueryMessageCode;
00304         mQueryMessage = message.mQueryMessage;
00305     }
00306     return *this;
00307 }
00308 
00309 
00310 /*  End of File */