Subversion Repositories HelenOS

Rev

Rev 2022 | Rev 2042 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 2022 Rev 2028
Line 43... Line 43...
43 
 
 43 
 
44 
static waitq_t can_start;
 44 
static waitq_t can_start;
45 
static atomic_t items_produced;
 45 
static atomic_t items_produced;
46 
static atomic_t items_consumed;
 46 
static atomic_t items_consumed;
47 
 
 47 
 
48 
static void consumer(void *arg);
 - 
 
49 
static void producer(void *arg);
 - 
 
50 
static void failed(void);
 - 
 
51 
 
 - 
 
52 
static void producer(void *arg)
 48 
static void producer(void *arg)
53 
{
 49 
{
54 
    thread_detach(THREAD); 
 50 
    thread_detach(THREAD); 
55 
 
 51 
 
56 
    waitq_sleep(&can_start);
 52 
    waitq_sleep(&can_start);
Line 71... Line 67...
71 
    atomic_inc(&items_consumed);
 67 
    atomic_inc(&items_consumed);
72 
    thread_usleep(500);
 68 
    thread_usleep(500);
73 
    semaphore_up(&sem);
 69 
    semaphore_up(&sem);
74 
}
 70 
}
75 
 
 71 
 
76 
static void failed(void)
 - 
 
77 
{
 - 
 
78 
    printf("Test failed prematurely.\n");
 - 
 
79 
    thread_exit();
 - 
 
80 
}
 - 
 
81 
 
 - 
 
82 
void test_semaphore1(void)
 72 
char * test_semaphore1(void)
83 
{
 73 
{
84 
    int i, j, k;
 74 
    int i, j, k;
85 
    int consumers, producers;
 75 
    int consumers, producers;
86 
   
 76 
   
87 
    printf("Semaphore test #1\n");
 - 
 
88 
   
 - 
 
89 
    waitq_initialize(&can_start);
 77 
    waitq_initialize(&can_start);
90 
    semaphore_initialize(&sem, AT_ONCE);
 78 
    semaphore_initialize(&sem, AT_ONCE);
91 
 
 79 
 
92 
 
 - 
 
93 
    for (i=1; i<=3; i++) {
 80 
    for (i = 1; i <= 3; i++) {
94 
        thread_t *thrd;
 81 
        thread_t *thrd;
95 
 
 82 
 
96 
        atomic_set(&items_produced, 0);
 83 
        atomic_set(&items_produced, 0);
97 
        atomic_set(&items_consumed, 0);
 84 
        atomic_set(&items_consumed, 0);
98 
       
 85 
       
99 
        consumers = i * CONSUMERS;
 86 
        consumers = i * CONSUMERS;
100 
        producers = (4-i) * PRODUCERS;
 87 
        producers = (4 - i) * PRODUCERS;
101 
       
 88 
       
102 
        printf("Creating %d consumers and %d producers...", consumers, producers);
 89 
        printf("Creating %d consumers and %d producers...", consumers, producers);
103 
   
 90 
   
104 
        for (j=0; j<(CONSUMERS+PRODUCERS)/2; j++) {
 91 
        for (j = 0; j < (CONSUMERS + PRODUCERS) / 2; j++) {
105 
            for (k=0; k<i; k++) {
 92 
            for (k = 0; k < i; k++) {
106 
                thrd = thread_create(consumer, NULL, TASK, 0, "consumer");
 93 
                thrd = thread_create(consumer, NULL, TASK, 0, "consumer");
107 
                if (thrd)
 94 
                if (thrd)
108 
                    thread_ready(thrd);
 95 
                    thread_ready(thrd);
109 
                else
 96 
                else
110 
                    failed();
 97 
                    printf("could not create consumer %d\n", i);
111 
            }
 98 
            }
112 
            for (k=0; k<(4-i); k++) {
 99 
            for (k = 0; k < (4 - i); k++) {
113 
                thrd = thread_create(producer, NULL, TASK, 0, "producer");
 100 
                thrd = thread_create(producer, NULL, TASK, 0, "producer");
114 
                if (thrd)
 101 
                if (thrd)
115 
                    thread_ready(thrd);
 102 
                    thread_ready(thrd);
116 
                else
 103 
                else
117 
                    failed();
 104 
                    printf("could not create producer %d\n", i);
118 
            }
 105 
            }
119 
        }
 106 
        }
120 
 
 107 
 
121 
        printf("ok\n");
 108 
        printf("ok\n");
122 
 
 109 
 
123 
        thread_sleep(1);
 110 
        thread_sleep(1);
124 
        waitq_wakeup(&can_start, WAKEUP_ALL);
 111 
        waitq_wakeup(&can_start, WAKEUP_ALL);
125 
   
 112 
   
126 
        while (items_consumed.count != consumers || items_produced.count != producers) {
 113 
        while ((items_consumed.count != consumers) || (items_produced.count != producers)) {
127 
            printf("%d consumers remaining, %d producers remaining\n", consumers - items_consumed.count, producers - items_produced.count);
 114 
            printf("%d consumers remaining, %d producers remaining\n", consumers - items_consumed.count, producers - items_produced.count);
128 
            thread_sleep(1);
 115 
            thread_sleep(1);
129 
        }
 116 
        }
130 
    }
 117 
    }
- 
 
 118 
   
131 
    printf("Test passed.\n");
 119 
    return NULL;
132 
}
 120 
}