Adding android support

Change-Id: Id8d0aaf61e6576209a8e329aa26cb73113832296
Signed-off-by: Mauro Sardara <msardara+fdio@cisco.com>

4 files changed, 144 insertions, 4 deletions

diff --git a/icnet/ccnx/icnet_ccnx_local_connector.cc b/icnet/ccnx/icnet_ccnx_local_connector.cc
index 2a47c117..efe995cc 100644
--- a/icnet/ccnx/icnet_ccnx_local_connector.cc
+++ b/icnet/ccnx/icnet_ccnx_local_connector.cc
@@ -13,8 +13,13 @@
  * limitations under the License.
  */
 
+#ifdef __ANDROID__
+#include <android/log.h>
+#endif
+
 #include "icnet_ccnx_local_connector.h"
 
+
 namespace icnet {
 
 namespace ccnx {
@@ -131,7 +136,11 @@ void LocalConnector::doReadHeader() {
 
 void LocalConnector::tryReconnect() {
   if (!is_connecting_) {
+#ifdef __ANDROID__
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Connection lost. Trying to reconnect...\n");
+#else
     std::cerr << "Connection lost. Trying to reconnect..." << std::endl;
+#endif
     is_connecting_ = true;
     is_reconnection_ = true;
     io_service_.post([this]() {
@@ -158,7 +167,11 @@ void LocalConnector::doConnect() {
 
                                  if (is_reconnection_) {
                                    is_reconnection_ = false;
-                                   std::cout << "Connection recovered!" << std::endl;
+#ifdef __ANDROID__
+                                     __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Connection recovered!\n");
+#else
+                                     std::cout << "Connection recovered!" << std::endl;
+#endif
                                    for (auto &name : served_name_list_) {
                                      bind(name);
                                    }
@@ -184,7 +197,11 @@ void LocalConnector::handleDeadline(const boost::system::error_code &ec) {
   if (!ec) {
     io_service_.post([this]() {
       socket_.close();
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Error connecting. Is the forwarder running?\n");
+#else
       std::cerr << "Error connecting. Is the forwarder running?" << std::endl;
+#endif
       io_service_.stop();
     });
   }
diff --git a/icnet/ccnx/icnet_ccnx_portal.cc b/icnet/ccnx/icnet_ccnx_portal.cc
index 99e2ee7f..33e8c82f 100644
--- a/icnet/ccnx/icnet_ccnx_portal.cc
+++ b/icnet/ccnx/icnet_ccnx_portal.cc
@@ -12,6 +12,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+#ifdef __ANDROID__
+#include <android/log.h>
+#endif
 
 #include "icnet_ccnx_portal.h"
 
@@ -135,9 +138,17 @@ void Portal::processControlMessage(CCNxMetaMessage *response) {
   CCNxControl *control_message = ccnxMetaMessage_GetControl(response);
 
   if (ccnxControl_IsACK(control_message)) {
+#ifdef __ANDROID__
+    __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Route set correctly!\n");
+#else
     std::cout << "Route set correctly!" << std::endl;
+#endif
   } else {
+#ifdef __ANDROID__
+    __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Failed to set the route.\n");
+#else
     std::cout << "Failed to set the route." << std::endl;
+#endif
   }
 }
 
diff --git a/icnet/transport/icnet_transport_raaqm.cc b/icnet/transport/icnet_transport_raaqm.cc
index 9a1b77b4..1a2856e0 100644
--- a/icnet/transport/icnet_transport_raaqm.cc
+++ b/icnet/transport/icnet_transport_raaqm.cc
@@ -13,6 +13,10 @@
  * limitations under the License.
  */
 
+#ifdef __ANDROID__
+#include <android/log.h>
+#endif
+
 #include "icnet_transport_raaqm.h"
 
 namespace icnet {
@@ -50,11 +54,19 @@ void RaaqmTransportProtocol::init() {
   avg_rtt_ = 0.0;
 
   if (!is) {
+#ifdef __ANDROID__
+    __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "WARNING: RAAQM parameters not found, set default values\n");
+#else
     std::cout << "WARNING: RAAQM parameters not found, set default values" << std::endl;
+#endif
     return;
   }
 
+#ifdef __ANDROID__
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Setting RAAQM parameters:\n");
+#else
   std::cout << "Setting RAAQM parameters:" << std::endl;
+#endif
   while (getline(is, line)) {
     std::string command;
     std::istringstream line_s(line);
@@ -74,7 +86,11 @@ void RaaqmTransportProtocol::init() {
       } else {
         raaqm_autotune_ = false;
       }
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  autotune = %s",raaqm_autotune_ == 1 ? "true" : "false");
+#else
       std::cout << "params:  autotune = " << raaqm_autotune_ << std::endl;
+#endif
       continue;
     }
 
@@ -82,7 +98,11 @@ void RaaqmTransportProtocol::init() {
       std::string tmp;
       int lifetime;
       line_s >> tmp >> lifetime;
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  lifetime = %d\n", lifetime);
+#else
       std::cout << "params:  lifetime = " << lifetime << std::endl;
+#endif
       socket_->setSocketOption(GeneralTransportOptions::INTEREST_LIFETIME, lifetime);
       continue;
     }
@@ -91,7 +111,11 @@ void RaaqmTransportProtocol::init() {
       std::string tmp;
       int rtx;
       line_s >> tmp >> rtx;
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  retransmissions = %d\n", rtx);
+#else
       std::cout << "params:  retransmissions = " << rtx << std::endl;
+#endif
       socket_->setSocketOption(ConsumerCallbacksOptions::INTEREST_RETRANSMISSION, rtx);
       continue;
     }
@@ -99,7 +123,11 @@ void RaaqmTransportProtocol::init() {
     if (command == "beta") {
       std::string tmp;
       line_s >> tmp >> default_beta_;
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  beta = %f\n", default_beta_);
+#else
       std::cout << "params:  beta = " << default_beta_ << std::endl;
+#endif
       socket_->setSocketOption(RaaqmTransportOptions::BETA_VALUE, default_beta_);
       continue;
     }
@@ -107,7 +135,11 @@ void RaaqmTransportProtocol::init() {
     if (command == "drop") {
       std::string tmp;
       line_s >> tmp >> default_drop_;
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  drop = %f\n", default_drop_);
+#else
       std::cout << "params:  drop = " << default_drop_ << std::endl;
+#endif
       socket_->setSocketOption(RaaqmTransportOptions::DROP_FACTOR, default_drop_);
       continue;
     }
@@ -115,42 +147,66 @@ void RaaqmTransportProtocol::init() {
     if (command == "beta_wifi_") {
       std::string tmp;
       line_s >> tmp >> beta_wifi_;
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  beta_wifi_ = %f\n", beta_wifi_);
+#else
       std::cout << "params:  beta_wifi_ = " << beta_wifi_ << std::endl;
+#endif
       continue;
     }
 
     if (command == "drop_wifi_") {
       std::string tmp;
       line_s >> tmp >> drop_wifi_;
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  drop_wifi_ = %f\n", drop_wifi_);
+#else
       std::cout << "params:  drop_wifi_ = " << drop_wifi_ << std::endl;
+#endif
       continue;
     }
 
     if (command == "beta_lte_") {
       std::string tmp;
       line_s >> tmp >> beta_lte_;
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  beta_lte_ = %f\n", beta_lte_);
+#else
       std::cout << "params:  beta_lte_ = " << beta_lte_ << std::endl;
+#endif
       continue;
     }
 
     if (command == "drop_lte_") {
       std::string tmp;
       line_s >> tmp >> drop_lte_;
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  drop_lte_ = %f\n", drop_lte_);
+#else
       std::cout << "params:  drop_lte_ = " << drop_lte_ << std::endl;
+#endif
       continue;
     }
 
     if (command == "wifi_delay_") {
       std::string tmp;
       line_s >> tmp >> wifi_delay_;
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  wifi_delay_ = %u\n", wifi_delay_);
+#else
       std::cout << "params:  wifi_delay_ = " << wifi_delay_ << std::endl;
+#endif
       continue;
     }
 
     if (command == "lte_delay_") {
       std::string tmp;
       line_s >> tmp >> lte_delay_;
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  lte_delay_ = %u\n", lte_delay_);
+#else
       std::cout << "params:  lte_delay_ = " << lte_delay_ << std::endl;
+#endif
       continue;
     }
     if (command == "alpha") {
@@ -158,7 +214,11 @@ void RaaqmTransportProtocol::init() {
       double rate_alpha = 0.0;
       line_s >> tmp >> rate_alpha;
       socket_->setSocketOption(RateEstimationOptions::RATE_ESTIMATION_ALPHA, rate_alpha);
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  alpha = %f\n", rate_alpha);
+#else
       std::cout << "params:  alpha = " << rate_alpha << std::endl;
+#endif
       continue;
     }
 
@@ -167,7 +227,11 @@ void RaaqmTransportProtocol::init() {
       int batching_param = 0;
       line_s >> tmp >> batching_param;
       socket_->setSocketOption(RateEstimationOptions::RATE_ESTIMATION_BATCH_PARAMETER, batching_param);
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params:  batching = %d\n", batching_param);
+#else
       std::cout << "params:  batching = " << batching_param << std::endl;
+#endif
       continue;
     }
 
@@ -176,12 +240,20 @@ void RaaqmTransportProtocol::init() {
       int choice_param = 0;
       line_s >> tmp >> choice_param;
       socket_->setSocketOption(RateEstimationOptions::RATE_ESTIMATION_CHOICE, choice_param);
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "params: choice = %d\n", choice_param);
+#else
       std::cout << "params: choice = " << choice_param << std::endl;
+#endif
       continue;
     }
   }
   is.close();
+#ifdef __ANDROID__
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "init done\n");
+#else
   std::cout << "init done" << std::endl;
+#endif
 }
 
 void RaaqmTransportProtocol::reset() {
@@ -216,12 +288,19 @@ void RaaqmTransportProtocol::start() {
     socket_->getSocketOption(SAMPLE_NUMBER, sample_number);
     socket_->getSocketOption(INTEREST_LIFETIME, interest_lifetime);
     socket_->getSocketOption(BETA_VALUE, beta);
-
+#ifdef __ANDROID__
+    __android_log_print(ANDROID_LOG_DEBUG, "Drop Factor: %f\n", drop_factor);
+    __android_log_print(ANDROID_LOG_DEBUG, "Minimum drop prob: %f\n", minimum_drop_probability);
+    __android_log_print(ANDROID_LOG_DEBUG, "Sample number: %d\n", sample_number);
+    __android_log_print(ANDROID_LOG_DEBUG, "lifetime: %d\n", interest_lifetime);
+    __android_log_print(ANDROID_LOG_DEBUG, "beta: %f\n", beta);
+#else
     std::cout << "Drop Factor: " << drop_factor << std::endl;
     std::cout << "Minimum drop prob: " << minimum_drop_probability << std::endl;
     std::cout << "Sample number: " << sample_number << std::endl;
     std::cout << "lifetime: " << interest_lifetime << std::endl;
     std::cout << "beta: " << beta << std::endl;
+#endif
 
     double alpha = 0.0;
     int batching_param = 0;
@@ -259,7 +338,11 @@ void RaaqmTransportProtocol::updatePathTable(const ContentObject &content_object
     if (cur_path_) {
       // Create a new path with some default param
       if (path_table_.empty()) {
+#ifdef __ANDROID__
+        __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "No path initialized for path table, error could be in default path initialization.\n");
+#else
         std::cerr << "No path initialized for path table, error could be in default path initialization." << std::endl;
+#endif
         exit(EXIT_FAILURE);
       } else {
         // Initiate the new path default param
@@ -269,7 +352,11 @@ void RaaqmTransportProtocol::updatePathTable(const ContentObject &content_object
         path_table_[path_id] = new_path;
       }
     } else {
+#ifdef __ANDROID__
+      __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "UNEXPECTED ERROR: when running,current path not found.\n");
+#else
       std::cerr << "UNEXPECTED ERROR: when running,current path not found." << std::endl;
+#endif
       exit(EXIT_FAILURE);
     }
   }
@@ -344,10 +431,12 @@ void RaaqmTransportProtocol::check_drop_probability() {
   if (drop_prob == old_drop_prob && beta == old_beta) {
     return;
   }
-
+#ifdef __ANDROID__
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "*************[RAAQM TUNING] new beta = %f new drop = %f max pd = %u\n", beta, drop_prob, max_pd);
+#else
   std::cout << "*************[RAAQM TUNING] new beta = " << beta << " new drop = " << drop_prob << " max pd = "
             << max_pd << std::endl;
-
+#endif
   socket_->setSocketOption(BETA_VALUE, beta);
   socket_->setSocketOption(DROP_FACTOR, drop_prob);
 
@@ -413,7 +502,11 @@ void RaaqmTransportProtocol::decreaseWindow() {
 
 void RaaqmTransportProtocol::RAAQM() {
   if (!cur_path_) {
+#ifdef __ANDROID__
+    __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "ERROR: no current path found, exit\n");
+#else
     std::cerr << "ERROR: no current path found, exit" << std::endl;
+#endif
     exit(EXIT_FAILURE);
   } else {
     // Change drop probability according to RTT statistics
@@ -453,8 +546,12 @@ RaaqmTransportProtocol::onInterest(const Interest &interest)
     uint64_t segment = name[-1].toSegment();
     timeval now;
     gettimeofday(&now, 0);
+#ifdef __ANDROID__
+    __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "%ld.%u RAAQM: M-Interest %ld %s\n", (long) now.tv_sec, (unsigned) now.tv_usec, segment, interest.getName());
+#else
     std::cout << (long) now.tv_sec << "." << (unsigned) now.tv_usec << " RAAQM: M-Interest " <<
     segment << " " << interest.getName() << std::endl;
+#endif
     NackSet::iterator it = m_nackSet.find(segment);
     if(it == m_nackSet.end()){
       m_nackSet.insert(segment);
diff --git a/icnet/transport/icnet_transport_raaqm_data_path.cc b/icnet/transport/icnet_transport_raaqm_data_path.cc
index dfef6762..1ff3f667 100644
--- a/icnet/transport/icnet_transport_raaqm_data_path.cc
+++ b/icnet/transport/icnet_transport_raaqm_data_path.cc
@@ -12,6 +12,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+#ifdef __ANDROID__
+#include <android/log.h>
+#endif
 
 #include "icnet_transport_raaqm_data_path.h"
 
@@ -56,11 +59,23 @@ RaaqmDataPath &RaaqmDataPath::pathReporter() {
 
   delta_t = getMicroSeconds(now) - getMicroSeconds(previous_call_of_path_reporter_);
   rate = (m_packets_bytes_received_ - last_packets_bytes_received_) * 8 / delta_t; // MB/s
+#ifdef __ANDROID__
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "RaaqmDataPath status report: at time %ld . %ld \n", now.tv_sec,  now.tv_usec);
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "path\n");
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Packets Received: %lld\n", (packets_received_ - last_packets_received_));
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "delta_t %f [us]\n", delta_t);
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "rate %f [Mbps]\n", rate);
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Last RTT %llu [us]\n", rtt_);
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Max RTT %llu [us]\n", rtt_max_);
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Min RTT %llu [us]\n", rtt_min_);
+  __android_log_print(ANDROID_LOG_DEBUG, "libICNet", "Prop delay %llu [us]\n", prop_delay_);
+#else
   std::cout << "RaaqmDataPath status report: " << "at time " << (long) now.tv_sec << "." << (unsigned) now.tv_usec
             << " sec:\n" << (void *) this << " path\n" << "Packets Received: "
             << (packets_received_ - last_packets_received_) << "\n" << "delta_t " << delta_t << " [us]\n" << "rate "
             << rate << " [Mbps]\n" << "Last RTT " << rtt_ << " [us]\n" << "Max RTT " << rtt_max_ << " [us]\n"
             << "Min RTT " << rtt_min_ << " [us]\n" << "Prop delay " << prop_delay_ << " [us]\n";
+#endif
   last_packets_received_ = packets_received_;
   last_packets_bytes_received_ = m_packets_bytes_received_;
   gettimeofday(&previous_call_of_path_reporter_, 0);