1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
/**
* This file is part of Hercules.
* http://herc.ws - http://github.com/HerculesWS/Hercules
*
* Copyright (C) 2012-2018 Hercules Dev Team
* Copyright (C) Athena Dev Teams
*
* Hercules is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#define HERCULES_CORE
#include "common/atomic.h"
#include "common/cbasetypes.h"
#include "common/core.h"
#include "common/thread.h"
#include "common/spinlock.h"
#include "common/showmsg.h"
#include <stdio.h>
#include <stdlib.h>
//
// Simple test for the spinlock implementation to see if it works properly..
//
#define THRC 32 //thread Count
#define PERINC 100000
#define LOOPS 47
static struct spin_lock lock;
static unsigned int val = 0;
static volatile int32 done_threads = 0;
static void *worker(void *p){
register int i;
for(i = 0; i < PERINC; i++){
EnterSpinLock(&lock);
EnterSpinLock(&lock);
val++;
LeaveSpinLock(&lock);
LeaveSpinLock(&lock);
}
InterlockedIncrement(&done_threads);
return NULL;
}//end: worker()
int do_init(int argc, char **argv)
{
struct thread_handle *t[THRC];
int j, i;
int ok;
ShowStatus("==========\n");
ShowStatus("TEST: %d Runs, (%d Threads)\n", LOOPS, THRC);
ShowStatus("This can take a while\n");
ShowStatus("\n\n");
ok =0;
for(j = 0; j < LOOPS; j++){
val = 0;
done_threads = 0;
InitializeSpinLock(&lock);
for(i =0; i < THRC; i++){
t[i] = thread->create_opt(worker, NULL, 1024*512, THREADPRIO_NORMAL);
}
(void)t;
while(1){
if(InterlockedCompareExchange(&done_threads, THRC, THRC) == THRC)
break;
thread->yield();
}
FinalizeSpinLock(&lock);
// Everything fine?
if (val != (THRC*PERINC)) {
printf("FAILED! (Result: %u, Expected: %d)\n", val, (THRC*PERINC));
} else {
printf("OK! (Result: %u, Expected: %d)\n", val, (THRC*PERINC));
ok++;
}
}
if (ok != LOOPS) {
ShowFatalError("Test failed.\n");
exit(1);
}
core->runflag = CORE_ST_STOP;
return EXIT_SUCCESS;
}//end: do_init()
void do_abort(void) {
}//end: do_abort()
void set_server_type(void) {
SERVER_TYPE = SERVER_TYPE_UNKNOWN;
}//end: set_server_type()
int do_final(void) {
ShowStatus("Test passed.\n");
return EXIT_SUCCESS;
}//end: do_final()
int parse_console(const char* command){
return 0;
}//end: parse_console
void cmdline_args_init_local(void) { }
|
