dm-vdo/indexer/index.c

64 	/* The result from the most recent write */
65 	int result;
88 	int result;
91 	result = vdo_allocate(1, struct uds_request, __func__, &request);
92 	if (result != VDO_SUCCESS)
93 		return result;
113 		int result = launch_zone_message(message, zone, index);
115 		VDO_ASSERT_LOG_ONLY((result == UDS_SUCCESS), "barrier message allocation");
181 	int result;
187 	result = writer->result;
190 	if (result != UDS_SUCCESS)
191 		return vdo_log_error_strerror(result,
199 	int result;
202 	result = finish_previous_chapter(zone->index, zone->newest_virtual_chapter);
203 	if (result != UDS_SUCCESS)
204 		return result;
234 	int result;
245 		result = launch_zone_message(zone_message, i, zone->index);
246 		if (result != UDS_SUCCESS)
247 			return result;
255 	int result;
266 	result = swap_open_chapter(zone);
267 	if (result != UDS_SUCCESS)
268 		return result;
278 		result = announce_chapter_closed(zone, closed_chapter);
279 		if (result != UDS_SUCCESS)
280 			return result;
347 	int result;
352 	result = uds_search_sparse_cache(zone, &request->record_name, &virtual_chapter,
354 	if ((result != UDS_SUCCESS) || (virtual_chapter == NO_CHAPTER))
355 		return result;
416 	int result;
422 	result = uds_get_volume_index_record(zone->index->volume_index,
424 	if (result != UDS_SUCCESS)
425 		return result;
432 		result = get_record_from_zone(zone, request, &found);
433 		if (result != UDS_SUCCESS)
434 			return result;
461 			result = uds_set_volume_index_record_chapter(&record, chapter);
470 		 * a previous search, use that result instead.
479 			result = search_sparse_cache_in_zone(zone, request, NO_CHAPTER,
481 			if (result != UDS_SUCCESS)
482 				return result;
498 		result = uds_put_volume_index_record(&record, chapter);
501 	if (result == UDS_OVERFLOW) {
509 	if (result != UDS_SUCCESS)
510 		return result;
525 	int result;
528 	result = uds_get_volume_index_record(zone->index->volume_index,
530 	if (result != UDS_SUCCESS)
531 		return result;
548 		result = get_record_from_zone(zone, request, &found);
549 		if (result != UDS_SUCCESS)
550 			return result;
565 	result = uds_remove_volume_index_record(&record);
566 	if (result != UDS_SUCCESS)
567 		return result;
581 	int result;
585 		result = simulate_index_zone_barrier_message(zone, request);
586 		if (result != UDS_SUCCESS)
587 			return result;
595 		result = search_index_zone(zone, request);
599 		result = remove_from_index_zone(zone, request);
603 		result = vdo_log_warning_strerror(UDS_INVALID_ARGUMENT,
609 	return result;
615 	int result;
619 		result = dispatch_index_zone_control_request(request);
620 		if (result != UDS_SUCCESS) {
621 			vdo_log_error_strerror(result, "error executing message: %d",
637 	result = dispatch_index_request(index, request);
638 	if (result == UDS_QUEUED) {
646 	request->status = result;
653 	int result;
657 		result = uds_make_request_queue("indexW", &execute_zone_request,
659 		if (result != UDS_SUCCESS)
660 			return result;
665 		result = uds_make_request_queue("triageW", &triage_request,
667 		if (result != UDS_SUCCESS)
668 			return result;
677 	int result;
712 			result = uds_discard_open_chapter(index->layout);
713 			if (result == UDS_SUCCESS)
717 		result = uds_close_open_chapter(writer->chapters, index->zone_count,
728 		writer->result = result;
765 	int result;
770 	result = vdo_allocate_extended(struct chapter_writer, index->zone_count,
773 	if (result != VDO_SUCCESS)
774 		return result;
780 	result = vdo_allocate_cache_aligned(collated_records_size, "collated records",
782 	if (result != VDO_SUCCESS) {
784 		return result;
787 	result = uds_make_open_chapter_index(&writer->open_chapter_index,
790 	if (result != UDS_SUCCESS) {
792 		return result;
800 	result = vdo_create_thread(close_chapters, writer, "writer", &writer->thread);
801 	if (result != VDO_SUCCESS) {
803 		return result;
812 	int result;
815 	result = uds_load_index_state(index->layout, index);
816 	if (result != UDS_SUCCESS)
830 	int result;
842 		result = uds_get_volume_index_page(index->volume, chapter,
845 		if (result != UDS_SUCCESS) {
846 			return vdo_log_error_strerror(result,
870 	int result;
883 	result = uds_get_volume_index_record(index->volume_index, name, &record);
884 	if (result != UDS_SUCCESS)
885 		return result;
913 			result = uds_search_volume_page_cache_for_rebuild(index->volume,
917 			if (result != UDS_SUCCESS)
918 				return result;
929 		result = uds_set_volume_index_record_chapter(&record, virtual_chapter);
937 		result = uds_put_volume_index_record(&record, virtual_chapter);
940 	if ((result == UDS_DUPLICATE_NAME) || (result == UDS_OVERFLOW)) {
945 	return result;
976 	int result;
993 	result = rebuild_index_page_map(index, virtual);
994 	if (result != UDS_SUCCESS) {
995 		return vdo_log_error_strerror(result,
1005 		result = uds_get_volume_record_page(index->volume, physical_chapter,
1007 		if (result != UDS_SUCCESS) {
1008 			return vdo_log_error_strerror(result, "could not get page %d",
1018 			result = replay_record(index, &name, virtual, sparse);
1019 			if (result != UDS_SUCCESS)
1020 				return result;
1029 	int result;
1057 		result = replay_chapter(index, virtual, will_be_sparse);
1058 		if (result != UDS_SUCCESS)
1059 			return result;
1077 	int result;
1084 	result = uds_find_volume_chapter_boundaries(index->volume, &lowest, &highest,
1086 	if (result != UDS_SUCCESS) {
1087 		return vdo_log_fatal_strerror(result,
1106 	result = replay_volume(index);
1107 	if (result != UDS_SUCCESS)
1108 		return result;
1126 	int result;
1129 	result = vdo_allocate(1, struct index_zone, "index zone", &zone);
1130 	if (result != VDO_SUCCESS)
1131 		return result;
1133 	result = uds_make_open_chapter(index->volume->geometry, index->zone_count,
1135 	if (result != UDS_SUCCESS) {
1137 		return result;
1140 	result = uds_make_open_chapter(index->volume->geometry, index->zone_count,
1142 	if (result != UDS_SUCCESS) {
1144 		return result;
1158 	int result;
1166 	result = vdo_allocate_extended(struct uds_index, config->zone_count,
1168 	if (result != VDO_SUCCESS)
1169 		return result;
1173 	result = uds_make_index_layout(config, new, &index->layout);
1174 	if (result != UDS_SUCCESS) {
1176 		return result;
1179 	result = vdo_allocate(index->zone_count, struct index_zone *, "zones",
1181 	if (result != VDO_SUCCESS) {
1183 		return result;
1186 	result = uds_make_volume(config, index->layout, &index->volume);
1187 	if (result != UDS_SUCCESS) {
1189 		return result;
1194 		result = make_index_zone(index, z);
1195 		if (result != UDS_SUCCESS) {
1197 			return vdo_log_error_strerror(result,
1203 	result = uds_make_volume_index(config, nonce, &index->volume_index);
1204 	if (result != UDS_SUCCESS) {
1206 		return vdo_log_error_strerror(result, "could not make volume index");
1212 	result = initialize_index_queues(index, config->geometry);
1213 	if (result != UDS_SUCCESS) {
1215 		return result;
1218 	result = make_chapter_writer(index, &index->chapter_writer);
1219 	if (result != UDS_SUCCESS) {
1221 		return result;
1225 		result = load_index(index);
1226 		switch (result) {
1232 			vdo_log_error_strerror(result, "index could not be loaded");
1235 			vdo_log_error_strerror(result, "index could not be loaded");
1237 				result = rebuild_index(index);
1238 				if (result != UDS_SUCCESS) {
1239 					vdo_log_error_strerror(result,
1247 	if (result != UDS_SUCCESS) {
1249 		return vdo_log_error_strerror(result, "fatal error in %s()", __func__);
1314 	int result;
1325 	result = uds_save_index_state(index->layout, index);
1326 	if (result != UDS_SUCCESS) {
1336 	return result;