Lines Matching refs:current_epoch
1265 if (connection->current_epoch != epoch) { in drbd_may_finish_epoch()
1525 connection->current_epoch->barrier_nr = p->barrier; in receive_Barrier()
1526 connection->current_epoch->connection = connection; in receive_Barrier()
1527 rv = drbd_may_finish_epoch(connection, connection->current_epoch, EV_GOT_BARRIER_NR); in receive_Barrier()
1553 if (atomic_read(&connection->current_epoch->epoch_size)) { in receive_Barrier()
1571 if (atomic_read(&connection->current_epoch->epoch_size)) { in receive_Barrier()
1572 list_add(&epoch->list, &connection->current_epoch->list); in receive_Barrier()
1573 connection->current_epoch = epoch; in receive_Barrier()
2293 atomic_inc(&connection->current_epoch->epoch_size); in receive_Data()
2336 peer_req->epoch = connection->current_epoch; in receive_Data()
4678 if (!list_empty(&connection->current_epoch->list)) in conn_disconnect()
4681 atomic_set(&connection->current_epoch->epoch_size, 0); in conn_disconnect()