remove some now unneeded debugging
This commit was SVN r26364.
Этот коммит содержится в:
родитель
c654ee6afc
Коммит
5dec52af8d
@ -257,15 +257,10 @@ ompi_mtl_portals4_flowctl_trigger(void)
|
|||||||
{
|
{
|
||||||
int ret;
|
int ret;
|
||||||
|
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
|
||||||
"Enter flowctl_trigger"));
|
|
||||||
|
|
||||||
if (false == ompi_mtl_portals4.flowctl.flowctl_active) {
|
if (false == ompi_mtl_portals4.flowctl.flowctl_active) {
|
||||||
ompi_mtl_portals4.flowctl.flowctl_active = true;
|
ompi_mtl_portals4.flowctl.flowctl_active = true;
|
||||||
|
|
||||||
/* send trigger to root */
|
/* send trigger to root */
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
|
||||||
"Sending flow control trigger"));
|
|
||||||
ret = PtlPut(ompi_mtl_portals4.zero_md_h,
|
ret = PtlPut(ompi_mtl_portals4.zero_md_h,
|
||||||
0,
|
0,
|
||||||
0,
|
0,
|
||||||
@ -296,7 +291,7 @@ start_recover(void)
|
|||||||
ompi_mtl_portals4.flowctl.flowctl_active = true;
|
ompi_mtl_portals4.flowctl.flowctl_active = true;
|
||||||
ompi_mtl_portals4.flowctl.epoch_counter++;
|
ompi_mtl_portals4.flowctl.epoch_counter++;
|
||||||
|
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
OPAL_OUTPUT_VERBOSE((50, ompi_mtl_base_output,
|
||||||
"Entering flowctl_start_recover %d",
|
"Entering flowctl_start_recover %d",
|
||||||
ompi_mtl_portals4.flowctl.epoch_counter));
|
ompi_mtl_portals4.flowctl.epoch_counter));
|
||||||
|
|
||||||
@ -318,26 +313,14 @@ start_recover(void)
|
|||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
|
||||||
"flowctl_start_recover %d: draining active sends",
|
|
||||||
ompi_mtl_portals4.flowctl.epoch_counter));
|
|
||||||
|
|
||||||
/* drain all pending sends */
|
/* drain all pending sends */
|
||||||
while (0 != opal_list_get_size(&ompi_mtl_portals4.flowctl.active_sends)) {
|
while (0 != opal_list_get_size(&ompi_mtl_portals4.flowctl.active_sends)) {
|
||||||
opal_progress();
|
opal_progress();
|
||||||
}
|
}
|
||||||
|
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
|
||||||
"flowctl_start_recover %d: draining event queue",
|
|
||||||
ompi_mtl_portals4.flowctl.epoch_counter));
|
|
||||||
|
|
||||||
/* drain event queue */
|
/* drain event queue */
|
||||||
while (0 != ompi_mtl_portals4_progress()) { ; }
|
while (0 != ompi_mtl_portals4_progress()) { ; }
|
||||||
|
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
|
||||||
"flowctl_start_recover %d: checking short blocks",
|
|
||||||
ompi_mtl_portals4.flowctl.epoch_counter));
|
|
||||||
|
|
||||||
/* check short block active count */
|
/* check short block active count */
|
||||||
ret = ompi_mtl_portals4_recv_short_link(1);
|
ret = ompi_mtl_portals4_recv_short_link(1);
|
||||||
if (OMPI_SUCCESS != ret) {
|
if (OMPI_SUCCESS != ret) {
|
||||||
@ -349,10 +332,6 @@ start_recover(void)
|
|||||||
/* drain event queue */
|
/* drain event queue */
|
||||||
while (0 != ompi_mtl_portals4_progress()) { ; }
|
while (0 != ompi_mtl_portals4_progress()) { ; }
|
||||||
|
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
|
||||||
"flowctl_start_recover %d: starting barrier. Async time!",
|
|
||||||
ompi_mtl_portals4.flowctl.epoch_counter));
|
|
||||||
|
|
||||||
/* send barrier entry message */
|
/* send barrier entry message */
|
||||||
ret = PtlPut(ompi_mtl_portals4.zero_md_h,
|
ret = PtlPut(ompi_mtl_portals4.zero_md_h,
|
||||||
0,
|
0,
|
||||||
@ -376,7 +355,7 @@ start_recover(void)
|
|||||||
ret = OMPI_SUCCESS;
|
ret = OMPI_SUCCESS;
|
||||||
|
|
||||||
error:
|
error:
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
OPAL_OUTPUT_VERBOSE((50, ompi_mtl_base_output,
|
||||||
"Exiting flowctl_start_recover %d",
|
"Exiting flowctl_start_recover %d",
|
||||||
ompi_mtl_portals4.flowctl.epoch_counter));
|
ompi_mtl_portals4.flowctl.epoch_counter));
|
||||||
|
|
||||||
@ -530,14 +509,7 @@ static int
|
|||||||
flowctl_alert_callback(ptl_event_t *ev,
|
flowctl_alert_callback(ptl_event_t *ev,
|
||||||
ompi_mtl_portals4_base_request_t *ptl_base_request)
|
ompi_mtl_portals4_base_request_t *ptl_base_request)
|
||||||
{
|
{
|
||||||
int ret = OMPI_SUCCESS;
|
return start_recover();
|
||||||
|
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
|
||||||
"-----> flowctl_alert_callback <-----"));
|
|
||||||
|
|
||||||
ret = start_recover();
|
|
||||||
|
|
||||||
return ret;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -547,17 +519,19 @@ flowctl_fanout_callback(ptl_event_t *ev,
|
|||||||
{
|
{
|
||||||
int ret;
|
int ret;
|
||||||
|
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
|
||||||
"Enter flowctl_fanout_callback: %d",
|
|
||||||
ompi_mtl_portals4.flowctl.epoch_counter));
|
|
||||||
|
|
||||||
/* woo, we're recovered! */
|
|
||||||
ompi_mtl_portals4.flowctl.flowctl_active = false;
|
ompi_mtl_portals4.flowctl.flowctl_active = false;
|
||||||
ret = PtlPTEnable(ompi_mtl_portals4.ni_h, ompi_mtl_portals4.recv_idx);
|
ret = PtlPTEnable(ompi_mtl_portals4.ni_h, ompi_mtl_portals4.recv_idx);
|
||||||
if (PTL_OK != ret) abort();
|
if (PTL_OK != ret) {
|
||||||
|
opal_output_verbose(1, ompi_mtl_base_output,
|
||||||
|
"%s:%d: PtlPTEnabled failed: %d\n",
|
||||||
|
__FILE__, __LINE__, ret);
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
|
||||||
ompi_mtl_portals4_pending_list_progress();
|
ompi_mtl_portals4_pending_list_progress();
|
||||||
OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_output,
|
|
||||||
"Exit flowctl_fanout_callback: %d",
|
OPAL_OUTPUT_VERBOSE((50, ompi_mtl_base_output,
|
||||||
|
"Exiting flowctl_fanout_callback %d",
|
||||||
ompi_mtl_portals4.flowctl.epoch_counter));
|
ompi_mtl_portals4.flowctl.epoch_counter));
|
||||||
|
|
||||||
return OMPI_SUCCESS;
|
return OMPI_SUCCESS;
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user