Lines Matching refs:subs
330 * monc->subs.
349 for (i = 0; i < ARRAY_SIZE(monc->subs); i++) {
350 if (monc->subs[i].want)
355 for (i = 0; i < ARRAY_SIZE(monc->subs); i++) {
359 if (!monc->subs[i].want)
368 le64_to_cpu(monc->subs[i].item.start),
369 monc->subs[i].item.flags);
371 memcpy(p, &monc->subs[i].item, sizeof(monc->subs[i].item));
372 p += sizeof(monc->subs[i].item);
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;
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;
503 while (monc->subs[CEPH_SUB_OSDMAP].have < epoch) {
510 monc->subs[CEPH_SUB_OSDMAP].have >= epoch,
1112 dout("%s renew subs? now %lu renew after %lu\n",