X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/4dbb8aa24d54e0a4091b1f01017032702d0376f7..d99d3238efb76357fcc6437c15fb900c3c02ebd4:/src/simix/smx_network_private.h diff --git a/src/simix/smx_network_private.h b/src/simix/smx_network_private.h index 93778b104e..0484c4b8f4 100644 --- a/src/simix/smx_network_private.h +++ b/src/simix/smx_network_private.h @@ -7,50 +7,47 @@ #ifndef _SIMIX_NETWORK_PRIVATE_H #define _SIMIX_NETWORK_PRIVATE_H +#include + #include "simgrid/simix.h" #include "popping_private.h" /** @brief Rendez-vous point datatype */ -typedef struct s_smx_rvpoint { +typedef struct s_smx_mailbox { char *name; xbt_fifo_t comm_fifo; void *data; smx_process_t permanent_receiver; //process which the mailbox is attached to xbt_fifo_t done_comm_fifo;//messages already received in the permanent receive mode -} s_smx_rvpoint_t; - -void SIMIX_network_init(void); -void SIMIX_network_exit(void); - -#ifdef HAVE_LATENCY_BOUND_TRACKING -XBT_PUBLIC(int) SIMIX_comm_is_latency_bounded(smx_synchro_t comm); -#endif - -smx_rdv_t SIMIX_rdv_create(const char *name); -void SIMIX_rdv_destroy(smx_rdv_t rdv); -smx_rdv_t SIMIX_rdv_get_by_name(const char *name); -void SIMIX_rdv_remove(smx_rdv_t rdv, smx_synchro_t comm); -int SIMIX_rdv_comm_count_by_host(smx_rdv_t rdv, sg_host_t host); -smx_synchro_t SIMIX_rdv_get_head(smx_rdv_t rdv); -void SIMIX_rdv_set_receiver(smx_rdv_t rdv, smx_process_t proc); -smx_process_t SIMIX_rdv_get_receiver(smx_rdv_t rdv); -smx_synchro_t SIMIX_comm_irecv(smx_process_t dst_proc, smx_rdv_t rdv, +} s_smx_mailbox_t; + +XBT_PRIVATE void SIMIX_mailbox_exit(void); + +XBT_PRIVATE smx_mailbox_t SIMIX_mbox_create(const char *name); +XBT_PRIVATE void SIMIX_mbox_destroy(smx_mailbox_t mbox); +XBT_PRIVATE smx_mailbox_t SIMIX_mbox_get_by_name(const char *name); +XBT_PRIVATE void SIMIX_mbox_remove(smx_mailbox_t mbox, smx_synchro_t comm); +XBT_PRIVATE int SIMIX_mbox_comm_count_by_host(smx_mailbox_t mbox, sg_host_t host); +XBT_PRIVATE smx_synchro_t SIMIX_mbox_get_head(smx_mailbox_t mbox); +XBT_PRIVATE void SIMIX_mbox_set_receiver(smx_mailbox_t mbox, smx_process_t proc); +XBT_PRIVATE smx_process_t SIMIX_mbox_get_receiver(smx_mailbox_t mbox); +XBT_PRIVATE smx_synchro_t SIMIX_comm_irecv(smx_process_t dst_proc, smx_mailbox_t mbox, void *dst_buff, size_t *dst_buff_size, int (*)(void *, void *, smx_synchro_t), void (*copy_data_fun)(smx_synchro_t, void*, size_t), void *data, double rate); -void SIMIX_comm_destroy(smx_synchro_t synchro); -void SIMIX_comm_destroy_internal_actions(smx_synchro_t synchro); -smx_synchro_t SIMIX_comm_iprobe(smx_process_t dst_proc, smx_rdv_t rdv, int type, int src, +XBT_PRIVATE void SIMIX_comm_destroy(smx_synchro_t synchro); +XBT_PRIVATE void SIMIX_comm_destroy_internal_actions(smx_synchro_t synchro); +XBT_PRIVATE smx_synchro_t SIMIX_comm_iprobe(smx_process_t dst_proc, smx_mailbox_t mbox, int type, int src, int tag, int (*match_fun)(void *, void *, smx_synchro_t), void *data); -void SIMIX_post_comm(smx_synchro_t synchro); -void SIMIX_comm_cancel(smx_synchro_t synchro); -double SIMIX_comm_get_remains(smx_synchro_t synchro); -e_smx_state_t SIMIX_comm_get_state(smx_synchro_t synchro); -void SIMIX_comm_suspend(smx_synchro_t synchro); -void SIMIX_comm_resume(smx_synchro_t synchro); -smx_process_t SIMIX_comm_get_src_proc(smx_synchro_t synchro); -smx_process_t SIMIX_comm_get_dst_proc(smx_synchro_t synchro); +XBT_PRIVATE void SIMIX_post_comm(smx_synchro_t synchro); +XBT_PRIVATE void SIMIX_comm_cancel(smx_synchro_t synchro); +XBT_PRIVATE double SIMIX_comm_get_remains(smx_synchro_t synchro); +XBT_PRIVATE e_smx_state_t SIMIX_comm_get_state(smx_synchro_t synchro); +XBT_PRIVATE void SIMIX_comm_suspend(smx_synchro_t synchro); +XBT_PRIVATE void SIMIX_comm_resume(smx_synchro_t synchro); +XBT_PRIVATE smx_process_t SIMIX_comm_get_src_proc(smx_synchro_t synchro); +XBT_PRIVATE smx_process_t SIMIX_comm_get_dst_proc(smx_synchro_t synchro); #endif