check_list.c File Reference

#include <string.h>
#include <unistd.h>
#include <signal.h>
#include "gwlib/gwlib.h"

Go to the source code of this file.

Data Structures
struct	producer_info
struct	Item

Macros
#define	NUM_PRODUCERS   (4)
#define	NUM_CONSUMERS   (4)
#define	NUM_ITEMS_PER_PRODUCER   (1*1000)

Functions
static Item *	new_item (long producer, long num, long index)
static void	producer (void *arg)
static void	consumer (void *arg)
static void	init_received (void)
static void	main_for_producer_and_consumer (void)
static int	compare_cstr (void *item, void *pat)
static void	main_for_list_add_and_delete (void)
static void	main_for_extract (void)
int	main (void)

Variables
static char	received [NUM_PRODUCERS *NUM_ITEMS_PER_PRODUCER]

Macro Definition Documentation

NUM_CONSUMERS

#define NUM_CONSUMERS   (4)

Definition at line 68 of file check_list.c.

Referenced by main_for_producer_and_consumer().

NUM_ITEMS_PER_PRODUCER

#define NUM_ITEMS_PER_PRODUCER   (1*1000)

Definition at line 69 of file check_list.c.

Referenced by main_for_producer_and_consumer(), and producer().

NUM_PRODUCERS

#define NUM_PRODUCERS   (4)

Definition at line 67 of file check_list.c.

Referenced by main_for_producer_and_consumer().

Function Documentation

compare_cstr()

static int compare_cstr ( void *  item, void *  pat  )

static

Definition at line 181 of file check_list.c.

Referenced by main_for_extract(), and main_for_list_add_and_delete().

                                               {
        /* Remove a macro definition of strcmp to prevent warnings from
     * a broken version in the glibc libary. */
    #undef strcmp
    return strcmp(item, pat) == 0;
}

consumer()

static void consumer ( void *  arg )

static

Definition at line 113 of file check_list.c.

References gwlist_consume(), Item::index, producer_info::list, and received.

Referenced by main_for_producer_and_consumer().

                                {
    List *list;
    Item *item;
    
    list = arg;
    for (;;) {
        item = gwlist_consume(list);
        if (item == NULL)
            break;
        received[item->index] = 1;
        gw_free(item);
    }
}

init_received()

static void init_received ( void  )

static

Definition at line 128 of file check_list.c.

References received.

Referenced by main_for_producer_and_consumer().

                                {
    memset(received, 0, sizeof(received));
}

main()

int main

(

void

)

Definition at line 269 of file check_list.c.

References GW_INFO, gwlib_init(), gwlib_shutdown(), log_set_output_level(), main_for_extract(), main_for_list_add_and_delete(), and main_for_producer_and_consumer().

               {
    gwlib_init();
    log_set_output_level(GW_INFO);
    main_for_list_add_and_delete();
    main_for_extract();
    main_for_producer_and_consumer();
    gwlib_shutdown();
    return 0;
}

main_for_extract()

static void main_for_extract ( void  )

static

Definition at line 223 of file check_list.c.

References compare_cstr(), gwlist_append(), gwlist_create, gwlist_destroy(), gwlist_extract_matching(), gwlist_get(), gwlist_len(), producer_info::list, and panic.

Referenced by main().

                                   {
    static char *items[] = {
        "one",
        "two",
        "three",
    };
    int num_items = sizeof(items) / sizeof(items[0]);
    int num_repeats = 3;
    int i, j;
    char *p;
    List *list, *extracted;

    list = gwlist_create();
    
    for (j = 0; j < num_repeats; ++j)
        for (i = 0; i < num_items; ++i)
            gwlist_append(list, items[i]);

    for (j = 0; j < num_items; ++j) {
        extracted = gwlist_extract_matching(list, items[j], 
                    compare_cstr);
        if (extracted == NULL)
            panic(0, "no extracted elements, should have!");
        for (i = 0; i < gwlist_len(list); ++i) {
            p = gwlist_get(list, i);
            if (strcmp(p, items[j]) == 0)
                panic(0, "list contains `%s' after "
                         "extracting it!",
                    items[j]);
        }
        for (i = 0; i < gwlist_len(extracted); ++i) {
            p = gwlist_get(extracted, i);
            if (strcmp(p, items[j]) != 0)
                panic(0, 
                  "extraction returned wrong element!");
        }
        gwlist_destroy(extracted, NULL);
    }
    
    if (gwlist_len(list) != 0)
        panic(0, "list is not empty after extracting everything");
    
    gwlist_destroy(list, NULL);
}

main_for_list_add_and_delete()

