#ifndef AWS_COMMON_PRIORITY_QUEUE_H #define AWS_COMMON_PRIORITY_QUEUE_H /** * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * SPDX-License-Identifier: Apache-2.0. */ #include #include /* The comparator should return a positive value if the second argument has a * higher priority than the first; Otherwise, it should return a negative value * or zero. NOTE: priority_queue pops its highest priority element first. For * example: int cmp(const void *a, const void *b) { return a < b; } would result * in a max heap, while: int cmp(const void *a, const void *b) { return a > b; } * would result in a min heap. */ typedef int(aws_priority_queue_compare_fn)(const void *a, const void *b); struct aws_priority_queue { /** * predicate that determines the priority of the elements in the queue. */ aws_priority_queue_compare_fn *pred; /** * The underlying container storing the queue elements. */ struct aws_array_list container; /** * An array of pointers to backpointer elements. This array is initialized when * the first call to aws_priority_queue_push_bp is made, and is subsequently maintained * through any heap node manipulations. * * Each element is a struct aws_priority_queue_node *, pointing to a backpointer field * owned by the calling code, or a NULL. The backpointer field is continually updated * with information needed to locate and remove a specific node later on. */ struct aws_array_list backpointers; }; struct aws_priority_queue_node { /** The current index of the node in question, or SIZE_MAX if the node has been removed. */ size_t current_index; }; AWS_EXTERN_C_BEGIN /** * Initializes a priority queue struct for use. This mode will grow memory automatically (exponential model) * Default size is the inital size of the queue * item_size is the size of each element in bytes. Mixing items types is not supported by this API. * pred is the function that will be used to determine priority. */ AWS_COMMON_API int aws_priority_queue_init_dynamic( struct aws_priority_queue *queue, struct aws_allocator *alloc, size_t default_size, size_t item_size, aws_priority_queue_compare_fn *pred); /** * Initializes a priority queue struct for use. This mode will not allocate any additional memory. When the heap fills * new enqueue operations will fail with AWS_ERROR_PRIORITY_QUEUE_FULL. * * Heaps initialized using this call do not support the aws_priority_queue_push_ref call with a non-NULL backpointer * parameter. * * heap is the raw memory allocated for this priority_queue * item_count is the maximum number of elements the raw heap can contain * item_size is the size of each element in bytes. Mixing items types is not supported by this API. * pred is the function that will be used to determine priority. */ AWS_COMMON_API void aws_priority_queue_init_static( struct aws_priority_queue *queue, void *heap, size_t item_count, size_t item_size, aws_priority_queue_compare_fn *pred); /** * Checks that the backpointer at a specific index of the queue is * NULL or points to a correctly allocated aws_priority_queue_node. */ bool aws_priority_queue_backpointer_index_valid(const struct aws_priority_queue *const queue, size_t index); /** * Checks that the backpointers of the priority queue are either NULL * or correctly allocated to point at aws_priority_queue_nodes. This * check is O(n), as it accesses every backpointer in a loop, and thus * shouldn't be used carelessly. */ bool aws_priority_queue_backpointers_valid_deep(const struct aws_priority_queue *const queue); /** * Checks that the backpointers of the priority queue satisfy validity * constraints. */ bool aws_priority_queue_backpointers_valid(const struct aws_priority_queue *const queue); /** * Set of properties of a valid aws_priority_queue. */ AWS_COMMON_API bool aws_priority_queue_is_valid(const struct aws_priority_queue *const queue); /** * Cleans up any internally allocated memory and resets the struct for reuse or deletion. */ AWS_COMMON_API void aws_priority_queue_clean_up(struct aws_priority_queue *queue); /** * Copies item into the queue and places it in the proper priority order. Complexity: O(log(n)). */ AWS_COMMON_API int aws_priority_queue_push(struct aws_priority_queue *queue, void *item); /** * Copies item into the queue and places it in the proper priority order. Complexity: O(log(n)). * * If the backpointer parameter is non-null, the heap will continually update the pointed-to field * with information needed to remove the node later on. *backpointer must remain valid until the node * is removed from the heap, and may be updated on any mutating operation on the priority queue. * * If the node is removed, the backpointer will be set to a sentinel value that indicates that the * node has already been removed. It is safe (and a no-op) to call aws_priority_queue_remove with * such a sentinel value. */ AWS_COMMON_API int aws_priority_queue_push_ref( struct aws_priority_queue *queue, void *item, struct aws_priority_queue_node *backpointer); /** * Copies the element of the highest priority, and removes it from the queue.. Complexity: O(log(n)). * If queue is empty, AWS_ERROR_PRIORITY_QUEUE_EMPTY will be raised. */ AWS_COMMON_API int aws_priority_queue_pop(struct aws_priority_queue *queue, void *item); /** * Removes a specific node from the priority queue. Complexity: O(log(n)) * After removing a node (using either _remove or _pop), the backpointer set at push_ref time is set * to a sentinel value. If this sentinel value is passed to aws_priority_queue_remove, * AWS_ERROR_PRIORITY_QUEUE_BAD_NODE will be raised. Note, however, that passing uninitialized * aws_priority_queue_nodes, or ones from different priority queues, results in undefined behavior. */ AWS_COMMON_API int aws_priority_queue_remove(struct aws_priority_queue *queue, void *item, const struct aws_priority_queue_node *node); /** * Obtains a pointer to the element of the highest priority. Complexity: constant time. * If queue is empty, AWS_ERROR_PRIORITY_QUEUE_EMPTY will be raised. */ AWS_COMMON_API int aws_priority_queue_top(const struct aws_priority_queue *queue, void **item); /** * Current number of elements in the queue */ AWS_COMMON_API size_t aws_priority_queue_size(const struct aws_priority_queue *queue); /** * Current allocated capacity for the queue, in dynamic mode this grows over time, in static mode, this will never * change. */ AWS_COMMON_API size_t aws_priority_queue_capacity(const struct aws_priority_queue *queue); AWS_EXTERN_C_END #endif /* AWS_COMMON_PRIORITY_QUEUE_H */