Lines Matching refs:cm_sock
164 mngr->cm_sock = sk; in nl_cache_mngr_alloc()
174 nl_socket_disable_seq_check(mngr->cm_sock); in nl_cache_mngr_alloc()
176 if ((err = nl_connect(mngr->cm_sock, protocol)) < 0) in nl_cache_mngr_alloc()
179 if ((err = nl_socket_set_nonblocking(mngr->cm_sock)) < 0) in nl_cache_mngr_alloc()
338 err = nl_socket_add_membership(mngr->cm_sock, grp->ag_group); in nl_cache_mngr_add_cache()
361 nl_socket_drop_membership(mngr->cm_sock, grp->ag_group); in nl_cache_mngr_add_cache()
473 return nl_socket_get_fd(mngr->cm_sock); in nl_cache_mngr_get_fd()
499 .fd = nl_socket_get_fd(mngr->cm_sock), in nl_cache_mngr_poll()
540 mngr, nl_socket_get_fd(mngr->cm_sock)); in nl_cache_mngr_data_ready()
542 cb = nl_cb_clone(mngr->cm_sock->s_cb); in nl_cache_mngr_data_ready()
548 while ((err = nl_recvmsgs_report(mngr->cm_sock, cb)) > 0) { in nl_cache_mngr_data_ready()
580 nl_dump_line(p, " .sock = <%p>\n", mngr->cm_sock); in nl_cache_mngr_info()
616 if (mngr->cm_sock) in nl_cache_mngr_free()
617 nl_close(mngr->cm_sock); in nl_cache_mngr_free()
625 nl_socket_free(mngr->cm_sock); in nl_cache_mngr_free()