msg-queue.h

Go to the documentation of this file.

/*
 * Copyright (C) 2019 Xinyu Ma
 *
 * This file is subject to the terms and conditions of the GNU Lesser
 * General Public License v3.0. See the file LICENSE in the top level
 * directory for more details.
 */

#ifndef FORWARDER_MSG_QUEUE_H_
#define FORWARDER_MSG_QUEUE_H_

#include <inttypes.h>
#include <stdbool.h>
#include <stddef.h>

#ifdef __cplusplus
extern "C" {
#endif

#define NDN_MSGQUEUE_SIZE 4096

#pragma pack(1)
struct ndn_msg;
#pragma pack()

typedef void(*ndn_msg_callback)(void *self,
                                size_t param_length,
                                void *param);

void
ndn_msgqueue_init(void);

struct ndn_msg*
ndn_msgqueue_post(void *target,
                  ndn_msg_callback reason,
                  size_t param_length,
                  void *param);

bool
ndn_msgqueue_dispatch(void);

bool
ndn_msgqueue_empty(void);

void
ndn_msgqueue_process(void);

void
ndn_msgqueue_cancel(struct ndn_msg* msg);

#ifdef __cplusplus
}
#endif

#endif // #define FORWARDER_MSG_QUEUE_H_