All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
Data Structures | Functions
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_statusas_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

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_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 
)
inlinestatic

Definition at line 161 of file as_partition_tracker.h.

References as_vector_get().

static as_partition_status* as_partition_tracker_get_status ( as_partition_tracker pt,
as_vector list,
uint32_t  index 
)
inlinestatic
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 
)
inlinestatic
static bool as_partition_tracker_reached_max_records_sync ( as_partition_tracker pt,
as_node_partitions np 
)
inlinestatic
static void as_partition_tracker_set_digest ( as_partition_tracker pt,
as_node_partitions np,
as_digest digest,
uint32_t  n_partitions 
)
inlinestatic
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
bool as_partition_tracker_should_retry ( as_partition_tracker pt,
as_node_partitions np,
as_status  status 
)