Lines Matching defs:sub
353 BUG_ON(num < 1); /* monmap sub is always there */
417 * @sub: one of CEPH_SUB_*
420 static bool __ceph_monc_want_map(struct ceph_mon_client *monc, int sub,
426 dout("%s %s epoch %u continuous %d\n", __func__, ceph_sub_str[sub],
429 if (monc->subs[sub].want &&
430 monc->subs[sub].item.start == start &&
431 monc->subs[sub].item.flags == flags)
434 monc->subs[sub].item.start = start;
435 monc->subs[sub].item.flags = flags;
436 monc->subs[sub].want = true;
441 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch,
447 need_request = __ceph_monc_want_map(monc, sub, epoch, continuous);
457 * @sub: one of CEPH_SUB_*
459 static void __ceph_monc_got_map(struct ceph_mon_client *monc, int sub,
462 dout("%s %s epoch %u\n", __func__, ceph_sub_str[sub], epoch);
464 if (monc->subs[sub].want) {
465 if (monc->subs[sub].item.flags & CEPH_SUBSCRIBE_ONETIME)
466 monc->subs[sub].want = false;
468 monc->subs[sub].item.start = cpu_to_le64(epoch + 1);
471 monc->subs[sub].have = epoch;
474 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch)
477 __ceph_monc_got_map(monc, sub, epoch);