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 #ifndef ORO_MQ_TEMPATE_PROTOCOL_HPP
00040 #define ORO_MQ_TEMPATE_PROTOCOL_HPP
00041
00042 #include "MQLib.hpp"
00043 #include "../../types/TypeMarshaller.hpp"
00044 #include "MQChannelElement.hpp"
00045 #include "MQTemplateProtocolBase.hpp"
00046
00047 #include <boost/type_traits/has_virtual_destructor.hpp>
00048 #include <boost/static_assert.hpp>
00049
00050 namespace RTT
00051 { namespace mqueue
00052 {
00060 template<class T>
00061 class MQTemplateProtocol
00062 : public MQTemplateProtocolBase<T>
00063 {
00064 public:
00070 BOOST_STATIC_ASSERT( !boost::has_virtual_destructor<T>::value );
00074 typedef T UserType;
00075
00076 virtual std::pair<void const*,int> fillBlob( base::DataSourceBase::shared_ptr source, void* blob, int size, void* cookie) const
00077 {
00078 if ( sizeof(T) <= (unsigned int)size)
00079 return std::make_pair(source->getRawConstPointer(), int(sizeof(T)));
00080 return std::make_pair((void const*)0,int(0));
00081 }
00082
00083 virtual bool updateFromBlob(const void* blob, int size, base::DataSourceBase::shared_ptr target, void* cookie) const
00084 {
00085 typename internal::AssignableDataSource<T>::shared_ptr ad = internal::AssignableDataSource<T>::narrow( target.get() );
00086 assert( size == sizeof(T) );
00087 if ( ad ) {
00088 ad->set( *(T*)(blob) );
00089 return true;
00090 }
00091 return false;
00092 }
00093
00094 virtual unsigned int getSampleSize(base::DataSourceBase::shared_ptr ignored, void* cookie) const
00095 {
00096
00097 return sizeof(T);
00098 }
00099 };
00100 }
00101 }
00102
00103 #endif