Lines Matching refs:epoch
47 u32 epoch, num_mon;
58 epoch = ceph_decode_32(&p);
68 m->epoch = epoch;
80 dout("monmap_decode epoch %d, num_mon %d\n", m->epoch,
347 * @epoch: X for "every map since X", or 0 for "just the latest"
350 u32 epoch, bool continuous)
352 __le64 start = cpu_to_le64(epoch);
355 dout("%s %s epoch %u continuous %d\n", __func__, ceph_sub_str[sub],
356 epoch, continuous);
370 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch,
376 need_request = __ceph_monc_want_map(monc, sub, epoch, continuous);
389 u32 epoch)
391 dout("%s %s epoch %u\n", __func__, ceph_sub_str[sub], epoch);
397 monc->subs[sub].item.start = cpu_to_le64(epoch + 1);
400 monc->subs[sub].have = epoch;
403 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch)
406 __ceph_monc_got_map(monc, sub, epoch);
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,
432 while (monc->subs[CEPH_SUB_OSDMAP].have < epoch) {
439 monc->subs[CEPH_SUB_OSDMAP].have >= epoch,
497 __ceph_monc_got_map(monc, CEPH_SUB_MONMAP, monc->monmap->epoch);