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 &);
 
    int AddPacket(packet_id_e);
 
    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