queueHeader.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2016 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;


      DtNetU8 subscribers[DtSubscribableMessageQueue::theMaxSubscribers];

      DtNetU32 readHead[DtSubscribableMessageQueue::theMaxSubscribers];

      DtNetU8 readHeadLoopCounts[DtSubscribableMessageQueue::theMaxSubscribers];

      DtNetU32 subscribed[DtSubscribableMessageQueue::theMaxSubscribers];

      DtNetU32 subscriberDrops[DtSubscribableMessageQueue::theMaxSubscribers];

      DtNetU32 writeHead;

      DtNetU8 writeHeadLoopCount;

      boost::interprocess::interprocess_mutex rwlock;


      DtNetU32 lastXPtr;
      DtNetU32 lastXSize;
      DtNetU32 currentTrackableSize;
      DtNetU32 maxTrackableSize;


   };


   struct DtBucketHeader
   {
      DtNetU8 senderId; 
      DtNetU32 sizeInBytes;
   };

}