Lines Matching refs:epoch
78 u32 epoch; in ceph_monmap_decode() local
91 ceph_decode_32_safe(p, end, epoch, e_inval); in ceph_monmap_decode()
115 dout("%s fsid %pU epoch %u num_mon %d\n", __func__, &fsid, epoch, in ceph_monmap_decode()
126 monmap->epoch = epoch; in ceph_monmap_decode()
421 u32 epoch, bool continuous) in __ceph_monc_want_map() argument
423 __le64 start = cpu_to_le64(epoch); in __ceph_monc_want_map()
427 epoch, continuous); in __ceph_monc_want_map()
441 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, in ceph_monc_want_map() argument
447 need_request = __ceph_monc_want_map(monc, sub, epoch, continuous); in ceph_monc_want_map()
460 u32 epoch) in __ceph_monc_got_map() argument
462 dout("%s %s epoch %u\n", __func__, ceph_sub_str[sub], epoch); in __ceph_monc_got_map()
468 monc->subs[sub].item.start = cpu_to_le64(epoch + 1); in __ceph_monc_got_map()
471 monc->subs[sub].have = epoch; in __ceph_monc_got_map()
474 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch) in ceph_monc_got_map() argument
477 __ceph_monc_got_map(monc, sub, epoch); in ceph_monc_got_map()
496 int ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch, in ceph_monc_wait_osdmap() argument
503 while (monc->subs[CEPH_SUB_OSDMAP].have < epoch) { in ceph_monc_wait_osdmap()
510 monc->subs[CEPH_SUB_OSDMAP].have >= epoch, in ceph_monc_wait_osdmap()
568 __ceph_monc_got_map(monc, CEPH_SUB_MONMAP, monc->monmap->epoch); in ceph_monc_handle_map()