Redis asynchronous command pipelining. More...

#include <freeradius-devel/server/connection.h>
#include <freeradius-devel/server/request.h>
#include <freeradius-devel/server/trunk.h>
#include <freeradius-devel/redis/io.h>
#include <hiredis/async.h>
#include "base.h"

Include dependency graph for pipeline.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Typedefs
typedef void(*	fr_redis_command_complete_t) (request_t request, fr_redis_command_t cmd, redisReply reply, void rctx)
	Process the reply from a single command.

typedef void(*	fr_redis_command_set_complete_t) (request_t request, fr_dlist_head_t completed, void *rctx)
	Do something meaningful with the replies to the commands previously issued.

typedef void(*	fr_redis_command_set_fail_t) (request_t request, fr_dlist_head_t completed, void *rctx)
	Write a failure result to the rctx so that the module is aware that the request failed.

typedef struct fr_redis_command_set_s	fr_redis_command_set_t

typedef struct fr_redis_command_s	fr_redis_command_t

typedef void(*	fr_redis_trunk_active_t) (fr_redis_trunk_t rtrunk, void uctx)

typedef struct fr_redis_trunk_s	fr_redis_trunk_t

Enumerations
enum	fr_redis_pipeline_status_t { FR_REDIS_PIPELINE_OK = 0 , FR_REDIS_PIPELINE_BAD_CMDS , FR_REDIS_PIPELINE_DST_UNAVAILABLE , FR_REDIS_PIPELINE_TOO_MANY_REDIRECTS , FR_REDIS_PIPELINE_FAIL }

Functions
fr_redis_pipeline_status_t	fr_redis_command_argv_add (fr_redis_command_set_t cmds, size_t argc, char const argv, size_t argv_len, fr_redis_command_complete_t complete, void *rctx)
	Add a command with arguments to the command set.

char const *	fr_redis_command_get_cmd (fr_redis_command_t *cmd)

fr_redis_pipeline_status_t	fr_redis_command_literal_add (fr_redis_command_set_t cmds, char const cmd_str, fr_redis_command_complete_t complete, void *rctx)
	Add a literal command to the command set.

fr_redis_pipeline_status_t	fr_redis_command_preformatted_add (fr_redis_command_set_t cmds, char const cmd_str, size_t cmd_len, fr_redis_command_complete_t complete, void *rctx)
	Add an preformatted command to the command set as formatted by redisCommandFormat or it's variants.

fr_redis_command_set_t *	fr_redis_command_set_alloc (TALLOC_CTX ctx, request_t request, fr_redis_command_set_complete_t complete, fr_redis_command_set_fail_t fail, void *rctx, bool autofree)
	Allocate a new command set.

void	fr_redis_command_set_cancel (fr_redis_command_set_t *cmds)
	Cancel a command set.

int	fr_redis_command_set_clear (fr_redis_command_set_t *cmds)

void	fr_redis_command_set_next_node (fr_redis_command_set_t cmds, fr_redis_io_conf_t ioconf)
	Extract the next node address and port from a command set.

fr_redis_async_rcode_t	fr_redis_command_set_rcode (fr_redis_command_set_t *cmds)
	Extract the rcode from a command set.

int	fr_redis_command_set_reset (fr_redis_command_set_t *cmds)
	Reset a command set to it's state before enqueuing.

fr_redis_trunk_t *	fr_redis_trunk_alloc (fr_redis_ct_t rtcluster, fr_redis_io_conf_t const conf, fr_pair_list_t trigger_args, fr_redis_trunk_active_t active, void active_uctx, bool active_oneshot)
	Allocate a new trunk.

fr_redis_pipeline_status_t	redis_command_set_enqueue (fr_redis_trunk_t rtrunk, fr_redis_command_set_t cmds)
	Enqueue a command set on a specific trunk.

Detailed Description

Redis asynchronous command pipelining.

Id: a893b69b249cb13d09629bb86b4d8d2925db5318

Copyright: 2019 The FreeRADIUS server project; 2019 Network RADIUS SAS (legal.nosp@m.@net.nosp@m.workr.nosp@m.adiu.nosp@m.s.com)

Author: Arran Cudbard-Bell (a.cud.nosp@m.bard.nosp@m.b@fre.nosp@m.erad.nosp@m.ius.o.nosp@m.rg)

Definition in file pipeline.h.

Typedef Documentation

◆ fr_redis_command_complete_t

typedef void(* fr_redis_command_complete_t) (request_t *request, fr_redis_command_t *cmd, redisReply *reply, void *rctx)

Process the reply from a single command.

Definition at line 60 of file pipeline.h.

◆ fr_redis_command_set_complete_t

typedef void(* fr_redis_command_set_complete_t) (request_t *request, fr_dlist_head_t *completed, void *rctx)

Do something meaningful with the replies to the commands previously issued.

