disk/nvme/nvme_disk.cpp

409 io_finished_callback(status_t* status, const struct nvme_cpl* cpl)
411 	*status = nvme_cpl_is_error(cpl) ? B_IO_ERROR : B_OK;
416 await_status(nvme_disk_driver_info* info, struct nvme_qpair* qpair, status_t& status)
422 	while (status == EINPROGRESS) {
427 		if (status != EINPROGRESS)
443 				status = B_TIMED_OUT;
459 	status_t status;
511 	request->status = EINPROGRESS;
535 	await_status(info, qpinfo->qpair, request->status);
537 	if (request->status != B_OK) {
544 	return request->status;
557 	status_t status = acquire_sem(handle->info->dma_buffers_sem);
558 	if (status != B_OK) {
559 		request->SetStatusAndNotify(status);
560 		return status;
572 		status = handle->info->dma_resource.TranslateNext(request, &operation, 0);
573 		if (status != B_OK)
587 			status = do_nvme_io_request(handle->info, &nvme_request);
589 			operation.SetStatus(status,
590 				status == B_OK ? operation.Length() : 0);
591 		} while (status == B_OK && !operation.Finish());
593 		if (status == B_OK && operation.Status() != B_OK) {
595 			status = operation.Status();
602 		TRACE("%p: status %s, remaining bytes %" B_PRIuGENADDR "\n", request,
603 			strerror(status), request->RemainingBytes());
604 		if (status != B_OK)
611 	if (status != B_OK && request->Status() == B_OK)
612 		request->SetStatusAndNotify(status);
615 	return status;
639 	status_t status = B_OK;
641 		status = buffer->LockMemory(request->TeamID(), request->IsWrite());
642 		if (status != B_OK) {
643 			TRACE_ERROR("failed to lock memory: %s\n", strerror(status));
644 			return status;
668 			status = get_memory_map_etc(request->TeamID(), (void*)virt.base,
670 			if (status == B_BUFFER_OVERFLOW) {
679 					status = B_NO_MEMORY;
686 			if (status != B_OK) {
687 				TRACE_ERROR("I/O get_memory_map failed: %s\n", strerror(status));
688 				request->SetStatusAndNotify(status);
689 				return status;
752 	if (status != B_OK) {
753 		TRACE_ERROR("I/O failed early: %s\n", strerror(status));
754 		request->SetStatusAndNotify(status);
755 		return status;
778 		status = do_nvme_io_request(handle->info, &nvme_request);
779 		if (status != B_OK)
787 	if (status != B_OK)
788 		TRACE_ERROR("I/O failed: %s\n", strerror(status));
790 	request->SetTransferredBytes(status != B_OK,
792 	request->SetStatusAndNotify(status);
793 	return status;
810 	status_t status = request.Init(pos, (addr_t)buffer, *length, false, 0);
811 	if (status != B_OK)
812 		return status;
814 	status = nvme_disk_io(handle, &request);
816 	return status;
833 	status_t status = request.Init(pos, (addr_t)buffer, *length, true, 0);
834 	if (status != B_OK)
835 		return status;
837 	status = nvme_disk_io(handle, &request);
839 	return status;
847 	status_t status = EINPROGRESS;
851 		(nvme_cmd_cb)io_finished_callback, &status);
855 	await_status(info, qpinfo->qpair, status);
856 	return status;
916 	status_t status = EINPROGRESS;
919 			(nvme_cmd_cb)io_finished_callback, &status) != 0)
922 	await_status(info, qpair->qpair, status);
923 	if (status != B_OK)
924 		return status;
958 			status_t status = get_geometry(handle, &geometry);
959 			if (status != B_OK)
960 				return status;
1082 	status_t status;
1092 	status = sDeviceManager->publish_device(info->node, name,
1095 	return status;