2020-03-19 23:44:59 -04:00
/* SPDX-License-Identifier: GPL-2.0 */
# ifndef _FS_CEPH_MDS_METRIC_H
# define _FS_CEPH_MDS_METRIC_H
# include <linux/types.h>
# include <linux/percpu_counter.h>
2020-03-19 23:45:01 -04:00
# include <linux/ktime.h>
2020-03-19 23:44:59 -04:00
2020-07-16 10:05:57 -04:00
extern bool disable_send_metrics ;
enum ceph_metric_type {
CLIENT_METRIC_TYPE_CAP_INFO ,
CLIENT_METRIC_TYPE_READ_LATENCY ,
CLIENT_METRIC_TYPE_WRITE_LATENCY ,
CLIENT_METRIC_TYPE_METADATA_LATENCY ,
CLIENT_METRIC_TYPE_DENTRY_LEASE ,
2021-03-24 13:08:25 +08:00
CLIENT_METRIC_TYPE_OPENED_FILES ,
CLIENT_METRIC_TYPE_PINNED_ICAPS ,
CLIENT_METRIC_TYPE_OPENED_INODES ,
2021-05-13 09:40:53 +08:00
CLIENT_METRIC_TYPE_READ_IO_SIZES ,
CLIENT_METRIC_TYPE_WRITE_IO_SIZES ,
2020-07-16 10:05:57 -04:00
2021-05-13 09:40:53 +08:00
CLIENT_METRIC_TYPE_MAX = CLIENT_METRIC_TYPE_WRITE_IO_SIZES ,
2020-07-16 10:05:57 -04:00
} ;
2020-07-16 10:05:58 -04:00
/*
* This will always have the highest metric bit value
* as the last element of the array .
*/
# define CEPHFS_METRIC_SPEC_CLIENT_SUPPORTED { \
CLIENT_METRIC_TYPE_CAP_INFO , \
CLIENT_METRIC_TYPE_READ_LATENCY , \
CLIENT_METRIC_TYPE_WRITE_LATENCY , \
CLIENT_METRIC_TYPE_METADATA_LATENCY , \
2020-11-05 23:30:21 -05:00
CLIENT_METRIC_TYPE_DENTRY_LEASE , \
2021-03-24 13:08:25 +08:00
CLIENT_METRIC_TYPE_OPENED_FILES , \
CLIENT_METRIC_TYPE_PINNED_ICAPS , \
CLIENT_METRIC_TYPE_OPENED_INODES , \
2021-05-13 09:40:53 +08:00
CLIENT_METRIC_TYPE_READ_IO_SIZES , \
CLIENT_METRIC_TYPE_WRITE_IO_SIZES , \
2020-07-16 10:05:58 -04:00
\
CLIENT_METRIC_TYPE_MAX , \
}
2021-05-13 09:40:52 +08:00
struct ceph_metric_header {
2020-07-16 10:05:57 -04:00
__le32 type ; /* ceph metric type */
__u8 ver ;
__u8 compat ;
__le32 data_len ; /* length of sizeof(hit + mis + total) */
2021-05-13 09:40:52 +08:00
} __packed ;
/* metric caps header */
struct ceph_metric_cap {
struct ceph_metric_header header ;
2020-07-16 10:05:57 -04:00
__le64 hit ;
__le64 mis ;
__le64 total ;
} __packed ;
/* metric read latency header */
struct ceph_metric_read_latency {
2021-05-13 09:40:52 +08:00
struct ceph_metric_header header ;
2020-07-16 10:05:57 -04:00
__le32 sec ;
__le32 nsec ;
} __packed ;
/* metric write latency header */
struct ceph_metric_write_latency {
2021-05-13 09:40:52 +08:00
struct ceph_metric_header header ;
2020-07-16 10:05:57 -04:00
__le32 sec ;
__le32 nsec ;
} __packed ;
/* metric metadata latency header */
struct ceph_metric_metadata_latency {
2021-05-13 09:40:52 +08:00
struct ceph_metric_header header ;
2020-07-16 10:05:57 -04:00
__le32 sec ;
__le32 nsec ;
} __packed ;
2020-11-05 23:30:21 -05:00
/* metric dentry lease header */
struct ceph_metric_dlease {
2021-05-13 09:40:52 +08:00
struct ceph_metric_header header ;
2020-11-05 23:30:21 -05:00
__le64 hit ;
__le64 mis ;
__le64 total ;
} __packed ;
2021-03-24 13:08:25 +08:00
/* metric opened files header */
struct ceph_opened_files {
2021-05-13 09:40:52 +08:00
struct ceph_metric_header header ;
2021-03-24 13:08:25 +08:00
__le64 opened_files ;
__le64 total ;
} __packed ;
/* metric pinned i_caps header */
struct ceph_pinned_icaps {
2021-05-13 09:40:52 +08:00
struct ceph_metric_header header ;
2021-03-24 13:08:25 +08:00
__le64 pinned_icaps ;
__le64 total ;
} __packed ;
/* metric opened inodes header */
struct ceph_opened_inodes {
2021-05-13 09:40:52 +08:00
struct ceph_metric_header header ;
2021-03-24 13:08:25 +08:00
__le64 opened_inodes ;
__le64 total ;
} __packed ;
2021-05-13 09:40:53 +08:00
/* metric read io size header */
struct ceph_read_io_size {
struct ceph_metric_header header ;
__le64 total_ops ;
__le64 total_size ;
} __packed ;
/* metric write io size header */
struct ceph_write_io_size {
struct ceph_metric_header header ;
__le64 total_ops ;
__le64 total_size ;
} __packed ;
2020-07-16 10:05:57 -04:00
struct ceph_metric_head {
__le32 num ; /* the number of metrics that will be sent */
} __packed ;
2021-10-29 15:09:28 +01:00
enum metric_type {
METRIC_READ ,
METRIC_WRITE ,
METRIC_METADATA ,
2021-11-04 12:31:47 +00:00
METRIC_COPYFROM ,
2021-10-29 15:09:28 +01:00
METRIC_MAX
} ;
struct ceph_metric {
spinlock_t lock ;
u64 total ;
u64 size_sum ;
u64 size_min ;
u64 size_max ;
ktime_t latency_sum ;
ktime_t latency_sq_sum ;
ktime_t latency_min ;
ktime_t latency_max ;
} ;
2020-03-19 23:44:59 -04:00
/* This is the global metrics */
struct ceph_client_metric {
atomic64_t total_dentries ;
struct percpu_counter d_lease_hit ;
struct percpu_counter d_lease_mis ;
2020-03-19 23:45:00 -04:00
2020-06-30 03:52:16 -04:00
atomic64_t total_caps ;
2020-03-19 23:45:00 -04:00
struct percpu_counter i_caps_hit ;
struct percpu_counter i_caps_mis ;
2020-03-19 23:45:01 -04:00
2021-10-29 15:09:28 +01:00
struct ceph_metric metric [ METRIC_MAX ] ;
2020-07-16 10:05:57 -04:00
2020-09-03 09:01:40 -04:00
/* The total number of directories and files that are opened */
atomic64_t opened_files ;
/* The total number of inodes that have opened files or directories */
struct percpu_counter opened_inodes ;
struct percpu_counter total_inodes ;
2020-07-16 10:05:57 -04:00
struct ceph_mds_session * session ;
struct delayed_work delayed_work ; /* delayed work */
2020-03-19 23:44:59 -04:00
} ;
2020-07-16 10:05:57 -04:00
static inline void metric_schedule_delayed ( struct ceph_client_metric * m )
{
if ( disable_send_metrics )
return ;
/* per second */
schedule_delayed_work ( & m - > delayed_work , round_jiffies_relative ( HZ ) ) ;
}
2020-03-19 23:44:59 -04:00
extern int ceph_metric_init ( struct ceph_client_metric * m ) ;
extern void ceph_metric_destroy ( struct ceph_client_metric * m ) ;
2020-03-19 23:45:00 -04:00
static inline void ceph_update_cap_hit ( struct ceph_client_metric * m )
{
percpu_counter_inc ( & m - > i_caps_hit ) ;
}
static inline void ceph_update_cap_mis ( struct ceph_client_metric * m )
{
percpu_counter_inc ( & m - > i_caps_mis ) ;
}
2020-03-19 23:45:01 -04:00
2021-10-29 15:09:28 +01:00
extern void ceph_update_metrics ( struct ceph_metric * m ,
ktime_t r_start , ktime_t r_end ,
unsigned int size , int rc ) ;
static inline void ceph_update_read_metrics ( struct ceph_client_metric * m ,
ktime_t r_start , ktime_t r_end ,
unsigned int size , int rc )
{
ceph_update_metrics ( & m - > metric [ METRIC_READ ] ,
r_start , r_end , size , rc ) ;
}
static inline void ceph_update_write_metrics ( struct ceph_client_metric * m ,
ktime_t r_start , ktime_t r_end ,
unsigned int size , int rc )
{
ceph_update_metrics ( & m - > metric [ METRIC_WRITE ] ,
r_start , r_end , size , rc ) ;
}
static inline void ceph_update_metadata_metrics ( struct ceph_client_metric * m ,
ktime_t r_start , ktime_t r_end ,
int rc )
{
ceph_update_metrics ( & m - > metric [ METRIC_METADATA ] ,
r_start , r_end , 0 , rc ) ;
}
2021-11-04 12:31:47 +00:00
static inline void ceph_update_copyfrom_metrics ( struct ceph_client_metric * m ,
ktime_t r_start , ktime_t r_end ,
unsigned int size , int rc )
{
ceph_update_metrics ( & m - > metric [ METRIC_COPYFROM ] ,
r_start , r_end , size , rc ) ;
}
2020-03-19 23:44:59 -04:00
# endif /* _FS_CEPH_MDS_METRIC_H */