as_partition_tracker.h File Reference

#include <aerospike/as_std.h>
#include <aerospike/as_partition.h>
#include <aerospike/as_partition_filter.h>
#include <aerospike/as_policy.h>
#include <aerospike/as_vector.h>
#include <pthread.h>

Include dependency graph for as_partition_tracker.h:

Go to the source code of this file.

Data Structures
struct	as_node_partitions
struct	as_partition_tracker

Functions
static void	as_partition_error (as_partitions_status *parts_all)
as_status	as_partition_tracker_assign (as_partition_tracker *pt, struct as_cluster_s *cluster, const char *ns, struct as_error_s *err)
void	as_partition_tracker_destroy (as_partition_tracker *pt)
static uint16_t	as_partition_tracker_get_id (as_vector *list, uint32_t index)
static as_partition_status *	as_partition_tracker_get_status (as_partition_tracker *pt, as_vector *list, uint32_t index)
as_status	as_partition_tracker_init_filter (as_partition_tracker *pt, struct as_cluster_s *cluster, const as_policy_base *policy, uint64_t max_records, as_policy_replica replica, as_partitions_status **parts_all, bool paginate, uint32_t cluster_size, as_partition_filter *pf, struct as_error_s *err)
void	as_partition_tracker_init_node (as_partition_tracker *pt, struct as_cluster_s *cluster, const as_policy_base *policy, uint64_t max_records, as_policy_replica replica, as_partitions_status **parts_all, bool paginate, struct as_node_s *node)
void	as_partition_tracker_init_nodes (as_partition_tracker *pt, struct as_cluster_s *cluster, const as_policy_base *policy, uint64_t max_records, as_policy_replica replica, as_partitions_status **parts_all, bool paginate, uint32_t cluster_size)
as_status	as_partition_tracker_is_complete (as_partition_tracker *pt, struct as_cluster_s *cluster, struct as_error_s *err)
void	as_partition_tracker_part_unavailable (as_partition_tracker *pt, as_node_partitions *np, uint32_t part_id)
static bool	as_partition_tracker_reached_max_records_async (as_partition_tracker *pt, as_node_partitions *np)
static bool	as_partition_tracker_reached_max_records_sync (as_partition_tracker *pt, as_node_partitions *np)
static void	as_partition_tracker_set_digest (as_partition_tracker *pt, as_node_partitions *np, as_digest *digest, uint32_t n_partitions)
static void	as_partition_tracker_set_last (as_partition_tracker *pt, as_node_partitions *np, as_digest *digest, uint64_t bval, uint32_t n_partitions)
bool	as_partition_tracker_should_retry (as_partition_tracker *pt, as_node_partitions *np, as_status status)

Function Documentation

as_partition_error()

static void as_partition_error ( as_partitions_status * parts_all )

inlinestatic

Definition at line 188 of file as_partition_tracker.h.

References as_partitions_status::retry.

as_partition_tracker_assign()

as_status as_partition_tracker_assign	(	as_partition_tracker *	pt,
		struct as_cluster_s *	cluster,
		const char *	ns,
		struct as_error_s *	err )

as_partition_tracker_destroy()

void as_partition_tracker_destroy

(

as_partition_tracker *

pt

)

as_partition_tracker_get_id()

static uint16_t as_partition_tracker_get_id ( as_vector * list, uint32_t index )

inlinestatic

Definition at line 161 of file as_partition_tracker.h.

References as_vector_get().

as_partition_tracker_get_status()

static as_partition_status * as_partition_tracker_get_status ( as_partition_tracker * pt, as_vector * list, uint32_t index )

inlinestatic

Definition at line 167 of file as_partition_tracker.h.

References as_vector_get(), as_partitions_status::part_begin, as_partitions_status::parts, and as_partition_tracker::parts_all.

as_partition_tracker_init_filter()

as_status as_partition_tracker_init_filter	(	as_partition_tracker *	pt,
		struct as_cluster_s *	cluster,
		const as_policy_base *	policy,
		uint64_t	max_records,
		as_policy_replica	replica,
		as_partitions_status **	parts_all,
		bool	paginate,
		uint32_t	cluster_size,
		as_partition_filter *	pf,
		struct as_error_s *	err )

as_partition_tracker_init_node()

void as_partition_tracker_init_node	(	as_partition_tracker *	pt,
		struct as_cluster_s *	cluster,
		const as_policy_base *	policy,
		uint64_t	max_records,
		as_policy_replica	replica,
		as_partitions_status **	parts_all,
		bool	paginate,
		struct as_node_s *	node )

as_partition_tracker_init_nodes()

void as_partition_tracker_init_nodes	(	as_partition_tracker *	pt,
		struct as_cluster_s *	cluster,
		const as_policy_base *	policy,
		uint64_t	max_records,
		as_policy_replica	replica,
		as_partitions_status **	parts_all,
		bool	paginate,
		uint32_t	cluster_size )

as_partition_tracker_is_complete()

as_status as_partition_tracker_is_complete	(	as_partition_tracker *	pt,
		struct as_cluster_s *	cluster,
		struct as_error_s *	err )

as_partition_tracker_part_unavailable()

void as_partition_tracker_part_unavailable	(	as_partition_tracker *	pt,
		as_node_partitions *	np,
		uint32_t	part_id )

as_partition_tracker_reached_max_records_async()

static bool as_partition_tracker_reached_max_records_async ( as_partition_tracker * pt, as_node_partitions * np )

inlinestatic

Definition at line 148 of file as_partition_tracker.h.

References as_partition_tracker::check_max, as_partition_tracker::max_records, as_partition_tracker::record_count, and as_node_partitions::retry.

as_partition_tracker_reached_max_records_sync()

static bool as_partition_tracker_reached_max_records_sync ( as_partition_tracker * pt, as_node_partitions * np )

inlinestatic

Definition at line 135 of file as_partition_tracker.h.

References as_aaf_uint64, as_partition_tracker::check_max, as_partition_tracker::max_records, as_partition_tracker::record_count, and as_node_partitions::retry.

as_partition_tracker_set_digest()

static void as_partition_tracker_set_digest ( as_partition_tracker * pt, as_node_partitions * np, as_digest * digest, uint32_t n_partitions )

inlinestatic

Definition at line 110 of file as_partition_tracker.h.

References as_partition_getid(), as_partition_status::digest, as_partitions_status::part_begin, as_partitions_status::parts, as_partition_tracker::parts_all, as_node_partitions::record_count, and as_digest::value.

as_partition_tracker_set_last()

static void as_partition_tracker_set_last ( as_partition_tracker * pt, as_node_partitions * np, as_digest * digest, uint64_t bval, uint32_t n_partitions )

inlinestatic

Definition at line 121 of file as_partition_tracker.h.

References as_partition_getid(), as_partition_status::bval, as_partition_status::digest, as_partitions_status::part_begin, as_partitions_status::parts, as_partition_tracker::parts_all, as_node_partitions::record_count, and as_digest::value.

as_partition_tracker_should_retry()

bool as_partition_tracker_should_retry	(	as_partition_tracker *	pt,
		as_node_partitions *	np,
		as_status	status )