1369 					       struct drbd_epoch *epoch,  in drbd_may_finish_epoch()  argument
1380 		epoch_size = atomic_read(&epoch->epoch_size);  in drbd_may_finish_epoch()
1384 			atomic_dec(&epoch->active);  in drbd_may_finish_epoch()
1387 			set_bit(DE_HAVE_BARRIER_NUMBER, &epoch->flags);  in drbd_may_finish_epoch()
1395 		    atomic_read(&epoch->active) == 0 &&  in drbd_may_finish_epoch()
1396 		    (test_bit(DE_HAVE_BARRIER_NUMBER, &epoch->flags) || ev & EV_CLEANUP)) {  in drbd_may_finish_epoch()
1399 				drbd_send_b_ack(epoch->connection, epoch->barrier_nr, epoch_size);  in drbd_may_finish_epoch()
1405 			if (test_bit(DE_HAVE_BARRIER_NUMBER, &epoch->flags))  in drbd_may_finish_epoch()
1406 				dec_unacked(epoch->connection);  in drbd_may_finish_epoch()
1409 			if (connection->current_epoch != epoch) {  in drbd_may_finish_epoch()
1410 				next_epoch = list_entry(epoch->list.next, struct drbd_epoch, list);  in drbd_may_finish_epoch()
1411 				list_del(&epoch->list);  in drbd_may_finish_epoch()
1414 				kfree(epoch);  in drbd_may_finish_epoch()
1419 				epoch->flags = 0;  in drbd_may_finish_epoch()
1420 				atomic_set(&epoch->epoch_size, 0);  in drbd_may_finish_epoch()
1430 		epoch = next_epoch;  in drbd_may_finish_epoch()
1670 	struct drbd_epoch *epoch;  in receive_Barrier()  local
1691 		epoch = kmalloc(sizeof(struct drbd_epoch), GFP_NOIO);  in receive_Barrier()
1692 		if (epoch)  in receive_Barrier()
1704 			epoch = kmalloc(sizeof(struct drbd_epoch), GFP_NOIO);  in receive_Barrier()
1705 			if (epoch)  in receive_Barrier()
1716 	epoch->flags = 0;  in receive_Barrier()
1717 	atomic_set(&epoch->epoch_size, 0);  in receive_Barrier()
1718 	atomic_set(&epoch->active, 0);  in receive_Barrier()
1722 		list_add(&epoch->list, &connection->current_epoch->list);  in receive_Barrier()
1723 		connection->current_epoch = epoch;  in receive_Barrier()
1727 		kfree(epoch);  in receive_Barrier()
2160 …drbd_may_finish_epoch(peer_device->connection, peer_req->epoch, EV_PUT + (cancel ? EV_CLEANUP : 0)…  in e_end_block()
2532 	peer_req->epoch = connection->current_epoch;  in receive_Data()
2533 	atomic_inc(&peer_req->epoch->epoch_size);  in receive_Data()
2534 	atomic_inc(&peer_req->epoch->active);  in receive_Data()
2622 	drbd_may_finish_epoch(connection, peer_req->epoch, EV_PUT | EV_CLEANUP);  in receive_Data()