/linux-master/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) argument 177 monc->pending_auth = 1; 178 monc->m_auth->front.iov_len = len; 179 monc->m_auth->hdr.front_len = cpu_to_le32(len); 180 ceph_msg_revoke(monc->m_auth); 181 ceph_msg_get(monc->m_auth); /* keep our ref */ 182 ceph_con_send(&monc->con, monc->m_auth); 188 static void __close_session(struct ceph_mon_client *monc) argument 205 pick_new_mon(struct ceph_mon_client *monc) argument 239 __open_session(struct ceph_mon_client *monc) argument 279 reopen_session(struct ceph_mon_client *monc) argument 289 ceph_monc_reopen_session(struct ceph_mon_client *monc) argument 296 un_backoff(struct ceph_mon_client *monc) argument 307 __schedule_delayed(struct ceph_mon_client *monc) argument 332 __send_subscribe(struct ceph_mon_client *monc) argument 382 handle_subscribe_ack(struct ceph_mon_client *monc, struct ceph_msg *msg) argument 420 __ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, bool continuous) argument 441 ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, bool continuous) argument 459 __ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch) argument 474 ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch) argument 482 ceph_monc_renew_subs(struct ceph_mon_client *monc) argument 496 ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch, unsigned long timeout) argument 527 ceph_monc_open_session(struct ceph_mon_client *monc) argument 539 ceph_monc_handle_map(struct ceph_mon_client *monc, struct ceph_msg *msg) argument 610 alloc_generic_request(struct ceph_mon_client *monc, gfp_t gfp) argument 629 struct ceph_mon_client *monc = req->monc; local 638 send_generic_request(struct ceph_mon_client *monc, struct ceph_mon_generic_request *req) argument 650 struct ceph_mon_client *monc = req->monc; local 676 struct ceph_mon_client *monc = req->monc; local 710 struct ceph_mon_client *monc = con->private; local 738 handle_statfs_reply(struct ceph_mon_client *monc, struct ceph_msg *msg) argument 773 ceph_monc_do_statfs(struct ceph_mon_client *monc, u64 data_pool, struct ceph_statfs *buf) argument 816 handle_get_version_reply(struct ceph_mon_client *monc, struct ceph_msg *msg) argument 853 __ceph_monc_get_version(struct ceph_mon_client *monc, const char *what, ceph_monc_callback_t cb, u64 private_data) argument 901 ceph_monc_get_version(struct ceph_mon_client *monc, const char *what, u64 *newest) argument 925 ceph_monc_get_version_async(struct ceph_mon_client *monc, const char *what, ceph_monc_callback_t cb, u64 private_data) argument 939 handle_command_ack(struct ceph_mon_client *monc, struct ceph_msg *msg) argument 973 do_mon_command_vargs(struct ceph_mon_client *monc, const char *fmt, va_list ap) argument 1014 do_mon_command(struct ceph_mon_client *monc, const char *fmt, ...) argument 1025 ceph_monc_blocklist_add(struct ceph_mon_client *monc, struct ceph_entity_addr *client_addr) argument 1065 __resend_generic_request(struct ceph_mon_client *monc) argument 1085 struct ceph_mon_client *monc = local 1126 build_initial_monmap(struct ceph_mon_client *monc) argument 1154 ceph_monc_init(struct ceph_mon_client *monc, struct ceph_client *cl) argument 1232 ceph_monc_stop(struct ceph_mon_client *monc) argument 1263 finish_hunting(struct ceph_mon_client *monc) argument 1274 finish_auth(struct ceph_mon_client *monc, int auth_err, bool was_authed) argument 1303 handle_auth_reply(struct ceph_mon_client *monc, struct ceph_msg *msg) argument 1324 __validate_auth(struct ceph_mon_client *monc) argument 1339 ceph_monc_validate_auth(struct ceph_mon_client *monc) argument 1354 struct ceph_mon_client *monc = con->private; local 1374 struct ceph_mon_client *monc = con->private; local 1395 struct ceph_mon_client *monc = con->private; local 1418 struct ceph_mon_client *monc = con->private; local 1437 struct ceph_mon_client *monc = con->private; local 1488 struct ceph_mon_client *monc = con->private; local 1546 struct ceph_mon_client *monc = con->private; local [all...] |
H A D | debugfs.c | 25 * .../monc - mon client state 39 if (client->monc.monmap == NULL) 42 seq_printf(s, "epoch %d\n", client->monc.monmap->epoch); 43 for (i = 0; i < client->monc.monmap->num_mon; i++) { 45 &client->monc.monmap->mon_inst[i]; 142 struct ceph_mon_client *monc = &client->monc; local 146 mutex_lock(&monc->mutex); 148 for (i = 0; i < ARRAY_SIZE(monc->subs); i++) { 150 monc 393 DEFINE_SHOW_ATTRIBUTE(monc); variable [all...] |
H A D | ceph_common.c | 185 if (ceph_monmap_contains(client->monc.monmap, 700 return client->monc.auth->global_id; 742 err = ceph_monc_init(&client->monc, client); 752 ceph_monc_stop(&client->monc); 768 ceph_monc_stop(&client->monc); 783 ceph_monc_reopen_session(&client->monc); 793 return client->monc.monmap && client->monc.monmap->epoch && 806 err = ceph_monc_open_session(&client->monc); 854 ret = ceph_monc_get_version(&client->monc, "osdma [all...] |
H A D | osd_client.c | 2390 if (ceph_monc_want_map(&osdc->client->monc, CEPH_SUB_OSDMAP, 2392 ceph_monc_renew_subs(&osdc->client->monc); 2733 struct ceph_osd_client *osdc = &greq->monc->client->osdc; 2774 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", 3367 struct ceph_osd_client *osdc = &greq->monc->client->osdc; 3410 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", 4249 ceph_monc_got_map(&osdc->client->monc, CEPH_SUB_OSDMAP, 5604 struct ceph_auth_client *ac = osdc->client->monc.auth; 5621 struct ceph_auth_client *ac = osdc->client->monc.auth; 5631 struct ceph_auth_client *ac = osdc->client->monc 5708 struct ceph_mon_client *monc = &o->o_osdc->client->monc; local [all...] |
/linux-master/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 in struct:ceph_mon_request 51 struct ceph_mon_client *monc; member in struct:ceph_mon_generic_request 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 | ceph_debug.h | 26 &client->fsid, client->monc.auth->global_id, \ 38 client->monc.auth->global_id, \ 51 client->monc.auth->global_id, __func__, ##__VA_ARGS__) 57 client->monc.auth->global_id, ##__VA_ARGS__) 60 client->monc.auth->global_id, ##__VA_ARGS__) 63 client->monc.auth->global_id, ##__VA_ARGS__) 66 client->monc.auth->global_id, ##__VA_ARGS__) 69 client->monc.auth->global_id, ##__VA_ARGS__) 72 client->monc.auth->global_id, ##__VA_ARGS__) 75 client->monc [all...] |
H A D | libceph.h | 133 struct ceph_mon_client monc; member in struct:ceph_client
|
/linux-master/fs/ceph/ |
H A D | super.c | 58 struct ceph_mon_client *monc = &fsc->client->monc; local 70 err = ceph_monc_do_statfs(monc, data_pool, &st); 109 mutex_lock(&monc->mutex); 110 for (i = 0 ; i < sizeof(monc->monmap->fsid) / sizeof(__le32) ; ++i) 111 buf->f_fsid.val[0] ^= le32_to_cpu(((__le32 *)&monc->monmap->fsid)[i]); 112 mutex_unlock(&monc->mutex); 115 buf->f_fsid.val[1] = monc->fs_cluster_id; 829 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_MDSMAP, 832 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_FSMA [all...] |
H A D | mds_client.c | 5816 ceph_monc_got_map(&fsc->client->monc, CEPH_SUB_FSMAP, epoch); 5818 fsc->client->monc.fs_cluster_id = mount_fscid; 5819 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_MDSMAP, 5821 ceph_monc_renew_subs(&fsc->client->monc); 5889 ceph_monc_got_map(&mdsc->fsc->client->monc, CEPH_SUB_MDSMAP, 6002 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; 6019 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; 6029 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; 6041 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; 6045 return ceph_monc_validate_auth(&mdsc->fsc->client->monc); 6107 struct ceph_mon_client *monc = &s->s_mdsc->fsc->client->monc; local [all...] |
H A D | debugfs.c | 320 struct ceph_auth_client *ac = fsc->client->monc.auth;
|
H A D | snap.c | 921 ret = ceph_monc_blocklist_add(&client->monc, &client->msgr.inst.addr); 927 client->monc.auth->global_id, __func__,
|
/linux-master/drivers/block/ |
H A D | rbd.c | 4033 ret = ceph_monc_blocklist_add(&client->monc,
|