Lines Matching full:epoch
1402 static void re_init_if_first_write(struct drbd_connection *connection, unsigned int epoch) in re_init_if_first_write() argument
1406 connection->send.current_epoch_nr = epoch; in re_init_if_first_write()
1412 static void maybe_send_barrier(struct drbd_connection *connection, unsigned int epoch) in maybe_send_barrier() argument
1417 if (connection->send.current_epoch_nr != epoch) { in maybe_send_barrier()
1420 connection->send.current_epoch_nr = epoch; in maybe_send_barrier()
1440 * replicated epoch, before we went into AHEAD mode. in w_send_out_of_sync()
1442 maybe_send_barrier(connection, req->epoch); in w_send_out_of_sync()
1470 re_init_if_first_write(connection, req->epoch); in w_send_dblock()
1471 maybe_send_barrier(connection, req->epoch); in w_send_dblock()
1503 /* Even read requests may close a write epoch, in w_send_read_req()
1505 maybe_send_barrier(connection, req->epoch); in w_send_read_req()
2096 * Maybe we still need to close the current epoch, in wait_for_work()
2127 * epoch. Next incoming request epoch will be connection -> in wait_for_work()
2128 * current transfer log epoch number. If that is different in wait_for_work()
2129 * from the epoch of the last request we communicated, it is in wait_for_work()
2130 * safe to send the epoch separating barrier now. in wait_for_work()
2150 * e.g. if the current epoch got closed. in wait_for_work()