queueHeader.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2015 VT MAK
 * All rights reserved.
 ****************************************************************************/


#pragma once

#include <boost/interprocess/sync/interprocess_mutex.hpp>
#include <portal/smSubscribableMessageQueue.h>
#include <vlutil/vlNetTypes.h>

namespace MAKVrExchange
{

   struct DtQueueHeader
   {
      DtNetU32 payloadSize;
      DtNetU32 numberOfBuckets;
      DtNetU32 front[DtSubscribableMessageQueue::theMaxSubscribers];
      DtNetU32 subscribed[DtSubscribableMessageQueue::theMaxSubscribers];
      DtNetU32 subscriberDrops[DtSubscribableMessageQueue::theMaxSubscribers];
      DtNetU32 back;
      boost::interprocess::interprocess_mutex rwlock;

      //The following are used strictly for performance information
      DtNetU32 lastXPtr;
      DtNetU32 lastXSize;
      DtNetU32 currentTrackableSize;
      DtNetU32 maxTrackableSize;
   };

   struct DtBucketHeader
   {
      DtNetU8 senderId; 
      DtNetU32 sizeInBytes;
   };

}