| 1 |
/*************************************************************************** |
/* SPDX-License-Identifier: GPL-3.0-or-later */ |
| 2 |
file_section_list.c - description |
/* |
| 3 |
------------------- |
* test_section_list |
| 4 |
Copyright : (C) 2004-2025 by Leaflet |
* - tester for data models and basic operations of section and article |
| 5 |
Email : leaflet@leafok.com |
* |
| 6 |
***************************************************************************/ |
* Copyright (C) 2004-2025 Leaflet <leaflet@leafok.com> |
| 7 |
|
*/ |
| 8 |
/*************************************************************************** |
|
| 9 |
* * |
#ifdef HAVE_CONFIG_H |
| 10 |
* This program is free software; you can redistribute it and/or modify * |
#include "config.h" |
| 11 |
* it under the terms of the GNU General Public License as published by * |
#endif |
|
* the Free Software Foundation; either version 3 of the License, or * |
|
|
* (at your option) any later version. * |
|
|
* * |
|
|
***************************************************************************/ |
|
| 12 |
|
|
|
#include "section_list.h" |
|
|
#include "trie_dict.h" |
|
| 13 |
#include "bbs.h" |
#include "bbs.h" |
| 14 |
#include "log.h" |
#include "log.h" |
| 15 |
|
#include "section_list.h" |
| 16 |
|
#include "trie_dict.h" |
| 17 |
|
#include "user_list.h" |
| 18 |
|
#include <errno.h> |
| 19 |
#include <stdio.h> |
#include <stdio.h> |
| 20 |
#include <unistd.h> |
#include <unistd.h> |
|
#include <errno.h> |
|
| 21 |
|
|
| 22 |
#define ARTICLE_BLOCK_SHM_FILE "~article_block_shm.dat" |
static const char ARTICLE_BLOCK_SHM_FILE[] = "~article_block_shm.dat"; |
| 23 |
#define SECTION_LIST_SHM_FILE "~section_list_shm.dat" |
static const char SECTION_LIST_SHM_FILE[] = "~section_list_shm.dat"; |
| 24 |
#define TRIE_DICT_SHM_FILE "~trie_dict_shm.dat" |
static const char TRIE_DICT_SHM_FILE[] = "~trie_dict_shm.dat"; |
| 25 |
|
static const char USER_LIST_SHM_FILE[] = "~user_list_shm.dat"; |
| 26 |
|
|
| 27 |
const char *sname[] = { |
const char *sname[] = { |
| 28 |
"Test", |
"Test", |
| 31 |
|
|
| 32 |
const char *stitle[] = { |
const char *stitle[] = { |
| 33 |
" Test Section ", |
" Test Section ", |
| 34 |
"ĸABC", |
"字母组合ABC", |
| 35 |
"__123"}; |
"_数字_123"}; |
| 36 |
|
|
| 37 |
const char *master_name[] = { |
const char *master_name[] = { |
| 38 |
"sysadm", |
"sysadm", |
| 68 |
return -1; |
return -1; |
| 69 |
} |
} |
| 70 |
|
|
| 71 |
log_std_redirect(STDOUT_FILENO); |
log_common_redir(STDOUT_FILENO); |
| 72 |
log_err_redirect(STDERR_FILENO); |
log_error_redir(STDERR_FILENO); |
| 73 |
|
|
| 74 |
// - 1 to make blocks allocated is less than required, to trigger error handling |
// - 1 to make blocks allocated is less than required, to trigger error handling |
| 75 |
block_count = BBS_article_limit_per_section * BBS_max_section / ARTICLE_PER_BLOCK; |
block_count = BBS_article_limit_per_section * BBS_max_section / BBS_article_count_per_block; |
| 76 |
|
|
| 77 |
if ((fp = fopen(ARTICLE_BLOCK_SHM_FILE, "w")) == NULL) |
if ((fp = fopen(ARTICLE_BLOCK_SHM_FILE, "w")) == NULL) |
| 78 |
{ |
{ |
| 95 |
} |
} |
| 96 |
fclose(fp); |
fclose(fp); |
| 97 |
|
|
| 98 |
|
if ((fp = fopen(USER_LIST_SHM_FILE, "w")) == NULL) |
| 99 |
|
{ |
| 100 |
|
log_error("fopen(%s) error\n", USER_LIST_SHM_FILE); |
| 101 |
|
return -1; |
| 102 |
|
} |
| 103 |
|
fclose(fp); |
| 104 |
|
|
| 105 |
if (trie_dict_init(TRIE_DICT_SHM_FILE, TRIE_NODE_PER_POOL) < 0) |
if (trie_dict_init(TRIE_DICT_SHM_FILE, TRIE_NODE_PER_POOL) < 0) |
| 106 |
{ |
{ |
| 107 |
printf("trie_dict_init failed\n"); |
printf("trie_dict_init failed\n"); |
| 120 |
return -2; |
return -2; |
| 121 |
} |
} |
| 122 |
|
|
| 123 |
|
// Load user_list and online_user_list |
| 124 |
|
if (user_list_pool_init(USER_LIST_SHM_FILE) < 0) |
| 125 |
|
{ |
| 126 |
|
log_error("user_list_pool_init() error\n"); |
| 127 |
|
return -2; |
| 128 |
|
} |
| 129 |
|
|
| 130 |
printf("Testing #1 ...\n"); |
printf("Testing #1 ...\n"); |
| 131 |
|
|
| 132 |
last_aid = 0; |
last_aid = 0; |
| 191 |
article.tid = 0; |
article.tid = 0; |
| 192 |
article.sid = i * 3 + 1; |
article.sid = i * 3 + 1; |
| 193 |
article.cid = article.aid; |
article.cid = article.aid; |
| 194 |
article.uid = 1; // TODO: randomize |
article.uid = 1; |
| 195 |
article.visible = 1; |
article.visible = 1; |
| 196 |
article.excerption = 0; |
article.excerption = 0; |
| 197 |
article.ontop = 0; |
article.ontop = 0; |
| 198 |
article.lock = 0; |
article.lock = 0; |
| 199 |
|
article.transship = 0; |
| 200 |
|
|
| 201 |
if (section_list_rw_lock(p_section[i]) < 0) |
if (section_list_rw_lock(p_section[i]) < 0) |
| 202 |
{ |
{ |
| 223 |
// printf("Loaded %d articles into section %d\n", p_section[i]->article_count, i); |
// printf("Loaded %d articles into section %d\n", p_section[i]->article_count, i); |
| 224 |
} |
} |
| 225 |
|
|
| 226 |
|
if (last_aid != article_block_last_aid()) |
| 227 |
|
{ |
| 228 |
|
printf("last_aid != %d\n", article_block_last_aid()); |
| 229 |
|
} |
| 230 |
|
|
| 231 |
|
if (article_block_article_count() != section_count * BBS_article_limit_per_section) |
| 232 |
|
{ |
| 233 |
|
printf("article_block_article_count() error %d != %d * %d\n", |
| 234 |
|
article_block_article_count(), section_count, BBS_article_limit_per_section); |
| 235 |
|
} |
| 236 |
|
|
| 237 |
last_aid = 0; |
last_aid = 0; |
| 238 |
|
|
| 239 |
for (j = 0; j < BBS_article_limit_per_section; j++) |
for (j = 0; j < BBS_article_limit_per_section; j++) |
| 314 |
article.tid = ((article.aid < section_first_aid + group_count) ? 0 : (section_first_aid + j % group_count)); |
article.tid = ((article.aid < section_first_aid + group_count) ? 0 : (section_first_aid + j % group_count)); |
| 315 |
article.sid = i * 3 + 1; |
article.sid = i * 3 + 1; |
| 316 |
article.cid = article.aid; |
article.cid = article.aid; |
| 317 |
article.uid = 1; // TODO: randomize |
article.uid = 1; |
| 318 |
article.visible = 1; |
article.visible = 1; |
| 319 |
article.excerption = 0; |
article.excerption = 0; |
| 320 |
article.ontop = 0; |
article.ontop = 0; |
| 321 |
article.lock = 0; |
article.lock = 0; |
| 322 |
|
article.transship = 0; |
| 323 |
|
|
| 324 |
if (section_list_append_article(p_section[i], &article) < 0) |
if (section_list_append_article(p_section[i], &article) < 0) |
| 325 |
{ |
{ |
| 558 |
(p_section[i]->visible_article_count % BBS_article_limit_per_page ? 1 : 0) != |
(p_section[i]->visible_article_count % BBS_article_limit_per_page ? 1 : 0) != |
| 559 |
p_section[i]->page_count) |
p_section[i]->page_count) |
| 560 |
{ |
{ |
| 561 |
printf("Inconsistent page count in section %d offset %d, %d != %d, " |
printf("#1 Inconsistent page count in section %d offset %d, %d != %d, " |
| 562 |
"visible_article_count = %d, last_page_visible_count = %d\n", |
"visible_article_count = %d, last_page_visible_count = %d\n", |
| 563 |
i, j, |
i, j, |
| 564 |
p_section[i]->visible_article_count / BBS_article_limit_per_page + |
p_section[i]->visible_article_count / BBS_article_limit_per_page + |
| 641 |
(p_section[i]->visible_article_count % BBS_article_limit_per_page ? 1 : 0) != |
(p_section[i]->visible_article_count % BBS_article_limit_per_page ? 1 : 0) != |
| 642 |
p_section[i]->page_count) |
p_section[i]->page_count) |
| 643 |
{ |
{ |
| 644 |
printf("Inconsistent page count in section %d offset %d, %d != %d, " |
printf("#2 Inconsistent page count in section %d offset %d, %d != %d, " |
| 645 |
"visible_article_count = %d, last_page_visible_count = %d\n", |
"visible_article_count = %d, last_page_visible_count = %d\n", |
| 646 |
i, j, |
i, j, |
| 647 |
p_section[i]->visible_article_count / BBS_article_limit_per_page + |
p_section[i]->visible_article_count / BBS_article_limit_per_page + |
| 710 |
(p_section[i]->visible_article_count % BBS_article_limit_per_page ? 1 : 0) != |
(p_section[i]->visible_article_count % BBS_article_limit_per_page ? 1 : 0) != |
| 711 |
p_section[i]->page_count) |
p_section[i]->page_count) |
| 712 |
{ |
{ |
| 713 |
printf("Inconsistent page count in section %d offset %d, %d != %d, " |
printf("#3 Inconsistent page count in section %d offset %d, %d != %d, " |
| 714 |
"visible_article_count = %d, last_page_visible_count = %d\n", |
"visible_article_count = %d, last_page_visible_count = %d\n", |
| 715 |
i, j, |
i, j, |
| 716 |
p_section[i]->visible_article_count / BBS_article_limit_per_page + |
p_section[i]->visible_article_count / BBS_article_limit_per_page + |
| 772 |
article.tid = ((article.aid < section_first_aid + group_count) ? 0 : (section_first_aid + j % group_count)); |
article.tid = ((article.aid < section_first_aid + group_count) ? 0 : (section_first_aid + j % group_count)); |
| 773 |
article.sid = i * 3 + 1; |
article.sid = i * 3 + 1; |
| 774 |
article.cid = article.aid; |
article.cid = article.aid; |
| 775 |
article.uid = 1; // TODO: randomize |
article.uid = 1; |
| 776 |
article.visible = 1; |
article.visible = 1; |
| 777 |
article.excerption = 0; |
article.excerption = 0; |
| 778 |
article.ontop = 0; |
article.ontop = 0; |
| 779 |
article.lock = 0; |
article.lock = 0; |
| 780 |
|
article.transship = 0; |
| 781 |
|
|
| 782 |
if (section_list_append_article(p_section[i], &article) < 0) |
if (section_list_append_article(p_section[i], &article) < 0) |
| 783 |
{ |
{ |
| 947 |
} |
} |
| 948 |
} |
} |
| 949 |
|
|
| 950 |
|
#ifndef __CYGWIN__ |
| 951 |
printf("Try rw_lock for 5 sec...\n"); |
printf("Try rw_lock for 5 sec...\n"); |
| 952 |
if (section_list_try_rw_lock(NULL, 5) == 0) |
if (section_list_try_rw_lock(NULL, 5) == 0) |
| 953 |
{ |
{ |
| 954 |
printf("section_list_try_rw_lock(sid = %d) error, expectation is timeout\n", p_section[i]->sid); |
printf("section_list_try_rw_lock(sid = %d) error, expectation is timeout\n", p_section[i]->sid); |
| 955 |
} |
} |
| 956 |
|
#endif |
| 957 |
|
|
| 958 |
for (i = 0; i < section_count; i++) |
for (i = 0; i < section_count; i++) |
| 959 |
{ |
{ |
| 969 |
printf("section_list_rd_lock(sid = %d) error\n", p_section[i]->sid); |
printf("section_list_rd_lock(sid = %d) error\n", p_section[i]->sid); |
| 970 |
} |
} |
| 971 |
|
|
| 972 |
|
#ifndef __CYGWIN__ |
| 973 |
for (i = 0; i < section_count; i++) |
for (i = 0; i < section_count; i++) |
| 974 |
{ |
{ |
| 975 |
if (section_list_try_rd_lock(p_section[i], 0) == 0) |
if (section_list_try_rd_lock(p_section[i], 0) == 0) |
| 978 |
break; |
break; |
| 979 |
} |
} |
| 980 |
} |
} |
| 981 |
|
#endif |
| 982 |
|
|
| 983 |
if (section_list_rw_unlock(NULL) < 0) |
if (section_list_rw_unlock(NULL) < 0) |
| 984 |
{ |
{ |
| 988 |
printf("Press ENTER to exit..."); |
printf("Press ENTER to exit..."); |
| 989 |
getchar(); |
getchar(); |
| 990 |
|
|
| 991 |
|
user_list_pool_cleanup(); |
| 992 |
section_list_cleanup(); |
section_list_cleanup(); |
| 993 |
article_block_cleanup(); |
article_block_cleanup(); |
| 994 |
trie_dict_cleanup(); |
trie_dict_cleanup(); |
| 995 |
|
|
| 996 |
|
if (unlink(USER_LIST_SHM_FILE) < 0) |
| 997 |
|
{ |
| 998 |
|
log_error("unlink(%s) error\n", USER_LIST_SHM_FILE); |
| 999 |
|
return -1; |
| 1000 |
|
} |
| 1001 |
|
|
| 1002 |
if (unlink(TRIE_DICT_SHM_FILE) < 0) |
if (unlink(TRIE_DICT_SHM_FILE) < 0) |
| 1003 |
{ |
{ |
| 1004 |
log_error("unlink(%s) error\n", TRIE_DICT_SHM_FILE); |
log_error("unlink(%s) error\n", TRIE_DICT_SHM_FILE); |