Definition at line 65 of file pipeline.h.

◆ fr_redis_command_set_fail_t

typedef void(* fr_redis_command_set_fail_t) (request_t *request, fr_dlist_head_t *completed, void *rctx)

Write a failure result to the rctx so that the module is aware that the request failed.

Definition at line 70 of file pipeline.h.

◆ fr_redis_command_set_t

typedef struct fr_redis_command_set_s fr_redis_command_set_t

Definition at line 52 of file pipeline.h.

◆ fr_redis_command_t

typedef struct fr_redis_command_s fr_redis_command_t

Definition at line 51 of file pipeline.h.

◆ fr_redis_trunk_active_t

typedef void(* fr_redis_trunk_active_t) (fr_redis_trunk_t *rtrunk, void *uctx)

Definition at line 55 of file pipeline.h.

◆ fr_redis_trunk_t

typedef struct fr_redis_trunk_s fr_redis_trunk_t

Definition at line 53 of file pipeline.h.

Enumeration Type Documentation

◆ fr_redis_pipeline_status_t

enum fr_redis_pipeline_status_t

Enumerator
FR_REDIS_PIPELINE_OK	No failure.
FR_REDIS_PIPELINE_BAD_CMDS	Malformed command set.
FR_REDIS_PIPELINE_DST_UNAVAILABLE	Cluster or host is down.
FR_REDIS_PIPELINE_TOO_MANY_REDIRECTS	Redirected too many times.
FR_REDIS_PIPELINE_FAIL	Generic failure.

Definition at line 43 of file pipeline.h.

Function Documentation

◆ fr_redis_command_argv_add()

fr_redis_pipeline_status_t fr_redis_command_argv_add	(	fr_redis_command_set_t *	cmds,
		size_t	argc,
		char const **	argv,
		size_t *	argv_len,
		fr_redis_command_complete_t	complete,
		void *	rctx
	)

Add a command with arguments to the command set.

The command and arguments must either be entirely static, or parented by the command set.

Parameters

[in]	cmds	Command set to add command to.
[in]	argc	Number of arguments.
[in]	argv	Redis command arguments.
[in]	argv_len	Length of the command arguments.
[in]	complete	Callback to run when this command completes
[in]	rctx	to pass to `complete`

Returns

FR_REDIS_PIPELINE_BAD_CMDS if a bad command sequence is enqueued.
FR_REDIS_PIPELINE_OK if command was enqueued successfully.

Definition at line 436 of file pipeline.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fr_redis_command_get_cmd()

char const * fr_redis_command_get_cmd ( fr_redis_command_t * cmd )

Definition at line 975 of file pipeline.c.

Here is the caller graph for this function:

◆ fr_redis_command_literal_add()

fr_redis_pipeline_status_t fr_redis_command_literal_add	(	fr_redis_command_set_t *	cmds,
		char const *	cmd_str,
		fr_redis_command_complete_t	complete,
		void *	rctx
	)

Add a literal command to the command set.

The command must either be entirely static, or parented by the command set.

Note: Caller should disallow "SUBSCRIBE" et al, if they're not appropriate. As subscribing to a stream where we're not expecting it would break things, badly.

Parameters

[in]	cmds	Command set to add command to.
[in]	cmd_str	A fully expanded/formatted command to send to redis. Must be static, or have the same lifetime as the command set (allocated with the command set as the parent).
[in]	complete	Callback to run when this command completes
[in]	rctx	to pass to `complete`

Returns

FR_REDIS_PIPELINE_BAD_CMDS if a bad command sequence is enqueued.
FR_REDIS_PIPELINE_OK if command was enqueued successfully.

Definition at line 401 of file pipeline.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fr_redis_command_preformatted_add()

fr_redis_pipeline_status_t fr_redis_command_preformatted_add	(	fr_redis_command_set_t *	cmds,
		char const *	cmd_str,
		size_t	cmd_len,
		fr_redis_command_complete_t	complete,
		void *	rctx
	)

Add an preformatted command to the command set as formatted by redisCommandFormat or it's variants.

The command must either be entirely static, or parented by the command set.

Note: Caller should disallow "SUBSCRIBE" et al, if they're not appropriate. As subscribing to a stream where we're not expecting it would break things, badly.

Parameters

[in]	cmds	Command set to add command to.
[in]	cmd_str	A fully formatted command to send to redis. Must be static, or have the same lifetime as the command set (allocated with the command set as the parent).
[in]	cmd_len	The length of cmd_str (as returned by redisCommandForamt)
[in]	complete	Callback to run when this command completes
[in]	rctx	to pass to `complete`

Returns

FR_REDIS_PIPELINE_BAD_CMDS if a bad command sequence is enqueued.
FR_REDIS_PIPELINE_OK if command was enqueued successfully.

Definition at line 479 of file pipeline.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fr_redis_command_set_alloc()

