redisx-net.c File Reference

Functions
void	rCloseClientAsync (RedisClient *cl)
int	rConnectAsync (Redis *redis, boolean usePipeline)
void	rDisconnectAsync (Redis *redis)
void *	RedisPipelineListener (void *pRedis)
int	redisxConnect (Redis *redis, boolean usePipeline)
void	redisxDestroy (Redis *redis)
void	redisxDisconnect (Redis *redis)
Redis *	redisxInit (const char *server)
boolean	redisxIsConnected (Redis *redis)
int	redisxReconnect (Redis *redis, boolean usePipeline)
int	redisxSetHostname (Redis *redis, const char *host)
int	redisxSetPort (Redis *redis, int port)
int	redisxSetSocketTimeout (Redis *redis, int millis)
int	redisxSetTcpBuf (Redis *redis, int size)
int	rSetServerAsync (Redis *redis, const char *desc, const char *hostname, int port)

Detailed Description

Date

Created on Aug 26, 2024

Author

Attila Kovacs

Network layer management functions for the RedisX library.

Function Documentation

rCloseClientAsync()

void rCloseClientAsync

(

RedisClient *

cl

)

Closes the Redis client on the specified communication channel. This call assumes that the caller has an exlusive lock on the client.

Parameters

cl	Pointer to the Redis client instance.

rConnectAsync()

int rConnectAsync	(	Redis *	redis,
		boolean	usePipeline
	)

Same as rConnectClient() but called with the client's mutex already locked.

Parameters

redis	Pointer to a Redis instance.
usePipeline	TRUE (non-zero) if a pipeline client should be connected also, or FALSE to create an interactive connection only.

Returns

X_SUCCESS (0) if successful, or X_ALREADY_OPEN if the Redis instance is alreast connected. X_NO_SERVICE if there was an error connecting to Redis, or else an error (<0) returned by rConnectClientAsync().

See also

rConnectClient()

References FALSE, Redis::id, Redis::interactive, Redis::pipeline, REDISX_INTERACTIVE_CHANNEL, REDISX_PIPELINE_CHANNEL, redisxErrorDescription(), redisxIsConnected(), TRUE, X_ALREADY_OPEN, X_NO_SERVICE, X_SUCCESS, x_trace(), x_warn(), and xvprintf.

rDisconnectAsync()

void rDisconnectAsync

(

Redis *

redis

)

Same as rCloseClient() except without the exlusive locking mechanism of the client's IO.

Parameters

redis

Pointer to a Redis instance.

References FALSE, Redis::interactive, Redis::pipeline, and xvprintf.

RedisPipelineListener()

void * RedisPipelineListener

(

void *

pRedis

)

The listener function that processes pipelined responses in the background. It is started when Redis is connected with the pipeline enabled.

Parameters

pRedis

Pointer to a Redis instance.

Returns

Always NULL.

References FALSE, RESP::n, Redis::pipeline, redisxCheckValid(), redisxDestroyRESP(), redisxReadReplyAsync(), RESP_SIMPLE_STRING, RESP::type, X_SUCCESS, x_trace_null(), and xvprintf.

redisxConnect()

int redisxConnect	(	Redis *	redis,
		boolean	usePipeline
	)

Connects to a Redis server.

Parameters

redis	Pointer to a Redis instance.
usePipeline	TRUE (non-zero) if Redis should be connected with a pipeline client also, or FALSE (0) if only the interactive client is needed.

Returns

X_SUCCESS (0) if successfully connected to the Redis server. X_NO_INIT if library was not initialized via initRedis(). X_ALREADY_OPEN if already connected. X_NO_SERVICE if the connection failed. X_NULL if the redis argument is NULL.

See also

redisxInit()

redisxSetPort()

redisxSetUser()

redisxSetPassword()

redisxSetTcpBuf()

redisxSelectDB()

redisxDisconnect()

References rConnectAsync(), and X_SUCCESS.

redisxDestroy()

void redisxDestroy

(

Redis *

redis

)

Destroys a Redis intance, disconnecting any clients that may be connected, and freeing all resources used by that Redis instance.

Parameters

redis

Pointer to a Redis instance.

References Redis::id, REDISX_CHANNELS, redisxClearSubscribers(), redisxDestroyRESP(), redisxDisconnect(), and redisxIsConnected().

redisxDisconnect()

void redisxDisconnect

(

Redis *

redis

)

Disconnect all clients from the Redis server.

Parameters

redis

Pointer to a Redis instance.

References rDisconnectAsync(), redisxCheckValid(), and X_SUCCESS.

redisxInit()

Redis * redisxInit

(

const char *

server

)

Initializes the Redis client library, and sets the hostname or IP address for the Redis server.

Parameters

server

Server host name or numeric IP address, e.g. "127.0.0.1". The string will be copied, not referenced, for the internal configuration, such that the string passed may be destroyed freely after the call.

Returns

