Easyelectronics.ru

struct WaitingPackage
{
   Time wasCreated = 0;
   Time nextTransmission = 0;
   bool isBroadcast = false;
   PackageTimings timings;
   PackageSendingDoneCallback callback;
   Package package;
};

using PackageId = uint16_t;


std::vector<WaitingPackage> m_waitingPackages;
std::vector<PackageId> m_lastReceivedIds;





bool package_already_received(PackageId packageID){

   bool result;
   std::vector<PackageId>::iterator findIter = std::find( m_lastReceivedIds.begin(),  m_lastReceivedIds.end(), packageID);
   result = (findIter!=m_lastReceivedIds.end());
   return result;


}


void lastReceivedIdsAdd(PackageId packageID){

   if (m_lastReceivedIds.size() >= last_packages_max_size){
      m_lastReceivedIds.erase(m_lastReceivedIds.begin());
   }
      m_lastReceivedIds.push_back(packageID);
}



void remove_waiting_package(PackageId packageID){
   for (auto it = m_waitingPackages.begin(); it != m_waitingPackages.end(); it++)
      {
         if ((*it).package.details.packageId == packageID){
            m_waitingPackages.erase(it);
            return;
         }
   }

}