Lines Matching refs:epoch
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()
348 u32 epoch, bool continuous) in __ceph_monc_want_map() argument
350 __le64 start = cpu_to_le64(epoch); in __ceph_monc_want_map()
354 epoch, continuous); in __ceph_monc_want_map()
368 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, in ceph_monc_want_map() argument
374 need_request = __ceph_monc_want_map(monc, sub, epoch, continuous); in ceph_monc_want_map()
387 u32 epoch) in __ceph_monc_got_map() argument
389 dout("%s %s epoch %u\n", __func__, ceph_sub_str[sub], epoch); in __ceph_monc_got_map()
395 monc->subs[sub].item.start = cpu_to_le64(epoch + 1); in __ceph_monc_got_map()
398 monc->subs[sub].have = epoch; in __ceph_monc_got_map()
401 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch) in ceph_monc_got_map() argument
404 __ceph_monc_got_map(monc, sub, epoch); in ceph_monc_got_map()
423 int ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch, in ceph_monc_wait_osdmap() argument
430 while (monc->subs[CEPH_SUB_OSDMAP].have < epoch) { in ceph_monc_wait_osdmap()
437 monc->subs[CEPH_SUB_OSDMAP].have >= epoch, in ceph_monc_wait_osdmap()
495 __ceph_monc_got_map(monc, CEPH_SUB_MONMAP, monc->monmap->epoch); in ceph_monc_handle_map()