X_SUCCESS or X_FAILURE if the IP address is invalid. X_NULL if the IP address is NULL.

See also

redisxInitSentinel()

References FALSE, Redis::interactive, Redis::pipeline, REDISX_CHANNELS, REDISX_DEFAULT_TIMEOUT_MILLIS, REDISX_INTERACTIVE_CHANNEL, REDISX_PIPELINE_CHANNEL, REDISX_RESP2, REDISX_SUBSCRIPTION_CHANNEL, REDISX_TCP_BUF_SIZE, rSetServerAsync(), Redis::subscription, TRUE, x_error(), X_SUCCESS, and x_trace_null().

redisxIsConnected()

boolean redisxIsConnected

(

Redis *

redis

)

Checks if a Redis instance is connected.

Parameters

redis

Pointer to a Redis instance.

Returns

TRUE (1) if the Redis instance is connected, or FALSE (0) otherwise.

References FALSE, Redis::interactive, redisxCheckValid(), and X_SUCCESS.

redisxReconnect()

int redisxReconnect	(	Redis *	redis,
		boolean	usePipeline
	)

Disconnects from Redis, and then connects again...

Parameters

redis	Pointer to a Redis instance.
usePipeline	Whether to reconnect in pipelined mode.

Returns

X_SUCCESS (0) if successful X_NULL if the Redis instance is NULL

or else an error (<0) as would be returned by redisxConnect().

References X_SUCCESS.

redisxSetHostname()

int redisxSetHostname	(	Redis *	redis,
		const char *	host
	)

Changes the host name for the Redis server, prior to calling redisxConnect().

Parameters

redis	Pointer to a Redis instance.
host	New host name or IP address to use.

Returns

X_SUCCESS (0) if successful, or else X_NULL if the redis instance or the host name is NULL, or X_NO_INIT if the redis instance is not initialized, X_ALREADY_OPEN if the redis instance is currently in a connected state, or X_FAILURE if Redis was initialized in Sentinel configuration.

See also

redisxSetPort()

redisxConnect()

References redisxIsConnected(), rSetServerAsync(), X_ALREADY_OPEN, x_error(), X_FAILURE, X_NULL, and X_SUCCESS.

redisxSetPort()

int redisxSetPort	(	Redis *	redis,
		int	port
	)

Sets a non-standard TCP port number to use for the Redis server, prior to calling redisxConnect().

Parameters

redis	Pointer to a Redis instance.
port	The TCP port number to use.

Returns

X_SUCCESS (0) if successful, or else X_NULL if the redis instance is NULL, or X_NO_INIT if the redis instance is not initialized, X_ALREADY_OPEN if the Redis instance is lready connected to a server, or X_FAILURE if Redis was initialized in Sentinel configuration.

See also

redisxSetHostname()

redisxConnect()

References redisxIsConnected(), X_ALREADY_OPEN, x_error(), X_FAILURE, and X_SUCCESS.

redisxSetSocketTimeout()

int redisxSetSocketTimeout	(	Redis *	redis,
		int	millis
	)

Sets a socket timeout for future client connections on a Redis instance. Effectively this is a timeout for send() only. The timeout for interatvice replies is controlled separately via redisxSetReplyTimoeut().

If not set (or set to zero or a negative value), then the timeout will not be configured for sockets, and the system default timeout values will apply.

Parameters

redis	The Redis instance
millis	[ms] The desired socket read/write timeout, or <0 for socket default.

Returns

X_SUCCESS (0) if successful, or else X_NULL if the redis instance is NULL, or X_NO_INIT if the redis instance is not initialized.

See also

redisxSetReplyTimeout()

References REDISX_DEFAULT_TIMEOUT_MILLIS, and X_SUCCESS.

redisxSetTcpBuf()

int redisxSetTcpBuf	(	Redis *	redis,
		int	size
	)

Set the size of the TCP/IP buffers (send and receive) for future client connections.

Parameters

redis	Pointer to a Redis instance.
size	(bytes) requested buffer size, or <= 0 to use default value

Returns

X_SUCCESS (0) if successful, or else X_NULL if the redis instance is NULL, or X_NO_INIT if the redis instance is not initialized, or X_FAILURE if Redis was initialized in Sentinel configuration.

References X_SUCCESS.

rSetServerAsync()

int rSetServerAsync	(	Redis *	redis,
		const char *	desc,
		const char *	hostname,
		int	port
	)

Configures a new server by name or IP address and port number for a given Redis instance

Parameters

redis	A Redis instance
desc	The type of server, e.g. "master", "replica", "sentinel-18"
hostname	The new host name or IP address
port	The new port number, or &lt=0 to use the default Redis port.

Returns

X_SUCCESS (0) if successful or else an error code <0.

References Redis::id, REDISX_TCP_PORT, x_error(), X_NAME_INVALID, X_NULL, X_SUCCESS, x_trace(), and xStringCopyOf().