4 * gcc -O1 -ggdb -Wall -Wextra -I ../src/ -I ../ -o benchmark-registry benchmark-registry.c ../src/dictionary.o ../src/log.o ../src/avl.o ../src/common.o ../src/appconfig.o ../src/web_buffer.o ../src/storage_number.o ../src/rrd.o -pthread -luuid -lm -DHAVE_CONFIG_H -DVARLIB_DIR="\"/tmp\""
9 #include "../src/registry.c"
11 // ----------------------------------------------------------------------------
14 int test1(int argc, char **argv) {
16 void print_stats(uint32_t requests, unsigned long long start, unsigned long long end) {
17 fprintf(stderr, " > SPEED: %u requests served in %0.2f seconds ( >>> %llu per second <<< )\n",
18 requests, (end-start) / 1000000.0, (unsigned long long)requests * 1000000ULL / (end-start));
20 fprintf(stderr, " > DB : persons %llu, machines %llu, unique URLs %llu, accesses %llu, URLs: for persons %llu, for machines %llu\n",
21 registry.persons_count, registry.machines_count, registry.urls_count, registry.usages_count,
22 registry.persons_urls_count, registry.machines_urls_count);
28 uint32_t u, users = 1000000;
29 uint32_t m, machines = 200000;
30 uint32_t machines2 = machines * 2;
32 char **users_guids = malloc(users * sizeof(char *));
33 char **machines_guids = malloc(machines2 * sizeof(char *));
34 char **machines_urls = malloc(machines2 * sizeof(char *));
35 unsigned long long start;
39 fprintf(stderr, "Generating %u machine guids\n", machines2);
40 for(m = 0; m < machines2 ;m++) {
42 machines_guids[m] = malloc(36+1);
44 uuid_unparse(uuid, machines_guids[m]);
46 char buf[FILENAME_MAX + 1];
47 snprintfz(buf, FILENAME_MAX, "http://%u.netdata.rocks/", m+1);
48 machines_urls[m] = strdup(buf);
50 // fprintf(stderr, "\tmachine %u: '%s', url: '%s'\n", m + 1, machines_guids[m], machines_urls[m]);
54 fprintf(stderr, "\nGenerating %u users accessing %u machines\n", users, machines);
56 time_t now = time(NULL);
57 for(u = 0; u < users ; u++) {
58 if(++m == machines) m = 0;
60 PERSON *p = registry_request_access(NULL, machines_guids[m], machines_urls[m], "test", now);
61 users_guids[u] = p->guid;
63 print_stats(u, start, timems());
66 fprintf(stderr, "\nAll %u users accessing again the same %u servers\n", users, machines);
69 for(u = 0; u < users ; u++) {
70 if(++m == machines) m = 0;
72 PERSON *p = registry_request_access(users_guids[u], machines_guids[m], machines_urls[m], "test", now);
74 if(p->guid != users_guids[u])
75 fprintf(stderr, "ERROR: expected to get user guid '%s' but git '%s'", users_guids[u], p->guid);
77 print_stats(u, start, timems());
80 fprintf(stderr, "\nAll %u users accessing a new server, out of the %u servers\n", users, machines);
83 for(u = 0; u < users ; u++) {
84 if(++m == machines) m = 0;
86 PERSON *p = registry_request_access(users_guids[u], machines_guids[m], machines_urls[m], "test", now);
88 if(p->guid != users_guids[u])
89 fprintf(stderr, "ERROR: expected to get user guid '%s' but git '%s'", users_guids[u], p->guid);
91 print_stats(u, start, timems());
94 fprintf(stderr, "\n%u random users accessing a random server, out of the %u servers\n", users, machines);
96 for(u = 0; u < users ; u++) {
97 uint32_t tu = random() * users / RAND_MAX;
98 uint32_t tm = random() * machines / RAND_MAX;
100 PERSON *p = registry_request_access(users_guids[tu], machines_guids[tm], machines_urls[tm], "test", now);
102 if(p->guid != users_guids[tu])
103 fprintf(stderr, "ERROR: expected to get user guid '%s' but git '%s'", users_guids[tu], p->guid);
105 print_stats(u, start, timems());
108 fprintf(stderr, "\n%u random users accessing a random server, out of %u servers\n", users, machines2);
110 for(u = 0; u < users ; u++) {
111 uint32_t tu = random() * users / RAND_MAX;
112 uint32_t tm = random() * machines2 / RAND_MAX;
114 PERSON *p = registry_request_access(users_guids[tu], machines_guids[tm], machines_urls[tm], "test", now);
116 if(p->guid != users_guids[tu])
117 fprintf(stderr, "ERROR: expected to get user guid '%s' but git '%s'", users_guids[tu], p->guid);
119 print_stats(u, start, timems());
121 for(m = 0; m < 10; m++) {
124 "\n%u random user accesses to a random server, out of %u servers,\n > using 1/10000 with a random url, 1/1000 with a mismatched url\n",
125 users * 2, machines2);
127 for (u = 0; u < users * 2; u++) {
128 uint32_t tu = random() * users / RAND_MAX;
129 uint32_t tm = random() * machines2 / RAND_MAX;
131 char *url = machines_urls[tm];
132 char buf[FILENAME_MAX + 1];
133 if (random() % 10000 == 1234) {
134 snprintfz(buf, FILENAME_MAX, "http://random.%ld.netdata.rocks/", random());
137 else if (random() % 1000 == 123)
138 url = machines_urls[random() * machines2 / RAND_MAX];
140 PERSON *p = registry_request_access(users_guids[tu], machines_guids[tm], url, "test", now);
142 if (p->guid != users_guids[tu])
143 fprintf(stderr, "ERROR: expected to get user guid '%s' but git '%s'", users_guids[tu], p->guid);
145 print_stats(u, start, timems());
148 fprintf(stderr, "\n\nSAVE\n");
151 print_stats(registry.persons_count, start, timems());
153 fprintf(stderr, "\n\nCLEANUP\n");
156 print_stats(registry.persons_count, start, timems());
160 // ----------------------------------------------------------------------------
163 int main(int argc, char **argv) {
164 config_set_boolean("registry", "enabled", 1);
166 //debug_flags = 0xFFFFFFFF;
176 fprintf(stderr, "\n\nINITIALIZATION\n");
182 fprintf(stderr, "\n\nADDING ENTRY\n");
183 p1 = registry_request_access("2c95abd0-1542-11e6-8c66-00508db7e9c9", "7c173980-145c-11e6-b86f-00508db7e9c1", "http://localhost:19999/", "test", time(NULL));
187 #ifdef REGISTRY_STDOUT_DUMP
188 fprintf(stderr, "\n\nADDING ENTRY\n");
189 #endif /* REGISTRY_STDOUT_DUMP */
190 p1 = registry_request_access(NULL, "7c173980-145c-11e6-b86f-00508db7e9c1", "http://localhost:19999/", "test", time(NULL));
192 #ifdef REGISTRY_STDOUT_DUMP
193 fprintf(stderr, "\n\nADDING ANOTHER URL\n");
194 #endif /* REGISTRY_STDOUT_DUMP */
195 p1 = registry_request_access(p1->guid, "7c173980-145c-11e6-b86f-00508db7e9c1", "http://127.0.0.1:19999/", "test", time(NULL));
197 #ifdef REGISTRY_STDOUT_DUMP
198 fprintf(stderr, "\n\nADDING ANOTHER URL\n");
199 #endif /* REGISTRY_STDOUT_DUMP */
200 p1 = registry_request_access(p1->guid, "7c173980-145c-11e6-b86f-00508db7e9c1", "http://my.server:19999/", "test", time(NULL));
202 #ifdef REGISTRY_STDOUT_DUMP
203 fprintf(stderr, "\n\nADDING ANOTHER MACHINE\n");
204 #endif /* REGISTRY_STDOUT_DUMP */
205 p1 = registry_request_access(p1->guid, "7c173980-145c-11e6-b86f-00508db7e9c1", "http://my.server:19999/", "test", time(NULL));
207 #ifdef REGISTRY_STDOUT_DUMP
208 fprintf(stderr, "\n\nADDING ANOTHER PERSON\n");
209 #endif /* REGISTRY_STDOUT_DUMP */
210 p2 = registry_request_access(NULL, "7c173980-145c-11e6-b86f-00508db7e9c3", "http://localhost:19999/", "test", time(NULL));
212 #ifdef REGISTRY_STDOUT_DUMP
213 fprintf(stderr, "\n\nADDING ANOTHER MACHINE\n");
214 #endif /* REGISTRY_STDOUT_DUMP */
215 p2 = registry_request_access(p2->guid, "7c173980-145c-11e6-b86f-00508db7e9c3", "http://localhost:19999/", "test", time(NULL));
218 fprintf(stderr, "\n\nSAVE\n");
221 fprintf(stderr, "\n\nCLEANUP\n");