kvh_geo_fog_3d_packet_storage.hpp

Go to the documentation of this file.

/*********************************************************************
 * Software License Agreement (Apache 2.0)
 * 
 *  Copyright (c) 2019, The MITRE Corporation.
 *  All rights reserved.
 * 
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * 
 *     https://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * Sections of this project contains content developed by The MITRE Corporation.
 * If this code is used in a deployment or embedded within another project,
 * it is requested that you send an email to opensource@mitre.org in order to
 * let us know where this software is being used.
 *********************************************************************/

#pragma once

// STD
#include <map>
#include <memory> // share_ptr
#include <vector>
#include <typeinfo>


// GEO-FOG SDK
#include "an_packet_protocol.h"
#include "spatial_packets.h"
#include "kvh_geo_fog_3d_global_vars.hpp"

namespace kvh
{

  typedef std::map<packet_id_e, std::pair<bool, std::shared_ptr<void>>> KvhPacketMap;

  typedef std::vector<std::pair<packet_id_e, uint16_t>> KvhPacketRequest;

  class KvhPacketStorage
  {

  private:
    KvhPacketMap packetMap_; 

  public:
    KvhPacketStorage();

    int Init(KvhPacketRequest &);

    template <class T>
    int UpdatePacket(packet_id_e _packetId, T& _packetData)
    {
      // Check if packet type matches packet id
      if (supportedPackets_.count(_packetId) <= 0 || packetTypeStr_[_packetId] != typeid(T).name())
      {
        return -1;
      }
      else if (this->Contains(_packetId))
      {
        *static_cast<T*>(packetMap_[_packetId].second.get()) = _packetData;
        return 0;
      }

      return -2;
    }
    
    int SetPacketUpdated(packet_id_e, bool);

    bool PacketIsUpdated(packet_id_e);

    template <class T>
    int GetPacket(packet_id_e _packetId, T& _packet)
    {
      // Check if packet types matches id
      if (supportedPackets_.count(_packetId) <= 0 || packetTypeStr_[_packetId] != typeid(T).name())
      {
        return -1;
      }
      else if (this->Contains(_packetId))
      {
        _packet = *static_cast<T*>(packetMap_[_packetId].second.get());
        return 0;
      }

      return -2;
    }

    bool Contains(packet_id_e);

    int Size();

    static void PrintPacketTypes();

    static void PrintPacketSizes();
  };
} // namespace kvh