Set a priority for output of forwarded IO so it can effectively compete against inbound messages
This commit was SVN r27480.
Этот коммит содержится в:
родитель
e06c330635
Коммит
32c185f730
@ -149,6 +149,7 @@ typedef struct orte_iof_base_t orte_iof_base_t;
|
|||||||
ep->wev->ev, ep->wev->fd, \
|
ep->wev->ev, ep->wev->fd, \
|
||||||
OPAL_EV_WRITE, \
|
OPAL_EV_WRITE, \
|
||||||
wrthndlr, ep); \
|
wrthndlr, ep); \
|
||||||
|
opal_event_set_priority(ep->wev->ev, ORTE_MSG_PRI); \
|
||||||
} \
|
} \
|
||||||
if (NULL != (eplist)) { \
|
if (NULL != (eplist)) { \
|
||||||
opal_list_append((eplist), &ep->super); \
|
opal_list_append((eplist), &ep->super); \
|
||||||
@ -180,6 +181,7 @@ typedef struct orte_iof_base_t orte_iof_base_t;
|
|||||||
rev->ev, (fid), \
|
rev->ev, (fid), \
|
||||||
OPAL_EV_READ, \
|
OPAL_EV_READ, \
|
||||||
(cbfunc), rev); \
|
(cbfunc), rev); \
|
||||||
|
opal_event_set_priority(rev->ev, ORTE_MSG_PRI); \
|
||||||
if ((actv)) { \
|
if ((actv)) { \
|
||||||
rev->active = true; \
|
rev->active = true; \
|
||||||
opal_event_add(rev->ev, 0); \
|
opal_event_add(rev->ev, 0); \
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user