* properly set unlink thresholds - START/END combined are 1 event
This commit was SVN r6662.
Этот коммит содержится в:
родитель
747f23099e
Коммит
5e75cb2495
@ -410,7 +410,7 @@ mca_btl_portals_prepare_dst(struct mca_btl_base_module_t* btl_base,
|
|||||||
later :) */
|
later :) */
|
||||||
md.start = frag->segment.seg_addr.pval;
|
md.start = frag->segment.seg_addr.pval;
|
||||||
md.length = frag->segment.seg_len;
|
md.length = frag->segment.seg_len;
|
||||||
md.threshold = 2; /* unlink after START / END */
|
md.threshold = 1; /* unlink after START / END */
|
||||||
md.max_size = 0;
|
md.max_size = 0;
|
||||||
md.options = PTL_MD_OP_PUT | PTL_MD_OP_GET;
|
md.options = PTL_MD_OP_PUT | PTL_MD_OP_GET;
|
||||||
md.user_ptr = frag; /* keep a pointer to ourselves */
|
md.user_ptr = frag; /* keep a pointer to ourselves */
|
||||||
|
@ -38,8 +38,6 @@ mca_btl_portals_process_send(mca_btl_portals_module_t *btl,
|
|||||||
"send: PTL_EVENT_SEND_START for 0x%x",
|
"send: PTL_EVENT_SEND_START for 0x%x",
|
||||||
frag));
|
frag));
|
||||||
|
|
||||||
opal_output_verbose(10, mca_btl_portals_component.portals_output,
|
|
||||||
"start threshold: %d", ev->md.threshold);
|
|
||||||
if (ev->ni_fail_type != PTL_NI_OK) {
|
if (ev->ni_fail_type != PTL_NI_OK) {
|
||||||
opal_output(mca_btl_portals_component.portals_output,
|
opal_output(mca_btl_portals_component.portals_output,
|
||||||
"Failure to start send event\n");
|
"Failure to start send event\n");
|
||||||
@ -55,8 +53,6 @@ mca_btl_portals_process_send(mca_btl_portals_module_t *btl,
|
|||||||
OPAL_OUTPUT_VERBOSE((90, mca_btl_portals_component.portals_output,
|
OPAL_OUTPUT_VERBOSE((90, mca_btl_portals_component.portals_output,
|
||||||
"send: PTL_EVENT_SEND_END for 0x%x",
|
"send: PTL_EVENT_SEND_END for 0x%x",
|
||||||
frag));
|
frag));
|
||||||
opal_output_verbose(10, mca_btl_portals_component.portals_output,
|
|
||||||
"end threshold: %d", ev->md.threshold);
|
|
||||||
|
|
||||||
if (ev->ni_fail_type != PTL_NI_OK) {
|
if (ev->ni_fail_type != PTL_NI_OK) {
|
||||||
opal_output(mca_btl_portals_component.portals_output,
|
opal_output(mca_btl_portals_component.portals_output,
|
||||||
@ -105,9 +101,6 @@ mca_btl_portals_process_send(mca_btl_portals_module_t *btl,
|
|||||||
&frag->base,
|
&frag->base,
|
||||||
OMPI_SUCCESS);
|
OMPI_SUCCESS);
|
||||||
|
|
||||||
opal_output_verbose(10, mca_btl_portals_component.portals_output,
|
|
||||||
"ack threshold: %d", ev->md.threshold);
|
|
||||||
|
|
||||||
/* see if we can send someone else */
|
/* see if we can send someone else */
|
||||||
mca_btl_portals_progress_queued_sends(btl);
|
mca_btl_portals_progress_queued_sends(btl);
|
||||||
}
|
}
|
||||||
|
@ -33,7 +33,7 @@ mca_btl_portals_send_frag(mca_btl_portals_frag_t *frag)
|
|||||||
/* setup the send */
|
/* setup the send */
|
||||||
md.start = frag->segment.seg_addr.pval;
|
md.start = frag->segment.seg_addr.pval;
|
||||||
md.length = frag->segment.seg_len;
|
md.length = frag->segment.seg_len;
|
||||||
md.threshold = 3; /* unlink after start, end, ack */
|
md.threshold = 2; /* unlink after start, end, ack */
|
||||||
md.max_size = 0;
|
md.max_size = 0;
|
||||||
md.options = 0; /* BWB - can we optimize? */
|
md.options = 0; /* BWB - can we optimize? */
|
||||||
md.user_ptr = frag; /* keep a pointer to ourselves */
|
md.user_ptr = frag; /* keep a pointer to ourselves */
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user