mpmc.h

Go to the documentation of this file.

// 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);

size_t mpmc_nel(struct mpmc *c);

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

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

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

bool mpmc_send_nbfini(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_recv_nbinit(struct mpmc *c, size_t n, struct claim *r);

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

bool mpmc_recv_nbfini(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