gcs_xcom_input_queue.h File Reference

#include <future>
#include <memory>
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_mpsc_queue.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/xcom_input_request.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/xcom_memory.h"
#include "plugin/group_replication/libmysqlgcs/xdr_gen/xcom_vp.h"

Go to the source code of this file.

Classes
struct	xcom_input_request_ptr_deleter
class	Gcs_xcom_input_queue_impl< Queue >
	MPSC queue with FIFO semantics used to send commands to XCom. More...
class	Gcs_xcom_input_queue_impl< Queue >::Reply
	Wraps XCom's reply to a queued request. More...

Typedefs
using	Gcs_xcom_input_queue = Gcs_xcom_input_queue_impl<>

Functions
static void	do_not_reply (void *reply, pax_msg *payload)
static void	reply_by_resolving_future (void *reply, pax_msg *payload)

Typedef Documentation

Gcs_xcom_input_queue

using Gcs_xcom_input_queue = Gcs_xcom_input_queue_impl<>

Function Documentation

do_not_reply()

static void do_not_reply ( void *  reply, pax_msg *  payload  )

inlinestatic

reply_by_resolving_future()

static void reply_by_resolving_future ( void *  reply, pax_msg *  payload  )

inlinestatic