include/env.h: add comments for public APIs

Change-Id: Ic661748435a5fcd2ec233802366f6870b072e6df
Signed-off-by: Yanbo Zhou <yanbo.zhou@intel.com>
Reviewed-on: https://review.gerrithub.io/403444
Tested-by: SPDK Automated Test System <sys_sgsw@intel.com>
Reviewed-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: Daniel Verkamp <daniel.verkamp@intel.com>
Reviewed-by: Jim Harris <james.r.harris@intel.com>
This commit is contained in:
Yanbo Zhou 2018-03-12 13:10:49 +08:00 committed by Jim Harris
parent a04b77e6bd
commit 070e72eda7

View File

@ -68,76 +68,148 @@ struct spdk_env_opts {
}; };
/** /**
* \brief Initialize the default value of opts * Initialize the default value of opts.
*
* \param opts Data structure where SPDK will initialize the default options.
*/ */
void spdk_env_opts_init(struct spdk_env_opts *opts); void spdk_env_opts_init(struct spdk_env_opts *opts);
/** /**
* \brief Initialize the environment library. This must be called prior to using * Initialize the environment library. This must be called prior to using
* any other functions in this library. * any other functions in this library.
* \return 0 on success, or a negated errno value on failure. *
* \param opts Environment initialization options.
* \return 0 on success, or negative errno on failure.
*/ */
int spdk_env_init(const struct spdk_env_opts *opts); int spdk_env_init(const struct spdk_env_opts *opts);
/** /**
* Allocate a pinned, physically contiguous memory buffer with the * Allocate a pinned, physically contiguous memory buffer with the given size
* given size and alignment. * and alignment.
*
* \param size Size in bytes.
* \param align Alignment value for the allocated memory. If '0', the allocated
* buffer is suitably aligned (in the same manner as malloc()). Otherwise, the
* allocated buffer is aligned to the multiple of align. In this case, it must
* be a power of two.
* \param phys_addr A pointer to the variable to hold the physical address of
* the allocated buffer is passed. If NULL, the physical address is not returned.
*
* \return a pointer to the allocated memory buffer.
*/ */
void *spdk_dma_malloc(size_t size, size_t align, uint64_t *phys_addr); void *spdk_dma_malloc(size_t size, size_t align, uint64_t *phys_addr);
/** /**
* Allocate a pinned, physically contiguous memory buffer with the * Allocate a pinned, physically contiguous memory buffer with the given size,
* given size, alignment and socket id. * alignment and socket id.
*
* \param size Size in bytes.
* \param align Alignment value for the allocated memory. If '0', the allocated
* buffer is suitably aligned (in the same manner as malloc()). Otherwise, the
* allocated buffer is aligned to the multiple of align. In this case, it must
* be a power of two.
* \param phys_addr A pointer to the variable to hold the physical address of
* the allocated buffer is passed. If NULL, the physical address is not returned.
* \param socket_id Socket ID to allocate memory on, or SPDK_ENV_SOCKET_ID_ANY
* for any socket.
*
* \return a pointer to the allocated memory buffer.
*/ */
void *spdk_dma_malloc_socket(size_t size, size_t align, uint64_t *phys_addr, int socket_id); void *spdk_dma_malloc_socket(size_t size, size_t align, uint64_t *phys_addr, int socket_id);
/** /**
* Allocate a pinned, physically contiguous memory buffer with the * Allocate a pinned, physically contiguous memory buffer with the given size
* given size and alignment. The buffer will be zeroed. * and alignment. The buffer will be zeroed.
*
* \param size Size in bytes.
* \param align Alignment value for the allocated memory. If '0', the allocated
* buffer is suitably aligned (in the same manner as malloc()). Otherwise, the
* allocated buffer is aligned to the multiple of align. In this case, it must
* be a power of two.
* \param phys_addr A pointer to the variable to hold the physical address of
* the allocated buffer is passed. If NULL, the physical address is not returned.
*
* \return a pointer to the allocated memory buffer.
*/ */
void *spdk_dma_zmalloc(size_t size, size_t align, uint64_t *phys_addr); void *spdk_dma_zmalloc(size_t size, size_t align, uint64_t *phys_addr);
/** /**
* Allocate a pinned, physically contiguous memory buffer with the * Allocate a pinned, physically contiguous memory buffer with the given size,
* given size, alignment and socket id. The buffer will be zeroed. * alignment and socket id. The buffer will be zeroed.
*
* \param size Size in bytes.
* \param align Alignment value for the allocated memory. If '0', the allocated
* buffer is suitably aligned (in the same manner as malloc()). Otherwise, the
* allocated buffer is aligned to the multiple of align. In this case, it must
* be a power of two.
* \param phys_addr A pointer to the variable to hold the physical address of
* the allocated buffer is passed. If NULL, the physical address is not returned.
* \param socket_id Socket ID to allocate memory on, or SPDK_ENV_SOCKET_ID_ANY
* for any socket.
*
* \return a pointer to the allocated memory buffer.
*/ */
void *spdk_dma_zmalloc_socket(size_t size, size_t align, uint64_t *phys_addr, int socket_id); void *spdk_dma_zmalloc_socket(size_t size, size_t align, uint64_t *phys_addr, int socket_id);
/** /**
* Resize the allocated and pinned memory buffer with the given * Resize the allocated and pinned memory buffer with the given new size and
* new size and alignment. Existing contents are preserved. * alignment. Existing contents are preserved.
*
* \param buf Buffer to resize.
* \param size Size in bytes.
* \param align Alignment value for the allocated memory. If '0', the allocated
* buffer is suitably aligned (in the same manner as malloc()). Otherwise, the
* allocated buffer is aligned to the multiple of align. In this case, it must
* be a power of two.
* \param phys_addr A pointer to the variable to hold the physical address of
* the allocated buffer is passed. If NULL, the physical address is not returned.
*
* \return a pointer to the resized memory buffer.
*/ */
void *spdk_dma_realloc(void *buf, size_t size, size_t align, uint64_t *phys_addr); void *spdk_dma_realloc(void *buf, size_t size, size_t align, uint64_t *phys_addr);
/** /**
* Free a memory buffer previously allocated with spdk_dma_zmalloc. * Free a memory buffer previously allocated, for example from spdk_dma_zmalloc().
* This call is never made from the performance path. * This call is never made from the performance path.
*
* \param buf Buffer to free.
*/ */
void spdk_dma_free(void *buf); void spdk_dma_free(void *buf);
/** /**
* Reserve a named, process shared memory zone with the given size, * Reserve a named, process shared memory zone with the given size, socket_id
* socket_id and flags. * and flags.
* Return a pointer to the allocated memory address. If the allocation *
* cannot be done, return NULL. * \param name Name to set for this memory zone.
* Note: to pick any socket id, just set socket_id to SPDK_ENV_SOCKET_ID_ANY. * \param len Length in bytes.
* \param socket_id Socket ID to allocate memory on, or SPDK_ENV_SOCKET_ID_ANY
* for any socket.
* \param flags Flags to set for this memory zone.
*
* \return a pointer to the allocated memory address on success, or NULL on failure.
*/ */
void *spdk_memzone_reserve(const char *name, size_t len, int socket_id, unsigned flags); void *spdk_memzone_reserve(const char *name, size_t len, int socket_id, unsigned flags);
/** /**
* Lookup the memory zone identified by the given name. * Lookup the memory zone identified by the given name.
* Return a pointer to the reserved memory address. If the reservation *
* cannot be found, return NULL. * \param name Name of the memory zone.
*
* \return a pointer to the reserved memory address on success, or NULL on failure.
*/ */
void *spdk_memzone_lookup(const char *name); void *spdk_memzone_lookup(const char *name);
/** /**
* Free the memory zone identified by the given name. * Free the memory zone identified by the given name.
*
* \return 0 on success, -1 on failure.
*/ */
int spdk_memzone_free(const char *name); int spdk_memzone_free(const char *name);
/** /**
* Dump debug information about all memzones. * Dump debug information about all memzones.
*
* \param f File to write debug information to.
*/ */
void spdk_memzone_dump(FILE *f); void spdk_memzone_dump(FILE *f);
@ -148,38 +220,53 @@ struct spdk_mempool;
/** /**
* Create a thread-safe memory pool. * Create a thread-safe memory pool.
* *
* \param name Name for the memory pool.
* \param count Count of elements.
* \param ele_size Element size in bytes.
* \param cache_size How many elements may be cached in per-core caches. Use * \param cache_size How many elements may be cached in per-core caches. Use
* SPDK_MEMPOOL_DEFAULT_CACHE_SIZE for a reasonable default, or 0 for no * SPDK_MEMPOOL_DEFAULT_CACHE_SIZE for a reasonable default, or 0 for no per-core cache.
* per-core cache. * \param socket_id Socket ID to allocate memory on, or SPDK_ENV_SOCKET_ID_ANY
* \param socket_id Socket ID to allocate memory on, or SPDK_ENV_SOCKET_ID_ANY for any socket. * for any socket.
*
* \return a pointer to the created memory pool.
*/ */
struct spdk_mempool *spdk_mempool_create(const char *name, size_t count, struct spdk_mempool *spdk_mempool_create(const char *name, size_t count,
size_t ele_size, size_t cache_size, int socket_id); size_t ele_size, size_t cache_size, int socket_id);
/** /**
* An object callback function for mempool. * An object callback function for memory pool.
* *
* Used by spdk_mempool_create_ctor * Used by spdk_mempool_create_ctor().
*/ */
typedef void (spdk_mempool_obj_cb_t)(struct spdk_mempool *mp, typedef void (spdk_mempool_obj_cb_t)(struct spdk_mempool *mp,
void *opaque, void *obj, unsigned obj_idx); void *opaque, void *obj, unsigned obj_idx);
/** /**
* Create a thread-safe memory pool with user provided initialization function and argument. * Create a thread-safe memory pool with user provided initialization function
* and argument.
* *
* \param name Name for the memory pool.
* \param count Count of elements.
* \param ele_size Element size in bytes.
* \param cache_size How many elements may be cached in per-core caches. Use * \param cache_size How many elements may be cached in per-core caches. Use
* SPDK_MEMPOOL_DEFAULT_CACHE_SIZE for a reasonable default, or 0 for no * SPDK_MEMPOOL_DEFAULT_CACHE_SIZE for a reasonable default, or 0 for no per-core cache.
* per-core cache. * \param socket_id Socket ID to allocate memory on, or SPDK_ENV_SOCKET_ID_ANY
* \param socket_id Socket ID to allocate memory on, or SPDK_ENV_SOCKET_ID_ANY for any socket. * for any socket.
* \param obj_init User provided object calllback initialization function. * \param obj_init User provided object calllback initialization function.
* \param obj_init_arg User provided callback initialization function argument. * \param obj_init_arg User provided callback initialization function argument.
*
* \return a pointer to the created memory pool.
*/ */
struct spdk_mempool *spdk_mempool_create_ctor(const char *name, size_t count, struct spdk_mempool *spdk_mempool_create_ctor(const char *name, size_t count,
size_t ele_size, size_t cache_size, int socket_id, size_t ele_size, size_t cache_size, int socket_id,
spdk_mempool_obj_cb_t *obj_init, void *obj_init_arg); spdk_mempool_obj_cb_t *obj_init, void *obj_init_arg);
/** /**
* Get the name of a mempool * Get the name of a memory pool.
*
* \param mp Memory pool to query.
*
* \return the name of the memory pool.
*/ */
char *spdk_mempool_get_name(struct spdk_mempool *mp); char *spdk_mempool_get_name(struct spdk_mempool *mp);
@ -190,55 +277,79 @@ void spdk_mempool_free(struct spdk_mempool *mp);
/** /**
* Get an element from a memory pool. If no elements remain, return NULL. * Get an element from a memory pool. If no elements remain, return NULL.
*
* \param mp Memory pool to query.
*
* \return a pointer to the element.
*/ */
void *spdk_mempool_get(struct spdk_mempool *mp); void *spdk_mempool_get(struct spdk_mempool *mp);
/** /**
* Put an element back into the memory pool. * Put an element back into the memory pool.
*
* \param mp Memory pool to put element back into.
* \param ele Element to put.
*/ */
void spdk_mempool_put(struct spdk_mempool *mp, void *ele); void spdk_mempool_put(struct spdk_mempool *mp, void *ele);
/** /**
* Put multiple elements back into the memory pool. * Put multiple elements back into the memory pool.
*
* \param mp Memory pool to put multiple elements back into.
* \param ele_arr Array of the elements to put.
* \param count Count of elements to put.
*/ */
void spdk_mempool_put_bulk(struct spdk_mempool *mp, void *const *ele_arr, size_t count); void spdk_mempool_put_bulk(struct spdk_mempool *mp, void *const *ele_arr, size_t count);
/** /**
* Return the number of entries in the mempool. * Get the number of entries in the memory pool.
*
* \param pool Memory pool to query.
*
* \return the number of entries in the memory pool.
*/ */
size_t spdk_mempool_count(const struct spdk_mempool *pool); size_t spdk_mempool_count(const struct spdk_mempool *pool);
/** /**
* \brief Return the number of dedicated CPU cores utilized by * Get the number of dedicated CPU cores utilized by this env abstraction.
* this env abstraction *
* \return the number of dedicated CPU cores.
*/ */
uint32_t spdk_env_get_core_count(void); uint32_t spdk_env_get_core_count(void);
/** /**
* \brief Return the CPU core index of the current thread. * Get the CPU core index of the current thread.
* *
* This will only function when called from threads set up by * This will only function when called from threads set up by
* this environment abstraction. For any other threads * this environment abstraction. For any other threads \c SPDK_ENV_LCORE_ID_ANY
* \c SPDK_ENV_LCORE_ID_ANY will be returned. * will be returned.
*
* \return the CPU core index of the current thread.
*/ */
uint32_t spdk_env_get_current_core(void); uint32_t spdk_env_get_current_core(void);
/** /**
* \brief Return the index of the first dedicated CPU core for * Get the index of the first dedicated CPU core for this application.
* this application. *
* \return the index of the first dedicated CPU core.
*/ */
uint32_t spdk_env_get_first_core(void); uint32_t spdk_env_get_first_core(void);
/** /**
* \brief Return the index of the last dedicated CPU core for * Get the index of the last dedicated CPU core for this application.
* this application. *
* \return the index of the last dedicated CPU core.
*/ */
uint32_t spdk_env_get_last_core(void); uint32_t spdk_env_get_last_core(void);
/** /**
* \brief Return the index of the next dedicated CPU core for * Get the index of the next dedicated CPU core for this application.
* this application. *
* If there is no next core, return UINT32_MAX. * If there is no next core, return UINT32_MAX.
*
* \param prev_core Index of previous core.
*
* \return the index of the next dedicated CPU core.
*/ */
uint32_t spdk_env_get_next_core(uint32_t prev_core); uint32_t spdk_env_get_next_core(uint32_t prev_core);
@ -248,45 +359,59 @@ uint32_t spdk_env_get_next_core(uint32_t prev_core);
i = spdk_env_get_next_core(i)) i = spdk_env_get_next_core(i))
/** /**
* \brief Return the socket ID for the given core. * Get the socket ID for the given core.
*
* \param core CPU core to query.
*
* \return the socket ID for the given core.
*/ */
uint32_t spdk_env_get_socket_id(uint32_t core); uint32_t spdk_env_get_socket_id(uint32_t core);
typedef int (*thread_start_fn)(void *); typedef int (*thread_start_fn)(void *);
/** /**
* \brief Launch a thread pinned to the given core. Only a single pinned thread * Launch a thread pinned to the given core. Only a single pinned thread may be
* may be launched per core. Subsequent attempts to launch pinned threads on * launched per core. Subsequent attempts to launch pinned threads on that core
* that core will fail. * will fail.
* *
* \param core The core to pin the thread to. * \param core The core to pin the thread to.
* \param fn Entry point on the new thread. * \param fn Entry point on the new thread.
* \param arg Argument apssed to thread_start_fn * \param arg Argument apssed to thread_start_fn
*
* \return 0 on success, negative errno on failure.
*/ */
int spdk_env_thread_launch_pinned(uint32_t core, thread_start_fn fn, void *arg); int spdk_env_thread_launch_pinned(uint32_t core, thread_start_fn fn, void *arg);
/** /**
* \brief Wait for all threads to exit before returning. * Wait for all threads to exit before returning.
*/ */
void spdk_env_thread_wait_all(void); void spdk_env_thread_wait_all(void);
/** /**
* Return true if the calling process is primary process * Check whether the calling process is primary process.
*
* \return true if the calling process is primary process, or false otherwise.
*/ */
bool spdk_process_is_primary(void); bool spdk_process_is_primary(void);
/** /**
* Get a monotonic timestamp counter. * Get a monotonic timestamp counter.
*
* \return the monotonic timestamp counter.
*/ */
uint64_t spdk_get_ticks(void); uint64_t spdk_get_ticks(void);
/** /**
* Get the tick rate of spdk_get_ticks() per second. * Get the tick rate of spdk_get_ticks() per second.
*
* \return the tick rate of spdk_get_ticks() per second.
*/ */
uint64_t spdk_get_ticks_hz(void); uint64_t spdk_get_ticks_hz(void);
/** /**
* Delay the given number of microseconds * Delay the given number of microseconds.
*
* \param us Number of microseconds.
*/ */
void spdk_delay_us(unsigned int us); void spdk_delay_us(unsigned int us);
@ -298,39 +423,65 @@ enum spdk_ring_type {
}; };
/** /**
* Create a ring * Create a ring.
*
* \param type Type for the ring. (SPDK_RING_TYPE_SP_SC or SPDK_RING_TYPE_MP_SC).
* \param count Size of the ring in elements.
* \param socket_id Socket ID to allocate memory on, or SPDK_ENV_SOCKET_ID_ANY
* for any socket.
*
* \return a pointer to the created ring.
*/ */
struct spdk_ring *spdk_ring_create(enum spdk_ring_type type, size_t count, int socket_id); struct spdk_ring *spdk_ring_create(enum spdk_ring_type type, size_t count, int socket_id);
/** /**
* Free the ring * Free the ring.
*
* \param ring Ring to free.
*/ */
void spdk_ring_free(struct spdk_ring *ring); void spdk_ring_free(struct spdk_ring *ring);
/** /**
* Get the number of objects in the ring. * Get the number of objects in the ring.
* *
* \param ring the ring * \param ring the ring.
* \return number of objects in the ring *
* \return the number of objects in the ring.
*/ */
size_t spdk_ring_count(struct spdk_ring *ring); size_t spdk_ring_count(struct spdk_ring *ring);
/** /**
* Queue the array of objects (with length count) on the ring. * Queue the array of objects (with length count) on the ring.
* *
* Return the number of objects enqueued. * \param ring A pointer to the ring.
* \param objs A pointer to the array to be queued.
* \param count Length count of the array of objects.
*
* \return the number of objects enqueued.
*/ */
size_t spdk_ring_enqueue(struct spdk_ring *ring, void **objs, size_t count); size_t spdk_ring_enqueue(struct spdk_ring *ring, void **objs, size_t count);
/** /**
* Dequeue count objects from the ring into the array objs. * Dequeue count objects from the ring into the array objs.
* *
* Return the number of objects dequeued. * \param ring A pointer to the ring.
* \param objs A pointer to the array to be dequeued.
* \param count Maximum number of elements to be dequeued.
*
* \return the number of objects dequeued which is less than 'count'.
*/ */
size_t spdk_ring_dequeue(struct spdk_ring *ring, void **objs, size_t count); size_t spdk_ring_dequeue(struct spdk_ring *ring, void **objs, size_t count);
#define SPDK_VTOPHYS_ERROR (0xFFFFFFFFFFFFFFFFULL) #define SPDK_VTOPHYS_ERROR (0xFFFFFFFFFFFFFFFFULL)
/**
* Get the physical address of a buffer.
*
* \param buf A pointer to a buffer.
*
* \return the physical address of this buffer on success, or SPDK_VTOPHYS_ERROR
* on failure.
*/
uint64_t spdk_vtophys(void *buf); uint64_t spdk_vtophys(void *buf);
struct spdk_pci_addr { struct spdk_pci_addr {
@ -349,29 +500,163 @@ struct spdk_pci_id {
typedef int (*spdk_pci_enum_cb)(void *enum_ctx, struct spdk_pci_device *pci_dev); typedef int (*spdk_pci_enum_cb)(void *enum_ctx, struct spdk_pci_device *pci_dev);
/**
* Enumerate NVMe devices.
*
* \param enum_cb Called when the enumerate operation completes.
* \param enum_ctx Argument passed to the callback function.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_nvme_enumerate(spdk_pci_enum_cb enum_cb, void *enum_ctx); int spdk_pci_nvme_enumerate(spdk_pci_enum_cb enum_cb, void *enum_ctx);
/**
* Enumerate I/OAT device.
*
* \param enum_cb Called when the enumerate operation completes.
* \param enum_ctx Argument passed to the callback function.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_ioat_enumerate(spdk_pci_enum_cb enum_cb, void *enum_ctx); int spdk_pci_ioat_enumerate(spdk_pci_enum_cb enum_cb, void *enum_ctx);
/**
* Enumerate virtio device.
*
* \param enum_cb Called when the enumerate operation completes.
* \param enum_ctx Argument passed to the callback function.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_virtio_enumerate(spdk_pci_enum_cb enum_cb, void *enum_ctx); int spdk_pci_virtio_enumerate(spdk_pci_enum_cb enum_cb, void *enum_ctx);
/**
* Get PCI device from the given address.
*
* \param pci_addr A pointer to the PCI address struct.
*
* \return a pointer to the PCI device or NULL if no devide is found at the given
* address.
*/
struct spdk_pci_device *spdk_pci_get_device(struct spdk_pci_addr *pci_addr) struct spdk_pci_device *spdk_pci_get_device(struct spdk_pci_addr *pci_addr)
__attribute__((deprecated)); __attribute__((deprecated));
/**
* Get a mapping of the virtual address to the BAR of the PCI device.
*
* \param dev PCI device.
* \param bar Index to the BAR.
* \param mapped_addr A pointer to the pointer to hold the virtual address of
* the mapping.
* \param phys_addr A pointer to the variable to hold the physical address of
* the mapping.
* \param size A pointer to the variable to hold the mapped size in bytes.
*
* \return 0 on success.
*/
int spdk_pci_device_map_bar(struct spdk_pci_device *dev, uint32_t bar, int spdk_pci_device_map_bar(struct spdk_pci_device *dev, uint32_t bar,
void **mapped_addr, uint64_t *phys_addr, uint64_t *size); void **mapped_addr, uint64_t *phys_addr, uint64_t *size);
/**
* Remove the mapping of the virtual address to the BAR of the PCI device.
*
* \param dev PCI device.
* \param bar Index to the BAR.
* \param addr Virtual address to remove that must be the mapped_addr returned
* by a previous call to spdk_pci_device_map_bar().
*
* \return 0 on success.
*/
int spdk_pci_device_unmap_bar(struct spdk_pci_device *dev, uint32_t bar, void *addr); int spdk_pci_device_unmap_bar(struct spdk_pci_device *dev, uint32_t bar, void *addr);
/**
* Get the domain address of a PCI device.
*
* \param dev A pointer to the PCI device.
*
* \return the domain address of PCI device.
*/
uint32_t spdk_pci_device_get_domain(struct spdk_pci_device *dev); uint32_t spdk_pci_device_get_domain(struct spdk_pci_device *dev);
/**
* Get the bus address of a PCI device.
*
* \param dev A pointer to the PCI device.
*
* \return the bus address of PCI device.
*/
uint8_t spdk_pci_device_get_bus(struct spdk_pci_device *dev); uint8_t spdk_pci_device_get_bus(struct spdk_pci_device *dev);
/**
* Get the device address of a PCI device.
*
* \param dev A pointer to the PCI device.
*
* \return the device address of PCI device.
*/
uint8_t spdk_pci_device_get_dev(struct spdk_pci_device *dev); uint8_t spdk_pci_device_get_dev(struct spdk_pci_device *dev);
/**
* Get the function address of a PCI device.
*
* \param dev A pointer to the PCI device.
*
* \return the function address of PCI device.
*/
uint8_t spdk_pci_device_get_func(struct spdk_pci_device *dev); uint8_t spdk_pci_device_get_func(struct spdk_pci_device *dev);
/**
* Get the PCI address of a PCI device.
*
* \param dev A pointer to the PCI device.
*
* \return the PCI address structure.
*/
struct spdk_pci_addr spdk_pci_device_get_addr(struct spdk_pci_device *dev); struct spdk_pci_addr spdk_pci_device_get_addr(struct spdk_pci_device *dev);
/**
* Get the vendor ID of a PCI device.
*
* \param dev A pointer to the PCI device.
*
* \return the vendor ID of PCI device.
*/
uint16_t spdk_pci_device_get_vendor_id(struct spdk_pci_device *dev); uint16_t spdk_pci_device_get_vendor_id(struct spdk_pci_device *dev);
/**
* Get the device ID of a PCI device.
*
* \param dev A pointer to the PCI device.
*
* \return the device ID of PCI device.
*/
uint16_t spdk_pci_device_get_device_id(struct spdk_pci_device *dev); uint16_t spdk_pci_device_get_device_id(struct spdk_pci_device *dev);
/**
* Get the subvendor ID of a PCI device.
*
* \param dev A pointer to the PCI device.
*
* \return the subvendor ID of PCI device.
*/
uint16_t spdk_pci_device_get_subvendor_id(struct spdk_pci_device *dev); uint16_t spdk_pci_device_get_subvendor_id(struct spdk_pci_device *dev);
/**
* Get the subdevice ID of a PCI device.
*
* \param dev A pointer to the PCI device.
*
* \return the subdevice ID of PCI device.
*/
uint16_t spdk_pci_device_get_subdevice_id(struct spdk_pci_device *dev); uint16_t spdk_pci_device_get_subdevice_id(struct spdk_pci_device *dev);
/**
* Allocate a PCI ID struct for the PCI device.
*
* \param dev A pointer to the PCI device.
*
* \return a PCI ID struct.
*/
struct spdk_pci_id spdk_pci_device_get_id(struct spdk_pci_device *dev); struct spdk_pci_id spdk_pci_device_get_id(struct spdk_pci_device *dev);
/** /**
@ -379,49 +664,176 @@ struct spdk_pci_id spdk_pci_device_get_id(struct spdk_pci_device *dev);
* *
* \param dev PCI device to get the socket ID of. * \param dev PCI device to get the socket ID of.
* *
* \return Socket ID (>= 0), or negative if unknown. * \return the socket ID (>= 0) of PCI device.
*/ */
int spdk_pci_device_get_socket_id(struct spdk_pci_device *dev); int spdk_pci_device_get_socket_id(struct spdk_pci_device *dev);
/**
* Get the serial number of a PCI device.
*
* \param dev A pointer to the PCI device.
* \param sn String to store the serial number.
* \param len Length of the 'sn'.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_device_get_serial_number(struct spdk_pci_device *dev, char *sn, size_t len); int spdk_pci_device_get_serial_number(struct spdk_pci_device *dev, char *sn, size_t len);
/** /**
* Claim a PCI device for exclusive SPDK userspace access. * Claim a PCI device for exclusive SPDK userspace access.
* *
* Uses F_SETLK on a shared memory file with the PCI address embedded in its name. * Uses F_SETLK on a shared memory file with the PCI address embedded in its name.
* As long as this file remains open with the lock acquired, other processes will * As long as this file remains open with the lock acquired, other processes will
* not be able to successfully call this function on the same PCI device. * not be able to successfully call this function on the same PCI device.
* *
* \param pci_addr PCI address of the device to claim * \param pci_addr PCI address of the device to claim
* *
* \return -1 if the device has already been claimed, an fd otherwise. This fd * \return -1 if the device has already been claimed, an fd otherwise. This fd
* should be closed when the application no longer needs access to the * should be closed when the application no longer needs access to the PCI device
* PCI device (including when it is hot removed). * (including when it is hot removed).
*/ */
int spdk_pci_device_claim(const struct spdk_pci_addr *pci_addr); int spdk_pci_device_claim(const struct spdk_pci_addr *pci_addr);
/**
* Detach a PCI device.
*
* \param device PCI device to detach.
*/
void spdk_pci_device_detach(struct spdk_pci_device *device); void spdk_pci_device_detach(struct spdk_pci_device *device);
/**
* Attach a NVMe device.
*
* \param enum_cb Called when the attach operation completes.
* \param enum_ctx Argument passed to the callback function.
* \param pci_address PCI address of the NVMe device.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_nvme_device_attach(spdk_pci_enum_cb enum_cb, void *enum_ctx, int spdk_pci_nvme_device_attach(spdk_pci_enum_cb enum_cb, void *enum_ctx,
struct spdk_pci_addr *pci_address); struct spdk_pci_addr *pci_address);
/**
* Attach a I/OAT device.
*
* \param enum_cb Called when the attach operation completes.
* \param enum_ctx Argument passed to the callback function.
* \param pci_address PCI address of the I/OAT device.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_ioat_device_attach(spdk_pci_enum_cb enum_cb, void *enum_ctx, int spdk_pci_ioat_device_attach(spdk_pci_enum_cb enum_cb, void *enum_ctx,
struct spdk_pci_addr *pci_address); struct spdk_pci_addr *pci_address);
/**
* Attach a virtio device.
*
* \param enum_cb Called when the attach operation completes.
* \param enum_ctx Argument passed to the callback function.
* \param pci_address PCI address of the virtio device.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_virtio_device_attach(spdk_pci_enum_cb enum_cb, void *enum_ctx, int spdk_pci_virtio_device_attach(spdk_pci_enum_cb enum_cb, void *enum_ctx,
struct spdk_pci_addr *pci_address); struct spdk_pci_addr *pci_address);
/**
* Read PCI configuration space in any specified size.
*
* \param dev PCI device.
* \param value A pointer to the buffer to hold the value.
* \param len Length in bytes to read.
* \param offset Offset in bytes.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_device_cfg_read(struct spdk_pci_device *dev, void *value, uint32_t len, int spdk_pci_device_cfg_read(struct spdk_pci_device *dev, void *value, uint32_t len,
uint32_t offset); uint32_t offset);
/**
* Write PCI configuration space in any specified size.
*
* \param dev PCI device.
* \param value A pointer to the value to write.
* \param len Length in bytes to write.
* \param offset Offset in bytes.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_device_cfg_write(struct spdk_pci_device *dev, void *value, uint32_t len, int spdk_pci_device_cfg_write(struct spdk_pci_device *dev, void *value, uint32_t len,
uint32_t offset); uint32_t offset);
/**
* Read 1 byte from PCI configuration space.
*
* \param dev PCI device.
* \param value A pointer to the buffer to hold the value.
* \param offset Offset in bytes.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_device_cfg_read8(struct spdk_pci_device *dev, uint8_t *value, uint32_t offset); int spdk_pci_device_cfg_read8(struct spdk_pci_device *dev, uint8_t *value, uint32_t offset);
/**
* Write 1 byte to PCI configuration space.
*
* \param dev PCI device.
* \param value A value to write.
* \param offset Offset in bytes.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_device_cfg_write8(struct spdk_pci_device *dev, uint8_t value, uint32_t offset); int spdk_pci_device_cfg_write8(struct spdk_pci_device *dev, uint8_t value, uint32_t offset);
/**
* Read 2 bytes from PCI configuration space.
*
* \param dev PCI device.
* \param value A pointer to the buffer to hold the value.
* \param offset Offset in bytes.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_device_cfg_read16(struct spdk_pci_device *dev, uint16_t *value, uint32_t offset); int spdk_pci_device_cfg_read16(struct spdk_pci_device *dev, uint16_t *value, uint32_t offset);
/**
* Write 2 bytes to PCI configuration space.
*
* \param dev PCI device.
* \param value A value to write.
* \param offset Offset in bytes.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_device_cfg_write16(struct spdk_pci_device *dev, uint16_t value, uint32_t offset); int spdk_pci_device_cfg_write16(struct spdk_pci_device *dev, uint16_t value, uint32_t offset);
/**
* Read 4 bytes from PCI configuration space.
*
* \param dev PCI device.
* \param value A pointer to the buffer to hold the value.
* \param offset Offset in bytes.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_device_cfg_read32(struct spdk_pci_device *dev, uint32_t *value, uint32_t offset); int spdk_pci_device_cfg_read32(struct spdk_pci_device *dev, uint32_t *value, uint32_t offset);
/**
* Write 4 bytes to PCI configuration space.
*
* \param dev PCI device.
* \param value A value to write.
* \param offset Offset in bytes.
*
* \return 0 on success, -1 on failure.
*/
int spdk_pci_device_cfg_write32(struct spdk_pci_device *dev, uint32_t value, uint32_t offset); int spdk_pci_device_cfg_write32(struct spdk_pci_device *dev, uint32_t value, uint32_t offset);
/** /**
* Compare two PCI addresses. * Compare two PCI addresses.
* *
* \param a1 PCI address 1.
* \param a2 PCI address 2.
*
* \return 0 if a1 == a2, less than 0 if a1 < a2, greater than 0 if a1 > a2 * \return 0 if a1 == a2, less than 0 if a1 < a2, greater than 0 if a1 > a2
*/ */
int spdk_pci_addr_compare(const struct spdk_pci_addr *a1, const struct spdk_pci_addr *a2); int spdk_pci_addr_compare(const struct spdk_pci_addr *a1, const struct spdk_pci_addr *a2);
@ -429,11 +841,11 @@ int spdk_pci_addr_compare(const struct spdk_pci_addr *a1, const struct spdk_pci_
/** /**
* Convert a string representation of a PCI address into a struct spdk_pci_addr. * Convert a string representation of a PCI address into a struct spdk_pci_addr.
* *
* \param addr PCI adddress output on success * \param addr PCI adddress output on success.
* \param bdf PCI address in domain:bus:device.function format or * \param bdf PCI address in domain:bus:device.function format or
* domain.bus.device.function format * domain.bus.device.function format.
* *
* \return 0 on success, or a negated errno value on failure. * \return 0 on success, negative errno on failure.
*/ */
int spdk_pci_addr_parse(struct spdk_pci_addr *addr, const char *bdf); int spdk_pci_addr_parse(struct spdk_pci_addr *addr, const char *bdf);
@ -441,17 +853,16 @@ int spdk_pci_addr_parse(struct spdk_pci_addr *addr, const char *bdf);
* Convert a struct spdk_pci_addr to a string. * Convert a struct spdk_pci_addr to a string.
* *
* \param bdf String into which a string will be output in the format * \param bdf String into which a string will be output in the format
* domain:bus:device.function. The string must be at least * domain:bus:device.function. The string must be at least 14 characters in size.
* 14 characters in size. * \param sz Size of bdf in bytes. Must be at least 14.
* \param sz Size of bdf. Must be at least 14. * \param addr PCI address.
* \param addr PCI address input
* *
* \return 0 on success, or a negated errno value on failure. * \return 0 on success, or a negated errno on failure.
*/ */
int spdk_pci_addr_fmt(char *bdf, size_t sz, const struct spdk_pci_addr *addr); int spdk_pci_addr_fmt(char *bdf, size_t sz, const struct spdk_pci_addr *addr);
/** /**
* Removes any CPU affinitization from the current thread. * Remove any CPU affinity from the current thread.
*/ */
void spdk_unaffinitize_thread(void); void spdk_unaffinitize_thread(void);
@ -461,15 +872,15 @@ void spdk_unaffinitize_thread(void);
* This can be used to run a function that creates other threads without inheriting the calling * This can be used to run a function that creates other threads without inheriting the calling
* thread's CPU affinity. * thread's CPU affinity.
* *
* \param cb function to call * \param cb Function to call
* \param arg parameter to cb function * \param arg Parameter to the function cb().
* *
* \return the return value of cb() * \return the return value of cb().
*/ */
void *spdk_call_unaffinitized(void *cb(void *arg), void *arg); void *spdk_call_unaffinitized(void *cb(void *arg), void *arg);
/** /**
* Page-granularity memory address translation table * Page-granularity memory address translation table.
*/ */
struct spdk_mem_map; struct spdk_mem_map;
@ -483,25 +894,36 @@ typedef int (*spdk_mem_map_notify_cb)(void *cb_ctx, struct spdk_mem_map *map,
void *vaddr, size_t size); void *vaddr, size_t size);
/** /**
* Allocate a virtual memory address translation map * Allocate a virtual memory address translation map.
*
* \param default_translation Default translation for the map.
* \param notify_cb Callback function to notify the mapping.
* \param cb_ctx Argument passed to the callback function.
*
* \return a pointer to the allocated virtual memory address translation map.
*/ */
struct spdk_mem_map *spdk_mem_map_alloc(uint64_t default_translation, struct spdk_mem_map *spdk_mem_map_alloc(uint64_t default_translation,
spdk_mem_map_notify_cb notify_cb, void *cb_ctx); spdk_mem_map_notify_cb notify_cb, void *cb_ctx);
/** /**
* Free a memory map previously allocated by spdk_mem_map_alloc() * Free a memory map previously allocated by spdk_mem_map_alloc().
*
* \param pmap Memory map to free.
*/ */
void spdk_mem_map_free(struct spdk_mem_map **pmap); void spdk_mem_map_free(struct spdk_mem_map **pmap);
/** /**
* Register an address translation for a range of virtual memory. * Register an address translation for a range of virtual memory.
* *
* \param map Memory map * \param map Memory map.
* \param vaddr Virtual address of the region to register - must be 2 MB aligned. * \param vaddr Virtual address of the region to register - must be 2 MB aligned.
* \param size Size of the region - must be 2 MB in the current implementation. * \param size Size of the region in bytes - must be multiple of 2 MB in the
* current implementation.
* \param translation Translation to store in the map for this address range. * \param translation Translation to store in the map for this address range.
* *
* \sa spdk_mem_map_clear_translation() * \sa spdk_mem_map_clear_translation().
*
* \return 0 on success, negative errno on failure.
*/ */
int spdk_mem_map_set_translation(struct spdk_mem_map *map, uint64_t vaddr, uint64_t size, int spdk_mem_map_set_translation(struct spdk_mem_map *map, uint64_t vaddr, uint64_t size,
uint64_t translation); uint64_t translation);
@ -509,25 +931,49 @@ int spdk_mem_map_set_translation(struct spdk_mem_map *map, uint64_t vaddr, uint6
/** /**
* Unregister an address translation. * Unregister an address translation.
* *
* \sa spdk_mem_map_set_translation() * \param map Memory map.
* \param vaddr Virtual address of the region to unregister - must be 2 MB aligned.
* \param size Size of the region in bytes - must be multiple of 2 MB in the
* current implementation.
*
* \sa spdk_mem_map_set_translation().
*
* \return 0 on success, negative errno on failure.
*/ */
int spdk_mem_map_clear_translation(struct spdk_mem_map *map, uint64_t vaddr, uint64_t size); int spdk_mem_map_clear_translation(struct spdk_mem_map *map, uint64_t vaddr, uint64_t size);
/** /**
* Look up the translation of a virtual address in a memory map. * Look up the translation of a virtual address in a memory map.
*
* \param map Memory map.
* \param vaddr Virtual address.
*
* \return the translation of 2MB hugepage mapping.
*/ */
uint64_t spdk_mem_map_translate(const struct spdk_mem_map *map, uint64_t vaddr); uint64_t spdk_mem_map_translate(const struct spdk_mem_map *map, uint64_t vaddr);
/** /**
* Register the specified memory region for address translation. * Register the specified memory region for address translation.
*
* The memory region must map to pinned huge pages (2MB or greater). * The memory region must map to pinned huge pages (2MB or greater).
*
* \param vaddr Virtual address to register.
* \param len Length in bytes of the vaddr.
*
* \return 0 on success, negative errno on failure.
*/ */
int spdk_mem_register(void *vaddr, size_t len); int spdk_mem_register(void *vaddr, size_t len);
/** /**
* Unregister the specified memory region from vtophys address translation. * Unregister the specified memory region from vtophys address translation.
*
* The caller must ensure all in-flight DMA operations to this memory region * The caller must ensure all in-flight DMA operations to this memory region
* are completed or cancelled before calling this function. * are completed or cancelled before calling this function.
*
* \param vaddr Virtual address to unregister.
* \param leng Length in bytes of the vaddr.
*
* \return 0 on success, negative errno on failure.
*/ */
int spdk_mem_unregister(void *vaddr, size_t len); int spdk_mem_unregister(void *vaddr, size_t len);