| /kernel/linux/linux-5.10/net/ceph/ |
| H A D | mon_client.c | 37 static int __validate_auth(struct ceph_mon_client *monc);
110 static void __send_prepared_auth_request(struct ceph_mon_client *monc, int len) in __send_prepared_auth_request() argument
112 monc->pending_auth = 1; in __send_prepared_auth_request()
113 monc->m_auth->front.iov_len = len; in __send_prepared_auth_request()
114 monc->m_auth->hdr.front_len = cpu_to_le32(len); in __send_prepared_auth_request()
115 ceph_msg_revoke(monc->m_auth); in __send_prepared_auth_request()
116 ceph_msg_get(monc->m_auth); /* keep our ref */ in __send_prepared_auth_request()
117 ceph_con_send(&monc->con, monc->m_auth); in __send_prepared_auth_request()
123 static void __close_session(struct ceph_mon_client *monc) in __close_session() argument
140 pick_new_mon(struct ceph_mon_client *monc) pick_new_mon() argument
174 __open_session(struct ceph_mon_client *monc) __open_session() argument
208 reopen_session(struct ceph_mon_client *monc) reopen_session() argument
218 ceph_monc_reopen_session(struct ceph_mon_client *monc) ceph_monc_reopen_session() argument
225 un_backoff(struct ceph_mon_client *monc) un_backoff() argument
236 __schedule_delayed(struct ceph_mon_client *monc) __schedule_delayed() argument
261 __send_subscribe(struct ceph_mon_client *monc) __send_subscribe() argument
311 handle_subscribe_ack(struct ceph_mon_client *monc, struct ceph_msg *msg) handle_subscribe_ack() argument
349 __ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, bool continuous) __ceph_monc_want_map() argument
370 ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, bool continuous) ceph_monc_want_map() argument
388 __ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch) __ceph_monc_got_map() argument
403 ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch) ceph_monc_got_map() argument
411 ceph_monc_renew_subs(struct ceph_mon_client *monc) ceph_monc_renew_subs() argument
425 ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch, unsigned long timeout) ceph_monc_wait_osdmap() argument
456 ceph_monc_open_session(struct ceph_mon_client *monc) ceph_monc_open_session() argument
468 ceph_monc_handle_map(struct ceph_mon_client *monc, struct ceph_msg *msg) ceph_monc_handle_map() argument
539 alloc_generic_request(struct ceph_mon_client *monc, gfp_t gfp) alloc_generic_request() argument
558 struct ceph_mon_client *monc = req->monc; register_generic_request() local
567 send_generic_request(struct ceph_mon_client *monc, struct ceph_mon_generic_request *req) send_generic_request() argument
579 struct ceph_mon_client *monc = req->monc; __finish_generic_request() local
605 struct ceph_mon_client *monc = req->monc; cancel_generic_request() local
639 struct ceph_mon_client *monc = con->private; get_generic_reply() local
667 handle_statfs_reply(struct ceph_mon_client *monc, struct ceph_msg *msg) handle_statfs_reply() argument
702 ceph_monc_do_statfs(struct ceph_mon_client *monc, u64 data_pool, struct ceph_statfs *buf) ceph_monc_do_statfs() argument
745 handle_get_version_reply(struct ceph_mon_client *monc, struct ceph_msg *msg) handle_get_version_reply() argument
782 __ceph_monc_get_version(struct ceph_mon_client *monc, const char *what, ceph_monc_callback_t cb, u64 private_data) __ceph_monc_get_version() argument
830 ceph_monc_get_version(struct ceph_mon_client *monc, const char *what, u64 *newest) ceph_monc_get_version() argument
854 ceph_monc_get_version_async(struct ceph_mon_client *monc, const char *what, ceph_monc_callback_t cb, u64 private_data) ceph_monc_get_version_async() argument
868 handle_command_ack(struct ceph_mon_client *monc, struct ceph_msg *msg) handle_command_ack() argument
902 do_mon_command_vargs(struct ceph_mon_client *monc, const char *fmt, va_list ap) do_mon_command_vargs() argument
943 do_mon_command(struct ceph_mon_client *monc, const char *fmt, ...) do_mon_command() argument
954 ceph_monc_blocklist_add(struct ceph_mon_client *monc, struct ceph_entity_addr *client_addr) ceph_monc_blocklist_add() argument
994 __resend_generic_request(struct ceph_mon_client *monc) __resend_generic_request() argument
1014 struct ceph_mon_client *monc = delayed_work() local
1063 build_initial_monmap(struct ceph_mon_client *monc) build_initial_monmap() argument
1086 ceph_monc_init(struct ceph_mon_client *monc, struct ceph_client *cl) ceph_monc_init() argument
1165 ceph_monc_stop(struct ceph_mon_client *monc) ceph_monc_stop() argument
1198 finish_hunting(struct ceph_mon_client *monc) finish_hunting() argument
1209 handle_auth_reply(struct ceph_mon_client *monc, struct ceph_msg *msg) handle_auth_reply() argument
1251 __validate_auth(struct ceph_mon_client *monc) __validate_auth() argument
1266 ceph_monc_validate_auth(struct ceph_mon_client *monc) ceph_monc_validate_auth() argument
1282 struct ceph_mon_client *monc = con->private; dispatch() local
1333 struct ceph_mon_client *monc = con->private; mon_alloc_msg() local
1391 struct ceph_mon_client *monc = con->private; mon_fault() local
[all...] |
| H A D | debugfs.c | 25 * .../monc - mon client state
39 if (client->monc.monmap == NULL) in monmap_show()
42 seq_printf(s, "epoch %d\n", client->monc.monmap->epoch); in monmap_show()
43 for (i = 0; i < client->monc.monmap->num_mon; i++) { in monmap_show()
45 &client->monc.monmap->mon_inst[i]; in monmap_show()
142 struct ceph_mon_client *monc = &client->monc; in monc_show() local
146 mutex_lock(&monc->mutex); in monc_show()
148 for (i = 0; i < ARRAY_SIZE(monc->subs); i++) { in monc_show()
150 monc in monc_show()
393 DEFINE_SHOW_ATTRIBUTE(monc); global() variable
[all...] |
| H A D | ceph_common.c | 185 if (ceph_monmap_contains(client->monc.monmap, in ceph_compare_options()
664 return client->monc.auth->global_id; in ceph_client_gid()
706 err = ceph_monc_init(&client->monc, client); in ceph_create_client()
716 ceph_monc_stop(&client->monc); in ceph_create_client()
732 ceph_monc_stop(&client->monc); in ceph_destroy_client()
747 ceph_monc_reopen_session(&client->monc); in ceph_reset_client_addr()
757 return client->monc.monmap && client->monc.monmap->epoch && in have_mon_and_osd_map()
770 err = ceph_monc_open_session(&client->monc); in __ceph_open_session()
818 ret = ceph_monc_get_version(&client->monc, "osdma in ceph_wait_for_latest_osdmap()
[all...] |
| H A D | osd_client.c | 2309 if (ceph_monc_want_map(&osdc->client->monc, CEPH_SUB_OSDMAP, in maybe_request_map()
2311 ceph_monc_renew_subs(&osdc->client->monc); in maybe_request_map()
2646 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in map_check_cb()
2687 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", in send_map_check()
3280 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in linger_map_check_cb()
3323 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", in send_linger_map_check()
4159 ceph_monc_got_map(&osdc->client->monc, CEPH_SUB_OSDMAP, in ceph_osdc_handle_map()
5531 struct ceph_auth_client *ac = osdc->client->monc.auth; in get_authorizer()
5559 struct ceph_auth_client *ac = osdc->client->monc.auth; in add_authorizer_challenge()
5569 struct ceph_auth_client *ac = osdc->client->monc in verify_authorizer_reply()
[all...] |
| /kernel/linux/linux-6.6/net/ceph/ |
| H A D | mon_client.c | 37 static int __validate_auth(struct ceph_mon_client *monc);
175 static void __send_prepared_auth_request(struct ceph_mon_client *monc, int len) in __send_prepared_auth_request() argument
177 monc->pending_auth = 1; in __send_prepared_auth_request()
178 monc->m_auth->front.iov_len = len; in __send_prepared_auth_request()
179 monc->m_auth->hdr.front_len = cpu_to_le32(len); in __send_prepared_auth_request()
180 ceph_msg_revoke(monc->m_auth); in __send_prepared_auth_request()
181 ceph_msg_get(monc->m_auth); /* keep our ref */ in __send_prepared_auth_request()
182 ceph_con_send(&monc->con, monc->m_auth); in __send_prepared_auth_request()
188 static void __close_session(struct ceph_mon_client *monc) in __close_session() argument
205 pick_new_mon(struct ceph_mon_client *monc) pick_new_mon() argument
239 __open_session(struct ceph_mon_client *monc) __open_session() argument
279 reopen_session(struct ceph_mon_client *monc) reopen_session() argument
289 ceph_monc_reopen_session(struct ceph_mon_client *monc) ceph_monc_reopen_session() argument
296 un_backoff(struct ceph_mon_client *monc) un_backoff() argument
307 __schedule_delayed(struct ceph_mon_client *monc) __schedule_delayed() argument
332 __send_subscribe(struct ceph_mon_client *monc) __send_subscribe() argument
382 handle_subscribe_ack(struct ceph_mon_client *monc, struct ceph_msg *msg) handle_subscribe_ack() argument
420 __ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, bool continuous) __ceph_monc_want_map() argument
441 ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, bool continuous) ceph_monc_want_map() argument
459 __ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch) __ceph_monc_got_map() argument
474 ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch) ceph_monc_got_map() argument
482 ceph_monc_renew_subs(struct ceph_mon_client *monc) ceph_monc_renew_subs() argument
496 ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch, unsigned long timeout) ceph_monc_wait_osdmap() argument
527 ceph_monc_open_session(struct ceph_mon_client *monc) ceph_monc_open_session() argument
539 ceph_monc_handle_map(struct ceph_mon_client *monc, struct ceph_msg *msg) ceph_monc_handle_map() argument
610 alloc_generic_request(struct ceph_mon_client *monc, gfp_t gfp) alloc_generic_request() argument
629 struct ceph_mon_client *monc = req->monc; register_generic_request() local
638 send_generic_request(struct ceph_mon_client *monc, struct ceph_mon_generic_request *req) send_generic_request() argument
650 struct ceph_mon_client *monc = req->monc; __finish_generic_request() local
676 struct ceph_mon_client *monc = req->monc; cancel_generic_request() local
710 struct ceph_mon_client *monc = con->private; get_generic_reply() local
738 handle_statfs_reply(struct ceph_mon_client *monc, struct ceph_msg *msg) handle_statfs_reply() argument
773 ceph_monc_do_statfs(struct ceph_mon_client *monc, u64 data_pool, struct ceph_statfs *buf) ceph_monc_do_statfs() argument
816 handle_get_version_reply(struct ceph_mon_client *monc, struct ceph_msg *msg) handle_get_version_reply() argument
853 __ceph_monc_get_version(struct ceph_mon_client *monc, const char *what, ceph_monc_callback_t cb, u64 private_data) __ceph_monc_get_version() argument
901 ceph_monc_get_version(struct ceph_mon_client *monc, const char *what, u64 *newest) ceph_monc_get_version() argument
925 ceph_monc_get_version_async(struct ceph_mon_client *monc, const char *what, ceph_monc_callback_t cb, u64 private_data) ceph_monc_get_version_async() argument
939 handle_command_ack(struct ceph_mon_client *monc, struct ceph_msg *msg) handle_command_ack() argument
973 do_mon_command_vargs(struct ceph_mon_client *monc, const char *fmt, va_list ap) do_mon_command_vargs() argument
1014 do_mon_command(struct ceph_mon_client *monc, const char *fmt, ...) do_mon_command() argument
1025 ceph_monc_blocklist_add(struct ceph_mon_client *monc, struct ceph_entity_addr *client_addr) ceph_monc_blocklist_add() argument
1065 __resend_generic_request(struct ceph_mon_client *monc) __resend_generic_request() argument
1085 struct ceph_mon_client *monc = delayed_work() local
1126 build_initial_monmap(struct ceph_mon_client *monc) build_initial_monmap() argument
1154 ceph_monc_init(struct ceph_mon_client *monc, struct ceph_client *cl) ceph_monc_init() argument
1232 ceph_monc_stop(struct ceph_mon_client *monc) ceph_monc_stop() argument
1263 finish_hunting(struct ceph_mon_client *monc) finish_hunting() argument
1274 finish_auth(struct ceph_mon_client *monc, int auth_err, bool was_authed) finish_auth() argument
1303 handle_auth_reply(struct ceph_mon_client *monc, struct ceph_msg *msg) handle_auth_reply() argument
1324 __validate_auth(struct ceph_mon_client *monc) __validate_auth() argument
1339 ceph_monc_validate_auth(struct ceph_mon_client *monc) ceph_monc_validate_auth() argument
1354 struct ceph_mon_client *monc = con->private; mon_get_auth_request() local
1374 struct ceph_mon_client *monc = con->private; mon_handle_auth_reply_more() local
1395 struct ceph_mon_client *monc = con->private; mon_handle_auth_done() local
1418 struct ceph_mon_client *monc = con->private; mon_handle_auth_bad_method() local
1437 struct ceph_mon_client *monc = con->private; mon_dispatch() local
1488 struct ceph_mon_client *monc = con->private; mon_alloc_msg() local
1546 struct ceph_mon_client *monc = con->private; mon_fault() local
[all...] |
| H A D | debugfs.c | 25 * .../monc - mon client state
39 if (client->monc.monmap == NULL) in monmap_show()
42 seq_printf(s, "epoch %d\n", client->monc.monmap->epoch); in monmap_show()
43 for (i = 0; i < client->monc.monmap->num_mon; i++) { in monmap_show()
45 &client->monc.monmap->mon_inst[i]; in monmap_show()
142 struct ceph_mon_client *monc = &client->monc; in monc_show() local
146 mutex_lock(&monc->mutex); in monc_show()
148 for (i = 0; i < ARRAY_SIZE(monc->subs); i++) { in monc_show()
150 monc in monc_show()
393 DEFINE_SHOW_ATTRIBUTE(monc); global() variable
[all...] |
| H A D | ceph_common.c | 185 if (ceph_monmap_contains(client->monc.monmap, in ceph_compare_options()
700 return client->monc.auth->global_id; in ceph_client_gid()
742 err = ceph_monc_init(&client->monc, client); in ceph_create_client()
752 ceph_monc_stop(&client->monc); in ceph_create_client()
768 ceph_monc_stop(&client->monc); in ceph_destroy_client()
783 ceph_monc_reopen_session(&client->monc); in ceph_reset_client_addr()
793 return client->monc.monmap && client->monc.monmap->epoch && in have_mon_and_osd_map()
806 err = ceph_monc_open_session(&client->monc); in __ceph_open_session()
854 ret = ceph_monc_get_version(&client->monc, "osdma in ceph_wait_for_latest_osdmap()
[all...] |
| H A D | osd_client.c | 2390 if (ceph_monc_want_map(&osdc->client->monc, CEPH_SUB_OSDMAP, in maybe_request_map()
2392 ceph_monc_renew_subs(&osdc->client->monc); in maybe_request_map()
2733 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in map_check_cb()
2774 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", in send_map_check()
3367 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in linger_map_check_cb()
3410 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", in send_linger_map_check()
4249 ceph_monc_got_map(&osdc->client->monc, CEPH_SUB_OSDMAP, in ceph_osdc_handle_map()
5604 struct ceph_auth_client *ac = osdc->client->monc.auth; in osd_get_authorizer()
5621 struct ceph_auth_client *ac = osdc->client->monc.auth; in osd_add_authorizer_challenge()
5631 struct ceph_auth_client *ac = osdc->client->monc in osd_verify_authorizer_reply()
5708 struct ceph_mon_client *monc = &o->o_osdc->client->monc; osd_handle_auth_bad_method() local
[all...] |
| /kernel/linux/linux-5.10/include/linux/ceph/ |
| H A D | mon_client.h | 32 typedef void (*ceph_monc_request_func_t)(struct ceph_mon_client *monc,
37 struct ceph_mon_client *monc; member
51 struct ceph_mon_client *monc; member
110 extern int ceph_monc_init(struct ceph_mon_client *monc, struct ceph_client *cl);
111 extern void ceph_monc_stop(struct ceph_mon_client *monc);
112 extern void ceph_monc_reopen_session(struct ceph_mon_client *monc);
129 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch,
131 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch);
132 void ceph_monc_renew_subs(struct ceph_mon_client *monc);
134 extern int ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u3
[all...] |
| H A D | libceph.h | 140 struct ceph_mon_client monc; member
|
| /kernel/linux/linux-6.6/include/linux/ceph/ |
| H A D | mon_client.h | 32 typedef void (*ceph_monc_request_func_t)(struct ceph_mon_client *monc,
37 struct ceph_mon_client *monc; member
51 struct ceph_mon_client *monc; member
110 extern int ceph_monc_init(struct ceph_mon_client *monc, struct ceph_client *cl);
111 extern void ceph_monc_stop(struct ceph_mon_client *monc);
112 extern void ceph_monc_reopen_session(struct ceph_mon_client *monc);
129 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch,
131 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch);
132 void ceph_monc_renew_subs(struct ceph_mon_client *monc);
134 extern int ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u3
[all...] |
| H A D | libceph.h | 133 struct ceph_mon_client monc; member
|
| /kernel/linux/linux-5.10/fs/ceph/ |
| H A D | super.c | 53 struct ceph_mon_client *monc = &fsc->client->monc; in ceph_statfs() local
65 err = ceph_monc_do_statfs(monc, data_pool, &st); in ceph_statfs()
102 mutex_lock(&monc->mutex); in ceph_statfs()
103 for (i = 0 ; i < sizeof(monc->monmap->fsid) / sizeof(__le32) ; ++i) in ceph_statfs()
104 buf->f_fsid.val[0] ^= le32_to_cpu(((__le32 *)&monc->monmap->fsid)[i]); in ceph_statfs()
105 mutex_unlock(&monc->mutex); in ceph_statfs()
108 buf->f_fsid.val[1] = monc->fs_cluster_id; in ceph_statfs()
659 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_MDSMAP, in create_fs_client()
662 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_FSMA in create_fs_client()
[all...] |
| H A D | mds_client.c | 4994 ceph_monc_got_map(&fsc->client->monc, CEPH_SUB_FSMAP, epoch); in ceph_mdsc_handle_fsmap()
4996 fsc->client->monc.fs_cluster_id = mount_fscid; in ceph_mdsc_handle_fsmap()
4997 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_MDSMAP, in ceph_mdsc_handle_fsmap()
4999 ceph_monc_renew_subs(&fsc->client->monc); in ceph_mdsc_handle_fsmap()
5064 ceph_monc_got_map(&mdsc->fsc->client->monc, CEPH_SUB_MDSMAP, in ceph_mdsc_handle_mdsmap()
5170 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in get_authorizer()
5198 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in add_authorizer_challenge()
5208 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in verify_authorizer_reply()
5217 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in invalidate_authorizer()
5221 return ceph_monc_validate_auth(&mdsc->fsc->client->monc); in invalidate_authorizer()
[all...] |
| H A D | debugfs.c | 275 struct ceph_auth_client *ac = fsc->client->monc.auth; in mds_sessions_show()
|
| /kernel/linux/linux-6.6/fs/ceph/ |
| H A D | super.c | 57 struct ceph_mon_client *monc = &fsc->client->monc; in ceph_statfs() local
69 err = ceph_monc_do_statfs(monc, data_pool, &st); in ceph_statfs()
108 mutex_lock(&monc->mutex); in ceph_statfs()
109 for (i = 0 ; i < sizeof(monc->monmap->fsid) / sizeof(__le32) ; ++i) in ceph_statfs()
110 buf->f_fsid.val[0] ^= le32_to_cpu(((__le32 *)&monc->monmap->fsid)[i]); in ceph_statfs()
111 mutex_unlock(&monc->mutex); in ceph_statfs()
114 buf->f_fsid.val[1] = monc->fs_cluster_id; in ceph_statfs()
826 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_MDSMAP, in create_fs_client()
829 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_FSMA in create_fs_client()
[all...] |
| H A D | mds_client.c | 5612 ceph_monc_got_map(&fsc->client->monc, CEPH_SUB_FSMAP, epoch); in ceph_mdsc_handle_fsmap()
5614 fsc->client->monc.fs_cluster_id = mount_fscid; in ceph_mdsc_handle_fsmap()
5615 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_MDSMAP, in ceph_mdsc_handle_fsmap()
5617 ceph_monc_renew_subs(&fsc->client->monc); in ceph_mdsc_handle_fsmap()
5684 ceph_monc_got_map(&mdsc->fsc->client->monc, CEPH_SUB_MDSMAP, in ceph_mdsc_handle_mdsmap()
5793 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_get_authorizer()
5810 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_add_authorizer_challenge()
5820 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_verify_authorizer_reply()
5832 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_invalidate_authorizer()
5836 return ceph_monc_validate_auth(&mdsc->fsc->client->monc); in mds_invalidate_authorizer()
5898 struct ceph_mon_client *monc = &s->s_mdsc->fsc->client->monc; mds_handle_auth_bad_method() local
[all...] |
| H A D | debugfs.c | 320 struct ceph_auth_client *ac = fsc->client->monc.auth; in mds_sessions_show()
|
| H A D | snap.c | 906 ret = ceph_monc_blocklist_add(&client->monc, &client->msgr.inst.addr); in ceph_update_snap_trace()
|
| /kernel/linux/linux-5.10/drivers/block/ |
| H A D | rbd.c | 4089 ret = ceph_monc_blocklist_add(&client->monc, in rbd_try_lock()
|
| /kernel/linux/linux-6.6/drivers/block/ |
| H A D | rbd.c | 4033 ret = ceph_monc_blocklist_add(&client->monc, in rbd_try_lock()
|