Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Rename variables to avoid shadowed declarations.
authorArnaud Giersch <arnaud.giersch@univ-fcomte.fr>
Thu, 12 May 2022 08:29:08 +0000 (10:29 +0200)
committerArnaud Giersch <arnaud.giersch@univ-fcomte.fr>
Thu, 12 May 2022 16:00:26 +0000 (18:00 +0200)
examples/c/app-bittorrent/app-bittorrent.c
examples/c/app-bittorrent/bittorrent-peer.c
examples/c/app-bittorrent/bittorrent-peer.h
examples/c/app-bittorrent/tracker.c
examples/c/app-bittorrent/tracker.h
src/kernel/activity/ActivityImpl.cpp
src/kernel/actor/ActorImpl.cpp
src/mc/sosp/Region.cpp

index e8edbb8..71aa208 100644 (file)
@@ -20,8 +20,8 @@ int main(int argc, char* argv[])
 
   simgrid_load_platform(argv[1]);
 
-  simgrid_register_function("tracker", tracker);
-  simgrid_register_function("peer", peer);
+  simgrid_register_function("tracker", tracker_run);
+  simgrid_register_function("peer", peer_run);
 
   simgrid_load_deployment(argv[2]);
 
index 9a0e826..2d5275c 100644 (file)
@@ -77,7 +77,7 @@ static void peer_free(peer_t peer)
 }
 
 /** Peer main function */
-void peer(int argc, char* argv[])
+void peer_run(int argc, char* argv[])
 {
   // Check arguments
   xbt_assert(argc == 3 || argc == 4, "Wrong number of arguments");
index 6020c06..70171a6 100644 (file)
@@ -57,7 +57,7 @@ typedef s_peer_t* peer_t;
 typedef const s_peer_t* const_peer_t;
 
 /** Peer main function */
-void peer(int argc, char* argv[]);
+void peer_run(int argc, char* argv[]);
 
 int get_peers_from_tracker(const_peer_t peer);
 void send_handshake_to_all_peers(const_peer_t peer);
index d103c5c..6014e5a 100644 (file)
@@ -25,7 +25,7 @@ static int is_in_list(const_xbt_dynar_t peers, int id)
   return xbt_dynar_member(peers, &id);
 }
 
-void tracker(int argc, char* argv[])
+void tracker_run(int argc, char* argv[])
 {
   // Checking arguments
   xbt_assert(argc == 2, "Wrong number of arguments for the tracker.");
index 292f0fe..33e2508 100644 (file)
@@ -9,7 +9,7 @@
 #include "app-bittorrent.h"
 #include <xbt/dynar.h>
 
-void tracker(int argc, char* argv[]);
+void tracker_run(int argc, char* argv[]);
 /** Tasks exchanged between a tracker and peers. */
 typedef struct s_tracker_query {
   int peer_id;                 // peer id
index 1c569d2..c75799a 100644 (file)
@@ -111,13 +111,13 @@ void ActivityImpl::wait_for(actor::ActorImpl* issuer, double timeout)
     /* we need a sleep action (even when the timeout is infinite) to be notified of host failures */
     /* Comms handle that a bit differently of the other activities */
     if (auto* comm = dynamic_cast<CommImpl*>(this)) {
-      resource::Action* sleep = issuer->get_host()->get_cpu()->sleep(timeout);
-      sleep->set_activity(comm);
+      resource::Action* sleep_action = issuer->get_host()->get_cpu()->sleep(timeout);
+      sleep_action->set_activity(comm);
 
       if (issuer == comm->src_actor_)
-        comm->src_timeout_ = sleep;
+        comm->src_timeout_ = sleep_action;
       else
-        comm->dst_timeout_ = sleep;
+        comm->dst_timeout_ = sleep_action;
     } else {
       SynchroImplPtr synchro(new SynchroImpl([this, issuer]() {
         this->unregister_simcall(&issuer->simcall_);
index bb502be..bb40b4d 100644 (file)
@@ -367,17 +367,17 @@ void ActorImpl::resume()
 
 activity::ActivityImplPtr ActorImpl::join(const ActorImpl* actor, double timeout)
 {
-  activity::ActivityImplPtr sleep = this->sleep(timeout);
+  activity::ActivityImplPtr sleep_activity = this->sleep(timeout);
   if (actor->wannadie() || actor->to_be_freed()) {
-    if (sleep->surf_action_)
-      sleep->surf_action_->finish(resource::Action::State::FINISHED);
+    if (sleep_activity->surf_action_)
+      sleep_activity->surf_action_->finish(resource::Action::State::FINISHED);
   } else {
-    actor->on_exit->emplace_back([sleep](bool) {
-      if (sleep->surf_action_)
-        sleep->surf_action_->finish(resource::Action::State::FINISHED);
+    actor->on_exit->emplace_back([sleep_activity](bool) {
+      if (sleep_activity->surf_action_)
+        sleep_activity->surf_action_->finish(resource::Action::State::FINISHED);
     });
   }
-  return sleep;
+  return sleep_activity;
 }
 
 activity::ActivityImplPtr ActorImpl::sleep(double duration)
@@ -386,9 +386,9 @@ activity::ActivityImplPtr ActorImpl::sleep(double duration)
     throw_exception(std::make_exception_ptr(HostFailureException(
         XBT_THROW_POINT, std::string("Host ") + host_->get_cname() + " failed, you cannot sleep there.")));
 
-  auto sleep = new activity::SleepImpl();
-  sleep->set_name("sleep").set_host(host_).set_duration(duration).start();
-  return activity::SleepImplPtr(sleep);
+  auto sleep_activity = new activity::SleepImpl();
+  sleep_activity->set_name("sleep").set_host(host_).set_duration(duration).start();
+  return activity::SleepImplPtr(sleep_activity);
 }
 
 void ActorImpl::throw_exception(std::exception_ptr e)
index 74b573f..c11f781 100644 (file)
@@ -54,8 +54,8 @@ void* Region::read(void* target, const void* addr, std::size_t size) const
   xbt_assert(contain(simgrid::mc::remote(addr)), "Trying to read out of the region boundary.");
 
   // Last byte of the region:
-  const void* end = (const char*)addr + size - 1;
-  if (simgrid::mc::mmu::same_chunk((std::uintptr_t)addr, (std::uintptr_t)end)) {
+  const void* end_addr = (const char*)addr + size - 1;
+  if (simgrid::mc::mmu::same_chunk((std::uintptr_t)addr, (std::uintptr_t)end_addr)) {
     // The memory is contained in a single page:
     return mc_translate_address_region((uintptr_t)addr, this);
   }
@@ -66,7 +66,7 @@ void* Region::read(void* target, const void* addr, std::size_t size) const
   // We should remove this assumption.
 
   // Page of the last byte of the memory area:
-  size_t page_end = simgrid::mc::mmu::split((std::uintptr_t)end).first;
+  size_t page_end = simgrid::mc::mmu::split((std::uintptr_t)end_addr).first;
 
   void* dest = target; // iterator in the buffer to where we should copy next