rti_io.cpp

来自「这是广泛使用的通信开源项目,对于大容量,高并发的通讯要求完全能够胜任,他广泛可用」· C++ 代码 · 共 57 行

// RTI_IO.cpp,v 1.2 2003/10/28 18:34:32 bala Exp

#include "RTI_IO.h"
#include "ace/Log_Msg.h"

void
print_RtiPacket (Cubit::RtiPacket const &arg)
{
  ACE_DEBUG ((LM_DEBUG, 
              "packetHeader.packetLength %d\n"
              "packetHeader.federationHandle %d\n"
              "packetHeader.channelHandle %d\n"
              "packetHeader.packetColor %d\n",
              arg.packetHeader.packetLength,
              arg.packetHeader.federationHandle,
              arg.packetHeader.channelHandle,
              arg.packetHeader.packetColor));

  for (CORBA::ULong j = 0; j < arg.msgs.length (); ++j) 
    {
      ACE_DEBUG ((LM_DEBUG,
                  "* message * %d\n",
                  j));

      Cubit::RtiObjectUpdateMessageHeader const &oumh = arg.msgs[j].oumh ();

      ACE_DEBUG ((LM_DEBUG,
                  "\tupdateLength: %d\n" 
                  "\tupdateTag: %d\n"
                  "\tobjectHandle: %d\n" 
                  "\ttimestamp: %f\n"
                  //"\teventRetractionHandle: \n"
                  "\tclassHandle: %d\n" 
                  "\tsendingFederateHandle: %d\n"
                  "\tuserTag: %s\n"
                  "\ttransportationHandle: %x\n"
                  "\torderingHandle: %x\n",
                  oumh.updateLength,
                  oumh.updateTag,
                  oumh.objectHandle,
                  oumh.timestamp,
                  //oumh.eventRetractionHandle,
                  oumh.classHandle,
                  oumh.sendingFederateHandle,
                  oumh.userTag.in (),
                  oumh.transportationHandle,
                  oumh.orderingHandle));

      for (CORBA::ULong k = 0; k < oumh.messagePayload.length (); ++k) 
        {
          Cubit::HandleValuePair const & hvp=oumh.messagePayload[k];
          ACE_DEBUG ((LM_DEBUG, "\t\thandle: %d\n", hvp.handle));
        }
    }

}