block/drbd/drbd_actlog.c

206 static struct bm_extent *find_active_resync_extent(struct drbd_device *device, unsigned int enr)
209 	tmp = lc_find(device->resync, enr/AL_EXT_PER_BM_SECT);
218 static struct lc_element *_al_get(struct drbd_device *device, unsigned int enr, bool nonblock)
225 	bm_ext = find_active_resync_extent(device, enr);
234 		al_ext = lc_try_get(device->act_log, enr);
236 		al_ext = lc_get(device->act_log, enr);
264 	unsigned enr;
270 	for (enr = first; enr <= last; enr++) {
273 				(al_ext = _al_get(device, enr, false)) != NULL);
274 		if (al_ext->lc_number != enr)
493 	unsigned enr;
519 	for (enr = first; enr <= last; enr++) {
521 		tmp = lc_find(device->resync, enr/AL_EXT_PER_BM_SECT);
535 	for (enr = first; enr <= last; enr++) {
537 		al_ext = lc_get_cumulative(device->act_log, enr);
539 			drbd_info(device, "LOGIC BUG for enr=%u\n", enr);
550 	unsigned enr;
557 	for (enr = first; enr <= last; enr++) {
558 		extent = lc_find(device->act_log, enr);
560 			drbd_err(device, "al_complete_io() called on inactive extent %u\n", enr);
652 		unsigned int enr, int count,
667 		e = lc_find(device->resync, enr);
669 		e = lc_get(device->resync, enr);
672 		if (ext->lce.lc_number == enr) {
680 				drbd_warn(device, "BAD! enr=%u rs_left=%d "
692 				ext->rs_left = drbd_bm_e_weight(device, enr);
701 			int rs_left = drbd_bm_e_weight(device, enr);
706 				     ext->flags, enr, rs_left);
710 				drbd_warn(device, "Kicking resync_lru element enr=%u "
904 struct bm_extent *_bme_get(struct drbd_device *device, unsigned int enr)
916 	e = lc_get(device->resync, enr);
919 		if (bm_ext->lce.lc_number != enr) {
920 			bm_ext->rs_left = drbd_bm_e_weight(device, enr);
944 static int _is_in_al(struct drbd_device *device, unsigned int enr)
949 	rv = lc_is_used(device->act_log, enr);
966 	unsigned int enr = BM_SECT_TO_EXT(sector);
973 			(bm_ext = _bme_get(device, enr)));
985 					       !_is_in_al(device, enr * AL_EXT_PER_BM_SECT + i) ||
1021 	unsigned int enr = BM_SECT_TO_EXT(sector);
1022 	const unsigned int al_enr = enr*AL_EXT_PER_BM_SECT;
1033 	if (throttle && device->resync_wenr != enr)
1037 	if (device->resync_wenr != LC_FREE && device->resync_wenr != enr) {
1068 	e = lc_try_get(device->resync, enr);
1089 		e = lc_get(device->resync, enr);
1099 		if (bm_ext->lce.lc_number != enr) {
1100 			bm_ext->rs_left = drbd_bm_e_weight(device, enr);
1135 			device->resync_wenr = enr;
1143 	unsigned int enr = BM_SECT_TO_EXT(sector);
1149 	e = lc_find(device->resync, enr);
1162 		    (unsigned long long)sector, enr);