420 static bool __ceph_monc_want_map(struct ceph_mon_client *monc, int sub,  in __ceph_monc_want_map()  argument
426 	dout("%s %s epoch %u continuous %d\n", __func__, ceph_sub_str[sub],  in __ceph_monc_want_map()
429 	if (monc->subs[sub].want &&  in __ceph_monc_want_map()
430 	    monc->subs[sub].item.start == start &&  in __ceph_monc_want_map()
431 	    monc->subs[sub].item.flags == flags)  in __ceph_monc_want_map()
434 	monc->subs[sub].item.start = start;  in __ceph_monc_want_map()
435 	monc->subs[sub].item.flags = flags;  in __ceph_monc_want_map()
436 	monc->subs[sub].want = true;  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()
459 static void __ceph_monc_got_map(struct ceph_mon_client *monc, int sub,  in __ceph_monc_got_map()  argument
462 	dout("%s %s epoch %u\n", __func__, ceph_sub_str[sub], epoch);  in __ceph_monc_got_map()
464 	if (monc->subs[sub].want) {  in __ceph_monc_got_map()
465 		if (monc->subs[sub].item.flags & CEPH_SUBSCRIBE_ONETIME)  in __ceph_monc_got_map()
466 			monc->subs[sub].want = false;  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()