only poll high priority qp 1 per progress.
This commit was SVN r6918.
Этот коммит содержится в:
родитель
4b3969d2ab
Коммит
589d53e828
@ -558,7 +558,6 @@ int mca_btl_mvapi_component_progress()
|
|||||||
* we will check the high priority and process them until there are none left.
|
* we will check the high priority and process them until there are none left.
|
||||||
* note that low priority messages are only processed one per progress call.
|
* note that low priority messages are only processed one per progress call.
|
||||||
*/
|
*/
|
||||||
do{
|
|
||||||
ret = VAPI_poll_cq(mvapi_btl->nic, mvapi_btl->cq_hndl_high, &comp);
|
ret = VAPI_poll_cq(mvapi_btl->nic, mvapi_btl->cq_hndl_high, &comp);
|
||||||
if(VAPI_OK == ret) {
|
if(VAPI_OK == ret) {
|
||||||
if(comp.status != VAPI_SUCCESS) {
|
if(comp.status != VAPI_SUCCESS) {
|
||||||
@ -615,8 +614,6 @@ int mca_btl_mvapi_component_progress()
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
while(VAPI_OK == ret);
|
|
||||||
|
|
||||||
ret = VAPI_poll_cq(mvapi_btl->nic, mvapi_btl->cq_hndl_low, &comp);
|
ret = VAPI_poll_cq(mvapi_btl->nic, mvapi_btl->cq_hndl_low, &comp);
|
||||||
if(VAPI_OK == ret) {
|
if(VAPI_OK == ret) {
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user