commit aa60c96f609ba4a3c92344c77bbb63e6d7e116fa
author Zhiyi Zhang <zhiyi@cs.ucla.edu> Fri Jan 22 10:57:41 2021 -0800
committer Zhiyi Zhang <zhiyi@cs.ucla.edu> Fri Jan 22 10:57:41 2021 -0800
tree 20d7821acc693463e483307143fb1d136e777538
parent 276ba786afc52d404188f6c568ebc735e33c5d9b

update systemd default parameter in NDNCERT and update ndncert-ca-server

Change-Id: I56d01b5125602ca54b9726225ca50e26630ddd39

tools/ndncert-ca-server.cpp

diff --git a/tools/ndncert-ca-server.cpp b/tools/ndncert-ca-server.cpp
index 8a17c28..f803a97 100644
--- a/tools/ndncert-ca-server.cpp
+++ b/tools/ndncert-ca-server.cpp
@@ -26,6 +26,7 @@
 #include <boost/program_options/variables_map.hpp>
 #include <iostream>
 #include <chrono>
+#include <deque>
 #include <ndn-cxx/face.hpp>
 #include <ndn-cxx/security/key-chain.hpp>
 
@@ -37,6 +38,7 @@
 security::KeyChain keyChain;
 std::string repoHost = "localhost";
 std::string repoPort = "7376";
+const size_t MAX_CACHED_CERT_NUM = 100;
 
 static bool
 writeDataToRepo(const Data& data) {
@@ -48,7 +50,7 @@
 #endif //BOOST_VERSION >= 106600
   requestStream.connect(repoHost, repoPort);
   if (!requestStream) {
-    std::cerr << "ERROR: Cannot publish certificate to repo-ng"
+    std::cerr << "ERROR: Cannot publish the certificate to repo-ng"
               << " (" << requestStream.error().message() << ")" << std::endl;
     return false;
   }
@@ -118,7 +120,7 @@
   }
 
   CaModule ca(face, keyChain, configFilePath);
-  std::map<Name, Data> cachedCertificates;
+  std::deque<Data> cachedCertificates;
   auto profileData = ca.getCaProfileData();
 
   if (wantRepoOut) {
@@ -132,16 +134,25 @@
   else {
     ca.setStatusUpdateCallback([&](const RequestState& request) {
       if (request.status == Status::SUCCESS && request.requestType == RequestType::NEW) {
-        cachedCertificates[request.cert.getName()] = request.cert;
+        cachedCertificates.push_front(request.cert);
+        if (cachedCertificates.size() > MAX_CACHED_CERT_NUM) {
+          cachedCertificates.pop_back();
+        }
       }
     });
-    cachedCertificates[profileData.getName()] = profileData;
     face.setInterestFilter(
         InterestFilter(ca.getCaConf().caProfile.caPrefix),
         [&](const InterestFilter&, const Interest& interest) {
-          auto search = cachedCertificates.find(interest.getName());
-          if (search != cachedCertificates.end()) {
-            face.put(search->second);
+          const auto& interestName = interest.getName();
+          if (interestName.isPrefixOf(profileData.getName())) {
+            face.put(profileData);
+            return;
+          }
+          for (const auto& item : cachedCertificates) {
+            if (interestName.isPrefixOf(item.getName())) {
+              face.put(item);
+              return;
+            }
           }
         },
         [](const Name&, const std::string& errorInfo) {