fr_redis_command_set_t * fr_redis_command_set_alloc	(	TALLOC_CTX *	ctx,
		request_t *	request,
		fr_redis_command_set_complete_t	complete,
		fr_redis_command_set_fail_t	fail,
		void *	rctx,
		bool	autofree
	)

Allocate a new command set.

This is a set of commands that the calling module wants to execute on the redis server in sequence.

Control will be returned to the caller via the registered complete and fail functions.

Parameters

[in]	ctx	to bind the command set's lifetime to.
[in]	request	to pass to places that need it.
[in]	complete	Function to call when all commands have been processed.
[in]	fail	Function to call if the command set was not executed or was partially executed.
[in]	rctx	Resume context to pass to complete and fail functions.
[in]	autofree	Should the command set be freed when completed.

Returns: A new or refurbished command set.

Definition at line 249 of file pipeline.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fr_redis_command_set_cancel()

void fr_redis_command_set_cancel ( fr_redis_command_set_t * cmds )

Cancel a command set.

Parameters

[in] cmds Command set to cancel.

Definition at line 557 of file pipeline.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fr_redis_command_set_clear()

int fr_redis_command_set_clear ( fr_redis_command_set_t * cmds )

Definition at line 1032 of file pipeline.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fr_redis_command_set_next_node()

void fr_redis_command_set_next_node	(	fr_redis_command_set_t *	cmds,
		fr_redis_io_conf_t *	ioconf
	)

Extract the next node address and port from a command set.

Definition at line 997 of file pipeline.c.

Here is the caller graph for this function:

◆ fr_redis_command_set_rcode()

fr_redis_async_rcode_t fr_redis_command_set_rcode ( fr_redis_command_set_t * cmds )

Extract the rcode from a command set.

Definition at line 990 of file pipeline.c.

Here is the caller graph for this function:

◆ fr_redis_command_set_reset()

int fr_redis_command_set_reset ( fr_redis_command_set_t * cmds )

Reset a command set to it's state before enqueuing.

For use when handling MOVED / ASK where the command set needs to be sent to another node.

Definition at line 1008 of file pipeline.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fr_redis_trunk_alloc()

fr_redis_trunk_t * fr_redis_trunk_alloc	(	fr_redis_ct_t *	rtcluster,
		fr_redis_io_conf_t const *	io_conf,
		fr_pair_list_t *	trigger_args,
		fr_redis_trunk_active_t	active,
		void *	active_uctx,
		bool	active_oneshot
	)

Allocate a new trunk.

Parameters

[in]	rtcluster	to allocate the trunk for.
[in]	io_conf	Describing the connection to a single REDIS host.
[in]	trigger_args	Pairs to pass to trigger requests, if triggers are enabled.
[in]	active	Callback to run when the trunk becomes active.
[in]	active_uctx	Uctx to pass to active callback.
[in]	active_oneshot	Should the call back be run just once.

Returns

On success, a new fr_redis_trunk_t which can be used for pipelining commands.
NULL on failure.

Definition at line 941 of file pipeline.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ redis_command_set_enqueue()

fr_redis_pipeline_status_t redis_command_set_enqueue	(	fr_redis_trunk_t *	rtrunk,
		fr_redis_command_set_t *	cmds
	)

Enqueue a command set on a specific trunk.

The command set may be passed around several trunks before it is complete. This is to allow it to follow MOVED and ASK responses.

Parameters

[in]	rtrunk	to enqueue command set on.
[in]	cmds	Command set to enqueue.

Returns

FR_REDIS_PIPELINE_OK if commands were immediately enqueued or placed in the backlog.
FR_REDIS_PIPELINE_DST_UNAVAILABLE if the REDIS host is unreachable.
FR_REDIS_PIPELINE_FAIL any other general error.

Definition at line 532 of file pipeline.c.

Here is the call graph for this function:

Here is the caller graph for this function:

Typedefs

Enumerations

Functions

Detailed Description

Typedef Documentation

◆ fr_redis_command_complete_t

◆ fr_redis_command_set_complete_t

◆ fr_redis_command_set_fail_t

◆ fr_redis_command_set_t

◆ fr_redis_command_t

◆ fr_redis_trunk_active_t

◆ fr_redis_trunk_t

Enumeration Type Documentation

◆ fr_redis_pipeline_status_t

Function Documentation

◆ fr_redis_command_argv_add()

◆ fr_redis_command_get_cmd()

◆ fr_redis_command_literal_add()

◆ fr_redis_command_preformatted_add()

◆ fr_redis_command_set_alloc()

◆ fr_redis_command_set_cancel()

◆ fr_redis_command_set_clear()

◆ fr_redis_command_set_next_node()

◆ fr_redis_command_set_rcode()

◆ fr_redis_command_set_reset()

◆ fr_redis_trunk_alloc()

◆ redis_command_set_enqueue()