Commit 34edf9e2 authored by Mike Snitzer's avatar Mike Snitzer
Browse files

dm vdo thread-utils: return VDO_SUCCESS on vdo_create_thread success



Update all callers to check for VDO_SUCCESS.

Signed-off-by: default avatarMike Snitzer <snitzer@kernel.org>
Signed-off-by: default avatarMatthew Sakai <msakai@redhat.com>
parent 6c43cf24
Loading
Loading
Loading
Loading
+1 −1
Original line number Diff line number Diff line
@@ -221,7 +221,7 @@ int uds_make_request_queue(const char *queue_name,

	result = vdo_create_thread(request_queue_worker, queue, queue_name,
				   &queue->thread);
	if (result != UDS_SUCCESS) {
	if (result != VDO_SUCCESS) {
		uds_request_queue_finish(queue);
		return result;
	}
+1 −1
Original line number Diff line number Diff line
@@ -798,7 +798,7 @@ static int make_chapter_writer(struct uds_index *index,
			       writer->open_chapter_index->memory_size);

	result = vdo_create_thread(close_chapters, writer, "writer", &writer->thread);
	if (result != UDS_SUCCESS) {
	if (result != VDO_SUCCESS) {
		free_chapter_writer(writer);
		return result;
	}
+1 −1
Original line number Diff line number Diff line
@@ -1634,7 +1634,7 @@ int uds_make_volume(const struct uds_configuration *config, struct index_layout
	for (i = 0; i < config->read_threads; i++) {
		result = vdo_create_thread(read_thread_function, (void *) volume,
					   "reader", &volume->reader_threads[i]);
		if (result != UDS_SUCCESS) {
		if (result != VDO_SUCCESS) {
			uds_free_volume(volume);
			return result;
		}
+1 −1
Original line number Diff line number Diff line
@@ -119,7 +119,7 @@ int vdo_create_thread(void (*thread_function)(void *), void *thread_data,
	}

	*new_thread = thread;
	return UDS_SUCCESS;
	return VDO_SUCCESS;
}

void vdo_join_threads(struct thread *thread)