From: J. Eric Ivancich Date: Mon, 10 May 2021 21:36:49 +0000 (-0400) Subject: rgw: clean-up logging of function entering to make thorough and consistent X-Git-Tag: v16.2.8~121^2~1 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=aa53bf3ba2c3b8b2f5ea5bfbf91c29b665f1b643;p=ceph.git rgw: clean-up logging of function entering to make thorough and consistent This provides more thorough and consistent function tracing in CLS/RGW when logging is set to 10 or higher. Signed-off-by: J. Eric Ivancich --- diff --git a/src/cls/rgw/cls_rgw.cc b/src/cls/rgw/cls_rgw.cc index 9c4bdabcdece..cd7fa8191632 100644 --- a/src/cls/rgw/cls_rgw.cc +++ b/src/cls/rgw/cls_rgw.cc @@ -469,6 +469,8 @@ static int read_bucket_header(cls_method_context_t hctx, int rgw_bucket_list(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); + // maximum number of calls to get_obj_vals we'll try; compromise // between wanting to return the requested # of entries, but not // wanting to slow down this op with too many omap reads @@ -722,6 +724,7 @@ static int check_index(cls_method_context_t hctx, int rgw_bucket_check_index(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); rgw_cls_check_index_ret ret; int rc = check_index(hctx, &ret.existing_header, &ret.calculated_header); @@ -745,6 +748,7 @@ static int write_bucket_header(cls_method_context_t hctx, rgw_bucket_dir_header int rgw_bucket_rebuild_index(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); rgw_bucket_dir_header existing_header; rgw_bucket_dir_header calc_header; int rc = check_index(hctx, &existing_header, &calc_header); @@ -756,6 +760,7 @@ int rgw_bucket_rebuild_index(cls_method_context_t hctx, bufferlist *in, bufferli int rgw_bucket_update_stats(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_bucket_update_stats_op op; auto iter = in->cbegin(); @@ -790,6 +795,7 @@ int rgw_bucket_update_stats(cls_method_context_t hctx, bufferlist *in, bufferlis int rgw_bucket_init_index(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); bufferlist header_bl; int rc = cls_cxx_map_read_header(hctx, &header_bl); if (rc < 0) { @@ -814,6 +820,7 @@ int rgw_bucket_init_index(cls_method_context_t hctx, bufferlist *in, bufferlist int rgw_bucket_set_tag_timeout(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_tag_timeout_op op; auto iter = in->cbegin(); @@ -842,6 +849,7 @@ static int read_key_entry(cls_method_context_t hctx, cls_rgw_obj_key& key, int rgw_bucket_prepare_op(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_obj_prepare_op op; auto iter = in->cbegin(); @@ -984,6 +992,7 @@ static int read_key_entry(cls_method_context_t hctx, cls_rgw_obj_key& key, int rgw_bucket_complete_op(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_obj_complete_op op; auto iter = in->cbegin(); @@ -1382,7 +1391,7 @@ public: real_time mtime() { return instance_entry.meta.mtime; } -}; +}; // class BIVerObjEntry class BIOLHEntry { @@ -1558,6 +1567,7 @@ static int convert_plain_entry_to_versioned(cls_method_context_t hctx, */ static int rgw_bucket_link_olh(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); string olh_data_idx; string instance_idx; @@ -1792,6 +1802,7 @@ static int rgw_bucket_link_olh(cls_method_context_t hctx, bufferlist *in, buffer static int rgw_bucket_unlink_instance(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); string olh_data_idx; string instance_idx; @@ -1948,6 +1959,7 @@ static int rgw_bucket_unlink_instance(cls_method_context_t hctx, bufferlist *in, static int rgw_bucket_read_olh_log(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_read_olh_log_op op; auto iter = in->cbegin(); @@ -2001,6 +2013,7 @@ static int rgw_bucket_read_olh_log(cls_method_context_t hctx, bufferlist *in, bu static int rgw_bucket_trim_olh_log(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_trim_olh_log_op op; auto iter = in->cbegin(); @@ -2052,6 +2065,7 @@ static int rgw_bucket_trim_olh_log(cls_method_context_t hctx, bufferlist *in, bu static int rgw_bucket_clear_olh(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_bucket_clear_olh_op op; auto iter = in->cbegin(); @@ -2118,7 +2132,7 @@ static int rgw_bucket_clear_olh(cls_method_context_t hctx, bufferlist *in, buffe int rgw_dir_suggest_changes(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { - CLS_LOG(1, "rgw_dir_suggest_changes()"); + CLS_LOG(1, "entered %s()\n", __func__); bufferlist header_bl; rgw_bucket_dir_header header; @@ -2246,6 +2260,7 @@ int rgw_dir_suggest_changes(cls_method_context_t hctx, static int rgw_obj_remove(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_obj_remove_op op; auto iter = in->cbegin(); @@ -2319,6 +2334,7 @@ static int rgw_obj_remove(cls_method_context_t hctx, bufferlist *in, bufferlist static int rgw_obj_store_pg_ver(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_obj_store_pg_ver_op op; auto iter = in->cbegin(); @@ -2343,6 +2359,7 @@ static int rgw_obj_store_pg_ver(cls_method_context_t hctx, bufferlist *in, buffe static int rgw_obj_check_attrs_prefix(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_obj_check_attrs_prefix op; auto iter = in->cbegin(); @@ -2386,6 +2403,7 @@ static int rgw_obj_check_attrs_prefix(cls_method_context_t hctx, bufferlist *in, static int rgw_obj_check_mtime(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_obj_check_mtime op; auto iter = in->cbegin(); @@ -2449,6 +2467,7 @@ static int rgw_obj_check_mtime(cls_method_context_t hctx, bufferlist *in, buffer static int rgw_bi_get_op(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_bi_get_op op; auto iter = in->cbegin(); @@ -2497,6 +2516,7 @@ static int rgw_bi_get_op(cls_method_context_t hctx, bufferlist *in, bufferlist * static int rgw_bi_put_op(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_bi_put_op op; auto iter = in->cbegin(); @@ -2871,6 +2891,7 @@ static int rgw_bi_list_op(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); // decode request rgw_cls_bi_list_op op; auto iter = in->cbegin(); @@ -3064,6 +3085,7 @@ static int bi_log_list_entries(cls_method_context_t hctx, const string& marker, static int rgw_bi_log_list(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_bi_log_list_op op; @@ -3086,6 +3108,7 @@ static int rgw_bi_log_list(cls_method_context_t hctx, bufferlist *in, bufferlist static int rgw_bi_log_trim(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_bi_log_trim_op op; @@ -3147,6 +3170,7 @@ static int rgw_bi_log_trim(cls_method_context_t hctx, bufferlist *in, bufferlist static int rgw_bi_log_resync(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); rgw_bucket_dir_header header; int rc = read_bucket_header(hctx, &header); if (rc < 0) { @@ -3179,8 +3203,9 @@ static int rgw_bi_log_resync(cls_method_context_t hctx, bufferlist *in, bufferli return write_bucket_header(hctx, &header); } -static int rgw_bi_log_stop(cls_method_context_t hctx, bufferlist *in, bufferlist *out) +static int rgw_bi_log_stop(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); rgw_bucket_dir_header header; int rc = read_bucket_header(hctx, &header); if (rc < 0) { @@ -3256,7 +3281,7 @@ static int usage_record_decode(bufferlist& record_bl, rgw_usage_log_entry& e) int rgw_user_usage_log_add(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { - CLS_LOG(10, "rgw_user_usage_log_add()"); + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); rgw_cls_usage_log_add_op op; @@ -3316,7 +3341,7 @@ static int usage_iterate_range(cls_method_context_t hctx, uint64_t start, uint64 int (*cb)(cls_method_context_t, const string&, rgw_usage_log_entry&, void *), void *param) { - CLS_LOG(10, "usage_iterate_range"); + CLS_LOG(10, "entered %s()\n", __func__); map keys; string filter_prefix; @@ -3415,7 +3440,7 @@ static int usage_log_read_cb(cls_method_context_t hctx, const string& key, rgw_u int rgw_user_usage_log_read(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { - CLS_LOG(10, "rgw_user_usage_log_read()"); + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); rgw_cls_usage_log_read_op op; @@ -3465,7 +3490,7 @@ static int usage_log_trim_cb(cls_method_context_t hctx, const string& key, rgw_u int rgw_user_usage_log_trim(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { - CLS_LOG(10, "rgw_user_usage_log_trim()"); + CLS_LOG(10, "entered %s()\n", __func__); /* only continue if object exists! */ int ret = cls_cxx_stat(hctx, NULL, NULL); @@ -3498,7 +3523,7 @@ int rgw_user_usage_log_trim(cls_method_context_t hctx, bufferlist *in, bufferlis int rgw_usage_log_clear(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { - CLS_LOG(10,"%s", __func__); + CLS_LOG(10, "entered %s()\n", __func__); int ret = cls_cxx_map_clear(hctx); /* if object doesn't exist all the logs are cleared anyway */ @@ -3657,6 +3682,7 @@ int gc_record_decode(bufferlist& bl, cls_rgw_gc_obj_info& e) static int rgw_cls_gc_set_entry(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_gc_set_entry_op op; @@ -3672,6 +3698,7 @@ static int rgw_cls_gc_set_entry(cls_method_context_t hctx, bufferlist *in, buffe static int rgw_cls_gc_defer_entry(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_gc_defer_entry_op op; @@ -3794,6 +3821,7 @@ static int gc_list_entries(cls_method_context_t hctx, const string& marker, static int rgw_cls_gc_list(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_gc_list_op op; @@ -3849,6 +3877,7 @@ static int gc_remove(cls_method_context_t hctx, vector& tags) static int rgw_cls_gc_remove(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_gc_remove_op op; @@ -3864,6 +3893,7 @@ static int rgw_cls_gc_remove(cls_method_context_t hctx, bufferlist *in, bufferli static int rgw_cls_lc_get_entry(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_lc_get_entry_op op; @@ -3887,6 +3917,7 @@ static int rgw_cls_lc_get_entry(cls_method_context_t hctx, bufferlist *in, buffe static int rgw_cls_lc_set_entry(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_lc_set_entry_op op; @@ -3906,6 +3937,7 @@ static int rgw_cls_lc_set_entry(cls_method_context_t hctx, bufferlist *in, buffe static int rgw_cls_lc_rm_entry(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_lc_rm_entry_op op; @@ -3922,6 +3954,7 @@ static int rgw_cls_lc_rm_entry(cls_method_context_t hctx, bufferlist *in, buffer static int rgw_cls_lc_get_next_entry(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_lc_get_next_entry_ret op_ret; cls_rgw_lc_get_next_entry_op op; @@ -3957,6 +3990,7 @@ static int rgw_cls_lc_get_next_entry(cls_method_context_t hctx, bufferlist *in, static int rgw_cls_lc_list_entries(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); cls_rgw_lc_list_entries_op op; auto in_iter = in->cbegin(); try { @@ -3999,6 +4033,7 @@ static int rgw_cls_lc_list_entries(cls_method_context_t hctx, bufferlist *in, static int rgw_cls_lc_put_head(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_lc_put_head_op op; @@ -4017,6 +4052,7 @@ static int rgw_cls_lc_put_head(cls_method_context_t hctx, bufferlist *in, buffer static int rgw_cls_lc_get_head(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); bufferlist bl; int ret = cls_cxx_map_read_header(hctx, &bl); if (ret < 0) @@ -4042,6 +4078,7 @@ static int rgw_cls_lc_get_head(cls_method_context_t hctx, bufferlist *in, buffe static int rgw_reshard_add(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_reshard_add_op op; @@ -4069,6 +4106,7 @@ static int rgw_reshard_add(cls_method_context_t hctx, bufferlist *in, bufferlist static int rgw_reshard_list(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); cls_rgw_reshard_list_op op; auto in_iter = in->cbegin(); try { @@ -4104,6 +4142,7 @@ static int rgw_reshard_list(cls_method_context_t hctx, bufferlist *in, bufferlis static int rgw_reshard_get(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_reshard_get_op op; @@ -4130,6 +4169,7 @@ static int rgw_reshard_get(cls_method_context_t hctx, bufferlist *in, bufferlis static int rgw_reshard_remove(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); auto in_iter = in->cbegin(); cls_rgw_reshard_remove_op op; @@ -4163,6 +4203,7 @@ static int rgw_reshard_remove(cls_method_context_t hctx, bufferlist *in, bufferl static int rgw_set_bucket_resharding(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); cls_rgw_set_bucket_resharding_op op; auto in_iter = in->cbegin(); @@ -4187,6 +4228,7 @@ static int rgw_set_bucket_resharding(cls_method_context_t hctx, bufferlist *in, static int rgw_clear_bucket_resharding(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); cls_rgw_clear_bucket_resharding_op op; auto in_iter = in->cbegin(); @@ -4210,6 +4252,7 @@ static int rgw_clear_bucket_resharding(cls_method_context_t hctx, bufferlist *in static int rgw_guard_bucket_resharding(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); cls_rgw_guard_bucket_resharding_op op; auto in_iter = in->cbegin(); @@ -4237,6 +4280,7 @@ static int rgw_guard_bucket_resharding(cls_method_context_t hctx, bufferlist *in static int rgw_get_bucket_resharding(cls_method_context_t hctx, bufferlist *in, bufferlist *out) { + CLS_LOG(10, "entered %s()\n", __func__); cls_rgw_get_bucket_resharding_op op; auto in_iter = in->cbegin();