NAME¶

data_mover_threads_new(), data_mover_threads_delete(), data_mover_threads_default() - allocate, free or allocate with default parameters threads data mover structure

SYNOPSIS¶

#include <libminiasync.h>
enum future_notifier_type {


    FUTURE_NOTIFIER_NONE,


    FUTURE_NOTIFIER_WAKER,


    FUTURE_NOTIFIER_POLLER,
};
struct data_mover_threads;
struct data_mover_threads *data_mover_threads_new(size_t nthreads,


    size_t ringbuf_size, enum future_notifier_type desired_notifier);
void data_mover_threads_delete(struct data_mover_threads *dmt);
struct data_mover_threads *data_mover_threads_default();
    

For general description of thread data mover API, see miniasync_vdm_threads(7).

DESCRIPTION¶

The data_mover_threads_new() function allocates and initializes a new thread data mover structure. This function spawns nthreads working threads during initialization. Each thread data mover instance creates an internal ringuffer with size ringbuf_size bytes, it is needed for allocations associated with data mover operations. desired_notifier parameter specifies the notifier type that should be used.

The data_mover_threads_default() function allocates and initialzied a new thread data mover structure with default parameters. It spanws 12 threads and creates a ringbuffer with size of 128 bytes.

Currently, thread data mover supports following notifier types:

•

FUTURE_NOTIFIER_NONE

•

FUTURE_NOTIFIER_WAKER

For more information about notifiers, see miniasync_future(7).

The data_mover_threads_delete() function frees and finalizes the synchronous data mover structure pointed by dms. Spawned threads are cleaned up during finalization.

RETURN VALUE¶

data_mover_threads_new() and data_mover_threads_default functions return a pointer to struct data_mover_sync structure or NULL if the allocation or initialization failed.

The data_mover_threads_delete() function does not return any value.

SEE ALSO¶

miniasync(7), miniasync_future(7), miniasync_vdm_threads(7) and <https://pmem.io>