X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lnet%2Fulnds%2Fsocklnd%2Fconnection.c;h=ca6999a30093272578ee95cb69ee8948b50938c5;hb=bd1b99d7caa6ab2b7c771524af9178a3da69eeab;hp=29e75be88ede1b33f8bb6ad49b01902f22ee8aa4;hpb=96a46ae59026ac70bae1aa41f59bacc9bb606eef;p=fs%2Flustre-release.git diff --git a/lnet/ulnds/socklnd/connection.c b/lnet/ulnds/socklnd/connection.c index 29e75be..ca6999a 100644 --- a/lnet/ulnds/socklnd/connection.c +++ b/lnet/ulnds/socklnd/connection.c @@ -309,7 +309,8 @@ tcpnal_hello (int sockfd, ptl_nid_t *nid, int type, __u64 incarnation) */ connection force_tcp_connection(manager m, unsigned int ip, - unsigned short port) + unsigned short port, + procbridge pb) { connection conn; struct sockaddr_in addr; @@ -357,6 +358,10 @@ connection force_tcp_connection(manager m, exit(-1); conn = allocate_connection(m, ip, port, fd); + + /* let nal thread know this event right away */ + if (conn) + procbridge_wakeup_nal(pb); } pthread_mutex_unlock(&m->conn_lock);