Lines Matching defs:epoch
78 u32 epoch;
91 ceph_decode_32_safe(p, end, epoch, e_inval);
115 dout("%s fsid %pU epoch %u num_mon %d\n", __func__, &fsid, epoch,
126 monmap->epoch = epoch;
418 * @epoch: X for "every map since X", or 0 for "just the latest"
421 u32 epoch, bool continuous)
423 __le64 start = cpu_to_le64(epoch);
426 dout("%s %s epoch %u continuous %d\n", __func__, ceph_sub_str[sub],
427 epoch, continuous);
441 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch,
447 need_request = __ceph_monc_want_map(monc, sub, epoch, continuous);
460 u32 epoch)
462 dout("%s %s epoch %u\n", __func__, ceph_sub_str[sub], epoch);
468 monc->subs[sub].item.start = cpu_to_le64(epoch + 1);
471 monc->subs[sub].have = epoch;
474 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch)
477 __ceph_monc_got_map(monc, sub, epoch);
491 * Wait for an osdmap with a given epoch.
493 * @epoch: epoch to wait for
496 int ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch,
503 while (monc->subs[CEPH_SUB_OSDMAP].have < epoch) {
510 monc->subs[CEPH_SUB_OSDMAP].have >= epoch,
568 __ceph_monc_got_map(monc, CEPH_SUB_MONMAP, monc->monmap->epoch);