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

/linux-master/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) 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 Ddebugfs.c25 * .../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 Dceph_common.c185 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 Dosd_client.c2390 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 Dmon_client.h32 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 Dceph_debug.h26 &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 Dlibceph.h133 struct ceph_mon_client monc; member in struct:ceph_client
/linux-master/fs/ceph/
H A Dsuper.c58 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 Dmds_client.c5816 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 Ddebugfs.c320 struct ceph_auth_client *ac = fsc->client->monc.auth;
H A Dsnap.c921 ret = ceph_monc_blocklist_add(&client->monc, &client->msgr.inst.addr);
927 client->monc.auth->global_id, __func__,
/linux-master/drivers/block/
H A Drbd.c4033 ret = ceph_monc_blocklist_add(&client->monc,

Completed in 196 milliseconds