* Copyright (c) 2003, 2010, Oracle and/or its affiliates. All rights reserved.
* Use is subject to license terms.
*
- * Copyright (c) 2012, 2016, Intel Corporation.
+ * Copyright (c) 2012, 2017, Intel Corporation.
*/
/*
* This file is part of Lustre, http://www.lustre.org/
int lnet_lib_init(void);
void lnet_lib_exit(void);
+extern unsigned lnet_transaction_timeout;
extern unsigned int lnet_numa_range;
extern unsigned int lnet_peer_discovery_disabled;
extern int portal_rotor;
int lnet_notify(struct lnet_ni *ni, lnet_nid_t peer, int alive,
- cfs_time_t when);
+ time64_t when);
void lnet_notify_locked(struct lnet_peer_ni *lp, int notifylnd, int alive,
- cfs_time_t when);
+ time64_t when);
int lnet_add_route(__u32 net, __u32 hops, lnet_nid_t gateway_nid,
unsigned int priority);
int lnet_check_routes(void);
extern int libcfs_ioctl_getdata(struct libcfs_ioctl_hdr **hdr_pp,
struct libcfs_ioctl_hdr __user *uparam);
extern int lnet_get_peer_list(__u32 *countp, __u32 *sizep,
- lnet_process_id_t __user *ids);
+ struct lnet_process_id __user *ids);
-void lnet_proc_init(void);
-void lnet_proc_fini(void);
+void lnet_router_debugfs_init(void);
+void lnet_router_debugfs_fini(void);
int lnet_rtrpools_alloc(int im_a_router);
void lnet_destroy_rtrbuf(struct lnet_rtrbuf *rb, int npages);
int lnet_rtrpools_adjust(int tiny, int small, int large);
__u32 *peer_rtr_credits, __u32 *peer_min_rtr_credtis,
__u32 *peer_tx_qnob);
-
static inline bool
lnet_is_peer_ni_healthy_locked(struct lnet_peer_ni *lpni)
{
return false;
}
+static inline struct lnet_peer_net *
+lnet_find_peer_net_locked(struct lnet_peer *peer, __u32 net_id)
+{
+ struct lnet_peer_net *peer_net;
+
+ list_for_each_entry(peer_net, &peer->lp_peer_nets, lpn_peer_nets) {
+ if (peer_net->lpn_net_id == net_id)
+ return peer_net;
+ }
+
+ return NULL;
+}
+
static inline void
lnet_peer_set_alive(struct lnet_peer_ni *lp)
{
- lp->lpni_last_alive = lp->lpni_last_query = cfs_time_current();
+ lp->lpni_last_alive = ktime_get_seconds();
+ lp->lpni_last_query = lp->lpni_last_alive;
if (!lp->lpni_alive)
lnet_notify_locked(lp, 0, 1, lp->lpni_last_alive);
}
return false;
}
-void lnet_incr_stats(struct lnet_element_stats *stats, lnet_msg_type_t msg_type,
+void lnet_incr_stats(struct lnet_element_stats *stats,
+ enum lnet_msg_type msg_type,
enum lnet_stats_type stats_type);
__u32 lnet_sum_stats(struct lnet_element_stats *stats,