citrusleaf-internal.h File Reference

#include <inttypes.h>
#include <stdbool.h>
#include <netinet/in.h>
#include "citrusleaf/citrusleaf.h"
#include "citrusleaf/cl_cluster.h"
#include "citrusleaf/proto.h"
#include "citrusleaf/cf_atomic.h"
#include "citrusleaf/cf_ll.h"
#include "citrusleaf/cf_vector.h"
#include "citrusleaf/cf_queue.h"
#include "citrusleaf/cf_alloc.h"
#include "citrusleaf/cf_digest.h"
#include "citrusleaf/cf_log_internal.h"

Include dependency graph for citrusleaf-internal.h:

Go to the source code of this file.

Classes
struct	cl_async_work
struct	cl_scan_param_field_s

Typedefs
typedef struct cl_async_work	cl_async_work
typedef struct cl_scan_param_field_s	cl_scan_param_field

Functions
int	cl_value_to_op_get_size (cl_bin *v, size_t *sz)
uint8_t *	cl_write_header (uint8_t *buf, size_t msg_sz, uint info1, uint info2, uint info3, uint32_t generation, uint32_t record_ttl, uint32_t transaction_ttl, uint32_t n_fields, uint32_t n_ops)
int	cl_value_to_op (cl_bin *v, cl_operator clOperator, cl_operation *operation, cl_msg_op *op)
void	cl_set_value_particular (cl_msg_op *op, cl_bin *value)
int	cl_del_node_asyncworkitems (void *key, void *value, void *clnode)
int	cl_do_async_monte (cl_cluster *asc, int info1, int info2, const char *ns, const char *set, const cl_object *key, const cf_digest *digest, cl_bin **values, cl_operator operator, cl_operation **operations, int *n_values, uint32_t *cl_gen, const cl_write_parameters *cl_w_p, uint64_t *trid, void *udata)
void	citrusleaf_batch_shutdown ()
void	citrusleaf_async_shutdown ()
int	citrusleaf_info_host_limit (struct sockaddr_in *sa_in, char *names, char **values, int timeout_ms, bool send_asis, uint64_t max_response_length)
int	cl_compile (uint info1, uint info2, uint info3, const char *ns, const char *set, const cl_object *key, const cf_digest *digest, cl_bin *values, cl_operator operator, cl_operation *operations, int n_values, uint8_t **buf_r, size_t *buf_sz_r, const cl_write_parameters *cl_w_p, cf_digest *d_ret, uint64_t trid, cl_scan_param_field *scan_field)
int	cl_parse (cl_msg *msg, uint8_t *buf, size_t buf_len, cl_bin **values_r, cl_operation **operations_r, int *n_values_r, uint64_t *trid, char *setname_r)

Variables
shash *	g_cl_async_hashtab
cf_queue *	g_cl_async_q
cf_queue *	g_cl_workitems_freepool_q

Typedef Documentation

typedef struct cl_async_work cl_async_work

typedef struct cl_scan_param_field_s cl_scan_param_field

Function Documentation

void citrusleaf_async_shutdown

(

)

void citrusleaf_batch_shutdown

(

)

int citrusleaf_info_host_limit	(	struct sockaddr_in *	sa_in,
		char *	names,
		char **	values,
		int	timeout_ms,
		bool	send_asis,
		uint64_t	max_response_length
	)

int cl_compile	(	uint	info1,
		uint	info2,
		uint	info3,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		const cf_digest *	digest,
		cl_bin *	values,
		cl_operator	operator,
		cl_operation *	operations,
		int	n_values,
		uint8_t **	buf_r,
		size_t *	buf_sz_r,
		const cl_write_parameters *	cl_w_p,
		cf_digest *	d_ret,
		uint64_t	trid,
		cl_scan_param_field *	scan_field
	)

int cl_del_node_asyncworkitems	(	void *	key,
		void *	value,
		void *	clnode
	)

int cl_do_async_monte	(	cl_cluster *	asc,
		int	info1,
		int	info2,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		const cf_digest *	digest,
		cl_bin **	values,
		cl_operator	operator,
		cl_operation **	operations,
		int *	n_values,
		uint32_t *	cl_gen,
		const cl_write_parameters *	cl_w_p,
		uint64_t *	trid,
		void *	udata
	)

int cl_parse	(	cl_msg *	msg,
		uint8_t *	buf,
		size_t	buf_len,
		cl_bin **	values_r,
		cl_operation **	operations_r,
		int *	n_values_r,
		uint64_t *	trid,
		char *	setname_r
	)

void cl_set_value_particular	(	cl_msg_op *	op,
		cl_bin *	value
	)

int cl_value_to_op	(	cl_bin *	v,
		cl_operator	clOperator,
		cl_operation *	operation,
		cl_msg_op *	op
	)

int cl_value_to_op_get_size	(	cl_bin *	v,
		size_t *	sz
	)

uint8_t* cl_write_header	(	uint8_t *	buf,
		size_t	msg_sz,
		uint	info1,
		uint	info2,
		uint	info3,
		uint32_t	generation,
		uint32_t	record_ttl,
		uint32_t	transaction_ttl,
		uint32_t	n_fields,
		uint32_t	n_ops
	)

Variable Documentation

shash* g_cl_async_hashtab

cf_queue* g_cl_async_q

cf_queue* g_cl_workitems_freepool_q