X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lnet%2Flnet%2Frouter.c;h=b7d6c85e9eaa47dd71491736c3299778da4634bd;hp=9daa4ca6683222769abbedc9599c15e063ea53f7;hb=adb6cea0b70ac465b2a47635d9dc45d64ab1605b;hpb=0f8dca08a4f68cba82c2c822998ecc309d3b7aaf diff --git a/lnet/lnet/router.c b/lnet/lnet/router.c index 9daa4ca..b7d6c85 100644 --- a/lnet/lnet/router.c +++ b/lnet/lnet/router.c @@ -546,8 +546,8 @@ lnet_router_down_ni(lnet_peer_t *rtr, __u32 net) if (info->pi_magic == __swab32(LNET_PROTO_PING_MAGIC)) { lnet_swap_pinginfo(info); } else if (info->pi_magic != LNET_PROTO_PING_MAGIC) { - CDEBUG(D_NETERROR, "%s: Unexpected magic %08x\n", - libcfs_nid2str(rtr->lp_nid), info->pi_magic); + CNETERR("%s: Unexpected magic %08x\n", + libcfs_nid2str(rtr->lp_nid), info->pi_magic); return -EPROTO; } @@ -555,8 +555,8 @@ lnet_router_down_ni(lnet_peer_t *rtr, __u32 net) return -ENOENT; /* v1 doesn't carry NI status info */ if (info->pi_version != LNET_PROTO_PING_VERSION) { - CDEBUG(D_NETERROR, "%s: Unexpected version 0x%x\n", - libcfs_nid2str(rtr->lp_nid), info->pi_version); + CNETERR("%s: Unexpected version 0x%x\n", + libcfs_nid2str(rtr->lp_nid), info->pi_version); return -EPROTO; } @@ -565,8 +565,8 @@ lnet_router_down_ni(lnet_peer_t *rtr, __u32 net) lnet_nid_t nid = stat->ns_nid; if (nid == LNET_NID_ANY) { - CDEBUG(D_NETERROR, "%s: unexpected LNET_NID_ANY\n", - libcfs_nid2str(rtr->lp_nid)); + CNETERR("%s: unexpected LNET_NID_ANY\n", + libcfs_nid2str(rtr->lp_nid)); return -EPROTO; } @@ -582,8 +582,8 @@ lnet_router_down_ni(lnet_peer_t *rtr, __u32 net) } if (stat->ns_status != LNET_NI_STATUS_UP) { - CDEBUG(D_NETERROR, "%s: Unexpected status 0x%x\n", - libcfs_nid2str(rtr->lp_nid), stat->ns_status); + CNETERR("%s: Unexpected status 0x%x\n", + libcfs_nid2str(rtr->lp_nid), stat->ns_status); return -EPROTO; } @@ -1003,7 +1003,7 @@ lnet_router_checker_start(void) the_lnet.ln_rc_state = LNET_RC_STATE_RUNNING; #ifdef __KERNEL__ - rc = (int)cfs_kernel_thread(lnet_router_checker, NULL, 0); + rc = cfs_create_thread(lnet_router_checker, NULL, 0); if (rc < 0) { CERROR("Can't start router checker thread: %d\n", rc); the_lnet.ln_rc_state = LNET_RC_STATE_UNLINKING; @@ -1500,9 +1500,9 @@ lnet_router_checker (void) if (last != 0 && interval > MAX(live_router_check_interval, dead_router_check_interval)) - CDEBUG(D_NETERROR, "Checker(%d/%d) not called for %d seconds\n", - live_router_check_interval, dead_router_check_interval, - interval); + CNETERR("Checker(%d/%d) not called for %d seconds\n", + live_router_check_interval, dead_router_check_interval, + interval); LNET_LOCK(); LASSERT (!running); /* recursion check */