chic/mpsc_8h_source.html

// This Source Code Form is subject to the terms of the Mozilla Public

// License, v. 2.0. If a copy of the MPL was not distributed with this

// file, You can obtain one at https://mozilla.org/MPL/2.0/.


#pragma once

#include "claim.h"

#include "err.h"


#ifdef __cplusplus

    #if defined(__clang__) || defined(__GNUG__) || defined(_MSC_VER)

        #define restrict __restrict

    #else

        #define restrict

    #endif

    extern "C" {

#endif


struct mpsc;


#define make_mpsc(N, T) mpsc_alloc((N), sizeof(T))


#define sizeof_mpsc(N, T) mpsc_open(NULL, (N), sizeof(T))


#define mpsc_send1(C, SRC) mpsc_send((C), 1, (SRC))


#define mpsc_nbsend1(C, SRC) mpsc_nbsend((C), 1, (SRC))


#define mpsc_recv1(C, DST) mpsc_recv((C), 1, (DST))


#define mpsc_nbrecv1(C, DST) mpsc_nbrecv((C), 1, (DST))


size_t mpsc_open(void *c, size_t nel, size_t elsize);


struct mpsc *mpsc_alloc(size_t nel, size_t elsize);


enum chic_err mpsc_close(struct mpsc *c);


size_t mpsc_nel(struct mpsc *c);


enum chic_err mpsc_send_init(struct mpsc *c, size_t n, struct claim *s);


enum chic_err mpsc_send_nbinit(struct mpsc *c, size_t n, struct claim *s);


void mpsc_send_fini(struct mpsc *c, struct claim *s);


enum chic_err mpsc_send_nbfini(struct mpsc *c, struct claim *s);


enum chic_err mpsc_send(struct mpsc *restrict c, size_t n, void *restrict src);


enum chic_err mpsc_nbsend(struct mpsc *restrict c, size_t n, size_t *restrict n2, void *restrict src);


enum chic_err mpsc_sendv(struct mpsc *restrict c, size_t n, ...);


enum chic_err mpsc_nbsendv(struct mpsc *restrict c, size_t n, size_t *restrict n2, ...);


enum chic_err mpsc_recv_init(struct mpsc *c, size_t n, struct claim *r);


enum chic_err mpsc_recv_nbinit(struct mpsc *c, size_t n, struct claim *r);


void mpsc_recv_fini(struct mpsc *c, struct claim *r);


enum chic_err mpsc_recv(struct mpsc *restrict c, size_t n, void *restrict dst);


enum chic_err mpsc_nbrecv(struct mpsc *restrict c, size_t n, size_t *restrict n2, void *restrict dst);


enum chic_err mpsc_recvv(struct mpsc *restrict c, size_t n, ...);


enum chic_err mpsc_nbrecvv(struct mpsc *restrict c, size_t n, size_t *restrict n2, ...);


#ifdef __cplusplus

    }

    #undef restrict

#endif

claim.h
Exclusive claims for directly reading/writing into channels.

err.h
Error enumeration definition.

chic_err
chic_err
Identifiers for channel states and errors.
Definition err.h:14

mpsc_send_fini
void mpsc_send_fini(struct mpsc *c, struct claim *s)
Commits a claim, indicating the item slots within are finished being written to and are ready to be r...

mpsc_send_init
enum chic_err mpsc_send_init(struct mpsc *c, size_t n, struct claim *s)
Claims space in the channel to be manually written into.

mpsc_recv_fini
void mpsc_recv_fini(struct mpsc *c, struct claim *r)
Commits a claim, indicating the item slots within have been read from and are safe to be overwritten.

mpsc_send_nbfini
enum chic_err mpsc_send_nbfini(struct mpsc *c, struct claim *s)
Tries to commit a claim, indicating the item slots within have been written to and are ready to be re...

mpsc_send_nbinit
enum chic_err mpsc_send_nbinit(struct mpsc *c, size_t n, struct claim *s)
Claims up to an amount of space in the channel to be manually written into.

mpsc_recv_nbinit
enum chic_err mpsc_recv_nbinit(struct mpsc *c, size_t n, struct claim *r)
Claims up to an amount of space in the channel to be manually read from.

mpsc_recv_init
enum chic_err mpsc_recv_init(struct mpsc *c, size_t n, struct claim *r)
Claims space in the channel to be manually read from.

mpsc_alloc
struct mpsc * mpsc_alloc(size_t nel, size_t elsize)
Allocates a new mpsc using malloc() and opens it.

mpsc_nbrecv
enum chic_err mpsc_nbrecv(struct mpsc *restrict c, size_t n, size_t *restrict n2, void *restrict dst)
Receives whatever items are available from a channel.

mpsc_nel
size_t mpsc_nel(struct mpsc *c)
Gets the maximim number of elements a channel is capable of holding at once.

mpsc_nbrecvv
enum chic_err mpsc_nbrecvv(struct mpsc *restrict c, size_t n, size_t *restrict n2,...)
Receives whatever items are available from a channel.

mpsc_send
enum chic_err mpsc_send(struct mpsc *restrict c, size_t n, void *restrict src)
Sends items to a channel.

mpsc_sendv
enum chic_err mpsc_sendv(struct mpsc *restrict c, size_t n,...)
Sends items to a channel.

mpsc_close
enum chic_err mpsc_close(struct mpsc *c)
Closes a channel, forbidding any future send operations on it.

mpsc_nbsend
enum chic_err mpsc_nbsend(struct mpsc *restrict c, size_t n, size_t *restrict n2, void *restrict src)
Sends whatever items will fit to a channel.

mpsc_recvv
enum chic_err mpsc_recvv(struct mpsc *restrict c, size_t n,...)
Receives items from a channel.

mpsc_nbsendv
enum chic_err mpsc_nbsendv(struct mpsc *restrict c, size_t n, size_t *restrict n2,...)
Sends whatever items will fit to a channel.

mpsc_recv
enum chic_err mpsc_recv(struct mpsc *restrict c, size_t n, void *restrict dst)
Receives items from a channel.

mpsc_open
size_t mpsc_open(void *c, size_t nel, size_t elsize)
Constructs a mpsc in-place, or calculates the needed allocation size for one.

claim
Claimed space for reading or writing directly into the internal ringbuffer of a channel.
Definition claim.h:66

mpsc
Multiple-producer, single-consumer channel.