Mercurial > sm-archive

comparison src/test.cpp @ 13:75e1a9bcbc2e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
gpl3, add removal option for original recipients
author carl
date Sat, 25 Aug 2007 11:14:49 -0700
parents 616666e2f34c
children 8ebecad6530f
comparison
equal deleted inserted replaced
12:bb3d2cd6007e 13:75e1a9bcbc2e
1 /* 1 /*
2 2
3 Copyright (c) 2004 Carl Byington - 510 Software Group, released under 3 Copyright (c) 2007 Carl Byington - 510 Software Group, released under
4 the GPL version 2 or any later version at your choice available at 4 the GPL version 3 or any later version at your choice available at
5 http://www.fsf.org/licenses/gpl.txt 5 http://www.gnu.org/licenses/gpl-3.0.txt
6 6
7 */ 7 */
8 8
9 #include <stdio.h> 9 #include <stdio.h>
10 #include <unistd.h> 10 #include <unistd.h>
14 static char* test_version="$Id$"; 14 static char* test_version="$Id$";
15 15
16 using namespace std; 16 using namespace std;
17 17
18 struct ltstr { 18 struct ltstr {
19 bool operator()(char* s1, char* s2) const { 19 bool operator()(char* s1, char* s2) const {
20 return strcmp(s1, s2) < 0; 20 return strcmp(s1, s2) < 0;
21 } 21 }
22 }; 22 };
23 23
24 typedef set<char *, ltstr> string_set; 24 typedef set<char *, ltstr> string_set;
25 25
26 static string_set all_strings; // owns all the strings, only modified by the config loader thread 26 static string_set all_strings; // owns all the strings, only modified by the config loader thread
27 27
28 struct stats { 28 struct stats {
29 bool stop; 29 bool stop;
30 bool running; 30 bool running;
31 int counter; 31 int counter;
32 int errors; 32 int errors;
33 stats(); 33 stats();
34 }; 34 };
35 stats::stats() { 35 stats::stats() {
36 stop = false; 36 stop = false;
37 running = false; 37 running = false;
38 counter = 0; 38 counter = 0;
39 errors = 0; 39 errors = 0;
40 } 40 }
41 41
42 //////////////////////////////////////////////// 42 ////////////////////////////////////////////////
43 // helper to discard the strings held by a string_set 43 // helper to discard the strings held by a string_set
44 // 44 //
45 static void discard(string_set &s); 45 static void discard(string_set &s);
46 static void discard(string_set &s) { 46 static void discard(string_set &s) {
47 for (string_set::iterator i=s.begin(); i!=s.end(); i++) { 47 for (string_set::iterator i=s.begin(); i!=s.end(); i++) {
48 free(*i); 48 free(*i);
49 } 49 }
50 s.clear(); 50 s.clear();
51 } 51 }
52 52
53 //////////////////////////////////////////////// 53 ////////////////////////////////////////////////
54 // helper to register a string in a string set 54 // helper to register a string in a string set
55 // 55 //
56 static char* register_string(string_set &s, char *name); 56 static char* register_string(string_set &s, char *name);
57 static char* register_string(string_set &s, char *name) { 57 static char* register_string(string_set &s, char *name) {
58 string_set::iterator i = s.find(name); 58 string_set::iterator i = s.find(name);
59 if (i != s.end()) return *i; 59 if (i != s.end()) return *i;
60 char *x = strdup(name); 60 char *x = strdup(name);
61 s.insert(x); 61 s.insert(x);
62 return x; 62 return x;
63 } 63 }
64 64
65 65
66 //////////////////////////////////////////////// 66 ////////////////////////////////////////////////
67 // thread tester 67 // thread tester
68 // 68 //
69 static void* tester(void *arg); 69 static void* tester(void *arg);
70 static void* tester(void *arg) { 70 static void* tester(void *arg) {
71 stats &st = *((stats *)arg); 71 stats &st = *((stats *)arg);
72 st.running = true; 72 st.running = true;
73 while (!st.stop) { 73 while (!st.stop) {
74 const int LIMIT = 1000; 74 const int LIMIT = 1000;
75 string_set *mine = new string_set; 75 string_set *mine = new string_set;
76 string_set &me = *mine; 76 string_set &me = *mine;
77 for (int i=0; i<LIMIT; i++) { 77 for (int i=0; i<LIMIT; i++) {
78 char buf[100]; 78 char buf[100];
79 snprintf(buf, sizeof(buf), "this is string %d", i); 79 snprintf(buf, sizeof(buf), "this is string %d", i);
80 register_string(me, buf); 80 register_string(me, buf);
81 } 81 }
82 for (int i=0; i<LIMIT; i+=5) { 82 for (int i=0; i<LIMIT; i+=5) {
83 char buf[100]; 83 char buf[100];
84 snprintf(buf, sizeof(buf), "this is string %d", i); 84 snprintf(buf, sizeof(buf), "this is string %d", i);
85 string_set::iterator j = me.find(buf); 85 string_set::iterator j = me.find(buf);
86 if (j == me.end()) st.errors++; 86 if (j == me.end()) st.errors++;
87 } 87 }
88 discard(me); 88 discard(me);
89 delete mine; 89 delete mine;
90 st.counter++; 90 st.counter++;
91 } 91 }
92 st.running = false; 92 st.running = false;
93 return NULL; 93 return NULL;
94 } 94 }
95 95
96 int main(int argc, char**argv) 96 int main(int argc, char**argv)
97 { 97 {
98 stats st1; 98 stats st1;
99 stats st2; 99 stats st2;
100 pthread_t tid; 100 pthread_t tid;
101 if (pthread_create(&tid, 0, tester, &st1)) 101 if (pthread_create(&tid, 0, tester, &st1))
102 fprintf(stdout, "failed to create test thread"); 102 fprintf(stdout, "failed to create test thread");
103 if (pthread_detach(tid)) 103 if (pthread_detach(tid))
104 fprintf(stdout, "failed to detach test thread"); 104 fprintf(stdout, "failed to detach test thread");
105 if (pthread_create(&tid, 0, tester, &st2)) 105 if (pthread_create(&tid, 0, tester, &st2))
106 fprintf(stdout, "failed to create test thread"); 106 fprintf(stdout, "failed to create test thread");
107 if (pthread_detach(tid)) 107 if (pthread_detach(tid))
108 fprintf(stdout, "failed to detach test thread"); 108 fprintf(stdout, "failed to detach test thread");
109 109
110 fprintf(stdout, "tests are running\n"); 110 fprintf(stdout, "tests are running\n");
111 sleep(60); 111 sleep(60);
112 st1.stop = true; 112 st1.stop = true;
113 st2.stop = true; 113 st2.stop = true;
114 while (st1.running || st2.running) { 114 while (st1.running || st2.running) {
115 sleep(1); 115 sleep(1);
116 } 116 }
117 117
118 fprintf(stdout, "counter 1 = %d\n", st1.counter); 118 fprintf(stdout, "counter 1 = %d\n", st1.counter);
119 fprintf(stdout, "counter 2 = %d\n", st2.counter); 119 fprintf(stdout, "counter 2 = %d\n", st2.counter);
120 fprintf(stdout, "errors 1 = %d\n", st1.errors); 120 fprintf(stdout, "errors 1 = %d\n", st1.errors);
121 fprintf(stdout, "errors 2 = %d\n", st2.errors); 121 fprintf(stdout, "errors 2 = %d\n", st2.errors);
122 return 0; 122 return 0;
123 } 123 }
124 124