Commit d9331056 authored by James Simmons's avatar James Simmons Committed by Greg Kroah-Hartman

staging: lustre: lnet: change lnet_counter_t to proper structure

Change lnet_counter_t from typedef to proper structure.
Signed-off-by: default avatarJames Simmons <uja.ornl@yahoo.com>
Reviewed-on: https://review.whamcloud.com/20831Reviewed-by: default avatarOlaf Weber <olaf@sgi.com>
Reviewed-by: default avatarDoug Oucharek <doug.s.oucharek@intel.com>
Reviewed-by: default avatarDmitry Eremin <dmitry.eremin@intel.com>
Reviewed-by: default avatarOleg Drokin <oleg.drokin@intel.com>
Signed-off-by: default avatarJames Simmons <jsimmons@infradead.org>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent 79d2c25c
...@@ -603,7 +603,7 @@ bool lnet_delay_rule_match_locked(struct lnet_hdr *hdr, struct lnet_msg *msg); ...@@ -603,7 +603,7 @@ bool lnet_delay_rule_match_locked(struct lnet_hdr *hdr, struct lnet_msg *msg);
/** @} lnet_fault_simulation */ /** @} lnet_fault_simulation */
void lnet_counters_get(lnet_counters_t *counters); void lnet_counters_get(struct lnet_counters *counters);
void lnet_counters_reset(void); void lnet_counters_reset(void);
unsigned int lnet_iov_nob(unsigned int niov, struct kvec *iov); unsigned int lnet_iov_nob(unsigned int niov, struct kvec *iov);
......
...@@ -573,7 +573,7 @@ struct lnet { ...@@ -573,7 +573,7 @@ struct lnet {
struct cfs_percpt_lock *ln_net_lock; struct cfs_percpt_lock *ln_net_lock;
/* percpt message containers for active/finalizing/freed message */ /* percpt message containers for active/finalizing/freed message */
struct lnet_msg_container **ln_msg_containers; struct lnet_msg_container **ln_msg_containers;
lnet_counters_t **ln_counters; struct lnet_counters **ln_counters;
struct lnet_peer_table **ln_peer_tables; struct lnet_peer_table **ln_peer_tables;
/* failure simulation */ /* failure simulation */
struct list_head ln_test_peers; struct list_head ln_test_peers;
......
...@@ -250,7 +250,7 @@ struct lnet_ping_info { ...@@ -250,7 +250,7 @@ struct lnet_ping_info {
struct lnet_ni_status pi_ni[0]; struct lnet_ni_status pi_ni[0];
} WIRE_ATTR; } WIRE_ATTR;
typedef struct lnet_counters { struct lnet_counters {
__u32 msgs_alloc; __u32 msgs_alloc;
__u32 msgs_max; __u32 msgs_max;
__u32 errors; __u32 errors;
...@@ -262,7 +262,7 @@ typedef struct lnet_counters { ...@@ -262,7 +262,7 @@ typedef struct lnet_counters {
__u64 recv_length; __u64 recv_length;
__u64 route_length; __u64 route_length;
__u64 drop_length; __u64 drop_length;
} WIRE_ATTR lnet_counters_t; } WIRE_ATTR;
#define LNET_NI_STATUS_UP 0x15aac0de #define LNET_NI_STATUS_UP 0x15aac0de
#define LNET_NI_STATUS_DOWN 0xdeadface #define LNET_NI_STATUS_DOWN 0xdeadface
......
...@@ -315,9 +315,9 @@ lnet_unregister_lnd(struct lnet_lnd *lnd) ...@@ -315,9 +315,9 @@ lnet_unregister_lnd(struct lnet_lnd *lnd)
EXPORT_SYMBOL(lnet_unregister_lnd); EXPORT_SYMBOL(lnet_unregister_lnd);
void void
lnet_counters_get(lnet_counters_t *counters) lnet_counters_get(struct lnet_counters *counters)
{ {
lnet_counters_t *ctr; struct lnet_counters *ctr;
int i; int i;
memset(counters, 0, sizeof(*counters)); memset(counters, 0, sizeof(*counters));
...@@ -344,13 +344,13 @@ EXPORT_SYMBOL(lnet_counters_get); ...@@ -344,13 +344,13 @@ EXPORT_SYMBOL(lnet_counters_get);
void void
lnet_counters_reset(void) lnet_counters_reset(void)
{ {
lnet_counters_t *counters; struct lnet_counters *counters;
int i; int i;
lnet_net_lock(LNET_LOCK_EX); lnet_net_lock(LNET_LOCK_EX);
cfs_percpt_for_each(counters, i, the_lnet.ln_counters) cfs_percpt_for_each(counters, i, the_lnet.ln_counters)
memset(counters, 0, sizeof(lnet_counters_t)); memset(counters, 0, sizeof(struct lnet_counters));
lnet_net_unlock(LNET_LOCK_EX); lnet_net_unlock(LNET_LOCK_EX);
} }
...@@ -560,7 +560,7 @@ lnet_prepare(lnet_pid_t requested_pid) ...@@ -560,7 +560,7 @@ lnet_prepare(lnet_pid_t requested_pid)
the_lnet.ln_interface_cookie = ktime_get_ns(); the_lnet.ln_interface_cookie = ktime_get_ns();
the_lnet.ln_counters = cfs_percpt_alloc(lnet_cpt_table(), the_lnet.ln_counters = cfs_percpt_alloc(lnet_cpt_table(),
sizeof(lnet_counters_t)); sizeof(struct lnet_counters));
if (!the_lnet.ln_counters) { if (!the_lnet.ln_counters) {
CERROR("Failed to allocate counters for LNet\n"); CERROR("Failed to allocate counters for LNet\n");
rc = -ENOMEM; rc = -ENOMEM;
......
...@@ -132,7 +132,7 @@ void ...@@ -132,7 +132,7 @@ void
lnet_msg_commit(struct lnet_msg *msg, int cpt) lnet_msg_commit(struct lnet_msg *msg, int cpt)
{ {
struct lnet_msg_container *container = the_lnet.ln_msg_containers[cpt]; struct lnet_msg_container *container = the_lnet.ln_msg_containers[cpt];
lnet_counters_t *counters = the_lnet.ln_counters[cpt]; struct lnet_counters *counters = the_lnet.ln_counters[cpt];
/* routed message can be committed for both receiving and sending */ /* routed message can be committed for both receiving and sending */
LASSERT(!msg->msg_tx_committed); LASSERT(!msg->msg_tx_committed);
...@@ -164,7 +164,7 @@ lnet_msg_commit(struct lnet_msg *msg, int cpt) ...@@ -164,7 +164,7 @@ lnet_msg_commit(struct lnet_msg *msg, int cpt)
static void static void
lnet_msg_decommit_tx(struct lnet_msg *msg, int status) lnet_msg_decommit_tx(struct lnet_msg *msg, int status)
{ {
lnet_counters_t *counters; struct lnet_counters *counters;
lnet_event_t *ev = &msg->msg_ev; lnet_event_t *ev = &msg->msg_ev;
LASSERT(msg->msg_tx_committed); LASSERT(msg->msg_tx_committed);
...@@ -216,7 +216,7 @@ lnet_msg_decommit_tx(struct lnet_msg *msg, int status) ...@@ -216,7 +216,7 @@ lnet_msg_decommit_tx(struct lnet_msg *msg, int status)
static void static void
lnet_msg_decommit_rx(struct lnet_msg *msg, int status) lnet_msg_decommit_rx(struct lnet_msg *msg, int status)
{ {
lnet_counters_t *counters; struct lnet_counters *counters;
lnet_event_t *ev = &msg->msg_ev; lnet_event_t *ev = &msg->msg_ev;
LASSERT(!msg->msg_tx_committed); /* decommitted or never committed */ LASSERT(!msg->msg_tx_committed); /* decommitted or never committed */
......
...@@ -77,7 +77,7 @@ static int __proc_lnet_stats(void *data, int write, ...@@ -77,7 +77,7 @@ static int __proc_lnet_stats(void *data, int write,
loff_t pos, void __user *buffer, int nob) loff_t pos, void __user *buffer, int nob)
{ {
int rc; int rc;
lnet_counters_t *ctrs; struct lnet_counters *ctrs;
int len; int len;
char *tmpstr; char *tmpstr;
const int tmpsiz = 256; /* 7 %u and 4 %llu */ const int tmpsiz = 256; /* 7 %u and 4 %llu */
......
...@@ -1469,14 +1469,14 @@ lstcon_statrpc_readent(int transop, struct srpc_msg *msg, ...@@ -1469,14 +1469,14 @@ lstcon_statrpc_readent(int transop, struct srpc_msg *msg,
struct srpc_stat_reply *rep = &msg->msg_body.stat_reply; struct srpc_stat_reply *rep = &msg->msg_body.stat_reply;
struct sfw_counters __user *sfwk_stat; struct sfw_counters __user *sfwk_stat;
struct srpc_counters __user *srpc_stat; struct srpc_counters __user *srpc_stat;
lnet_counters_t __user *lnet_stat; struct lnet_counters __user *lnet_stat;
if (rep->str_status) if (rep->str_status)
return 0; return 0;
sfwk_stat = (struct sfw_counters __user *)&ent_up->rpe_payload[0]; sfwk_stat = (struct sfw_counters __user *)&ent_up->rpe_payload[0];
srpc_stat = (struct srpc_counters __user *)(sfwk_stat + 1); srpc_stat = (struct srpc_counters __user *)(sfwk_stat + 1);
lnet_stat = (lnet_counters_t __user *)(srpc_stat + 1); lnet_stat = (struct lnet_counters __user *)(srpc_stat + 1);
if (copy_to_user(sfwk_stat, &rep->str_fw, sizeof(*sfwk_stat)) || if (copy_to_user(sfwk_stat, &rep->str_fw, sizeof(*sfwk_stat)) ||
copy_to_user(srpc_stat, &rep->str_rpc, sizeof(*srpc_stat)) || copy_to_user(srpc_stat, &rep->str_rpc, sizeof(*srpc_stat)) ||
......
...@@ -163,7 +163,7 @@ struct srpc_stat_reply { ...@@ -163,7 +163,7 @@ struct srpc_stat_reply {
struct lst_sid str_sid; struct lst_sid str_sid;
struct sfw_counters str_fw; struct sfw_counters str_fw;
struct srpc_counters str_rpc; struct srpc_counters str_rpc;
lnet_counters_t str_lnet; struct lnet_counters str_lnet;
} WIRE_ATTR; } WIRE_ATTR;
struct test_bulk_req { struct test_bulk_req {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment