ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

opal/timing: Remove oob tracing

Просмотр исходного кода 
Signed-off-by: Artem Polyakov <artpol84@gmail.com>
Этот коммит содержится в:
Artem Polyakov 2017-03-28 23:05:27 +07:00 коммит произвёл Boris Karasev
родитель eba6c6b827
Коммит 79100de014
3 изменённых файлов: 0 добавлений и 22 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

2
orte/mca/oob/base/base.h
Просмотреть файл

@ -49,8 +49,6 @@
BEGIN_C_DECLS BEGIN_C_DECLS
OPAL_TIMING_DECLARE_EXT(ORTE_DECLSPEC, tm_oob)
/* /*
* Convenience Typedef * Convenience Typedef
*/ */

7
orte/mca/oob/base/oob_base_frame.c
Просмотреть файл

@ -52,8 +52,6 @@
* Global variables * Global variables
*/ */
orte_oob_base_t orte_oob_base = {0}; orte_oob_base_t orte_oob_base = {0};
OPAL_TIMING_DECLARE(tm_oob)
static int orte_oob_base_register(mca_base_register_flag_t flags) static int orte_oob_base_register(mca_base_register_flag_t flags)
{ {
@ -109,9 +107,6 @@ static int orte_oob_base_close(void)
OBJ_DESTRUCT(&orte_oob_base.peers); OBJ_DESTRUCT(&orte_oob_base.peers);
OPAL_TIMING_EVENT((&tm_oob, "Finish"));
OPAL_TIMING_REPORT(orte_oob_base.timing, &tm_oob);
return mca_base_framework_components_close(&orte_oob_base_framework, NULL); return mca_base_framework_components_close(&orte_oob_base_framework, NULL);
} }
@ -137,8 +132,6 @@ static int orte_oob_base_open(mca_base_open_flag_t flags)
orte_state.add_job_state(ORTE_JOB_STATE_FT_RESTART, orte_oob_base_ft_event, ORTE_ERROR_PRI); orte_state.add_job_state(ORTE_JOB_STATE_FT_RESTART, orte_oob_base_ft_event, ORTE_ERROR_PRI);
#endif #endif
OPAL_TIMING_INIT(&tm_oob);
/* Open up all available components */ /* Open up all available components */
return mca_base_framework_components_open(&orte_oob_base_framework, flags); return mca_base_framework_components_open(&orte_oob_base_framework, flags);
} }

13
orte/mca/oob/tcp/oob_tcp_sendrecv.c
Просмотреть файл

@ -110,9 +110,6 @@ static int send_msg(mca_oob_tcp_peer_t* peer, mca_oob_tcp_send_t* msg)
int iov_count, retries = 0; int iov_count, retries = 0;
ssize_t remain = msg->sdbytes, rc; ssize_t remain = msg->sdbytes, rc;
OPAL_TIMING_EVENT((&tm_oob, "to %s %d bytes",
ORTE_NAME_PRINT(&(peer->name)), msg->sdbytes));
iov[0].iov_base = msg->sdptr; iov[0].iov_base = msg->sdptr;
iov[0].iov_len = msg->sdbytes; iov[0].iov_len = msg->sdbytes;
if (!msg->hdr_sent) { if (!msg->hdr_sent) {
@ -420,9 +417,6 @@ static int read_bytes(mca_oob_tcp_peer_t* peer)
peer->recv_msg->rdptr += rc; peer->recv_msg->rdptr += rc;
} }
OPAL_TIMING_EVENT((&tm_oob, "from %s %d bytes",
ORTE_NAME_PRINT(&(peer->name)), to_read));
/* we read the full data block */ /* we read the full data block */
return ORTE_SUCCESS; return ORTE_SUCCESS;
} }
@ -516,8 +510,6 @@ void mca_oob_tcp_recv_handler(int sd, short flags, void *cbdata)
#if OPAL_ENABLE_TIMING #if OPAL_ENABLE_TIMING
timing_same_as_hdr = true; timing_same_as_hdr = true;
#endif #endif
OPAL_TIMING_EVENT((&tm_oob, "from %s %d bytes [header]",
ORTE_NAME_PRINT(&(peer->name)), to_recv));
/* completed reading the header */ /* completed reading the header */
peer->recv_msg->hdr_recvd = true; peer->recv_msg->hdr_recvd = true;
/* convert the header */ /* convert the header */
@ -570,11 +562,6 @@ void mca_oob_tcp_recv_handler(int sd, short flags, void *cbdata)
ORTE_NAME_PRINT(&peer->recv_msg->hdr.dst), ORTE_NAME_PRINT(&peer->recv_msg->hdr.dst),
peer->recv_msg->hdr.tag); peer->recv_msg->hdr.tag);
OPAL_TIMING_EVENT((&tm_oob, "from %s %d bytes [body:%s]",
ORTE_NAME_PRINT(&(peer->name)),
(int)peer->recv_msg->hdr.nbytes,
(timing_same_as_hdr) ? "same" : "next"));
/* am I the intended recipient (header was already converted back to host order)? */ /* am I the intended recipient (header was already converted back to host order)? */
if (peer->recv_msg->hdr.dst.jobid == ORTE_PROC_MY_NAME->jobid && if (peer->recv_msg->hdr.dst.jobid == ORTE_PROC_MY_NAME->jobid &&
peer->recv_msg->hdr.dst.vpid == ORTE_PROC_MY_NAME->vpid) { peer->recv_msg->hdr.dst.vpid == ORTE_PROC_MY_NAME->vpid) {