| 17 |
#include "log.h" |
#include "log.h" |
| 18 |
#include "section_list.h" |
#include "section_list.h" |
| 19 |
#include "trie_dict.h" |
#include "trie_dict.h" |
| 20 |
|
#include "user_list.h" |
| 21 |
#include <errno.h> |
#include <errno.h> |
| 22 |
#include <signal.h> |
#include <signal.h> |
| 23 |
#include <stdio.h> |
#include <stdio.h> |
| 76 |
|
|
| 77 |
static ARTICLE_BLOCK_POOL *p_article_block_pool = NULL; |
static ARTICLE_BLOCK_POOL *p_article_block_pool = NULL; |
| 78 |
|
|
| 79 |
struct section_list_pool_t |
SECTION_LIST_POOL *p_section_list_pool = NULL; |
|
{ |
|
|
int shmid; |
|
|
SECTION_LIST sections[BBS_max_section]; |
|
|
int section_count; |
|
|
int semid; |
|
|
TRIE_NODE *p_trie_dict_section_by_name; |
|
|
TRIE_NODE *p_trie_dict_section_by_sid; |
|
|
}; |
|
|
typedef struct section_list_pool_t SECTION_LIST_POOL; |
|
|
|
|
|
static SECTION_LIST_POOL *p_section_list_pool = NULL; |
|
| 80 |
|
|
| 81 |
int article_block_init(const char *filename, int block_count) |
int article_block_init(const char *filename, int block_count) |
| 82 |
{ |
{ |
| 343 |
} |
} |
| 344 |
|
|
| 345 |
left = 0; |
left = 0; |
| 346 |
right = p_article_block_pool->block_count; |
right = p_article_block_pool->block_count - 1; |
| 347 |
|
|
| 348 |
// aid in the range [ head aid of blocks[left], tail aid of blocks[right - 1] ] |
// aid in the range [ head aid of blocks[left], tail aid of blocks[right] ] |
| 349 |
while (left < right - 1) |
while (left < right) |
| 350 |
{ |
{ |
| 351 |
// get block offset no less than mid value of left and right block offsets |
// get block offset no less than mid value of left and right block offsets |
| 352 |
mid = (left + right) / 2 + (right - left) % 2; |
mid = (left + right) / 2 + (left + right) % 2; |
|
|
|
|
if (mid >= p_article_block_pool->block_count) |
|
|
{ |
|
|
log_error("block(mid = %d) is out of boundary\n", mid); |
|
|
return NULL; |
|
|
} |
|
| 353 |
|
|
| 354 |
if (aid < p_article_block_pool->p_block[mid]->articles[0].aid) |
if (aid < p_article_block_pool->p_block[mid]->articles[0].aid) |
| 355 |
{ |
{ |
| 356 |
right = mid; |
right = mid - 1; |
| 357 |
} |
} |
| 358 |
else |
else // if (aid >= p_article_block_pool->p_block[mid]->articles[0].aid) |
| 359 |
{ |
{ |
| 360 |
left = mid; |
left = mid; |
| 361 |
} |
} |
| 539 |
p_section_list_pool = NULL; |
p_section_list_pool = NULL; |
| 540 |
} |
} |
| 541 |
|
|
|
void section_list_ex_menu_set_cleanup(void) |
|
|
{ |
|
|
int i; |
|
|
|
|
|
for (i = 0; i < p_section_list_pool->section_count; i++) |
|
|
{ |
|
|
if (p_section_list_pool->sections[i].ex_menu_tm > 0) |
|
|
{ |
|
|
unload_menu(&(p_section_list_pool->sections[i].ex_menu_set)); |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
| 542 |
int set_section_list_shm_readonly(void) |
int set_section_list_shm_readonly(void) |
| 543 |
{ |
{ |
| 544 |
int shmid; |
int shmid; |
| 644 |
return p_section; |
return p_section; |
| 645 |
} |
} |
| 646 |
|
|
| 647 |
|
int section_list_update(SECTION_LIST *p_section, const char *sname, const char *stitle, const char *master_list) |
| 648 |
|
{ |
| 649 |
|
int64_t index; |
| 650 |
|
|
| 651 |
|
if (p_section == NULL || sname == NULL || stitle == NULL || master_list == NULL) |
| 652 |
|
{ |
| 653 |
|
log_error("NULL pointer error\n"); |
| 654 |
|
return -1; |
| 655 |
|
} |
| 656 |
|
|
| 657 |
|
index = get_section_index(p_section); |
| 658 |
|
|
| 659 |
|
strncpy(p_section->sname, sname, sizeof(p_section->sname) - 1); |
| 660 |
|
p_section->sname[sizeof(p_section->sname) - 1] = '\0'; |
| 661 |
|
|
| 662 |
|
strncpy(p_section->stitle, stitle, sizeof(p_section->stitle) - 1); |
| 663 |
|
p_section->stitle[sizeof(p_section->stitle) - 1] = '\0'; |
| 664 |
|
|
| 665 |
|
strncpy(p_section->master_list, master_list, sizeof(p_section->master_list) - 1); |
| 666 |
|
p_section->master_list[sizeof(p_section->master_list) - 1] = '\0'; |
| 667 |
|
|
| 668 |
|
if (trie_dict_set(p_section_list_pool->p_trie_dict_section_by_name, sname, index) < 0) |
| 669 |
|
{ |
| 670 |
|
log_error("trie_dict_set(section, %s, %d) error\n", sname, index); |
| 671 |
|
return -2; |
| 672 |
|
} |
| 673 |
|
|
| 674 |
|
return 0; |
| 675 |
|
} |
| 676 |
|
|
| 677 |
void section_list_reset_articles(SECTION_LIST *p_section) |
void section_list_reset_articles(SECTION_LIST *p_section) |
| 678 |
{ |
{ |
| 679 |
p_section->article_count = 0; |
p_section->article_count = 0; |
| 752 |
|
|
| 753 |
if (p_section == NULL || p_article_src == NULL) |
if (p_section == NULL || p_article_src == NULL) |
| 754 |
{ |
{ |
| 755 |
log_error("section_list_append_article() NULL pointer error\n"); |
log_error("NULL pointer error\n"); |
| 756 |
return -1; |
return -1; |
| 757 |
} |
} |
| 758 |
|
|
| 920 |
{ |
{ |
| 921 |
p_section->visible_article_count--; |
p_section->visible_article_count--; |
| 922 |
|
|
| 923 |
|
if (user_article_cnt_inc(p_article->uid, -1) < 0) |
| 924 |
|
{ |
| 925 |
|
log_error("user_article_cnt_inc(uid=%d, -1) error\n", p_article->uid); |
| 926 |
|
} |
| 927 |
|
|
| 928 |
if (p_article->tid == 0) |
if (p_article->tid == 0) |
| 929 |
{ |
{ |
| 930 |
p_section->visible_topic_count--; |
p_section->visible_topic_count--; |
| 943 |
p_reply->visible = 0; |
p_reply->visible = 0; |
| 944 |
p_section->visible_article_count--; |
p_section->visible_article_count--; |
| 945 |
affected_count++; |
affected_count++; |
| 946 |
|
|
| 947 |
|
if (user_article_cnt_inc(p_reply->uid, -1) < 0) |
| 948 |
|
{ |
| 949 |
|
log_error("user_article_cnt_inc(uid=%d, -1) error\n", p_reply->uid); |
| 950 |
|
} |
| 951 |
} |
} |
| 952 |
} |
} |
| 953 |
} |
} |
| 960 |
{ |
{ |
| 961 |
p_section->visible_topic_count++; |
p_section->visible_topic_count++; |
| 962 |
} |
} |
| 963 |
|
|
| 964 |
|
if (user_article_cnt_inc(p_article->uid, 1) < 0) |
| 965 |
|
{ |
| 966 |
|
log_error("user_article_cnt_inc(uid=%d, 1) error\n", p_article->uid); |
| 967 |
|
} |
| 968 |
} |
} |
| 969 |
|
|
| 970 |
p_article->visible = visible; |
p_article->visible = visible; |
| 1063 |
return -1; |
return -1; |
| 1064 |
} |
} |
| 1065 |
|
|
| 1066 |
page_count = p_section->page_count - 1 + |
page_count = p_section->page_count - (p_section->last_page_visible_article_count > 0 ? 1 : 0) + |
| 1067 |
(p_section->last_page_visible_article_count + p_section->ontop_article_count) / BBS_article_limit_per_page + |
(p_section->last_page_visible_article_count + p_section->ontop_article_count) / BBS_article_limit_per_page + |
| 1068 |
((p_section->last_page_visible_article_count + p_section->ontop_article_count) % BBS_article_limit_per_page == 0 ? 0 : 1); |
((p_section->last_page_visible_article_count + p_section->ontop_article_count) % BBS_article_limit_per_page == 0 ? 0 : 1); |
| 1069 |
|
|
| 1084 |
} |
} |
| 1085 |
else // if (page_id >= p_section->page_count - 1) |
else // if (page_id >= p_section->page_count - 1) |
| 1086 |
{ |
{ |
| 1087 |
return MAX(0, (p_section->last_page_visible_article_count + p_section->ontop_article_count - |
return MIN(MAX(0, |
| 1088 |
BBS_article_limit_per_page * (page_id - p_section->page_count + 1))); |
(p_section->last_page_visible_article_count + p_section->ontop_article_count - |
| 1089 |
|
BBS_article_limit_per_page * (page_id - p_section->page_count + 1))), |
| 1090 |
|
BBS_article_limit_per_page); |
| 1091 |
} |
} |
| 1092 |
} |
} |
| 1093 |
|
|
| 1104 |
|
|
| 1105 |
if (p_section == NULL) |
if (p_section == NULL) |
| 1106 |
{ |
{ |
| 1107 |
log_error("section_list_find_article_with_offset() NULL pointer error\n"); |
log_error("NULL pointer error\n"); |
| 1108 |
return NULL; |
return NULL; |
| 1109 |
} |
} |
| 1110 |
|
|
| 1116 |
} |
} |
| 1117 |
|
|
| 1118 |
left = 0; |
left = 0; |
| 1119 |
right = p_section->page_count; |
right = p_section->page_count - 1; |
| 1120 |
|
|
| 1121 |
// aid in the range [ head aid of pages[left], tail aid of pages[right - 1] ] |
// aid in the range [ head aid of pages[left], tail aid of pages[right] ] |
| 1122 |
while (left < right - 1) |
while (left < right) |
| 1123 |
{ |
{ |
| 1124 |
// get page id no less than mid value of left page id and right page id |
// get page id no less than mid value of left page id and right page id |
| 1125 |
mid = (left + right) / 2 + (right - left) % 2; |
mid = (left + right) / 2 + (left + right) % 2; |
|
|
|
|
if (mid >= p_section->page_count) |
|
|
{ |
|
|
log_error("page id (mid = %d) is out of boundary\n", mid); |
|
|
return NULL; |
|
|
} |
|
| 1126 |
|
|
| 1127 |
if (aid < p_section->p_page_first_article[mid]->aid) |
if (aid < p_section->p_page_first_article[mid]->aid) |
| 1128 |
{ |
{ |
| 1129 |
right = mid; |
right = mid - 1; |
| 1130 |
} |
} |
| 1131 |
else |
else // if (aid < p_section->p_page_first_article[mid]->aid) |
| 1132 |
{ |
{ |
| 1133 |
left = mid; |
left = mid; |
| 1134 |
} |
} |
| 1190 |
|
|
| 1191 |
if (p_section == NULL) |
if (p_section == NULL) |
| 1192 |
{ |
{ |
| 1193 |
log_error("section_list_calculate_page() NULL pointer error\n"); |
log_error("NULL pointer error\n"); |
| 1194 |
return -1; |
return -1; |
| 1195 |
} |
} |
| 1196 |
|
|
| 1349 |
|
|
| 1350 |
if (p_section_src == NULL || p_section_dest == NULL) |
if (p_section_src == NULL || p_section_dest == NULL) |
| 1351 |
{ |
{ |
| 1352 |
log_error("section_list_move_topic() NULL pointer error\n"); |
log_error("NULL pointer error\n"); |
| 1353 |
return -1; |
return -1; |
| 1354 |
} |
} |
| 1355 |
|
|
| 1562 |
return index; |
return index; |
| 1563 |
} |
} |
| 1564 |
|
|
| 1565 |
|
int get_section_info(SECTION_LIST *p_section, char *sname, char *stitle, char *master_list) |
| 1566 |
|
{ |
| 1567 |
|
if (p_section == NULL) |
| 1568 |
|
{ |
| 1569 |
|
log_error("NULL pointer error\n"); |
| 1570 |
|
return -1; |
| 1571 |
|
} |
| 1572 |
|
|
| 1573 |
|
if (section_list_rd_lock(p_section) < 0) |
| 1574 |
|
{ |
| 1575 |
|
log_error("section_list_rd_lock(sid=%d) error\n", p_section->sid); |
| 1576 |
|
return -2; |
| 1577 |
|
} |
| 1578 |
|
|
| 1579 |
|
if (sname != NULL) |
| 1580 |
|
{ |
| 1581 |
|
memcpy(sname, p_section->sname, sizeof(p_section->sname)); |
| 1582 |
|
} |
| 1583 |
|
if (stitle != NULL) |
| 1584 |
|
{ |
| 1585 |
|
memcpy(stitle, p_section->stitle, sizeof(p_section->stitle)); |
| 1586 |
|
} |
| 1587 |
|
if (master_list != NULL) |
| 1588 |
|
{ |
| 1589 |
|
memcpy(master_list, p_section->master_list, sizeof(p_section->master_list)); |
| 1590 |
|
} |
| 1591 |
|
|
| 1592 |
|
// release lock of section |
| 1593 |
|
if (section_list_rd_unlock(p_section) < 0) |
| 1594 |
|
{ |
| 1595 |
|
log_error("section_list_rd_unlock(sid=%d) error\n", p_section->sid); |
| 1596 |
|
return -2; |
| 1597 |
|
} |
| 1598 |
|
|
| 1599 |
|
return 0; |
| 1600 |
|
} |
| 1601 |
|
|
| 1602 |
int section_list_try_rd_lock(SECTION_LIST *p_section, int wait_sec) |
int section_list_try_rd_lock(SECTION_LIST *p_section, int wait_sec) |
| 1603 |
{ |
{ |
| 1604 |
int index; |
int index; |
| 1758 |
timer++; |
timer++; |
| 1759 |
if (timer % SECTION_TRY_LOCK_TIMES == 0) |
if (timer % SECTION_TRY_LOCK_TIMES == 0) |
| 1760 |
{ |
{ |
| 1761 |
log_error("section_list_rd_lock() tried %d times on section %d\n", sid, timer); |
log_error("section_list_try_rd_lock() tried %d times on section %d\n", timer, sid); |
| 1762 |
} |
} |
| 1763 |
} |
} |
| 1764 |
else // failed |
else // failed |
| 1765 |
{ |
{ |
| 1766 |
log_error("section_list_rd_lock() failed on section %d\n", sid); |
log_error("section_list_try_rd_lock() failed on section %d\n", sid); |
| 1767 |
break; |
break; |
| 1768 |
} |
} |
| 1769 |
} |
} |
| 1789 |
timer++; |
timer++; |
| 1790 |
if (timer % SECTION_TRY_LOCK_TIMES == 0) |
if (timer % SECTION_TRY_LOCK_TIMES == 0) |
| 1791 |
{ |
{ |
| 1792 |
log_error("acquire_section_rw_lock() tried %d times on section %d\n", sid, timer); |
log_error("section_list_try_rw_lock() tried %d times on section %d\n", timer, sid); |
| 1793 |
} |
} |
| 1794 |
} |
} |
| 1795 |
else // failed |
else // failed |
| 1796 |
{ |
{ |
| 1797 |
log_error("acquire_section_rw_lock() failed on section %d\n", sid); |
log_error("section_list_try_rw_lock() failed on section %d\n", sid); |
| 1798 |
break; |
break; |
| 1799 |
} |
} |
| 1800 |
} |
} |