Subversion Repositories HelenOS

Rev

Rev 2022 | Rev 2029 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 2022 Rev 2028
1 
/*
 1 
/*
2 
 * Copyright (C) 2005 Jakub Vana
 2 
 * Copyright (C) 2005 Jakub Vana
3 
 * Copyright (C) 2005 Jakub Jermar
 3 
 * Copyright (C) 2005 Jakub Jermar
4 
 * All rights reserved.
 4 
 * All rights reserved.
5 
 *
 5 
 *
6 
 * Redistribution and use in source and binary forms, with or without
 6 
 * Redistribution and use in source and binary forms, with or without
7 
 * modification, are permitted provided that the following conditions
 7 
 * modification, are permitted provided that the following conditions
8 
 * are met:
 8 
 * are met:
9 
 *
 9 
 *
10 
 * - Redistributions of source code must retain the above copyright
 10 
 * - Redistributions of source code must retain the above copyright
11 
 *   notice, this list of conditions and the following disclaimer.
 11 
 *   notice, this list of conditions and the following disclaimer.
12 
 * - Redistributions in binary form must reproduce the above copyright
 12 
 * - Redistributions in binary form must reproduce the above copyright
13 
 *   notice, this list of conditions and the following disclaimer in the
 13 
 *   notice, this list of conditions and the following disclaimer in the
14 
 *   documentation and/or other materials provided with the distribution.
 14 
 *   documentation and/or other materials provided with the distribution.
15 
 * - The name of the author may not be used to endorse or promote products
 15 
 * - The name of the author may not be used to endorse or promote products
16 
 *   derived from this software without specific prior written permission.
 16 
 *   derived from this software without specific prior written permission.
17 
 *
 17 
 *
18 
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 18 
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
19 
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 19 
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
20 
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 20 
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
21 
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 21 
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
22 
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 22 
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
23 
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 23 
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
24 
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 24 
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
25 
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 25 
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
26 
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 26 
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
27 
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 27 
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28 
 */
 28 
 */
29 
 
 29 
 
30 
#include <print.h>
 30 
#include <print.h>
31 
#include <debug.h>
 31 
#include <debug.h>
32 
#include <panic.h>
 32 
#include <panic.h>
33 
 
 33 
 
34 
#include <test.h>
 34 
#include <test.h>
35 
#include <atomic.h>
 35 
#include <atomic.h>
36 
#include <proc/thread.h>
 36 
#include <proc/thread.h>
37 
 
 37 
 
38 
#include <arch.h>
 38 
#include <arch.h>
39 
 
 39 
 
40 
#define THREADS 5
 40 
#define THREADS 5
41 
 
 41 
 
- 
 
 42 
static atomic_t finish;
- 
 
 43 
static atomic_t threads_finished;
- 
 
 44 
 
42 
static void threadtest(void *data)
 45 
static void threadtest(void *data)
43 
{
 46 
{
44 
 
 - 
 
45 
    thread_detach(THREAD); 
 47 
    thread_detach(THREAD); 
46 
 
 48 
 
47 
    while (1)
 49 
    while (atomic_get(&finish)) {
48 
        printf("%d\n",(int)(THREAD->tid));
 50 
        printf("%d\n", (int) (THREAD->tid));
- 
 
 51 
        thread_usleep(100);
- 
 
 52 
    }
- 
 
 53 
    atomic_inc(&threads_finished);
49 
}
 54 
}
50 
 
 55 
 
51 
void test_thread1(void)
 56 
char * test_thread1(void)
52 
{
 57 
{
53 
    thread_t *t;
 58 
    unsigned int i, total = 0;
54 
    int i;
 59 
   
- 
 
 60 
    atomic_set(&finish, 1);
- 
 
 61 
    atomic_set(&threads_finished, 0);
55 
 
 62 
 
56 
    for (i=0; i<THREADS; i++) {  
 63 
    for (i = 0; i < THREADS; i++) {  
- 
 
 64 
        thread_t *t;
57 
        if (!(t = thread_create(threadtest, NULL, TASK, 0, "threadtest")))
 65 
        if (!(t = thread_create(threadtest, NULL, TASK, 0, "threadtest"))) {
58 
            panic("could not create thread\n");
 66 
            printf("Could not create thread %d\n", i);
- 
 
 67 
            break;
- 
 
 68 
        }
59 
        thread_ready(t);
 69 
        thread_ready(t);
- 
 
 70 
        total++;
- 
 
 71 
    }
- 
 
 72 
   
- 
 
 73 
    printf("Running threads for 10 seconds...\n");
- 
 
 74 
    thread_sleep(10);
- 
 
 75 
   
- 
 
 76 
    atomic_set(&finish, 0);
- 
 
 77 
    while (atomic_get(&threads_finished) < total) {
- 
 
 78 
        printf("Threads left: %d\n", total - atomic_get(&threads_finished));
- 
 
 79 
        thread_sleep(1);
60 
    }
 80 
    }
- 
 
 81 
   
61 
    printf("ok\n");
 82 
    return NULL;
62 
}
 83 
}
63 
 
 84