Lines Matching refs:epoch
1361 struct drbd_epoch *epoch, in drbd_may_finish_epoch() argument
1372 epoch_size = atomic_read(&epoch->epoch_size); in drbd_may_finish_epoch()
1376 atomic_dec(&epoch->active); in drbd_may_finish_epoch()
1379 set_bit(DE_HAVE_BARRIER_NUMBER, &epoch->flags); in drbd_may_finish_epoch()
1387 atomic_read(&epoch->active) == 0 && in drbd_may_finish_epoch()
1388 (test_bit(DE_HAVE_BARRIER_NUMBER, &epoch->flags) || ev & EV_CLEANUP)) { in drbd_may_finish_epoch()
1391 drbd_send_b_ack(epoch->connection, epoch->barrier_nr, epoch_size); in drbd_may_finish_epoch()
1397 if (test_bit(DE_HAVE_BARRIER_NUMBER, &epoch->flags)) in drbd_may_finish_epoch()
1398 dec_unacked(epoch->connection); in drbd_may_finish_epoch()
1401 if (connection->current_epoch != epoch) { in drbd_may_finish_epoch()
1402 next_epoch = list_entry(epoch->list.next, struct drbd_epoch, list); in drbd_may_finish_epoch()
1403 list_del(&epoch->list); in drbd_may_finish_epoch()
1406 kfree(epoch); in drbd_may_finish_epoch()
1411 epoch->flags = 0; in drbd_may_finish_epoch()
1412 atomic_set(&epoch->epoch_size, 0); in drbd_may_finish_epoch()
1422 epoch = next_epoch; in drbd_may_finish_epoch()
1763 struct drbd_epoch *epoch; in receive_Barrier() local
1784 epoch = kmalloc(sizeof(struct drbd_epoch), GFP_NOIO); in receive_Barrier()
1785 if (epoch) in receive_Barrier()
1797 epoch = kmalloc(sizeof(struct drbd_epoch), GFP_NOIO); in receive_Barrier()
1798 if (epoch) in receive_Barrier()
1809 epoch->flags = 0; in receive_Barrier()
1810 atomic_set(&epoch->epoch_size, 0); in receive_Barrier()
1811 atomic_set(&epoch->active, 0); in receive_Barrier()
1815 list_add(&epoch->list, &connection->current_epoch->list); in receive_Barrier()
1816 connection->current_epoch = epoch; in receive_Barrier()
1820 kfree(epoch); in receive_Barrier()
2244 …drbd_may_finish_epoch(peer_device->connection, peer_req->epoch, EV_PUT + (cancel ? EV_CLEANUP : 0)… in e_end_block()
2626 peer_req->epoch = connection->current_epoch; in receive_Data()
2627 atomic_inc(&peer_req->epoch->epoch_size); in receive_Data()
2628 atomic_inc(&peer_req->epoch->active); in receive_Data()
2715 drbd_may_finish_epoch(connection, peer_req->epoch, EV_PUT | EV_CLEANUP); in receive_Data()