Scroll to navigation

DATA_MOVER_THREADS_NEW(3) MINIASYNC Programmer's Manual DATA_MOVER_THREADS_NEW(3)

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 notifer 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>

2022-06-04 MINIASYNC - miniasync version 0.1.0