TemporalMemory.h

Go to the documentation of this file.

 
#if !defined(_TEMPORALMEMORY_H_)
#define _TEMPORALMEMORY_H_
 
#include "MemoryManager.h"
#include "PsyTime.h"
 
namespace cmlabs {

    struct SlotEntryStruct {
        uint16 serial;      
        uint64 eol;         
        uint32 bin;         
        uint64 offset;      
        uint64 size;        
        uint64 usage;       
        uint32 startBlock;  
        uint32 blockUsage;  
        //uint32 blockSize;
    };

    struct TemporalMemoryStruct {
        uint64 size;            
        uint32 cid;             
        uint32 slotCount;       
        uint32 slotsInUse;      
        uint64 usage;           
        uint64 growStep;        
        uint64 maxSize;         
        uint64 createdTime;     // time of creation
        uint64 lastCheckTime;       
        uint64 checkTimeInterval;   
        uint16 binCount;        
        uint32 bitFieldSize; // number of bytes in the bitfield
        // Bitfield(bitFieldSize)
        // slotCount * SlotEntryStruct
        // bin0(size), bin1(size), bin2(size)...
    };

    struct BinHeaderStruct {
        uint64 size;        
        uint32 blockCount;  
        uint32 blockSize;   
        uint32 blocksInUse; 
        uint64 usage;       
        uint32 bitFieldSize; // number of bytes in the bitfield
        // Bitfield(bitFieldSize)
        // blockCount * blockSize data
    };
 
    //struct BinSpaceFit {
    //  uint32 bin;
    //  uint32 blocksNeeded;
    //  uint32 spaceWaisted;
    //};
    //bool BinSpaceFitSort(const BinSpaceFit& a, const BinSpaceFit& b) {
    //  return (a.blocksNeeded < b.blocksNeeded);
    //}

#define GETMSGNODE(id) (uint16)((id & 0xffff000000000000L)>>48)
#define GETMSGSERIAL(id) (uint16)((id & 0x0000ffff00000000L)>>32)
#define GETMSGSLOT(id) (uint32)(id & 0x00000000ffffffffL)
#define SETMSGID(id,node,serial,slot) id = (((uint64)node) << 48) | (((uint64)serial) << 32) | ((uint64)slot)

#define CHECKTEMPORALMEMORYSERIAL   if (serial != master->getDynamicShmemSerial()) {if (!open()) {mutex->leave();return 0;}}
 
    class MasterMemory;
    class TemporalMemory {
    public:
        TemporalMemory(MemoryController* master);
        ~TemporalMemory();

        bool getMemoryUsage(uint64& alloc, uint64& usage);

        bool open();
        bool create(uint32 slotCount, uint16 binCount, uint32 minBlockSize, uint32 maxBlockSize, uint64 initSize, uint64 maxSize, uint32 growSteps = 8);
        bool setNodeID(uint16 id);
 
        // Insert new block of memory and return full id
        bool insertMessage(DataMessage* msg, uint64& id);
        // Get copy of block of memory
        DataMessage* getCopyOfMessage(uint64 id);

        bool logUsage();

        bool maintenance();

        static bool UnitTest();
 
    private:
 
        std::vector<BinHeaderStruct> calcBinHeaders(uint32 binCount, uint32 minBlockSize, uint32 maxBlockSize, uint64 binDataSize);
        BinHeaderStruct* getBestBin(uint32 size, uint32& bin, uint32 &blocksNeeded);
        char* getMemoryBlock(uint64 id);
        bool checkSlots(uint64 now);
 
        bool resizeSlots();
        bool resizeBin(uint32 bin, BinHeaderStruct* binHeader, uint32 msgSize);
        std::vector<BinHeaderStruct> calcBinHeadersGrowth(uint32 bin = 0, uint32 msgSize = 0);
        bool resizeMemory(uint32 slotGrowth, std::vector<BinHeaderStruct>& binHeaderSizes);
 
        utils::Mutex* mutex;            
        MemoryController* master;       
        TemporalMemoryStruct* header;   
        SlotEntryStruct* slotEntries;   
        uint64 memorySize;              
        uint16 port;                    
        uint16 node;                    
        uint32 serial;                  
    };
 
 
//  
//  
//struct TemporalMemoryStruct {
//  uint64 size;
//  uint32 cid;
//  uint64 usage;
//  uint64 growStep;
//  uint64 maxSize;
//  uint64 createdTime;     // time of creation
//  uint16 slotCount;
//  uint64 slotSize;
//  uint32 slotDuration;
//  uint16 startSlot;
//  uint64 startTime;
//  // slots * SlotHeaderStruct
//};
//
//struct SlotHeaderStruct {
//  uint64 size;
//  uint32 count;
//  uint64 usage;
//  uint64 eol;
//  uint64 offset;
//};
//
//#define GETMSGNODE(id) (uint16)((id & 0xffff000000000000L)>>48)
//#define GETMSGSLOT(id) (uint16)((id & 0x0000ffff00000000L)>>32)
//#define GETMSGOFFSET(id) (uint64)(id & 0x00000000ffffffffL)
//#define SETMSGID(id,node,slot,offset) id = (((uint64)node) << 48) | (((uint64)slot) << 32) | ((uint64)offset)
//
//#define CHECKTEMPORALMEMORYSERIAL     if (serial != master->getDynamicShmemSerial()) {if (!open()) {mutex->leave();return 0;}}
//
//class MasterMemory;
//class TemporalMemory {
//public:
//  TemporalMemory(MemoryController* master);
//  ~TemporalMemory();
//
//  bool getMemoryUsage(uint64& alloc, uint64& usage);
//
//  bool open();
//  bool create(uint16 slotCount, uint32 slotDuration, uint64 initSize, uint64 maxSize, uint32 growSteps = 8);
//  bool setNodeID(uint16 id);
//
//  // Insert new block of memory and return full id
//  bool insertMessage(DataMessage* msg, uint64& id);
//  // Get copy of block of memory
//  DataMessage* getCopyOfMessage(uint64 id);
//
//  bool logUsage();
//
//  bool maintenance();
//
//  static bool UnitTest();
//
//private:
//  bool getSlotFromEOL(uint64 eol, uint16& slot);
//  char* getMemoryBlock(uint64 id);
//  bool growSlotSize(uint64 growAmount);
//  bool checkSlots();
//  bool resetSlot(uint16 slot, uint64 eol);
//  uint64 calcResizeAmount(uint32 msgSize);
//
//  utils::Mutex* mutex;
//  MemoryController* master;
//  TemporalMemoryStruct* header;
//  SlotHeaderStruct* slotHeaders;
//  uint64 memorySize;
//  uint16 port;
//  uint16 node;
//  uint32 serial;
//};
 
} // namespace cmlabs
 
#endif //_TEMPORALMEMORY_H_