Lines Matching full:epoch
38 req->epoch = 0; in drbd_req_new()
167 /* no point closing an epoch, if it is empty, anyways. */ in start_new_tl_epoch()
237 * we may need to close the current transfer log epoch. in drbd_req_complete()
239 * the request epoch number with the current transfer log in drbd_req_complete()
240 * epoch number. If they match, increase the current_tle_nr, in drbd_req_complete()
241 * and reset the transfer log epoch write_cnt. in drbd_req_complete()
244 req->epoch == atomic_read(&first_peer_device(device)->connection->current_tle_nr)) in drbd_req_complete()
683 * again ourselves to close the current epoch. in __req_mod()
685 * Add req to the (now) current epoch (barrier). */ in __req_mod()
699 /* close the epoch, in case it outgrew the limit */ in __req_mod()
734 * corresponding epoch barrier got acked as well, in __req_mod()
867 * As this is called for all requests within a matching epoch, in __req_mod()
1021 /* start a new epoch for non-mirrored writes */ in maybe_pull_ahead()
1116 * If this was a flush, just start a new epoch. in drbd_process_write_request()
1117 * Unless the current epoch was empty anyways, or we are not currently in drbd_process_write_request()
1359 /* which transfer log epoch does this belong to? */ in drbd_send_and_submit()
1360 req->epoch = atomic_read(&first_peer_device(device)->connection->current_tle_nr); in drbd_send_and_submit()
1648 * but are waiting for the epoch closing barrier ack. in net_timeout_reached()
1651 if (net_req->epoch == connection->send.current_epoch_nr) { in net_timeout_reached()
1659 * suddenly are able to send a lot of requests (and epoch separating in net_timeout_reached()
1749 * check the oldest requests which is still waiting on its epoch in request_timer_fn()