Home
last modified time | relevance | path

Searched refs:monc (Results 1 – 12 of 12) sorted by relevance

/linux/net/ceph/
H A Dmon_client.c37 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
190 dout("__close_session closing mon%d\n", monc->cur_mon); in __close_session()
[all …]
H A Ddebugfs.c39 mutex_lock(&client->monc.mutex); in monmap_show()
40 if (client->monc.monmap == NULL) in monmap_show()
43 seq_printf(s, "epoch %d\n", client->monc.monmap->epoch); in monmap_show()
44 for (i = 0; i < client->monc.monmap->num_mon; i++) { in monmap_show()
46 &client->monc.monmap->mon_inst[i]; in monmap_show()
54 mutex_unlock(&client->monc.mutex); in monmap_show()
148 struct ceph_mon_client *monc = &client->monc; in monc_show() local
152 mutex_lock(&monc->mutex); in monc_show()
154 for (i = 0; i < ARRAY_SIZE(monc->subs); i++) { in monc_show()
156 monc->subs[i].have); in monc_show()
[all …]
H A Dceph_common.c185 if (ceph_monmap_contains(client->monc.monmap, in ceph_compare_options()
699 return client->monc.auth->global_id; in ceph_client_gid()
741 err = ceph_monc_init(&client->monc, client); in ceph_create_client()
751 ceph_monc_stop(&client->monc); in ceph_create_client()
767 ceph_monc_stop(&client->monc); in ceph_destroy_client()
782 ceph_monc_reopen_session(&client->monc); in ceph_reset_client_addr()
798 err = ceph_monc_open_session(&client->monc); in __ceph_open_session()
804 mutex_lock(&client->monc.mutex); in __ceph_open_session()
806 have_monmap = client->monc.monmap && client->monc.monmap->epoch; in __ceph_open_session()
807 mutex_unlock(&client->monc.mutex); in __ceph_open_session()
[all …]
H A Dosd_client.c2373 if (ceph_monc_want_map(&osdc->client->monc, CEPH_SUB_OSDMAP, in maybe_request_map()
2375 ceph_monc_renew_subs(&osdc->client->monc); in maybe_request_map()
2716 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in map_check_cb()
2757 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", in send_map_check()
3350 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in linger_map_check_cb()
3393 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", in send_linger_map_check()
4232 ceph_monc_got_map(&osdc->client->monc, CEPH_SUB_OSDMAP, in ceph_osdc_handle_map()
5556 struct ceph_auth_client *ac = osdc->client->monc.auth; in osd_get_authorizer()
5573 struct ceph_auth_client *ac = osdc->client->monc.auth; in osd_add_authorizer_challenge()
5583 struct ceph_auth_client *ac = osdc->client->monc.auth; in osd_verify_authorizer_reply()
[all …]
/linux/include/linux/ceph/
H A Dmon_client.h32 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, u32 epoch,
[all …]
H A Dceph_debug.h26 &client->fsid, client->monc.auth->global_id, \
35 client->monc.auth->global_id, \
47 client->monc.auth->global_id, __func__, ##__VA_ARGS__)
53 client->monc.auth->global_id, ##__VA_ARGS__)
56 client->monc.auth->global_id, ##__VA_ARGS__)
59 client->monc.auth->global_id, ##__VA_ARGS__)
62 client->monc.auth->global_id, ##__VA_ARGS__)
65 client->monc.auth->global_id, ##__VA_ARGS__)
68 client->monc.auth->global_id, ##__VA_ARGS__)
71 client->monc.auth->global_id, ##__VA_ARGS__)
H A Dlibceph.h133 struct ceph_mon_client monc; member
/linux/fs/ceph/
H A Dsuper.c61 struct ceph_mon_client *monc = &fsc->client->monc; in ceph_statfs() local
73 err = ceph_monc_do_statfs(monc, data_pool, &st); in ceph_statfs()
112 mutex_lock(&monc->mutex); in ceph_statfs()
113 for (i = 0 ; i < sizeof(monc->monmap->fsid) / sizeof(__le32) ; ++i) in ceph_statfs()
114 buf->f_fsid.val[0] ^= le32_to_cpu(((__le32 *)&monc->monmap->fsid)[i]); in ceph_statfs()
115 mutex_unlock(&monc->mutex); in ceph_statfs()
118 buf->f_fsid.val[1] = monc->fs_cluster_id; in ceph_statfs()
829 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_MDSMAP, in create_fs_client()
832 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_FSMAP, in create_fs_client()
H A Dmds_client.c6171 ceph_monc_got_map(&fsc->client->monc, CEPH_SUB_FSMAP, epoch); in ceph_mdsc_handle_fsmap()
6173 fsc->client->monc.fs_cluster_id = mount_fscid; in ceph_mdsc_handle_fsmap()
6174 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_MDSMAP, in ceph_mdsc_handle_fsmap()
6176 ceph_monc_renew_subs(&fsc->client->monc); in ceph_mdsc_handle_fsmap()
6244 ceph_monc_got_map(&mdsc->fsc->client->monc, CEPH_SUB_MDSMAP, in ceph_mdsc_handle_mdsmap()
6357 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_get_authorizer()
6374 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_add_authorizer_challenge()
6384 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_verify_authorizer_reply()
6396 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_invalidate_authorizer()
6400 return ceph_monc_validate_auth(&mdsc->fsc->client->monc); in mds_invalidate_authorizer()
[all …]
H A Dsnap.c921 ret = ceph_monc_blocklist_add(&client->monc, &client->msgr.inst.addr); in ceph_update_snap_trace()
927 client->monc.auth->global_id, __func__, in ceph_update_snap_trace()
H A Ddebugfs.c318 struct ceph_auth_client *ac = fsc->client->monc.auth; in mds_sessions_show()
/linux/drivers/block/
H A Drbd.c4047 ret = ceph_monc_blocklist_add(&client->monc, in rbd_try_lock()