175 	int rc;  in bdev_daos_destruct_cb()  local
182 	rc = bdev_daos_put_engine();  in bdev_daos_destruct_cb()
183 	if (rc) {  in bdev_daos_destruct_cb()
184 		SPDK_ERRLOG("could not de-initialize DAOS engine: " DF_RC "\n", DP_RC(rc));  in bdev_daos_destruct_cb()
236 	int rc;  in bdev_daos_writev()  local
252 	if ((rc = daos_event_init(&task->ev, ch->queue, NULL))) {  in bdev_daos_writev()
254 			    daos->disk.name, DP_RC(rc));  in bdev_daos_writev()
255 		return -daos2posix_errno(rc);  in bdev_daos_writev()
267 	if ((rc = dfs_write(ch->dfs, ch->obj, &task->sgl, offset, &task->ev))) {  in bdev_daos_writev()
269 			    daos->disk.name, strerror(rc));  in bdev_daos_writev()
271 		return -rc;  in bdev_daos_writev()
282 	int rc;  in bdev_daos_readv()  local
298 	if ((rc = daos_event_init(&task->ev, ch->queue, NULL))) {  in bdev_daos_readv()
300 			    daos->disk.name, DP_RC(rc));  in bdev_daos_readv()
301 		return -daos2posix_errno(rc);  in bdev_daos_readv()
313 	if ((rc = dfs_read(ch->dfs, ch->obj, &task->sgl, offset, &task->read_size, &task->ev))) {  in bdev_daos_readv()
315 			    daos->disk.name, strerror(rc));  in bdev_daos_readv()
317 		return -rc;  in bdev_daos_readv()
327 	int64_t rc;  in bdev_daos_get_buf_cb()  local
335 	rc = bdev_daos_readv((struct bdev_daos *)bdev_io->bdev->ctxt,  in bdev_daos_get_buf_cb()
343 	if (rc < 0) {  in bdev_daos_get_buf_cb()
344 		spdk_bdev_io_complete_aio_status(bdev_io, rc);  in bdev_daos_get_buf_cb()
411 	int rc = 0;  in bdev_daos_unmap()  local
414 	if ((rc = dfs_punch(ch->dfs, ch->obj, offset, nbytes))) {  in bdev_daos_unmap()
415 		return -rc;  in bdev_daos_unmap()
425 	int64_t rc;  in _bdev_daos_submit_request()  local
433 		rc = bdev_daos_writev((struct bdev_daos *)bdev_io->bdev->ctxt,  in _bdev_daos_submit_request()
440 		if (rc < 0) {  in _bdev_daos_submit_request()
441 			spdk_bdev_io_complete_aio_status(bdev_io, rc);  in _bdev_daos_submit_request()
458 		rc = bdev_daos_unmap(dch,  in _bdev_daos_submit_request()
461 		if (!rc) {  in _bdev_daos_submit_request()
465 				      dch->disk->disk.name, strerror(-rc));  in _bdev_daos_submit_request()
466 			spdk_bdev_io_complete_aio_status(bdev_io, rc);  in _bdev_daos_submit_request()
503 	int rc = daos_eq_poll(ch->queue, 0, DAOS_EQ_NOWAIT,  in bdev_daos_channel_poll()  local
506 	if (rc < 0) {  in bdev_daos_channel_poll()
508 			      ch->disk->disk.name, DP_RC(rc));  in bdev_daos_channel_poll()
518 	for (int i = 0; i < rc; ++i) {  in bdev_daos_channel_poll()
532 	return rc > 0 ? SPDK_POLLER_BUSY : SPDK_POLLER_IDLE;  in bdev_daos_channel_poll()
590 	int rc = 0;  in bdev_daos_io_channel_setup_daos()  local
598 	rc = bdev_daos_get_engine();  in bdev_daos_io_channel_setup_daos()
599 	if (rc) {  in bdev_daos_io_channel_setup_daos()
600 		SPDK_ERRLOG("could not initialize DAOS engine: " DF_RC "\n", DP_RC(rc));  in bdev_daos_io_channel_setup_daos()
601 		return -daos2posix_errno(rc);  in bdev_daos_io_channel_setup_daos()
605 	if ((rc = daos_pool_connect(daos->pool_name, NULL, DAOS_PC_RW, &ch->pool, &pinfo, NULL))) {  in bdev_daos_io_channel_setup_daos()
607 			    daos->disk.name, DP_RC(rc));  in bdev_daos_io_channel_setup_daos()
608 		return -daos2posix_errno(rc);  in bdev_daos_io_channel_setup_daos()
611 	if ((rc = daos_cont_open(ch->pool, daos->cont_name, DAOS_COO_RW, &ch->cont, &cinfo, NULL))) {  in bdev_daos_io_channel_setup_daos()
613 			    daos->disk.name, DP_RC(rc));  in bdev_daos_io_channel_setup_daos()
614 		rc = daos2posix_errno(rc);  in bdev_daos_io_channel_setup_daos()
618 	if ((rc = dfs_mount(ch->pool, ch->cont, O_RDWR, &ch->dfs))) {  in bdev_daos_io_channel_setup_daos()
619 		SPDK_ERRLOG("%s: could not mount daos dfs: %s\n", daos->disk.name, strerror(rc));  in bdev_daos_io_channel_setup_daos()
623 	if ((rc = dfs_open(ch->dfs, NULL, daos->disk.name, mode, fd_oflag, daos->oclass,  in bdev_daos_io_channel_setup_daos()
625 		SPDK_ERRLOG("%s: could not open dfs object: %s\n", daos->disk.name, strerror(rc));  in bdev_daos_io_channel_setup_daos()
628 	if ((rc = daos_eq_create(&ch->queue))) {  in bdev_daos_io_channel_setup_daos()
630 			    daos->disk.name, DP_RC(rc));  in bdev_daos_io_channel_setup_daos()
631 		rc = daos2posix_errno(rc);  in bdev_daos_io_channel_setup_daos()
646 	return -rc;  in bdev_daos_io_channel_setup_daos()
652 	int rc;  in bdev_daos_io_channel_create_cb()  local
657 	if ((rc = bdev_daos_io_channel_setup_daos(ch))) {  in bdev_daos_io_channel_create_cb()
658 		return rc;  in bdev_daos_io_channel_create_cb()
672 	int rc;  in bdev_daos_io_channel_destroy_cb()  local
679 	if ((rc = daos_eq_destroy(ch->queue, DAOS_EQ_DESTROY_FORCE))) {  in bdev_daos_io_channel_destroy_cb()
680 		SPDK_ERRLOG("could not destroy daos event queue: " DF_RC "\n", DP_RC(rc));  in bdev_daos_io_channel_destroy_cb()
682 	if ((rc = dfs_release(ch->obj))) {  in bdev_daos_io_channel_destroy_cb()
683 		SPDK_ERRLOG("could not release dfs object: %s\n", strerror(rc));  in bdev_daos_io_channel_destroy_cb()
685 	if ((rc = dfs_umount(ch->dfs))) {  in bdev_daos_io_channel_destroy_cb()
686 		SPDK_ERRLOG("could not unmount dfs: %s\n", strerror(rc));  in bdev_daos_io_channel_destroy_cb()
688 	if ((rc = daos_cont_close(ch->cont, NULL))) {  in bdev_daos_io_channel_destroy_cb()
689 		SPDK_ERRLOG("could not close container: " DF_RC "\n", DP_RC(rc));  in bdev_daos_io_channel_destroy_cb()
691 	if ((rc = daos_pool_disconnect(ch->pool, NULL))) {  in bdev_daos_io_channel_destroy_cb()
692 		SPDK_ERRLOG("could not disconnect from pool: " DF_RC "\n", DP_RC(rc));  in bdev_daos_io_channel_destroy_cb()
694 	rc = bdev_daos_put_engine();  in bdev_daos_io_channel_destroy_cb()
695 	if (rc) {  in bdev_daos_io_channel_destroy_cb()
696 		SPDK_ERRLOG("could not de-initialize DAOS engine: " DF_RC "\n", DP_RC(rc));  in bdev_daos_io_channel_destroy_cb()
706 	int rc;  in create_bdev_daos()  local
782 	rc = bdev_daos_get_engine();  in create_bdev_daos()
783 	if (rc) {  in create_bdev_daos()
784 		SPDK_ERRLOG("could not initialize DAOS engine: " DF_RC "\n", DP_RC(rc));  in create_bdev_daos()
786 		return -daos2posix_errno(rc);  in create_bdev_daos()
794 	rc = bdev_daos_io_channel_create_cb(daos, &ch);  in create_bdev_daos()
795 	if (rc) {  in create_bdev_daos()
796 		SPDK_ERRLOG("'%s' could not initialize io-channel: %s\n", name, strerror(-rc));  in create_bdev_daos()
798 		return rc;  in create_bdev_daos()
808 	rc = spdk_bdev_register(&daos->disk);  in create_bdev_daos()
809 	if (rc) {  in create_bdev_daos()
812 		return rc;  in create_bdev_daos()
817 	return rc;  in create_bdev_daos()
828 	int rc = 0;  in bdev_daos_resize()  local
836 	rc = spdk_bdev_open_ext(name, false, dummy_bdev_event_cb, NULL, &desc);  in bdev_daos_resize()
837 	if (rc != 0) {  in bdev_daos_resize()
838 		return rc;  in bdev_daos_resize()
843 		rc = -EINVAL;  in bdev_daos_resize()
850 		rc = -EINVAL;  in bdev_daos_resize()
858 	rc = dfs_punch(dch->dfs, dch->obj, new_size_in_byte, DFS_MAX_FSIZE);  in bdev_daos_resize()
860 	if (rc != 0) {  in bdev_daos_resize()
861 		SPDK_ERRLOG("failed to resize daos bdev: %s", strerror(rc));  in bdev_daos_resize()
862 		rc = -rc;  in bdev_daos_resize()
872 	rc = spdk_bdev_notify_blockcnt_change(bdev, new_size_in_byte / bdev->blocklen);  in bdev_daos_resize()
873 	if (rc != 0) {  in bdev_daos_resize()
879 	return rc;  in bdev_daos_resize()
885 	int rc;  in delete_bdev_daos()  local
887 	rc = spdk_bdev_unregister_by_name(bdev_name, &daos_if, cb_fn, cb_arg);  in delete_bdev_daos()
888 	if (rc != 0) {  in delete_bdev_daos()
889 		cb_fn(cb_arg, rc);  in delete_bdev_daos()
896 	int rc = 0;  in bdev_daos_get_engine()  local
905 	rc = daos_init();  in bdev_daos_get_engine()
908 	if (rc != -DER_ALREADY && rc) {  in bdev_daos_get_engine()
909 		return rc;  in bdev_daos_get_engine()
917 	int rc = 0;  in bdev_daos_put_engine()  local
926 	rc = daos_fini();  in bdev_daos_put_engine()
929 	return rc;  in bdev_daos_put_engine()