Lines Matching refs:ceph_mon_client

37 static int __validate_auth(struct ceph_mon_client *monc);
104 static void __send_prepared_auth_request(struct ceph_mon_client *monc, int len) in __send_prepared_auth_request()
117 static void __close_session(struct ceph_mon_client *monc) in __close_session()
134 static void pick_new_mon(struct ceph_mon_client *monc) in pick_new_mon()
168 static void __open_session(struct ceph_mon_client *monc) in __open_session()
202 static void reopen_session(struct ceph_mon_client *monc) in reopen_session()
212 static void un_backoff(struct ceph_mon_client *monc) in un_backoff()
223 static void __schedule_delayed(struct ceph_mon_client *monc) in __schedule_delayed()
248 static void __send_subscribe(struct ceph_mon_client *monc) in __send_subscribe()
298 static void handle_subscribe_ack(struct ceph_mon_client *monc, in handle_subscribe_ack()
336 static bool __ceph_monc_want_map(struct ceph_mon_client *monc, int sub, in __ceph_monc_want_map()
357 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, in ceph_monc_want_map()
375 static void __ceph_monc_got_map(struct ceph_mon_client *monc, int sub, in __ceph_monc_got_map()
390 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch) in ceph_monc_got_map()
398 void ceph_monc_renew_subs(struct ceph_mon_client *monc) in ceph_monc_renew_subs()
412 int ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch, in ceph_monc_wait_osdmap()
443 int ceph_monc_open_session(struct ceph_mon_client *monc) in ceph_monc_open_session()
455 static void ceph_monc_handle_map(struct ceph_mon_client *monc, in ceph_monc_handle_map()
525 alloc_generic_request(struct ceph_mon_client *monc, gfp_t gfp) in alloc_generic_request()
544 struct ceph_mon_client *monc = req->monc; in register_generic_request()
553 static void send_generic_request(struct ceph_mon_client *monc, in send_generic_request()
565 struct ceph_mon_client *monc = req->monc; in __finish_generic_request()
591 struct ceph_mon_client *monc = req->monc; in cancel_generic_request()
625 struct ceph_mon_client *monc = con->private; in get_generic_reply()
653 static void handle_statfs_reply(struct ceph_mon_client *monc, in handle_statfs_reply()
688 int ceph_monc_do_statfs(struct ceph_mon_client *monc, u64 data_pool, in ceph_monc_do_statfs()
731 static void handle_get_version_reply(struct ceph_mon_client *monc, in handle_get_version_reply()
768 __ceph_monc_get_version(struct ceph_mon_client *monc, const char *what, in __ceph_monc_get_version()
816 int ceph_monc_get_version(struct ceph_mon_client *monc, const char *what, in ceph_monc_get_version()
840 int ceph_monc_get_version_async(struct ceph_mon_client *monc, const char *what, in ceph_monc_get_version_async()
854 static void handle_command_ack(struct ceph_mon_client *monc, in handle_command_ack()
887 int ceph_monc_blacklist_add(struct ceph_mon_client *monc, in ceph_monc_blacklist_add()
934 static void __resend_generic_request(struct ceph_mon_client *monc) in __resend_generic_request()
954 struct ceph_mon_client *monc = in delayed_work()
955 container_of(work, struct ceph_mon_client, delayed_work.work); in delayed_work()
995 static int build_initial_monmap(struct ceph_mon_client *monc) in build_initial_monmap()
1018 int ceph_monc_init(struct ceph_mon_client *monc, struct ceph_client *cl) in ceph_monc_init()
1097 void ceph_monc_stop(struct ceph_mon_client *monc) in ceph_monc_stop()
1128 static void finish_hunting(struct ceph_mon_client *monc) in finish_hunting()
1139 static void handle_auth_reply(struct ceph_mon_client *monc, in handle_auth_reply()
1181 static int __validate_auth(struct ceph_mon_client *monc) in __validate_auth()
1196 int ceph_monc_validate_auth(struct ceph_mon_client *monc) in ceph_monc_validate_auth()
1212 struct ceph_mon_client *monc = con->private; in dispatch()
1266 struct ceph_mon_client *monc = con->private; in mon_alloc_msg()
1324 struct ceph_mon_client *monc = con->private; in mon_fault()