Lines Matching refs:epoch_size
1229 int epoch_size; in drbd_may_finish_epoch() local
1237 epoch_size = atomic_read(&epoch->epoch_size); in drbd_may_finish_epoch()
1251 if (epoch_size != 0 && in drbd_may_finish_epoch()
1256 drbd_send_b_ack(epoch->connection, epoch->barrier_nr, epoch_size); in drbd_may_finish_epoch()
1277 atomic_set(&epoch->epoch_size, 0); in drbd_may_finish_epoch()
1554 if (atomic_read(&connection->current_epoch->epoch_size)) { in receive_Barrier()
1568 atomic_set(&epoch->epoch_size, 0); in receive_Barrier()
1572 if (atomic_read(&connection->current_epoch->epoch_size)) { in receive_Barrier()
2294 atomic_inc(&connection->current_epoch->epoch_size); in receive_Data()
2338 atomic_inc(&peer_req->epoch->epoch_size); in receive_Data()
4702 atomic_set(&connection->current_epoch->epoch_size, 0); in conn_disconnect()