Lines Matching full:epoch

481 	dest->epoch = src->epoch;  in target_copy()
1559 (osdc->osdmap->epoch < osdc->epoch_barrier); in target_should_be_paused()
1625 t->epoch = osdc->osdmap->epoch; in calc_target()
1633 if (osdc->osdmap->epoch == pi->last_force_request_resend) { in calc_target()
2183 ceph_encode_32(&p, req->r_osdc->osdmap->epoch); in encode_request_partial()
2255 __le32 epoch; in encode_request_finish() member
2295 ceph_encode_copy(&p, &head.epoch, sizeof(head.epoch)); in encode_request_finish()
2364 req->r_t.spgid.shard, osd->o_osd, req->r_t.epoch, req->r_flags, in send_request()
2381 WARN_ON(!osdc->osdmap->epoch); in maybe_request_map()
2393 osdc->osdmap->epoch + 1, continuous)) in maybe_request_map()
2426 } else if (osdc->osdmap->epoch < osdc->epoch_barrier) { in __submit_request()
2427 dout("req %p epoch %u barrier %u\n", req, osdc->osdmap->epoch, in __submit_request()
2641 if (eb > osdc->osdmap->epoch) in update_epoch_barrier()
2663 * has an updated epoch barrier in it, so set the epoch barrier prior to
2675 update_epoch_barrier(osdc, osdc->osdmap->epoch); in abort_on_full_fn()
2687 * osdc->epoch_barrier to the latest map epoch that we've seen if any were
2705 WARN_ON(!map->epoch); in check_pool_dne()
2713 req->r_map_dne_bound = map->epoch; in check_pool_dne()
2718 req, req->r_tid, req->r_map_dne_bound, map->epoch); in check_pool_dne()
2722 if (map->epoch >= req->r_map_dne_bound) { in check_pool_dne()
3342 WARN_ON(!map->epoch); in check_linger_pool_dne()
3345 lreq->map_dne_bound = map->epoch; in check_linger_pool_dne()
3351 map->epoch); in check_linger_pool_dne()
3355 if (map->epoch >= lreq->map_dne_bound) { in check_linger_pool_dne()
3678 u32 epoch; member
3712 ceph_decode_32_safe(&p, end, m->epoch, e_inval); in decode_MOSDOpReply()
3803 dout("%s req %p tid %llu flags 0x%llx pgid %llu.%x epoch %u attempt %d v %u'%llu uv %llu\n", in handle_reply()
3805 m.epoch, m.retry_attempt, le32_to_cpu(m.replay_version.epoch), in handle_reply()
3979 * scan_requests() for the previous epoch(s) in scan_requests()
4065 if (osdc->osdmap->epoch && in handle_one_map()
4066 osdc->osdmap->epoch + 1 < newmap->epoch) { in handle_one_map()
4111 if (req->r_t.epoch < osdc->osdmap->epoch) { in kick_requests()
4158 u32 epoch; in ceph_osdc_handle_map() local
4167 dout("%s have %u\n", __func__, osdc->osdmap->epoch); in ceph_osdc_handle_map()
4186 epoch = ceph_decode_32(&p); in ceph_osdc_handle_map()
4189 if (osdc->osdmap->epoch && in ceph_osdc_handle_map()
4190 osdc->osdmap->epoch + 1 == epoch) { in ceph_osdc_handle_map()
4192 epoch, maplen); in ceph_osdc_handle_map()
4200 epoch, maplen); in ceph_osdc_handle_map()
4213 epoch = ceph_decode_32(&p); in ceph_osdc_handle_map()
4218 epoch, maplen); in ceph_osdc_handle_map()
4219 } else if (osdc->osdmap->epoch >= epoch) { in ceph_osdc_handle_map()
4221 "older than our %u\n", epoch, maplen, in ceph_osdc_handle_map()
4222 osdc->osdmap->epoch); in ceph_osdc_handle_map()
4224 dout("taking full map %u len %d\n", epoch, maplen); in ceph_osdc_handle_map()
4245 osdc->osdmap->epoch < osdc->epoch_barrier) in ceph_osdc_handle_map()
4252 osdc->osdmap->epoch); in ceph_osdc_handle_map()
4450 * Ack with original backoff's epoch so that the OSD can in handle_backoff_block()