net/ceph/osd_client.c

481 	dest->epoch = src->epoch;
1557 	       (osdc->osdmap->epoch < osdc->epoch_barrier);
1623 	t->epoch = osdc->osdmap->epoch;
1631 	if (osdc->osdmap->epoch == pi->last_force_request_resend) {
2181 	ceph_encode_32(&p, req->r_osdc->osdmap->epoch);
2253 			__le32 epoch;
2293 		ceph_encode_copy(&p, &head.epoch, sizeof(head.epoch));
2362 	     req->r_t.spgid.shard, osd->o_osd, req->r_t.epoch, req->r_flags,
2379 	WARN_ON(!osdc->osdmap->epoch);
2391 			       osdc->osdmap->epoch + 1, continuous))
2424 	} else if (osdc->osdmap->epoch < osdc->epoch_barrier) {
2425 		dout("req %p epoch %u barrier %u\n", req, osdc->osdmap->epoch,
2639 		if (eb > osdc->osdmap->epoch)
2661  * has an updated epoch barrier in it, so set the epoch barrier prior to
2673 			update_epoch_barrier(osdc, osdc->osdmap->epoch);
2685  * osdc->epoch_barrier to the latest map epoch that we've seen if any were
2703 	WARN_ON(!map->epoch);
2711 		req->r_map_dne_bound = map->epoch;
2716 		     req, req->r_tid, req->r_map_dne_bound, map->epoch);
2720 		if (map->epoch >= req->r_map_dne_bound) {
3340 	WARN_ON(!map->epoch);
3343 		lreq->map_dne_bound = map->epoch;
3349 		     map->epoch);
3353 		if (map->epoch >= lreq->map_dne_bound) {
3676 	u32 epoch;
3710 	ceph_decode_32_safe(&p, end, m->epoch, e_inval);
3801 	dout("%s req %p tid %llu flags 0x%llx pgid %llu.%x epoch %u attempt %d v %u'%llu uv %llu\n",
3803 	     m.epoch, m.retry_attempt, le32_to_cpu(m.replay_version.epoch),
3977 			 * scan_requests() for the previous epoch(s)
4063 		if (osdc->osdmap->epoch &&
4064 		    osdc->osdmap->epoch + 1 < newmap->epoch) {
4109 		if (req->r_t.epoch < osdc->osdmap->epoch) {
4156 	u32 epoch;
4165 	dout("%s have %u\n", __func__, osdc->osdmap->epoch);
4184 		epoch = ceph_decode_32(&p);
4187 		if (osdc->osdmap->epoch &&
4188 		    osdc->osdmap->epoch + 1 == epoch) {
4190 			     epoch, maplen);
4198 			     epoch, maplen);
4211 		epoch = ceph_decode_32(&p);
4216 			     epoch, maplen);
4217 		} else if (osdc->osdmap->epoch >= epoch) {
4219 			     "older than our %u\n", epoch, maplen,
4220 			     osdc->osdmap->epoch);
4222 			dout("taking full map %u len %d\n", epoch, maplen);
4243 	    osdc->osdmap->epoch < osdc->epoch_barrier)
4250 			  osdc->osdmap->epoch);
4448 	 * Ack with original backoff's epoch so that the OSD can