From 94bd8bd15ea0c4d297ba0b1a5214d1cec8425736 Mon Sep 17 00:00:00 2001 From: bobijam Date: Tue, 12 Aug 2008 04:17:36 +0000 Subject: [PATCH] Branch b1_8_gate b=16573 o=adilger i=johann, nathan Description: Export bytes_read/bytes_write count on OSC/OST. --- lustre/include/lustre_net.h | 21 ++++++++++----------- 1 file changed, 10 insertions(+), 11 deletions(-) diff --git a/lustre/include/lustre_net.h b/lustre/include/lustre_net.h index 70bc2c9..cff7ad7 100644 --- a/lustre/include/lustre_net.h +++ b/lustre/include/lustre_net.h @@ -355,11 +355,11 @@ struct ptlrpc_request { struct ptlrpc_bulk_desc *rq_bulk; /* client side bulk */ /* client outgoing req */ - time_t rq_sent; /* when request sent, seconds, + time_t rq_sent; /* when request sent, seconds, * or time when request should * be sent */ volatile time_t rq_deadline; /* when request must finish. volatile - so that servers' early reply updates to the deadline aren't + so that servers' early reply updates to the deadline aren't kept in per-cpu cache */ int rq_timeout; /* service time estimate (secs) */ @@ -515,7 +515,7 @@ struct ptlrpc_bulk_desc { struct ptlrpc_thread { - struct list_head t_link; /* active threads for service, from svc->srv_threads */ + struct list_head t_link; /* active threads in svc->srv_threads */ void *t_data; /* thread-private data (preallocated memory) */ __u32 t_flags; @@ -559,7 +559,7 @@ struct ptlrpc_service { __u32 srv_req_portal; __u32 srv_rep_portal; - + /* AT stuff */ struct adaptive_timeout srv_at_estimate;/* estimated rpc service time */ spinlock_t srv_at_lock; @@ -606,7 +606,7 @@ struct ptlrpc_service { struct list_head srv_free_rs_list; /* waitq to run, when adding stuff to srv_free_rs_list */ cfs_waitq_t srv_free_rs_waitq; - + /* * if non-NULL called during thread creation (ptlrpc_start_thread()) * to initialize service specific per-thread state. @@ -756,7 +756,7 @@ struct ptlrpc_service *ptlrpc_init_svc(int nbufs, int bufsize, int max_req_size, int watchdog_factor, svc_handler_t, char *name, cfs_proc_dir_entry_t *proc_entry, - svcreq_printfn_t, + svcreq_printfn_t, int min_threads, int max_threads, char *threadname); void ptlrpc_stop_all_threads(struct ptlrpc_service *svc); @@ -871,7 +871,7 @@ ptlrpc_rs_decref(struct ptlrpc_reply_state *rs) /* Should only be called once per req */ static inline void ptlrpc_req_drop_rs(struct ptlrpc_request *req) { - if (req->rq_reply_state == NULL) + if (req->rq_reply_state == NULL) return; /* shouldn't occur */ ptlrpc_rs_decref(req->rq_reply_state); req->rq_reply_state = NULL; @@ -902,7 +902,7 @@ static inline void ptlrpc_req_set_repsize(struct ptlrpc_request *req, int count, __u32 *lens) { int size = lustre_msg_size(req->rq_reqmsg->lm_magic, count, lens); - + req->rq_replen = size + lustre_msg_early_size(); if (req->rq_reqmsg->lm_magic == LUSTRE_MSG_MAGIC_V2) req->rq_reqmsg->lm_repsize = size; @@ -942,12 +942,11 @@ const char* ll_opcode2str(__u32 opcode); #ifdef LPROCFS void ptlrpc_lprocfs_register_obd(struct obd_device *obd); void ptlrpc_lprocfs_unregister_obd(struct obd_device *obd); -void ptlrpc_lprocfs_brw(struct ptlrpc_request *req, int opc, int bytes); +void ptlrpc_lprocfs_brw(struct ptlrpc_request *req, int bytes); #else static inline void ptlrpc_lprocfs_register_obd(struct obd_device *obd) {} static inline void ptlrpc_lprocfs_unregister_obd(struct obd_device *obd) {} -static inline void ptlrpc_lprocfs_brw(struct ptlrpc_request *req, int opc, - int bytes) {} +static inline void ptlrpc_lprocfs_brw(struct ptlrpc_request *req, int bytes) {} #endif /* ptlrpc/llog_server.c */ -- 1.8.3.1