check in some cleanup
This commit was SVN r2163.
Этот коммит содержится в:
родитель
3dae1199a6
Коммит
61b4bc71a5
@ -545,7 +545,6 @@ ompi_mca_ptl_elan_finalize (mca_ptl_elan_component_t * emp)
|
|||||||
RAIL *rail;
|
RAIL *rail;
|
||||||
|
|
||||||
rail = ems->all_rails[i];
|
rail = ems->all_rails[i];
|
||||||
|
|
||||||
free (rail->r_railTable);
|
free (rail->r_railTable);
|
||||||
|
|
||||||
/* Free the memory from the rail allocator */
|
/* Free the memory from the rail allocator */
|
||||||
@ -575,4 +574,3 @@ ompi_mca_ptl_elan_finalize (mca_ptl_elan_component_t * emp)
|
|||||||
END_FUNC(PTL_ELAN_DEBUG_FIN);
|
END_FUNC(PTL_ELAN_DEBUG_FIN);
|
||||||
return (OMPI_SUCCESS);
|
return (OMPI_SUCCESS);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -677,7 +677,7 @@ mca_ptl_elan_drain_recv (mca_ptl_elan_component_t * emp)
|
|||||||
|
|
||||||
OMPI_LOCK (&queue->rx_lock);
|
OMPI_LOCK (&queue->rx_lock);
|
||||||
|
|
||||||
#if 0
|
#if 1
|
||||||
rc = (*(int *) (&rxq->qr_doneWord));
|
rc = (*(int *) (&rxq->qr_doneWord));
|
||||||
#else
|
#else
|
||||||
rc = elan4_pollevent_word (ctx, &rxq->qr_doneWord, 2000);
|
rc = elan4_pollevent_word (ctx, &rxq->qr_doneWord, 2000);
|
||||||
@ -789,7 +789,7 @@ mca_ptl_elan_update_desc (mca_ptl_elan_component_t * emp)
|
|||||||
while (ompi_list_get_size (&queue->tx_desc) > 0) {
|
while (ompi_list_get_size (&queue->tx_desc) > 0) {
|
||||||
desc = (mca_ptl_elan_send_frag_t *)
|
desc = (mca_ptl_elan_send_frag_t *)
|
||||||
ompi_list_get_first (&queue->tx_desc);
|
ompi_list_get_first (&queue->tx_desc);
|
||||||
#if 0
|
#if 1
|
||||||
rc = * ((int *) (&desc->desc->main_doneWord));
|
rc = * ((int *) (&desc->desc->main_doneWord));
|
||||||
#else
|
#else
|
||||||
/* Poll the completion event for 1usec */
|
/* Poll the completion event for 1usec */
|
||||||
|
@ -27,7 +27,6 @@ main (int argc, char *argv[])
|
|||||||
|
|
||||||
if (argc < 2) {
|
if (argc < 2) {
|
||||||
fprintf (stderr, "Usage: %s msg_size\n", argv[0]);
|
fprintf (stderr, "Usage: %s msg_size\n", argv[0]);
|
||||||
MPI_Finalize ();
|
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
size = atoi (argv[1]);
|
size = atoi (argv[1]);
|
||||||
@ -70,7 +69,6 @@ main (int argc, char *argv[])
|
|||||||
hostname, __FUNCTION__, __LINE__);
|
hostname, __FUNCTION__, __LINE__);
|
||||||
fflush(stdout);
|
fflush(stdout);
|
||||||
|
|
||||||
|
|
||||||
if (myid == 0) {
|
if (myid == 0) {
|
||||||
double latency;
|
double latency;
|
||||||
latency = ((1.0e6 * t_end.tv_sec + t_end.tv_usec)
|
latency = ((1.0e6 * t_end.tv_sec + t_end.tv_usec)
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user