| 21 |
#include <unistd.h> |
#include <unistd.h> |
| 22 |
#include <errno.h> |
#include <errno.h> |
| 23 |
|
|
| 24 |
|
#define ARTICLE_BLOCK_SHM_FILE "~article_block_shm.dat" |
| 25 |
|
#define SECTION_LIST_SHM_FILE "~section_list_shm.dat" |
| 26 |
|
|
| 27 |
const char *sname[] = { |
const char *sname[] = { |
| 28 |
"Test", |
"Test", |
| 29 |
"ABCDEFG", |
"ABCDEFG", |
| 50 |
ARTICLE article; |
ARTICLE article; |
| 51 |
int block_count; |
int block_count; |
| 52 |
int i, j; |
int i, j; |
| 53 |
|
int sid; |
| 54 |
int last_aid; |
int last_aid; |
| 55 |
int current_tid; |
int current_tid; |
| 56 |
int section_first_aid; |
int section_first_aid; |
| 60 |
int32_t page; |
int32_t page; |
| 61 |
int32_t offset; |
int32_t offset; |
| 62 |
int affected_count; |
int affected_count; |
| 63 |
|
FILE *fp; |
| 64 |
|
|
| 65 |
if (log_begin("../log/bbsd.log", "../log/error.log") < 0) |
if (log_begin("../log/bbsd.log", "../log/error.log") < 0) |
| 66 |
{ |
{ |
| 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 / ARTICLE_PER_BLOCK; |
| 76 |
|
|
| 77 |
if (article_block_init("../conf/menu.conf", block_count) < 0) |
if ((fp = fopen(ARTICLE_BLOCK_SHM_FILE, "w")) == NULL) |
| 78 |
|
{ |
| 79 |
|
log_error("fopen(%s) error\n", ARTICLE_BLOCK_SHM_FILE); |
| 80 |
|
return -1; |
| 81 |
|
} |
| 82 |
|
fclose(fp); |
| 83 |
|
|
| 84 |
|
if ((fp = fopen(SECTION_LIST_SHM_FILE, "w")) == NULL) |
| 85 |
|
{ |
| 86 |
|
log_error("fopen(%s) error\n", SECTION_LIST_SHM_FILE); |
| 87 |
|
return -1; |
| 88 |
|
} |
| 89 |
|
fclose(fp); |
| 90 |
|
|
| 91 |
|
if (article_block_init(ARTICLE_BLOCK_SHM_FILE, block_count) < 0) |
| 92 |
|
{ |
| 93 |
|
log_error("article_block_init(%s, %d) error\n", ARTICLE_BLOCK_SHM_FILE, block_count); |
| 94 |
|
return -2; |
| 95 |
|
} |
| 96 |
|
|
| 97 |
|
if (section_list_pool_init(SECTION_LIST_SHM_FILE) < 0) |
| 98 |
{ |
{ |
| 99 |
log_error("section_data_pool_init() error\n"); |
log_error("section_list_pool_init(%s) error\n", SECTION_LIST_SHM_FILE); |
| 100 |
return -2; |
return -2; |
| 101 |
} |
} |
| 102 |
|
|
| 106 |
|
|
| 107 |
for (i = 0; i < section_count; i++) |
for (i = 0; i < section_count; i++) |
| 108 |
{ |
{ |
| 109 |
p_section[i] = section_list_create(i + 1, |
sid = i * 3 + 1; |
| 110 |
|
p_section[i] = section_list_create(sid, |
| 111 |
sname[i % section_conf_count], |
sname[i % section_conf_count], |
| 112 |
stitle[i % section_conf_count], |
stitle[i % section_conf_count], |
| 113 |
master_name[i % section_conf_count]); |
master_name[i % section_conf_count]); |
| 114 |
if (p_section[i] == NULL) |
if (p_section[i] == NULL) |
| 115 |
{ |
{ |
| 116 |
log_error("section_data_create(i=%d) error\n", i); |
log_error("section_list_create(i = %d) error\n", i); |
| 117 |
return -3; |
return -3; |
| 118 |
} |
} |
| 119 |
} |
} |
| 122 |
{ |
{ |
| 123 |
if (section_list_find_by_name(sname[i]) == NULL) |
if (section_list_find_by_name(sname[i]) == NULL) |
| 124 |
{ |
{ |
| 125 |
printf("section_data_find_section_by_name(%s) error\n", sname[i]); |
printf("section_list_find_by_name(%s) error\n", sname[i]); |
| 126 |
|
return -3; |
| 127 |
|
} |
| 128 |
|
} |
| 129 |
|
|
| 130 |
|
for (i = 0; i < section_count; i++) |
| 131 |
|
{ |
| 132 |
|
sid = i * 3 + 1; |
| 133 |
|
if (section_list_find_by_sid(sid) == NULL) |
| 134 |
|
{ |
| 135 |
|
printf("section_list_find_by_sid(%d) error\n", sid); |
| 136 |
return -3; |
return -3; |
| 137 |
} |
} |
| 138 |
} |
} |
| 145 |
|
|
| 146 |
// Set article data |
// Set article data |
| 147 |
article.aid = last_aid; |
article.aid = last_aid; |
|
article.cid = article.aid; |
|
| 148 |
article.tid = 0; |
article.tid = 0; |
| 149 |
|
article.sid = i * 3 + 1; |
| 150 |
|
article.cid = article.aid; |
| 151 |
article.uid = 1; // TODO: randomize |
article.uid = 1; // TODO: randomize |
| 152 |
article.visible = 1; |
article.visible = 1; |
| 153 |
article.excerption = 0; |
article.excerption = 0; |
| 169 |
|
|
| 170 |
last_aid = 0; |
last_aid = 0; |
| 171 |
|
|
| 172 |
for (i = 0; i < section_count; i++) |
for (j = 0; j < BBS_article_limit_per_section; j++) |
| 173 |
{ |
{ |
| 174 |
if (p_section[i]->article_count == 0) |
for (i = 0; i < section_count; i++) |
|
{ |
|
|
continue; |
|
|
} |
|
|
|
|
|
for (j = 0; j < p_section[i]->article_count; j++) |
|
| 175 |
{ |
{ |
| 176 |
last_aid++; |
last_aid++; |
| 177 |
|
|
| 181 |
printf("article_block_find_by_aid() at section %d index %d, %d != %d\n", i, j, p_article->aid, last_aid); |
printf("article_block_find_by_aid() at section %d index %d, %d != %d\n", i, j, p_article->aid, last_aid); |
| 182 |
} |
} |
| 183 |
|
|
|
p_article = article_block_find_by_index(last_aid - 1); |
|
|
if (p_article == NULL || p_article->aid != last_aid) |
|
|
{ |
|
|
printf("article_block_find_by_index() at section %d index %d, %d != %d\n", i, j, p_article->aid, last_aid); |
|
|
} |
|
|
|
|
| 184 |
if (section_list_set_article_visible(p_section[i], p_article->aid, 0) != 1) |
if (section_list_set_article_visible(p_section[i], p_article->aid, 0) != 1) |
| 185 |
{ |
{ |
| 186 |
printf("section_list_set_article_visible(aid = %d) error\n", p_article->aid); |
printf("section_list_set_article_visible(aid = %d) error\n", p_article->aid); |
| 194 |
|
|
| 195 |
if (article_block_reset() != 0) |
if (article_block_reset() != 0) |
| 196 |
{ |
{ |
| 197 |
log_error("section_data_free_block(i=%d) error\n", i); |
log_error("article_block_reset() error\n"); |
| 198 |
return -4; |
return -4; |
| 199 |
} |
} |
| 200 |
|
|
| 215 |
|
|
| 216 |
// Set article data |
// Set article data |
| 217 |
article.aid = last_aid; |
article.aid = last_aid; |
|
article.cid = article.aid; |
|
| 218 |
// Group articles into group_count topics |
// Group articles into group_count topics |
| 219 |
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)); |
| 220 |
|
article.sid = i * 3 + 1; |
| 221 |
|
article.cid = article.aid; |
| 222 |
article.uid = 1; // TODO: randomize |
article.uid = 1; // TODO: randomize |
| 223 |
article.visible = 1; |
article.visible = 1; |
| 224 |
article.excerption = 0; |
article.excerption = 0; |
| 334 |
{ |
{ |
| 335 |
printf("Count of articles in topic %d is different from expected %d != %d\n", |
printf("Count of articles in topic %d is different from expected %d != %d\n", |
| 336 |
j + 1, article_count, p_section[i]->article_count / group_count); |
j + 1, article_count, p_section[i]->article_count / group_count); |
| 337 |
break; |
// break; |
| 338 |
} |
} |
| 339 |
} |
} |
| 340 |
|
|
| 569 |
|
|
| 570 |
if (article_block_reset() != 0) |
if (article_block_reset() != 0) |
| 571 |
{ |
{ |
| 572 |
log_error("section_data_free_block(i=%d) error\n", i); |
log_error("article_block_reset() error\n"); |
| 573 |
return -4; |
return -4; |
| 574 |
} |
} |
| 575 |
|
|
| 590 |
|
|
| 591 |
// Set article data |
// Set article data |
| 592 |
article.aid = last_aid; |
article.aid = last_aid; |
|
article.cid = article.aid; |
|
| 593 |
// Group articles into group_count topics |
// Group articles into group_count topics |
| 594 |
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)); |
| 595 |
|
article.sid = i * 3 + 1; |
| 596 |
|
article.cid = article.aid; |
| 597 |
article.uid = 1; // TODO: randomize |
article.uid = 1; // TODO: randomize |
| 598 |
article.visible = 1; |
article.visible = 1; |
| 599 |
article.excerption = 0; |
article.excerption = 0; |
| 614 |
{ |
{ |
| 615 |
section_first_aid = p_section[i]->p_article_head->aid; |
section_first_aid = p_section[i]->p_article_head->aid; |
| 616 |
|
|
| 617 |
for (j = 0; j < group_count; j++) |
for (j = 0; j < group_count; j += 2) |
| 618 |
{ |
{ |
| 619 |
p_article = section_list_find_article_with_offset(p_section[i], section_first_aid + j, &page, &offset, &p_next); |
p_article = section_list_find_article_with_offset(p_section[i], section_first_aid + j, &page, &offset, &p_next); |
| 620 |
if (p_article == NULL) |
if (p_article == NULL) |
| 623 |
section_first_aid + j, i); |
section_first_aid + j, i); |
| 624 |
break; |
break; |
| 625 |
} |
} |
| 626 |
|
|
| 627 |
|
if (section_list_set_article_visible(p_section[i], p_article->aid, 0) != BBS_article_limit_per_section / group_count) |
| 628 |
|
{ |
| 629 |
|
printf("section_list_set_article_visible(aid = %d) error\n", p_article->aid); |
| 630 |
|
} |
| 631 |
} |
} |
| 632 |
} |
} |
| 633 |
|
|
| 650 |
printf("move topic (aid = %d) affected article count %d != %d\n", |
printf("move topic (aid = %d) affected article count %d != %d\n", |
| 651 |
section_first_aid + j, affected_count, |
section_first_aid + j, affected_count, |
| 652 |
BBS_article_limit_per_section / group_count); |
BBS_article_limit_per_section / group_count); |
| 653 |
break; |
// break; |
| 654 |
} |
} |
| 655 |
} |
} |
| 656 |
} |
} |
| 664 |
break; |
break; |
| 665 |
} |
} |
| 666 |
|
|
| 667 |
|
if (p_section[i]->visible_topic_count != (i < section_count / 2 ? 0 : group_count / 2)) |
| 668 |
|
{ |
| 669 |
|
printf("Visible topic count error in section %d, %d != %d\n", i, |
| 670 |
|
p_section[i]->visible_topic_count, (i < section_count / 2 ? 0 : group_count / 2)); |
| 671 |
|
break; |
| 672 |
|
} |
| 673 |
|
|
| 674 |
if (p_section[i]->article_count != (i < section_count / 2 ? 0 : BBS_article_limit_per_section)) |
if (p_section[i]->article_count != (i < section_count / 2 ? 0 : BBS_article_limit_per_section)) |
| 675 |
{ |
{ |
| 676 |
printf("Article count error in section %d, %d != %d\n", i, |
printf("Article count error in section %d, %d != %d\n", i, |
| 678 |
break; |
break; |
| 679 |
} |
} |
| 680 |
|
|
| 681 |
if (p_section[i]->page_count != (i < section_count / 2 ? 0 : BBS_article_limit_per_section / BBS_article_limit_per_page)) |
if (p_section[i]->visible_article_count != (i < section_count / 2 ? 0 : BBS_article_limit_per_section / 2)) |
| 682 |
|
{ |
| 683 |
|
printf("Visible article count error in section %d, %d != %d\n", i, |
| 684 |
|
p_section[i]->visible_article_count, (i < section_count / 2 ? 0 : BBS_article_limit_per_section / 2)); |
| 685 |
|
break; |
| 686 |
|
} |
| 687 |
|
|
| 688 |
|
if (p_section[i]->page_count != (i < section_count / 2 ? 0 : BBS_article_limit_per_section / 2 / BBS_article_limit_per_page)) |
| 689 |
{ |
{ |
| 690 |
printf("Page count error in section %d, %d != %d\n", i, |
printf("Page count error in section %d, %d != %d\n", i, |
| 691 |
p_section[i]->page_count, (i < section_count / 2 ? 0 : BBS_article_limit_per_section / BBS_article_limit_per_page)); |
p_section[i]->page_count, (i < section_count / 2 ? 0 : BBS_article_limit_per_section / 2 / BBS_article_limit_per_page)); |
| 692 |
break; |
break; |
| 693 |
} |
} |
| 694 |
} |
} |
| 697 |
getchar(); |
getchar(); |
| 698 |
|
|
| 699 |
article_block_cleanup(); |
article_block_cleanup(); |
| 700 |
|
section_list_pool_cleanup(); |
| 701 |
|
|
| 702 |
|
if (unlink(ARTICLE_BLOCK_SHM_FILE) < 0) |
| 703 |
|
{ |
| 704 |
|
log_error("unlink(%s) error\n", ARTICLE_BLOCK_SHM_FILE); |
| 705 |
|
return -1; |
| 706 |
|
} |
| 707 |
|
|
| 708 |
|
if (unlink(SECTION_LIST_SHM_FILE) < 0) |
| 709 |
|
{ |
| 710 |
|
log_error("unlink(%s) error\n", SECTION_LIST_SHM_FILE); |
| 711 |
|
return -1; |
| 712 |
|
} |
| 713 |
|
|
| 714 |
log_end(); |
log_end(); |
| 715 |
|
|