Lines Matching refs:sub
282 BUG_ON(num < 1); /* monmap sub is always there */
346 * @sub: one of CEPH_SUB_*
349 static bool __ceph_monc_want_map(struct ceph_mon_client *monc, int sub,
355 dout("%s %s epoch %u continuous %d\n", __func__, ceph_sub_str[sub],
358 if (monc->subs[sub].want &&
359 monc->subs[sub].item.start == start &&
360 monc->subs[sub].item.flags == flags)
363 monc->subs[sub].item.start = start;
364 monc->subs[sub].item.flags = flags;
365 monc->subs[sub].want = true;
370 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch,
376 need_request = __ceph_monc_want_map(monc, sub, epoch, continuous);
386 * @sub: one of CEPH_SUB_*
388 static void __ceph_monc_got_map(struct ceph_mon_client *monc, int sub,
391 dout("%s %s epoch %u\n", __func__, ceph_sub_str[sub], epoch);
393 if (monc->subs[sub].want) {
394 if (monc->subs[sub].item.flags & CEPH_SUBSCRIBE_ONETIME)
395 monc->subs[sub].want = false;
397 monc->subs[sub].item.start = cpu_to_le64(epoch + 1);
400 monc->subs[sub].have = epoch;
403 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch)
406 __ceph_monc_got_map(monc, sub, epoch);