static void main_for_list_add_and_delete ( void  )

static

Definition at line 189 of file check_list.c.

References compare_cstr(), gwlist_append(), gwlist_create, gwlist_delete_equal(), gwlist_delete_matching(), gwlist_destroy(), gwlist_get(), gwlist_len(), producer_info::list, and panic.

Referenced by main().

                                               {
    static char *items[] = {
        "one",
        "two",
        "three",
    };
    int num_items = sizeof(items) / sizeof(items[0]);
    int num_repeats = 3;
    int i, j;
    char *p;
    List *list;

    list = gwlist_create();
    
    for (j = 0; j < num_repeats; ++j)
        for (i = 0; i < num_items; ++i)
            gwlist_append(list, items[i]);
    gwlist_delete_matching(list, items[0], compare_cstr);
    for (i = 0; i < gwlist_len(list); ++i) {
        p = gwlist_get(list, i);
        if (strcmp(p, items[0]) == 0)
            panic(0, "list contains `%s' after deleting it!",
                items[0]);
    }
    
    for (i = 0; i < num_items; ++i)
        gwlist_delete_equal(list, items[i]);
    if (gwlist_len(list) != 0)
        panic(0, "list is not empty after deleting everything");
    
    gwlist_destroy(list, NULL);
}

main_for_producer_and_consumer()

static void main_for_producer_and_consumer ( void  )

static

Definition at line 133 of file check_list.c.

References consumer(), error(), gwlist_add_producer(), gwlist_create, gwlist_delete(), gwlist_get(), gwlist_len(), gwthread_create, gwthread_join_every(), producer_info::id, Item::index, init_received(), producer_info::list, Item::num, NUM_CONSUMERS, NUM_ITEMS_PER_PRODUCER, NUM_PRODUCERS, panic, Item::producer, producer(), received, producer_info::start_index, and warning().

Referenced by main().

                                                 {
    List *list;
    int i;
    Item *item;
    struct producer_info tab[NUM_PRODUCERS];
    long p, n, index;
    int errors;
    
    list = gwlist_create();
    init_received();
    
    for (i = 0; i < NUM_PRODUCERS; ++i) {
            tab[i].list = list;
        tab[i].start_index = i * NUM_ITEMS_PER_PRODUCER;
            gwlist_add_producer(list);
        tab[i].id = gwthread_create(producer, tab + i);
    }
    for (i = 0; i < NUM_CONSUMERS; ++i)
        gwthread_create(consumer, list);
    
        gwthread_join_every(producer);
        gwthread_join_every(consumer);

    while (gwlist_len(list) > 0) {
        item = gwlist_get(list, 0);
        gwlist_delete(list, 0, 1);
        warning(0, "main: %ld %ld %ld", (long) item->producer, 
                item->num, item->index);
    }
    
    errors = 0;
    for (p = 0; p < NUM_PRODUCERS; ++p) {
        for (n = 0; n < NUM_ITEMS_PER_PRODUCER; ++n) {
            index = p * NUM_ITEMS_PER_PRODUCER + n;
            if (!received[index]) {
                error(0, "Not received: producer=%ld "
                         "item=%ld index=%ld", 
                     tab[p].id, n, index);
                errors = 1;
            }
        }
    }
    
    if (errors)
        panic(0, "Not all messages were received.");
}

new_item()

static Item* new_item ( long  producer, long  num, long  index  )

static

Definition at line 88 of file check_list.c.

References Item::index, Item::num, Item::producer, and producer().

Referenced by add_tid(), and producer().

                                                           {
    Item *item;
    
    item = gw_malloc(sizeof(Item));
    item->producer = producer;
    item->num = num;
    item->index = index;
    return item;
}

producer()

static void producer ( void *  arg )

static

Definition at line 99 of file check_list.c.

References gwlist_produce(), gwlist_remove_producer(), gwthread_self(), info(), new_item(), and NUM_ITEMS_PER_PRODUCER.

Referenced by main_for_producer_and_consumer(), and new_item().

                                {
    long i, index;
    long id;
    struct producer_info *info;

    info = arg;

    id = gwthread_self();
    index = info->start_index;
    for (i = 0; i < NUM_ITEMS_PER_PRODUCER; ++i, ++index)
        gwlist_produce(info->list, new_item(id, i, index));
    gwlist_remove_producer(info->list);
}

Variable Documentation

received

char received[NUM_PRODUCERS *NUM_ITEMS_PER_PRODUCER]

static

Definition at line 78 of file check_list.c.

Referenced by consumer(), init_received(), and main_for_producer_and_consumer().