LASSERT (lp->lp_rtr_refcount == 0);
LASSERT (list_empty(&lp->lp_txq));
LASSERT (lp->lp_txqnob == 0);
+ LASSERT (lp->lp_rcd == NULL);
LIBCFS_FREE(lp, sizeof(*lp));
lp->lp_alive_count = 0;
lp->lp_timestamp = 0;
lp->lp_alive = !lnet_peers_start_down(); /* 1 bit!! */
- lp->lp_last_alive = cfs_time_current_sec(); /* assumes alive */
- lp->lp_last_query = 0; /* didn't ask LND yet */
+ lp->lp_last_alive = cfs_time_current(); /* assumes alive */
+ lp->lp_last_query = 0; /* haven't asked NI yet */
lp->lp_ping_timestamp = 0;
lp->lp_nid = nid;
lp->lp_refcount = 2; /* 1 for caller; 1 for hash */
return the_lnet.ln_shutdown ? -ESHUTDOWN : -EHOSTUNREACH;
}
- lp->lp_txcredits =
- lp->lp_mintxcredits = lp->lp_ni->ni_peertxcredits;
+ lp->lp_txcredits =
+ lp->lp_mintxcredits = lp->lp_ni->ni_peertxcredits;
+ lp->lp_rtrcredits =
+ lp->lp_minrtrcredits = lnet_peer_buffer_credits(lp->lp_ni);
- /* As a first approximation; allow this peer the same number of router
- * buffers as it is allowed outstanding sends */
- lp->lp_rtrcredits = lp->lp_minrtrcredits = lp->lp_txcredits;
-
- LASSERT (!the_lnet.ln_shutdown);
/* can't add peers after shutdown starts */
+ LASSERT (!the_lnet.ln_shutdown);
list_add_tail(&lp->lp_hashlist, lnet_nid2peerhash(nid));
the_lnet.ln_npeers++;
return;
}
- if (lnet_isrouter(lp) || lp->lp_ni->ni_peertimeout > 0)
+ if (lnet_isrouter(lp) || lnet_peer_aliveness_enabled(lp))
aliveness = lp->lp_alive ? "up" : "down";
CDEBUG(D_WARNING, "%-24s %4d %5s %5d %5d %5d %5d %5d %ld\n",