Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Merge branch 'master' into depencencies
authorFrederic Suter <frederic.suter@cc.in2p3.fr>
Wed, 29 Jan 2020 20:21:15 +0000 (21:21 +0100)
committerFrederic Suter <frederic.suter@cc.in2p3.fr>
Wed, 29 Jan 2020 20:21:15 +0000 (21:21 +0100)
examples/deprecated/java/cloud/migration/Daemon.java
src/mc/ModelChecker.hpp
src/smpi/bindings/smpi_f77.cpp
src/smpi/include/private.hpp
src/surf/sg_platf.cpp

index 7013adb..d5fe01f 100644 (file)
@@ -18,7 +18,6 @@ public class Daemon extends Process {
   public void main(String[] args) throws MsgException {
     int i = 1;
     while(!Main.isEndOfTest()) {
-      // TODO the binding is not yet available
     try {
       currentTask.execute();
     } catch (HostFailureException e) {
index 50af859..53ff36b 100644 (file)
@@ -25,7 +25,6 @@ class ModelChecker {
   struct event* socket_event_ = nullptr;
   struct event* signal_event_ = nullptr;
   /** String pool for host names */
-  // TODO, use std::set with heterogeneous comparison lookup (C++14)?
   std::set<std::string> hostnames_;
   // This is the parent snapshot of the current state:
   PageStore page_store_{500};
index 451dfd7..86e43b5 100644 (file)
@@ -979,4 +979,16 @@ void mpi_file_write_ ( int* fh, void* buf, int* count, int* datatype, MPI_Status
   *ierr=  MPI_File_write(reinterpret_cast<MPI_File>(*fh), buf, *count, simgrid::smpi::Datatype::f2c(*datatype), status);
 }
 
+void smpi_execute_flops_(double* flops){
+  smpi_execute_flops(*flops);
+}
+
+void smpi_execute_(double* duration){
+  smpi_execute(*duration);
+}
+
+void smpi_execute_benched_(double* duration){
+  smpi_execute_benched(*duration);
+}
+
 } // extern "C"
index 07c4bfd..9f6c7d1 100644 (file)
@@ -461,6 +461,9 @@ void mpi_file_set_view_(int* fh, long long int* offset, int* etype, int* filetyp
 void mpi_file_read_(int* fh, void* buf, int* count, int* datatype, MPI_Status* status, int* ierr);
 void mpi_file_write_(int* fh, void* buf, int* count, int* datatype, MPI_Status* status, int* ierr);
 void smpi_init_fortran_types();
+void smpi_execute_flops_(double* flops);
+void smpi_execute_(double* duration);
+void smpi_execute_benched_(double* duration);
 } // extern "C"
 
 XBT_PRIVATE int smpi_temp_shm_get();
index 43a1913..8f89621 100644 (file)
@@ -116,6 +116,13 @@ simgrid::kernel::routing::NetPoint* sg_platf_new_router(const std::string& name,
 
 static void sg_platf_new_link(const simgrid::kernel::routing::LinkCreationArgs* link, const std::string& link_name)
 {
+  static double last_warned_latency = sg_surf_precision;
+  if (link->latency != 0.0 && link->latency < last_warned_latency) {
+    XBT_WARN("Latency for link %s is smaller than surf/precision (%g < %g)."
+             " For more accuracy, consider setting \"--cfg=surf/precision:%g\".",
+             link_name.c_str(), link->latency, sg_surf_precision, link->latency);
+    last_warned_latency = link->latency;
+  }
   simgrid::kernel::resource::LinkImpl* l =
       surf_network_model->create_link(link_name, link->bandwidths, link->latency, link->policy);