Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Merge s4u wait_any
authorGabriel Corona <gabriel.corona@loria.fr>
Fri, 22 Jul 2016 14:30:32 +0000 (16:30 +0200)
committerGabriel Corona <gabriel.corona@loria.fr>
Fri, 22 Jul 2016 14:30:32 +0000 (16:30 +0200)
1  2 
include/simgrid/simix.h
src/msg/msg_gos.cpp
src/simix/libsmx.cpp
src/simix/popping_accessors.h
src/simix/popping_bodies.cpp
src/simix/popping_generated.cpp
src/simix/simcalls.in
src/simix/smx_network.cpp
src/smpi/smpi_base.cpp

@@@ -359,10 -359,10 +359,10 @@@ XBT_PUBLIC(smx_synchro_t) simcall_comm_
  XBT_PUBLIC(void) simcall_comm_cancel(smx_synchro_t comm);
  
  /* FIXME: waitany is going to be a vararg function, and should take a timeout */
- XBT_PUBLIC(unsigned int) simcall_comm_waitany(xbt_dynar_t comms);
+ XBT_PUBLIC(unsigned int) simcall_comm_waitany(xbt_dynar_t comms, double timeout);
  XBT_PUBLIC(void) simcall_comm_wait(smx_synchro_t comm, double timeout);
  XBT_PUBLIC(int) simcall_comm_test(smx_synchro_t comm);
 -XBT_PUBLIC(int) simcall_comm_testany(xbt_dynar_t comms);
 +XBT_PUBLIC(int) simcall_comm_testany(smx_synchro_t* comms, size_t count);
  
  /************************** Tracing handling **********************************/
  XBT_PUBLIC(void) simcall_set_category(smx_synchro_t synchro, const char *category);
Simple merge
Simple merge
@@@ -1185,10 -1185,10 +1191,10 @@@ XBT_PRIVATE void simcall_HANDLER_comm_s
  XBT_PRIVATE smx_synchro_t simcall_HANDLER_comm_isend(smx_simcall_t simcall, smx_process_t sender, smx_mailbox_t mbox, double task_size, double rate, void* src_buff, size_t src_buff_size, simix_match_func_t match_fun, simix_clean_func_t clean_fun, simix_copy_data_func_t copy_data_fun, void* data, int detached);
  XBT_PRIVATE void simcall_HANDLER_comm_recv(smx_simcall_t simcall, smx_process_t receiver, smx_mailbox_t mbox, void* dst_buff, size_t* dst_buff_size, simix_match_func_t match_fun, simix_copy_data_func_t copy_data_fun, void* data, double timeout, double rate);
  XBT_PRIVATE smx_synchro_t simcall_HANDLER_comm_irecv(smx_simcall_t simcall, smx_process_t receiver, smx_mailbox_t mbox, void* dst_buff, size_t* dst_buff_size, simix_match_func_t match_fun, simix_copy_data_func_t copy_data_fun, void* data, double rate);
- XBT_PRIVATE void simcall_HANDLER_comm_waitany(smx_simcall_t simcall, xbt_dynar_t comms);
+ XBT_PRIVATE void simcall_HANDLER_comm_waitany(smx_simcall_t simcall, xbt_dynar_t comms, double timeout);
  XBT_PRIVATE void simcall_HANDLER_comm_wait(smx_simcall_t simcall, smx_synchro_t comm, double timeout);
  XBT_PRIVATE void simcall_HANDLER_comm_test(smx_simcall_t simcall, smx_synchro_t comm);
 -XBT_PRIVATE void simcall_HANDLER_comm_testany(smx_simcall_t simcall, xbt_dynar_t comms);
 +XBT_PRIVATE void simcall_HANDLER_comm_testany(smx_simcall_t simcall, smx_synchro_t* comms, size_t count);
  XBT_PRIVATE smx_mutex_t simcall_HANDLER_mutex_init(smx_simcall_t simcall);
  XBT_PRIVATE void simcall_HANDLER_mutex_lock(smx_simcall_t simcall, smx_mutex_t mutex);
  XBT_PRIVATE int simcall_HANDLER_mutex_trylock(smx_simcall_t simcall, smx_mutex_t mutex);
Simple merge
Simple merge
@@@ -72,10 -72,10 +72,10 @@@ void          comm_send(smx_process_t s
  smx_synchro_t comm_isend(smx_process_t sender, smx_mailbox_t mbox, double task_size, double rate, void* src_buff, size_t src_buff_size, simix_match_func_t match_fun, simix_clean_func_t clean_fun, simix_copy_data_func_t copy_data_fun, void* data, int detached);
  void          comm_recv(smx_process_t receiver, smx_mailbox_t mbox, void* dst_buff, size_t* dst_buff_size, simix_match_func_t match_fun, simix_copy_data_func_t copy_data_fun, void* data, double timeout, double rate) [[block]];
  smx_synchro_t comm_irecv(smx_process_t receiver, smx_mailbox_t mbox, void* dst_buff, size_t* dst_buff_size, simix_match_func_t match_fun, simix_copy_data_func_t copy_data_fun, void* data, double rate);
- int           comm_waitany(xbt_dynar_t comms) [[block]];
+ int           comm_waitany(xbt_dynar_t comms, double timeout) [[block]];
  void          comm_wait(smx_synchro_t comm, double timeout) [[block]];
  int           comm_test(smx_synchro_t comm) [[block]];
 -int           comm_testany(xbt_dynar_t comms) [[block]];
 +int           comm_testany(smx_synchro_t* comms, size_t count) [[block]];
  
  smx_mutex_t mutex_init();
  void        mutex_lock(smx_mutex_t mutex) [[block]];
Simple merge
Simple merge