chic/mpmc_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"


#ifdef __cplusplus

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

        #define restrict __restrict

    #else

        #define restrict

    #endif

    extern "C" {

#endif


struct mpmc;


#define make_mpmc(N, T) mpmc_alloc((N), sizeof(T))


#define sizeof_mpmc(N, T) mpmc_open(NULL, (N), sizeof(T))


#define mpmc_send1(C, SRC) mpmc_send((C), 1, (SRC))


#define mpmc_nbsend1(C, SRC) mpmc_nbsend((C), 1, (SRC))


#define mpmc_recv1(C, DST) mpmc_recv((C), 1, (DST))


#define mpmc_nbrecv1(C, DST) mpmc_nbrecv((C), 1, (DST))


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


struct mpmc *mpmc_alloc(size_t nel, size_t elsize);


bool mpmc_close(struct mpmc *c);


bool mpmc_send_init(struct mpmc *c, size_t n, struct claim *s);


size_t mpmc_nbsend_init(struct mpmc *c, size_t n, struct claim *s);


bool mpmc_send_fini(struct mpmc *c, struct claim *s);


bool mpmc_nbsend_fini(struct mpmc *c, struct claim *s);


bool mpmc_send(struct mpmc *restrict c, size_t n, void *restrict src);


size_t mpmc_nbsend(struct mpmc *restrict c, size_t n, void *restrict src);


bool mpmc_sendv(struct mpmc *restrict c, size_t n, ...);


size_t mpmc_nbsendv(struct mpmc *restrict c, size_t n, ...);


bool mpmc_recv_init(struct mpmc *c, size_t n, struct claim *r);


size_t mpmc_nbrecv_init(struct mpmc *c, size_t n, struct claim *r);


bool mpmc_recv_fini(struct mpmc *c, struct claim *r);


bool mpmc_nbrecv_fini(struct mpmc *c, struct claim *r);


bool mpmc_recv(struct mpmc *restrict c, size_t n, void *restrict dst);


size_t mpmc_nbrecv(struct mpmc *restrict c, size_t n, void *restrict dst);


bool mpmc_recvv(struct mpmc *restrict c, size_t n, ...);


size_t mpmc_nbrecvv(struct mpmc *restrict c, size_t n, ...);


#ifdef __cplusplus

    }

    #undef restrict

#endif

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

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

mpmc_nbsendv
size_t mpmc_nbsendv(struct mpmc *restrict c, size_t n,...)
Sends whatever items will fit to a channel.

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

mpmc_nbrecvv
size_t mpmc_nbrecvv(struct mpmc *restrict c, size_t n,...)
Receives whatever items are available from a channel.

mpmc_close
bool mpmc_close(struct mpmc *c)
Closes a channel, forbidding any future send operations on it.

mpmc_recv_fini
bool mpmc_recv_fini(struct mpmc *c, struct claim *r)
Commits a claim, indicating the item slots within have been read from and are ready to be overwritten...

mpmc_nbsend
size_t mpmc_nbsend(struct mpmc *restrict c, size_t n, void *restrict src)
Sends whatever items will fit to a channel.

mpmc_nbsend_fini
bool mpmc_nbsend_fini(struct mpmc *c, struct claim *s)
Tries to commit a claim, indicating the item slots within have been written to and are ready to be re...

mpmc_send
bool mpmc_send(struct mpmc *restrict c, size_t n, void *restrict src)
Sends items to a channel.

mpmc_sendv
bool mpmc_sendv(struct mpmc *restrict c, size_t n,...)
Sends items to a channel.

mpmc_nbrecv
size_t mpmc_nbrecv(struct mpmc *restrict c, size_t n, void *restrict dst)
Receives whatever items are available from a channel.

mpmc_recv
bool mpmc_recv(struct mpmc *restrict c, size_t n, void *restrict dst)
Receives items from a channel.

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

mpmc_recvv
bool mpmc_recvv(struct mpmc *restrict c, size_t n,...)
Receives items from a channel.

mpmc_nbrecv_fini
bool mpmc_nbrecv_fini(struct mpmc *c, struct claim *r)
Tries to commit a claim, indicating the item slots within have been read from and are safe to be over...

mpmc_send_init
bool mpmc_send_init(struct mpmc *c, size_t n, struct claim *s)
Claims space in the channel to be manually written into.

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

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

mpmc_recv_init
bool mpmc_recv_init(struct mpmc *c, size_t n, struct claim *r)
Claims space in the channel to be manually read from.

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

mpmc
Multiple-producer, multiple-consumer channel.