DtVrvControlMessageMarshaller_v0.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2010 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/


#pragma once

#include <vrvVrl/DtVrvControlFactory_v0.h>

#include <vlutil/vlPrint.h>

namespace vrvControlToolkit
{

   template<class DataMsg>
   class DtVrvControlMessageMarshaller_v0
   {
   public: 
      DtVrvControlMessageMarshaller_v0();

      virtual ~DtVrvControlMessageMarshaller_v0();

      virtual void encode(DtVrvControl_v0* cmd, DataMsg* msg);
      virtual DtVrvControl_v0* decode(const DataMsg* msg);

   protected:

   };



   template<class DataMsg>
   DtVrvControlMessageMarshaller_v0<DataMsg>::DtVrvControlMessageMarshaller_v0()
   {

   }

   template<class DataMsg>
   DtVrvControlMessageMarshaller_v0<DataMsg>::~DtVrvControlMessageMarshaller_v0()
   {

   }

   template<class DataMsg>
   void DtVrvControlMessageMarshaller_v0<DataMsg>::encode(DtVrvControl_v0* cmd, DataMsg* msg)
   {
      DtDatumRetCode ret;
      int size=cmd->bufferSize();

      //serialize to a buffer
      char* buffer=new char[size];
      cmd->encode(buffer);

      //setup the var field
      msg->setNumVarFields(1);

      //odd that these start their indexes at 1
      msg->setDatumParam(DtVar, 1, (DtDatumParam)DtVrvDatumParamId_v0);
      msg->setVarDataBytes(1, size, &ret);
      msg->setDatumValByteArray(DtVar, 1, buffer, &ret);

      delete [] buffer;
   }

   template<class DataMsg>
   DtVrvControl_v0* DtVrvControlMessageMarshaller_v0<DataMsg>::decode(const DataMsg* msg)
   {
      DtDatumRetCode ret;
      DtDatumRecordType type;
      int index;
      int size;

      msg->getIndex((DtDatumParam)DtVrvDatumParamId_v0, &type, &index, &ret);
      if(ret!=DtDatumValid)
      {
         return NULL;
      }

      //actually get the data out of the pdu/interaction
      size=msg->datumSizeBytes(type, index);
      const char* buffer=msg->datumValByteArray(type, index);
      DtVrvControl_v0* cmd=vrvControlToolkit::DtVrvControlFactory_v0::instance().create(buffer, size);

      return cmd;

   }

} //vrvControlToolkit::