Protect against an obscure race condition that AFAICT only occurs when we are in a loop waiting to recv a message from a peer who is then killed by signal.
This commit was SVN r23662.
Этот коммит содержится в:
родитель
7a1bdd2327
Коммит
4ecd9a0bbe
@ -587,6 +587,13 @@ static void mca_oob_tcp_peer_connected(mca_oob_tcp_peer_t* peer, int sd)
|
|||||||
*/
|
*/
|
||||||
void mca_oob_tcp_peer_close(mca_oob_tcp_peer_t* peer)
|
void mca_oob_tcp_peer_close(mca_oob_tcp_peer_t* peer)
|
||||||
{
|
{
|
||||||
|
if (NULL == peer) {
|
||||||
|
/* weird race condition that only occurs if the peer
|
||||||
|
* dies via signal
|
||||||
|
*/
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
if(mca_oob_tcp_component.tcp_debug >= OOB_TCP_DEBUG_CONNECT) {
|
if(mca_oob_tcp_component.tcp_debug >= OOB_TCP_DEBUG_CONNECT) {
|
||||||
opal_output(0, "%s-%s mca_oob_tcp_peer_close(%p) sd %d state %d\n",
|
opal_output(0, "%s-%s mca_oob_tcp_peer_close(%p) sd %d state %d\n",
|
||||||
ORTE_NAME_PRINT(ORTE_PROC_MY_NAME),
|
ORTE_NAME_PRINT(ORTE_PROC_MY_NAME),
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user