io.h

Go to the documentation of this file.

#pragma once

#include <map>
#include <deque>
#include <mist/shared_memory.h>
#include <mist/defines.h>
#include <mist/dtsc.h>

#include <mist/encryption.h>//LTS
namespace Mist {
  enum negotiationState {
    FILL_NEW,
    FILL_NEG,
    FILL_DEC,
    FILL_ACC
  };

  struct DTSCPageData {
    DTSCPageData() : pageNum(0), keyNum(0), partNum(0), dataSize(0), curOffset(0), firstTime(0), lastKeyTime(-5000){}
    unsigned long pageNum;
    unsigned long keyNum;
    unsigned long partNum;
    unsigned long long int dataSize;
    unsigned long long int curOffset;
    unsigned long long int firstTime;
    unsigned long lastKeyTime;
  };

  class negotiationProxy {
    public:
      negotiationProxy() : encrypt(false) {}
      void initiateEncryption();//LTS
      bool bufferStart(unsigned long tid, unsigned long pageNumber, DTSC::Meta & myMeta);
      void bufferNext(DTSC::Packet & pack, DTSC::Meta & myMeta);
      void bufferFinalize(unsigned long tid, DTSC::Meta &myMeta);
      void bufferLivePacket(DTSC::Packet & packet, DTSC::Meta & myMeta);
      bool isBuffered(unsigned long tid, unsigned long keyNum);
      unsigned long bufferedOnPage(unsigned long tid, unsigned long keyNum);




      std::map<unsigned long, std::map<unsigned long, DTSCPageData> > pagesByTrack;

      //Negotiation stuff (from unmapped tid's)
      std::map<unsigned long, unsigned long> trackOffset; 
      std::map<unsigned long, negotiationState> trackState; 
      std::map<unsigned long, unsigned long> trackMap;
      std::map<unsigned long, IPC::sharedPage> metaPages;
      std::map<unsigned long, unsigned long> curPageNum;
      std::map<unsigned long, IPC::sharedPage> curPage;

      IPC::sharedClient userClient;

      std::string streamName;

      bool encrypt;
      Encryption::verimatrixData vmData;
      std::map<int,unsigned long long int> iVecs;
      IPC::sharedPage encryptionPage;

      void continueNegotiate(unsigned long tid, DTSC::Meta & myMeta);
  };

  class InOutBase {
    public:
      void initiateMeta();
      bool bufferStart(unsigned long tid, unsigned long pageNumber);
      void bufferNext(DTSC::Packet & pack);
      void bufferNext(JSON::Value & pack);
      void bufferFinalize(unsigned long tid);
      void bufferRemove(unsigned long tid, unsigned long pageNumber);
      void bufferLivePacket(JSON::Value & packet);
      void bufferLivePacket(DTSC::Packet & packet);
    protected:
      void continueNegotiate(unsigned long tid);



      bool standAlone;
      static Util::Config * config;

      negotiationProxy nProxy;

      DTSC::Packet thisPacket;//The current packet that is being parsed

      std::string streamName;


      std::set<unsigned long> selectedTracks;

      DTSC::Meta myMeta;
  };
}