46 #ifndef MQSERIALIZATIONPROTOCOL_HPP_ 47 #define MQSERIALIZATIONPROTOCOL_HPP_ 51 #include <boost/iostreams/stream.hpp> 52 #include <boost/iostreams/device/array.hpp> 70 namespace io = boost::iostreams;
75 io::stream<io::array_sink> outbuf( (
char*)blob, size);
80 return std::make_pair((
void*)0,
int(0));
87 namespace io = boost::iostreams;
90 io::stream<io::array_source> inbuf((
const char*)blob, size);
104 namespace io = boost::iostreams;
106 io::stream<io::array_sink> outbuf(sink,1);
108 out << tsample->
get();
virtual result_t get() const =0
virtual void set(param_t t)=0
MQSerializationProtocol()
virtual bool updateFromBlob(const void *blob, int size, base::DataSourceBase::shared_ptr target, void *cookie) const
virtual const_reference_t rvalue() const =0
virtual unsigned int getSampleSize(base::DataSourceBase::shared_ptr sample, void *cookie) const
static AssignableDataSource< T > * narrow(base::DataSourceBase *db)
boost::intrusive_ptr< DataSource< T > > shared_ptr
boost::intrusive_ptr< AssignableDataSource< T > > shared_ptr
boost::intrusive_ptr< DataSourceBase > shared_ptr
Contains TaskContext, Activity, OperationCaller, Operation, Property, InputPort, OutputPort, Attribute.
static Logger::LogFunction endlog()
virtual std::pair< void const *, int > fillBlob(base::DataSourceBase::shared_ptr source, void *blob, int size, void *cookie) const