Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
sonar
authorMartin Quinson <martin.quinson@loria.fr>
Wed, 29 Aug 2018 13:19:17 +0000 (15:19 +0200)
committerMartin Quinson <martin.quinson@loria.fr>
Wed, 29 Aug 2018 13:19:17 +0000 (15:19 +0200)
include/simgrid/forward.h
include/smpi/smpi_helpers_internal.h
src/kernel/context/Context.hpp
src/msg/msg_gos.cpp

index c95d3ff..38d662d 100644 (file)
@@ -176,7 +176,6 @@ typedef simgrid::kernel::actor::ActorImpl* smx_actor_t;
 typedef simgrid::kernel::activity::ConditionVariableImpl* smx_cond_t;
 typedef simgrid::kernel::activity::MutexImpl* smx_mutex_t;
 typedef simgrid::kernel::activity::MailboxImpl* smx_mailbox_t;
-typedef simgrid::surf::StorageImpl* surf_storage_t;
 
 #else
 
@@ -195,7 +194,6 @@ typedef struct s_smx_actor* smx_actor_t;
 typedef struct s_smx_cond_t* smx_cond_t;
 typedef struct s_smx_mutex* smx_mutex_t;
 typedef struct s_smx_mailbox* smx_mailbox_t;
-typedef struct s_surf_storage* surf_storage_t;
 
 #endif
 
index 0c78541..8977aa2 100644 (file)
@@ -6,6 +6,7 @@
 #ifndef SMPI_HELPERS_INTERNAL_H
 #define SMPI_HELPERS_INTERNAL_H
 
+#include <getopt.h>
 #include <unistd.h>
 
 #include <sys/time.h>
@@ -25,7 +26,6 @@ int smpi_clock_gettime(clockid_t clk_id, struct timespec* tp);
 unsigned int smpi_sleep(unsigned int secs);
 int smpi_gettimeofday(struct timeval* tv, struct timezone* tz);
 
-struct option;
 int smpi_getopt_long_only(int argc, char* const* argv, const char* options, const struct option* long_options,
                           int* opt_index);
 int smpi_getopt_long(int argc, char* const* argv, const char* options, const struct option* long_options,
index ac073ab..082677c 100644 (file)
@@ -63,7 +63,8 @@ public:
      */
   public:
     StopRequest() = default;
-    StopRequest(std::string msg) : msg_(msg) { }
+    explicit StopRequest(std::string msg) : msg_(msg) {}
+
   private:
     std::string msg_;
   };
index 97781b9..3c8121b 100644 (file)
@@ -83,13 +83,10 @@ msg_error_t MSG_parallel_task_execute_with_timeout(msg_task_t task, double timeo
   } catch (simgrid::TimeoutError& e) {
     status = MSG_TIMEOUT;
   } catch (xbt_ex& e) {
-    switch (e.category) {
-    case cancel_error:
+    if (e.category == cancel_error)
       status = MSG_TASK_CANCELED;
-      break;
-    default:
+    else
       throw;
-    }
   }
 
   /* action ended, set comm and compute = nullptr, the actions is already destroyed in the main function */
@@ -486,13 +483,11 @@ int MSG_comm_test(msg_comm_t comm)
     finished     = true;
   }
   catch (xbt_ex& e) {
-    switch (e.category) {
-      case network_error:
-        comm->status = MSG_TRANSFER_FAILURE;
-        finished     = true;
-        break;
-      default:
-        throw;
+    if (e.category == network_error) {
+      comm->status = MSG_TRANSFER_FAILURE;
+      finished     = true;
+    } else {
+      throw;
     }
   }
 
@@ -584,13 +579,10 @@ msg_error_t MSG_comm_wait(msg_comm_t comm, double timeout)
     comm->status = MSG_TIMEOUT;
   }
   catch (xbt_ex& e) {
-    switch (e.category) {
-    case network_error:
+    if (e.category == network_error)
       comm->status = MSG_TRANSFER_FAILURE;
-      break;
-    default:
+    else
       throw;
-    }
   }
 
   return comm->status;
@@ -638,13 +630,11 @@ int MSG_comm_waitany(xbt_dynar_t comms)
     status         = MSG_TIMEOUT;
   }
   catch(xbt_ex& e) {
-    switch (e.category) {
-      case network_error:
-        finished_index = e.value;
-        status = MSG_TRANSFER_FAILURE;
-        break;
-      default:
-        throw;
+    if (e.category == network_error) {
+      finished_index = e.value;
+      status         = MSG_TRANSFER_FAILURE;
+    } else {
+      throw;
     }
   }