47 	u32 epoch, num_mon;  in ceph_monmap_decode()  local
58 	epoch = ceph_decode_32(&p);  in ceph_monmap_decode()
68 	m->epoch = epoch;  in ceph_monmap_decode()
80 	dout("monmap_decode epoch %d, num_mon %d\n", m->epoch,  in ceph_monmap_decode()
347  * @epoch: X for "every map since X", or 0 for "just the latest"
350 				 u32 epoch, bool continuous)  in __ceph_monc_want_map()  argument
352 	__le64 start = cpu_to_le64(epoch);  in __ceph_monc_want_map()
355 	dout("%s %s epoch %u continuous %d\n", __func__, ceph_sub_str[sub],  in __ceph_monc_want_map()
356 	     epoch, continuous);  in __ceph_monc_want_map()
370 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch,  in ceph_monc_want_map()  argument
376 	need_request = __ceph_monc_want_map(monc, sub, epoch, continuous);  in ceph_monc_want_map()
389 				u32 epoch)  in __ceph_monc_got_map()  argument
391 	dout("%s %s epoch %u\n", __func__, ceph_sub_str[sub], epoch);  in __ceph_monc_got_map()
397 			monc->subs[sub].item.start = cpu_to_le64(epoch + 1);  in __ceph_monc_got_map()
400 	monc->subs[sub].have = epoch;  in __ceph_monc_got_map()
403 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch)  in ceph_monc_got_map()  argument
406 	__ceph_monc_got_map(monc, sub, epoch);  in ceph_monc_got_map()
420  * Wait for an osdmap with a given epoch.
422  * @epoch: epoch to wait for
425 int ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch,  in ceph_monc_wait_osdmap()  argument
432 	while (monc->subs[CEPH_SUB_OSDMAP].have < epoch) {  in ceph_monc_wait_osdmap()
439 				     monc->subs[CEPH_SUB_OSDMAP].have >= epoch,  in ceph_monc_wait_osdmap()
497 	__ceph_monc_got_map(monc, CEPH_SUB_MONMAP, monc->monmap->epoch);  in ceph_monc_handle_map()