priority_list.h

Go to the documentation of this file.

#ifndef _CP_PRIORITY_LIST_H
#define _CP_PRIORITY_LIST_H

#include "common.h"

__BEGIN_DECLS

#include "config.h"

#include "collection.h"
#include "linked_list.h"

#define PRIORITY_LIST_IMMEDIATE 1
#define PRIORITY_LIST_NORMAL    2

typedef CPROPS_DLL struct _cp_priority_list
{
    cp_list *immediate;         
    cp_list **normal;           
    int *weight;                
    int normal_priority_queues; 
    int distribution_counter;   
    int cycle_position;         
    int mode;                   
    cp_thread txowner;          
    cp_compare_fn compare_fn;

    int item_count;             
    cp_lock *lock;              
    int txtype;                 
} cp_priority_list;


//void cp_priority_list_destroy_internal(cp_priority_list *list);

#define cp_priority_list_create(immediate, normal_priorities, weights) \
    cp_priority_list_create_by_option(immediate, normal_priorities, weights, \
                        NULL, NULL, NULL, COLLECTION_MODE_MULTIPLE_VALUES)

CPROPS_DLL
cp_priority_list *
    cp_priority_list_create_by_option(int immediate, 
                                      int normal_priority_queues, 
                                      int *weights, 
                                      cp_compare_fn compare_fn, 
                                      cp_copy_fn copy_fn, 
                                      cp_destructor_fn item_destructor,
                                      int mode);

CPROPS_DLL
void cp_priority_list_destroy(cp_priority_list *list);
//#define cp_priority_list_destroy(list) cp_priority_list_destroy_by_option((list), (list)->mode)

CPROPS_DLL
void cp_priority_list_destroy_by_option(cp_priority_list *list, int option);

CPROPS_DLL
void *cp_priority_list_insert(cp_priority_list *list, void *item, int priority);

CPROPS_DLL
void *cp_priority_list_insert_by_option(cp_priority_list *list, void *item, int priority, int mode);

//void *cp_priority_list_get_next(cp_priority_list *list);
#define cp_priority_list_get_next(l) cp_priority_list_get_next_by_option((l), (l)->mode)

CPROPS_DLL
void *cp_priority_list_get_next_by_option(cp_priority_list *list, int mode);

CPROPS_DLL
int cp_priority_list_is_empty(cp_priority_list *list);


#define cp_priority_list_rdlock(list) cp_priority_list_lock(list, COLLECTION_LOCK_READ)

#define cp_priority_list_wrlock(list) cp_priority_list_lock(list, COLLECTION_LOCK_WRITE)

CPROPS_DLL
int cp_priority_list_lock(cp_priority_list *list, int lock_mode);

CPROPS_DLL
int cp_priority_list_unlock(cp_priority_list *list);

CPROPS_DLL
long cp_priority_list_item_count(cp_priority_list *list);

__END_DECLS

#endif 

---