Commit b2e55c24 authored by Seth Howell's avatar Seth Howell Committed by Tomasz Zawadzki
Browse files

lib/nvme: add functions for registering new transports 



Signed-off-by: default avatarSeth Howell <seth.howell@intel.com>
Change-Id: I7f04968957fbc80ca8ed3ddd96e13bb9cb855813
Reviewed-on: https://review.gerrithub.io/c/spdk/spdk/+/478866


Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarJim Harris <james.r.harris@intel.com>
Reviewed-by: default avatarShuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
parent 017a8f88

include/spdk/nvme.h

+19 −0
Original line number Diff line number Diff line
@@ -2895,6 +2895,25 @@ struct spdk_nvme_transport_ops { 
	void (*admin_qpair_abort_aers)(struct spdk_nvme_qpair *qpair);

};



/**

 * Register the operations for a given transport type.

 *

 * This function should be invoked by referencing the macro

 * SPDK_NVME_TRANSPORT_REGISTER macro in the transport's .c file.

 *

 * \param ops The operations associated with an NVMe-oF transport.

 */

void spdk_nvme_transport_register(const struct spdk_nvme_transport_ops *ops);



/*

 * Macro used to register new transports.

 */

#define SPDK_NVME_TRANSPORT_REGISTER(name, transport_ops) \

static void __attribute__((constructor)) spdk_nvme_transport_register_##name(void) \

{ \

	spdk_nvme_transport_register(transport_ops); \

}\



#ifdef __cplusplus

}

#endif

lib/nvme/nvme_transport.c

+28 −0
Original line number Diff line number Diff line
@@ -36,6 +36,7 @@ 
 */



#include "nvme_internal.h"

#include "spdk/queue.h"



#ifdef DEBUG

static __attribute__((noreturn)) void
@@ -76,6 +77,9 @@ nvme_transport_unknown(enum spdk_nvme_transport_type trtype) 
		SPDK_UNREACHABLE();				\

	} while (0)



TAILQ_HEAD(nvme_transport_list, nvme_transport) g_spdk_nvme_transports =

	TAILQ_HEAD_INITIALIZER(g_spdk_nvme_transports);



bool

spdk_nvme_transport_available(enum spdk_nvme_transport_type trtype)

{
@@ -105,6 +109,30 @@ spdk_nvme_transport_available_by_name(const char *transport_name) 
	return spdk_nvme_transport_available(trtype);

}



void

spdk_nvme_transport_register(const struct spdk_nvme_transport_ops *ops)

{

	struct nvme_transport *registered_transport, *new_transport;



	TAILQ_FOREACH(registered_transport, &g_spdk_nvme_transports, link) {

		if (strcasecmp(ops->name, registered_transport->ops.name) == 0) {

			SPDK_ERRLOG("Double registering NVMe transport %s is prohibited.\n", ops->name);

			assert(false);

			return;

		}

	}



	new_transport = calloc(1, sizeof(*new_transport));

	if (new_transport == NULL) {

		SPDK_ERRLOG("Unable to allocate memory to register new NVMe transport.\n");

		assert(false);

		return;

	}



	new_transport->ops = *ops;

	TAILQ_INSERT_TAIL(&g_spdk_nvme_transports, new_transport, link);

}



struct spdk_nvme_ctrlr *nvme_transport_ctrlr_construct(const struct spdk_nvme_transport_id *trid,

		const struct spdk_nvme_ctrlr_opts *opts,

		void *devhandle)