Lines Matching full:epoch
1383 static void re_init_if_first_write(struct drbd_connection *connection, unsigned int epoch) in re_init_if_first_write() argument
1387 connection->send.current_epoch_nr = epoch; in re_init_if_first_write()
1393 static void maybe_send_barrier(struct drbd_connection *connection, unsigned int epoch) in maybe_send_barrier() argument
1398 if (connection->send.current_epoch_nr != epoch) { in maybe_send_barrier()
1401 connection->send.current_epoch_nr = epoch; in maybe_send_barrier()
1421 * replicated epoch, before we went into AHEAD mode. in w_send_out_of_sync()
1423 maybe_send_barrier(connection, req->epoch); in w_send_out_of_sync()
1451 re_init_if_first_write(connection, req->epoch); in w_send_dblock()
1452 maybe_send_barrier(connection, req->epoch); in w_send_dblock()
1484 /* Even read requests may close a write epoch, in w_send_read_req()
1486 maybe_send_barrier(connection, req->epoch); in w_send_read_req()
2078 * Maybe we still need to close the current epoch, in wait_for_work()
2109 * epoch. Next incoming request epoch will be connection -> in wait_for_work()
2110 * current transfer log epoch number. If that is different in wait_for_work()
2111 * from the epoch of the last request we communicated, it is in wait_for_work()
2112 * safe to send the epoch separating barrier now. in wait_for_work()
2132 * e.g. if the current epoch got closed. in wait_for_work()