Lines Matching refs:epoch
47 u32 epoch, num_mon; in ceph_monmap_decode() local
58 epoch = ceph_decode_32(&p); in ceph_monmap_decode()
69 m->epoch = epoch; in ceph_monmap_decode()
75 dout("monmap_decode epoch %d, num_mon %d\n", m->epoch, in ceph_monmap_decode()
337 u32 epoch, bool continuous) in __ceph_monc_want_map() argument
339 __le64 start = cpu_to_le64(epoch); in __ceph_monc_want_map()
343 epoch, continuous); in __ceph_monc_want_map()
357 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, in ceph_monc_want_map() argument
363 need_request = __ceph_monc_want_map(monc, sub, epoch, continuous); in ceph_monc_want_map()
376 u32 epoch) in __ceph_monc_got_map() argument
378 dout("%s %s epoch %u\n", __func__, ceph_sub_str[sub], epoch); in __ceph_monc_got_map()
384 monc->subs[sub].item.start = cpu_to_le64(epoch + 1); in __ceph_monc_got_map()
387 monc->subs[sub].have = epoch; in __ceph_monc_got_map()
390 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch) in ceph_monc_got_map() argument
393 __ceph_monc_got_map(monc, sub, epoch); in ceph_monc_got_map()
412 int ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch, in ceph_monc_wait_osdmap() argument
419 while (monc->subs[CEPH_SUB_OSDMAP].have < epoch) { in ceph_monc_wait_osdmap()
426 monc->subs[CEPH_SUB_OSDMAP].have >= epoch, in ceph_monc_wait_osdmap()
483 __ceph_monc_got_map(monc, CEPH_SUB_MONMAP, monc->monmap->epoch); in ceph_monc_handle_map()