Lines Matching refs:cl
415 struct ceph_client *cl = req->r_mdsc->fsc->client; in parse_reply_info_readdir() local
438 pr_err_client(cl, "dir contents are larger than expected\n"); in parse_reply_info_readdir()
459 doutc(cl, "parsed dir dname '%.*s'\n", _name_len, _name); in parse_reply_info_readdir()
519 pr_err_client(cl, "unable to decode %.*s, got %d\n", in parse_reply_info_readdir()
544 pr_err_client(cl, "problem parsing dir contents %d\n", err); in parse_reply_info_readdir()
575 struct ceph_client *cl = s->s_mdsc->fsc->client; in ceph_parse_deleg_inos() local
579 doutc(cl, "got %u sets of delegated inodes\n", sets); in ceph_parse_deleg_inos()
588 pr_warn_ratelimited_client(cl, in ceph_parse_deleg_inos()
598 doutc(cl, "added delegated inode 0x%llx\n", start - 1); in ceph_parse_deleg_inos()
600 pr_warn_client(cl, in ceph_parse_deleg_inos()
751 struct ceph_client *cl = s->s_mdsc->fsc->client; in parse_reply_info() local
791 pr_err_client(cl, "mds parse_reply err %d\n", err); in parse_reply_info()
839 struct ceph_client *cl = fsc->client; in ceph_wait_on_conflict_unlink() local
864 pr_warn_client(cl, "dentry %p:%pd async unlink bit is not set\n", in ceph_wait_on_conflict_unlink()
881 doutc(cl, "dentry %p:%pd conflict with old %p:%pd\n", dentry, dentry, in ceph_wait_on_conflict_unlink()
966 struct ceph_client *cl = mdsc->fsc->client; in register_session() local
983 doutc(cl, "realloc to %d\n", newmax); in register_session()
996 doutc(cl, "mds%d\n", mds); in register_session()
1167 struct ceph_client *cl = mdsc->fsc->client; in __register_request() local
1175 pr_err_client(cl, "%p failed to reserve caps: %d\n", in __register_request()
1182 doutc(cl, "%p tid %lld\n", req, req->r_tid); in __register_request()
1293 struct ceph_client *cl = mdsc->fsc->client; in __choose_mds() local
1305 doutc(cl, "using resend_mds mds%d\n", req->r_resend_mds); in __choose_mds()
1322 doutc(cl, "using snapdir's parent %p %llx.%llx\n", in __choose_mds()
1343 doutc(cl, "using nonsnap parent %p %llx.%llx\n", in __choose_mds()
1363 doutc(cl, "%p %llx.%llx is_hash=%d (0x%x) mode %d\n", inode, in __choose_mds()
1380 doutc(cl, "%p %llx.%llx frag %u mds%d (%d/%d)\n", in __choose_mds()
1395 doutc(cl, "%p %llx.%llx frag %u mds%d (auth)\n", in __choose_mds()
1420 doutc(cl, "%p %llx.%llx mds%d (%scap %p)\n", inode, in __choose_mds()
1433 doutc(cl, "chose random mds%d\n", mds); in __choose_mds()
1547 struct ceph_client *cl = mdsc->fsc->client; in create_session_full_msg() local
1589 pr_err_client(cl, "ENOMEM creating session open msg\n"); in create_session_full_msg()
1629 pr_err_client(cl, "encode_supported_features failed!\n"); in create_session_full_msg()
1636 pr_err_client(cl, "encode_metric_spec failed!\n"); in create_session_full_msg()
1718 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_open_export_target_session() local
1720 doutc(cl, "to mds%d\n", target); in ceph_mdsc_open_export_target_session()
1735 struct ceph_client *cl = mdsc->fsc->client; in __open_export_target_sessions() local
1741 doutc(cl, "for mds%d (%d targets)\n", session->s_mds, in __open_export_target_sessions()
1757 struct ceph_client *cl = session->s_mdsc->fsc->client; in detach_cap_releases() local
1763 doutc(cl, "mds%d\n", session->s_mds); in detach_cap_releases()
1781 struct ceph_client *cl = mdsc->fsc->client; in cleanup_session_requests() local
1785 doutc(cl, "mds%d\n", session->s_mds); in cleanup_session_requests()
1790 pr_warn_ratelimited_client(cl, " dropping unsafe request %llu\n", in cleanup_session_requests()
1820 struct ceph_client *cl = session->s_mdsc->fsc->client; in ceph_iterate_session_caps() local
1827 doutc(cl, "%p mds%d\n", session, session->s_mds); in ceph_iterate_session_caps()
1858 doutc(cl, "finishing cap %p removal\n", cap); in ceph_iterate_session_caps()
1887 struct ceph_client *cl = ceph_inode_to_client(inode); in remove_session_caps_cb() local
1895 doutc(cl, " removing cap %p, ci is %p, inode is %p\n", in remove_session_caps_cb()
2001 struct ceph_client *cl = session->s_mdsc->fsc->client; in wake_up_session_caps() local
2003 doutc(cl, "session %p mds%d\n", session, session->s_mds); in wake_up_session_caps()
2017 struct ceph_client *cl = mdsc->fsc->client; in send_renew_caps() local
2023 pr_info_client(cl, "mds%d caps stale\n", session->s_mds); in send_renew_caps()
2030 doutc(cl, "ignoring mds%d (%s)\n", session->s_mds, in send_renew_caps()
2035 doutc(cl, "to mds%d (%s)\n", session->s_mds, in send_renew_caps()
2048 struct ceph_client *cl = mdsc->fsc->client; in send_flushmsg_ack() local
2051 doutc(cl, "to mds%d (%s)s seq %lld\n", session->s_mds, in send_flushmsg_ack()
2069 struct ceph_client *cl = mdsc->fsc->client; in renewed_caps() local
2081 pr_info_client(cl, "mds%d caps renewed\n", in renewed_caps()
2085 pr_info_client(cl, "mds%d caps still stale\n", in renewed_caps()
2089 doutc(cl, "mds%d ttl now %lu, was %s, now %s\n", session->s_mds, in renewed_caps()
2103 struct ceph_client *cl = session->s_mdsc->fsc->client; in request_close_session() local
2106 doutc(cl, "mds%d state %s seq %lld\n", session->s_mds, in request_close_session()
2164 struct ceph_client *cl = mdsc->fsc->client; in trim_caps_cb() local
2184 doutc(cl, "%p %llx.%llx cap %p mine %s oissued %s used %s wanted %s\n", in trim_caps_cb()
2227 doutc(cl, "%p %llx.%llx cap %p pruned, count now %d\n", in trim_caps_cb()
2247 struct ceph_client *cl = mdsc->fsc->client; in ceph_trim_caps() local
2250 doutc(cl, "mds%d start: %d / %d, trim %d\n", session->s_mds, in ceph_trim_caps()
2256 doutc(cl, "mds%d done: %d / %d, trimmed %d\n", in ceph_trim_caps()
2268 struct ceph_client *cl = mdsc->fsc->client; in check_caps_flush() local
2277 doutc(cl, "still flushing tid %llu <= %llu\n", in check_caps_flush()
2294 struct ceph_client *cl = mdsc->fsc->client; in wait_caps_flush() local
2296 doutc(cl, "want %llu\n", want_flush_tid); in wait_caps_flush()
2301 doutc(cl, "ok, flushed thru %llu\n", want_flush_tid); in wait_caps_flush()
2310 struct ceph_client *cl = mdsc->fsc->client; in ceph_send_cap_releases() local
2369 doutc(cl, "mds%d %p\n", session->s_mds, msg); in ceph_send_cap_releases()
2389 doutc(cl, "mds%d %p\n", session->s_mds, msg); in ceph_send_cap_releases()
2394 pr_err_client(cl, "mds%d, failed to allocate message\n", in ceph_send_cap_releases()
2418 struct ceph_client *cl = mdsc->fsc->client; in ceph_flush_session_cap_releases() local
2425 doutc(cl, "cap release work queued\n"); in ceph_flush_session_cap_releases()
2428 doutc(cl, "failed to queue cap release work\n"); in ceph_flush_session_cap_releases()
2456 struct ceph_client *cl = mdsc->fsc->client; in ceph_queue_cap_reclaim_work() local
2461 doutc(cl, "caps reclaim work queued\n"); in ceph_queue_cap_reclaim_work()
2463 doutc(cl, "failed to queue caps release work\n"); in ceph_queue_cap_reclaim_work()
2481 struct ceph_client *cl = mdsc->fsc->client; in ceph_queue_cap_unlink_work() local
2486 doutc(cl, "caps unlink work queued\n"); in ceph_queue_cap_unlink_work()
2488 doutc(cl, "failed to queue caps unlink work\n"); in ceph_queue_cap_unlink_work()
2496 struct ceph_client *cl = mdsc->fsc->client; in ceph_cap_unlink_work() local
2498 doutc(cl, "begin\n"); in ceph_cap_unlink_work()
2512 doutc(cl, "on %p %llx.%llx\n", inode, in ceph_cap_unlink_work()
2520 doutc(cl, "done\n"); in ceph_cap_unlink_work()
2705 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_build_path() local
2731 doutc(cl, "path+%d: %p SNAPDIR\n", pos, cur); in ceph_mdsc_build_path()
2815 doutc(cl, "on %p %d built %llx '%.*s'\n", dentry, d_count(dentry), in ceph_mdsc_build_path()
2879 struct ceph_client *cl = mdsc->fsc->client; in set_request_path_attr() local
2884 doutc(cl, " inode %p %llx.%llx\n", rinode, ceph_ino(rinode), in set_request_path_attr()
2889 doutc(cl, " dentry %p %llx/%.*s\n", rdentry, *ino, *pathlen, *ppath); in set_request_path_attr()
2894 doutc(cl, " path %.*s\n", *pathlen, rpath); in set_request_path_attr()
2968 struct ceph_client *cl = mdsc->fsc->client; in create_request_message() local
3083 pr_warn_once_client(cl, in create_request_message()
3093 pr_err_ratelimited_client(cl, in create_request_message()
3257 struct ceph_client *cl = mdsc->fsc->client; in __prepare_send_request() local
3276 pr_warn_ratelimited_client(cl, "request tid %llu seq overflow\n", in __prepare_send_request()
3292 doutc(cl, "%p tid %lld %s (attempt %d)\n", req, req->r_tid, in __prepare_send_request()
3361 doutc(cl, " r_parent = %p\n", req->r_parent); in __prepare_send_request()
3389 struct ceph_client *cl = mdsc->fsc->client; in __do_request() local
3402 doutc(cl, "metadata corrupted\n"); in __do_request()
3408 doutc(cl, "timed out\n"); in __do_request()
3413 doutc(cl, "forced umount\n"); in __do_request()
3420 doutc(cl, "mdsmap err %d\n", err); in __do_request()
3424 doutc(cl, "no mdsmap, waiting for map\n"); in __do_request()
3445 doutc(cl, "no mds or not active, waiting for map\n"); in __do_request()
3461 doutc(cl, "mds%d session %p state %s\n", mds, session, in __do_request()
3553 doutc(cl, "session changed for auth cap %d -> %d\n", in __do_request()
3581 doutc(cl, "early error %d\n", err); in __do_request()
3595 struct ceph_client *cl = mdsc->fsc->client; in __wake_requests() local
3605 doutc(cl, " wake request %p tid %llu\n", req, in __wake_requests()
3617 struct ceph_client *cl = mdsc->fsc->client; in kick_requests() local
3621 doutc(cl, "kick_requests mds%d\n", mds); in kick_requests()
3631 doutc(cl, " kicking tid %llu\n", req->r_tid); in kick_requests()
3641 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_submit_request() local
3663 doutc(cl, "wait for async create returned: %d\n", err); in ceph_mdsc_submit_request()
3671 doutc(cl, "wait for async create returned: %d\n", err); in ceph_mdsc_submit_request()
3676 doutc(cl, "submit_request on %p for inode %p\n", req, dir); in ceph_mdsc_submit_request()
3689 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_wait_request() local
3693 doutc(cl, "do_request waiting\n"); in ceph_mdsc_wait_request()
3707 doutc(cl, "do_request waited, got %d\n", err); in ceph_mdsc_wait_request()
3714 doutc(cl, "aborted request %lld with %d\n", req->r_tid, err); in ceph_mdsc_wait_request()
3745 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_do_request() local
3748 doutc(cl, "do_request on %p\n", req); in ceph_mdsc_do_request()
3754 doutc(cl, "do_request %p done, result %d\n", req, err); in ceph_mdsc_do_request()
3766 struct ceph_client *cl = req->r_mdsc->fsc->client; in ceph_invalidate_dir_request() local
3768 doutc(cl, "invalidate_dir_request %p %p (complete, lease(s))\n", in ceph_invalidate_dir_request()
3790 struct ceph_client *cl = mdsc->fsc->client; in handle_reply() local
3801 pr_err_client(cl, "got corrupt (short) reply\n"); in handle_reply()
3811 doutc(cl, "on unknown tid %llu\n", tid); in handle_reply()
3815 doutc(cl, "handle_reply %p\n", req); in handle_reply()
3819 pr_err_client(cl, "got %llu on session mds%d not mds%d\n", in handle_reply()
3829 pr_warn_client(cl, "got a dup %s reply on %llu from mds%d\n", in handle_reply()
3835 pr_warn_client(cl, "got unsafe after safe on %llu from mds%d\n", in handle_reply()
3859 doutc(cl, "got safe reply %llu, mds%d\n", tid, mds); in handle_reply()
3869 doutc(cl, "tid %lld result %d\n", tid, result); in handle_reply()
3909 pr_err_client(cl, "got corrupt reply mds%d(tid:%lld)\n", in handle_reply()
3974 doutc(cl, "reply arrived after request %lld was aborted\n", tid); in handle_reply()
4003 struct ceph_client *cl = mdsc->fsc->client; in handle_forward() local
4021 doutc(cl, "forward tid %llu to mds%d - req dne\n", tid, next_mds); in handle_forward()
4026 doutc(cl, "forward tid %llu aborted, unregistering\n", tid); in handle_forward()
4042 pr_warn_ratelimited_client(cl, "forward tid %llu seq overflow\n", in handle_forward()
4046 doutc(cl, "forward tid %llu to mds%d (we resend)\n", tid, next_mds); in handle_forward()
4064 pr_err_client(cl, "decode error err=%d\n", err); in handle_forward()
4103 struct ceph_client *cl = mdsc->fsc->client; in handle_session() local
4154 pr_warn_client(cl, "mds%d session blocklisted\n", in handle_session()
4162 doutc(cl, "cap_auths_num %d\n", cap_auths_num); in handle_session()
4173 pr_err_client(cl, "No memory for cap_auths\n"); in handle_session()
4191 pr_err_client(cl, "No memory for gids\n"); in handle_session()
4207 pr_err_client(cl, "No memory for path\n"); in handle_session()
4224 pr_err_client(cl, "No memory for fs_name\n"); in handle_session()
4233 …doutc(cl, "uid %lld, num_gids %u, path %s, fs_name %s, root_squash %d, readable %d, writeable %d\n… in handle_session()
4265 doutc(cl, "mds%d %s %p state %s seq %llu\n", mds, in handle_session()
4271 pr_info_client(cl, "mds%d came back\n", session->s_mds); in handle_session()
4277 pr_info_client(cl, "mds%d reconnect success\n", in handle_session()
4282 pr_notice_client(cl, "mds%d is already opened\n", in handle_session()
4312 pr_info_client(cl, "mds%d reconnect denied\n", in handle_session()
4322 pr_info_client(cl, "mds%d caps went stale, renewing\n", in handle_session()
4344 doutc(cl, "force_session_readonly %p\n", session); in handle_session()
4353 pr_info_client(cl, "mds%d rejected session\n", in handle_session()
4364 pr_err_client(cl, "bad op %d mds%d\n", op, mds); in handle_session()
4381 pr_err_client(cl, "corrupt message mds%d len %d\n", mds, in handle_session()
4396 struct ceph_client *cl = req->r_mdsc->fsc->client; in ceph_mdsc_release_dir_caps() local
4401 doutc(cl, "releasing r_dir_caps=%s\n", ceph_cap_string(dcaps)); in ceph_mdsc_release_dir_caps()
4408 struct ceph_client *cl = req->r_mdsc->fsc->client; in ceph_mdsc_release_dir_caps_async() local
4413 doutc(cl, "releasing r_dir_caps=%s\n", ceph_cap_string(dcaps)); in ceph_mdsc_release_dir_caps_async()
4572 struct ceph_client *cl = ceph_inode_to_client(inode); in reconnect_caps_cb() local
4609 doutc(cl, " adding %p ino %llx.%llx cap %p %lld %s\n", inode, in reconnect_caps_cb()
4765 struct ceph_client *cl = mdsc->fsc->client; in encode_snap_realms() local
4804 doutc(cl, " adding snap realm %llx seq %lld parent %llx\n", in encode_snap_realms()
4834 struct ceph_client *cl = mdsc->fsc->client; in send_mds_reconnect() local
4843 pr_info_client(cl, "mds%d reconnect start\n", mds); in send_mds_reconnect()
4859 doutc(cl, "session %p state %s\n", session, in send_mds_reconnect()
4994 pr_err_client(cl, "error %d preparing reconnect for mds%d\n", in send_mds_reconnect()
5014 struct ceph_client *cl = mdsc->fsc->client; in check_new_map() local
5016 doutc(cl, "new %u old %u\n", newmap->m_epoch, oldmap->m_epoch); in check_new_map()
5032 doutc(cl, "mds%d state %s%s -> %s%s (session %s)\n", in check_new_map()
5090 pr_info_client(cl, "mds%d recovery completed\n", in check_new_map()
5135 pr_err_client(cl, in check_new_map()
5141 doutc(cl, "send reconnect to export target mds.%d\n", i); in check_new_map()
5157 doutc(cl, " connecting to export targets of laggy mds%d\n", i); in check_new_map()
5184 struct ceph_client *cl = mdsc->fsc->client; in handle_lease() local
5196 doutc(cl, "from mds%d\n", mds); in handle_lease()
5214 doutc(cl, "%s, ino %llx %p %.*s\n", ceph_lease_op_name(h->action), in handle_lease()
5219 doutc(cl, "no inode %llx\n", vino.ino); in handle_lease()
5226 doutc(cl, "no parent dentry on inode %p\n", inode); in handle_lease()
5286 pr_err_client(cl, "corrupt lease message\n"); in handle_lease()
5294 struct ceph_client *cl = session->s_mdsc->fsc->client; in ceph_mdsc_lease_send_msg() local
5300 doutc(cl, "identry %p %s to mds%d\n", dentry, ceph_lease_op_name(action), in ceph_mdsc_lease_send_msg()
5334 struct ceph_client *cl = mdsc->fsc->client; in maybe_recover_session() local
5346 pr_info_client(cl, "auto reconnect after blocklisted\n"); in maybe_recover_session()
5352 struct ceph_client *cl = s->s_mdsc->fsc->client; in check_session_state() local
5358 pr_info_client(cl, "mds%d hung\n", s->s_mds); in check_session_state()
5378 struct ceph_client *cl = s->s_mdsc->fsc->client; in inc_session_sequence() local
5387 doutc(cl, "resending session close request for mds%d\n", s->s_mds); in inc_session_sequence()
5390 pr_err_client(cl, "unable to close session to mds%d: %d\n", in inc_session_sequence()
5557 struct ceph_client *cl = mdsc->fsc->client; in wait_requests() local
5565 doutc(cl, "waiting for requests\n"); in wait_requests()
5572 doutc(cl, "timed out on tid %llu\n", req->r_tid); in wait_requests()
5578 doutc(cl, "done\n"); in wait_requests()
5583 struct ceph_client *cl = s->s_mdsc->fsc->client; in send_flush_mdlog() local
5593 doutc(cl, "request mdlog flush to mds%d (%s)s seq %lld\n", in send_flush_mdlog()
5598 pr_err_client(cl, "failed to request mdlog flush to mds%d (%s) seq %lld\n", in send_flush_mdlog()
5613 struct ceph_client *cl = mdsc->fsc->client; in ceph_mds_auth_match() local
5619 doutc(cl, "match.uid %lld\n", auth->match.uid); in ceph_mds_auth_match()
5659 doutc(cl, "server path %s, tpath %s, match.path %s\n", in ceph_mds_auth_match()
5683 doutc(cl, "_tpath %s\n", _tpath); in ceph_mds_auth_match()
5713 doutc(cl, "matched\n"); in ceph_mds_auth_match()
5723 struct ceph_client *cl = mdsc->fsc->client; in ceph_mds_check_access() local
5727 doutc(cl, "tpath '%s', mask %d, caller_uid %d, caller_gid %d\n", in ceph_mds_check_access()
5753 doutc(cl, "root_squash_perms %d, rw_perms_s %p\n", root_squash_perms, in ceph_mds_check_access()
5756 doutc(cl, "access allowed\n"); in ceph_mds_check_access()
5761 doutc(cl, "root_squash is enabled and user(%d %d) isn't allowed to write", in ceph_mds_check_access()
5765 doutc(cl, "mds auth caps readable/writeable %d/%d while request r/w %d/%d", in ceph_mds_check_access()
5769 doutc(cl, "access denied\n"); in ceph_mds_check_access()
5803 struct ceph_client *cl = mdsc->fsc->client; in flush_mdlog_and_wait_mdsc_unsafe_requests() local
5809 doutc(cl, "want %lld\n", want_tid); in flush_mdlog_and_wait_mdsc_unsafe_requests()
5843 doutc(cl, "wait on %llu (want %llu)\n", in flush_mdlog_and_wait_mdsc_unsafe_requests()
5862 doutc(cl, "done\n"); in flush_mdlog_and_wait_mdsc_unsafe_requests()
5867 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_sync() local
5873 doutc(cl, "sync\n"); in ceph_mdsc_sync()
5890 doutc(cl, "sync want tid %lld flush_seq %lld\n", want_tid, want_flush); in ceph_mdsc_sync()
5912 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_close_sessions() local
5917 doutc(cl, "begin\n"); in ceph_mdsc_close_sessions()
5935 doutc(cl, "waiting for sessions to close\n"); in ceph_mdsc_close_sessions()
5964 doutc(cl, "done\n"); in ceph_mdsc_close_sessions()
6056 struct ceph_client *cl = fsc->client; in ceph_mdsc_handle_fsmap() local
6068 doutc(cl, "epoch %u\n", epoch); in ceph_mdsc_handle_fsmap()
6113 pr_err_client(cl, "error decoding fsmap %d. Shutting down mount.\n", in ceph_mdsc_handle_fsmap()
6129 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_handle_mdsmap() local
6144 doutc(cl, "epoch %u len %d\n", epoch, (int)maplen); in ceph_mdsc_handle_mdsmap()
6149 doutc(cl, "epoch %u <= our %u\n", epoch, mdsc->mdsmap->m_epoch); in ceph_mdsc_handle_mdsmap()
6183 pr_err_client(cl, "error decoding mdsmap %d. Shutting down mount.\n", in ceph_mdsc_handle_mdsmap()
6226 struct ceph_client *cl = mdsc->fsc->client; in mds_dispatch() local
6266 pr_err_client(cl, "received unknown message type %d %s\n", in mds_dispatch()