| 15 |
***************************************************************************/ |
***************************************************************************/ |
| 16 |
|
|
| 17 |
#include "article_cache.h" |
#include "article_cache.h" |
| 18 |
|
#include "article_view_log.h" |
| 19 |
#include "bbs.h" |
#include "bbs.h" |
| 20 |
#include "database.h" |
#include "database.h" |
| 21 |
|
#include "ip_mask.h" |
| 22 |
#include "log.h" |
#include "log.h" |
| 23 |
#include "menu.h" |
#include "menu.h" |
| 24 |
#include "section_list_loader.h" |
#include "section_list_loader.h" |
| 25 |
|
#include "user_list.h" |
| 26 |
|
#include "user_priv.h" |
| 27 |
#include <errno.h> |
#include <errno.h> |
| 28 |
#include <signal.h> |
#include <signal.h> |
| 29 |
#include <stdio.h> |
#include <stdio.h> |
| 34 |
int section_list_loader_pid; |
int section_list_loader_pid; |
| 35 |
int last_article_op_log_mid; |
int last_article_op_log_mid; |
| 36 |
|
|
| 37 |
int load_section_config_from_db(void) |
int load_section_config_from_db(int update_gen_ex) |
| 38 |
{ |
{ |
| 39 |
MYSQL *db = NULL; |
MYSQL *db = NULL; |
| 40 |
MYSQL_RES *rs = NULL, *rs2 = NULL; |
MYSQL_RES *rs = NULL, *rs2 = NULL; |
| 43 |
int32_t sid; |
int32_t sid; |
| 44 |
char master_list[(BBS_username_max_len + 1) * 3 + 1]; |
char master_list[(BBS_username_max_len + 1) * 3 + 1]; |
| 45 |
SECTION_LIST *p_section; |
SECTION_LIST *p_section; |
| 46 |
|
char ex_menu_conf[FILE_PATH_LEN]; |
| 47 |
|
MENU_SET ex_menu_set_new; |
| 48 |
int ret = 0; |
int ret = 0; |
| 49 |
|
|
| 50 |
db = db_open(); |
db = db_open(); |
| 57 |
|
|
| 58 |
snprintf(sql, sizeof(sql), |
snprintf(sql, sizeof(sql), |
| 59 |
"SELECT section_config.SID, sname, section_config.title, section_config.CID, " |
"SELECT section_config.SID, sname, section_config.title, section_config.CID, " |
| 60 |
"read_user_level, write_user_level, section_config.enable * section_class.enable AS enable " |
"read_user_level, write_user_level, section_config.enable * section_class.enable AS enable, " |
| 61 |
|
"UNIX_TIMESTAMP(ex_menu_tm) AS ex_menu_tm " |
| 62 |
"FROM section_config INNER JOIN section_class ON section_config.CID = section_class.CID " |
"FROM section_config INNER JOIN section_class ON section_config.CID = section_class.CID " |
| 63 |
"ORDER BY section_config.SID"); |
"ORDER BY section_config.SID"); |
| 64 |
|
|
| 138 |
break; |
break; |
| 139 |
} |
} |
| 140 |
|
|
| 141 |
strncpy(p_section->sname, row[0], sizeof(p_section->sname) - 1); |
if (section_list_update(p_section, row[1], row[2], master_list) < 0) |
| 142 |
p_section->sname[sizeof(p_section->sname) - 1] = '\0'; |
{ |
| 143 |
strncpy(p_section->stitle, row[1], sizeof(p_section->stitle) - 1); |
log_error("section_list_update(sid=%d) error\n", p_section->sid); |
| 144 |
p_section->stitle[sizeof(p_section->stitle) - 1] = '\0'; |
ret = -4; |
| 145 |
strncpy(p_section->master_list, master_list, sizeof(p_section->master_list) - 1); |
break; |
| 146 |
p_section->master_list[sizeof(p_section->master_list) - 1] = '\0'; |
} |
| 147 |
} |
} |
| 148 |
|
|
| 149 |
p_section->class_id = atoi(row[3]); |
p_section->class_id = atoi(row[3]); |
| 151 |
p_section->write_user_level = atoi(row[5]); |
p_section->write_user_level = atoi(row[5]); |
| 152 |
p_section->enable = (int8_t)atoi(row[6]); |
p_section->enable = (int8_t)atoi(row[6]); |
| 153 |
|
|
| 154 |
|
// Update gen_ex menu set |
| 155 |
|
if (update_gen_ex && p_section->enable && atol(row[7] == NULL ? "0" : row[7]) > p_section->ex_menu_tm) |
| 156 |
|
{ |
| 157 |
|
snprintf(ex_menu_conf, sizeof(ex_menu_conf), "%s/%d", VAR_GEN_EX_MENU_DIR, p_section->sid); |
| 158 |
|
|
| 159 |
|
ret = load_menu(&ex_menu_set_new, ex_menu_conf); |
| 160 |
|
if (ret < 0) |
| 161 |
|
{ |
| 162 |
|
unload_menu(&ex_menu_set_new); |
| 163 |
|
log_error("load_menu(%s) error: %d\n", ex_menu_conf, ret); |
| 164 |
|
} |
| 165 |
|
else |
| 166 |
|
{ |
| 167 |
|
if (p_section->ex_menu_tm > 0) |
| 168 |
|
{ |
| 169 |
|
unload_menu(&(p_section->ex_menu_set)); |
| 170 |
|
} |
| 171 |
|
|
| 172 |
|
ex_menu_set_new.allow_exit = 1; // Allow exit menu |
| 173 |
|
memcpy(&(p_section->ex_menu_set), &ex_menu_set_new, sizeof(ex_menu_set_new)); |
| 174 |
|
|
| 175 |
|
p_section->ex_menu_tm = atol(row[7]); |
| 176 |
|
#ifdef _DEBUG |
| 177 |
|
log_common("Loaded gen_ex_menu of section %d [%s]\n", p_section->sid, p_section->sname); |
| 178 |
|
#endif |
| 179 |
|
} |
| 180 |
|
} |
| 181 |
|
|
| 182 |
// release rw lock |
// release rw lock |
| 183 |
ret = section_list_rw_unlock(p_section); |
ret = section_list_rw_unlock(p_section); |
| 184 |
if (ret < 0) |
if (ret < 0) |
| 188 |
} |
} |
| 189 |
|
|
| 190 |
cleanup: |
cleanup: |
| 191 |
|
mysql_free_result(rs2); |
| 192 |
mysql_free_result(rs); |
mysql_free_result(rs); |
| 193 |
mysql_close(db); |
mysql_close(db); |
| 194 |
|
|
| 356 |
mysql_free_result(rs); |
mysql_free_result(rs); |
| 357 |
mysql_close(db); |
mysql_close(db); |
| 358 |
|
|
| 359 |
|
article_cache_cleanup(); |
| 360 |
|
|
| 361 |
return (ret < 0 ? ret : article_count); |
return (ret < 0 ? ret : article_count); |
| 362 |
} |
} |
| 363 |
|
|
| 624 |
p_article->excerption = 0; |
p_article->excerption = 0; |
| 625 |
break; |
break; |
| 626 |
case 'F': // Set article on top |
case 'F': // Set article on top |
|
p_article->ontop = 1; |
|
|
break; |
|
| 627 |
case 'V': // Unset article on top |
case 'V': // Unset article on top |
| 628 |
p_article->ontop = 0; |
p_article->ontop = (row[2][0] == 'F' ? 1 : 0); |
| 629 |
|
if (section_list_update_article_ontop(p_section, p_article) < 0) |
| 630 |
|
{ |
| 631 |
|
log_error("section_list_update_article_ontop(sid=%d, aid=%d) error\n", |
| 632 |
|
p_section->sid, p_article->aid); |
| 633 |
|
} |
| 634 |
break; |
break; |
| 635 |
case 'Z': // Set article as trnasship |
case 'Z': // Set article as trnasship |
| 636 |
p_article->transship = 1; |
p_article->transship = 1; |
| 668 |
return (ret < 0 ? ret : op_count); |
return (ret < 0 ? ret : op_count); |
| 669 |
} |
} |
| 670 |
|
|
| 671 |
|
static void section_list_ex_menu_set_cleanup(void) |
| 672 |
|
{ |
| 673 |
|
int i; |
| 674 |
|
|
| 675 |
|
for (i = 0; i < p_section_list_pool->section_count; i++) |
| 676 |
|
{ |
| 677 |
|
if (p_section_list_pool->sections[i].ex_menu_tm > 0) |
| 678 |
|
{ |
| 679 |
|
unload_menu(&(p_section_list_pool->sections[i].ex_menu_set)); |
| 680 |
|
} |
| 681 |
|
} |
| 682 |
|
} |
| 683 |
|
|
| 684 |
int section_list_loader_launch(void) |
int section_list_loader_launch(void) |
| 685 |
{ |
{ |
| 686 |
|
struct sigaction act = {0}; |
| 687 |
int pid; |
int pid; |
| 688 |
int ret; |
int ret; |
| 689 |
int32_t last_aid; |
int32_t last_aid; |
| 690 |
int article_count; |
int article_count; |
| 691 |
int load_count; |
int load_count; |
| 692 |
int last_mid; |
int last_mid; |
| 693 |
int i; |
time_t tm_section_list_reload = 0; |
| 694 |
|
time_t tm_user_list_reload = time(NULL); |
| 695 |
|
time_t tm_user_online_list_reload = time(NULL); |
| 696 |
|
|
| 697 |
if (section_list_loader_pid != 0) |
if (section_list_loader_pid != 0) |
| 698 |
{ |
{ |
| 719 |
SYS_child_process_count = 0; |
SYS_child_process_count = 0; |
| 720 |
|
|
| 721 |
// Detach menu in shared memory |
// Detach menu in shared memory |
| 722 |
detach_menu_shm(p_bbs_menu); |
detach_menu_shm(&bbs_menu); |
| 723 |
free(p_bbs_menu); |
detach_menu_shm(&top10_menu); |
| 724 |
p_bbs_menu = NULL; |
|
| 725 |
|
// Set signal handler |
| 726 |
|
act.sa_handler = SIG_DFL; |
| 727 |
|
if (sigaction(SIGHUP, &act, NULL) == -1) |
| 728 |
|
{ |
| 729 |
|
log_error("set signal action of SIGHUP error: %d\n", errno); |
| 730 |
|
} |
| 731 |
|
act.sa_handler = SIG_DFL; |
| 732 |
|
if (sigaction(SIGCHLD, &act, NULL) == -1) |
| 733 |
|
{ |
| 734 |
|
log_error("set signal action of SIGCHLD error: %d\n", errno); |
| 735 |
|
} |
| 736 |
|
|
| 737 |
// Do section data loader periodically |
// Do section data loader periodically |
| 738 |
while (!SYS_server_exit) |
while (!SYS_server_exit) |
| 739 |
{ |
{ |
| 740 |
if (SYS_section_list_reload) |
tm_section_list_reload = time(NULL); |
| 741 |
|
|
| 742 |
|
if (SYS_conf_reload) |
| 743 |
{ |
{ |
| 744 |
SYS_section_list_reload = 0; |
SYS_conf_reload = 0; |
| 745 |
|
|
| 746 |
// Load section config |
// Load section config |
| 747 |
if (load_section_config_from_db() < 0) |
if (load_section_config_from_db(0) < 0) |
| 748 |
{ |
{ |
| 749 |
log_error("load_section_config_from_db() error\n"); |
log_error("load_section_config_from_db(0) error\n"); |
| 750 |
} |
} |
| 751 |
else |
else |
| 752 |
{ |
{ |
| 767 |
|
|
| 768 |
if (ret == ERR_UNKNOWN_SECTION) |
if (ret == ERR_UNKNOWN_SECTION) |
| 769 |
{ |
{ |
| 770 |
SYS_section_list_reload = 1; // Force reload section_list |
SYS_conf_reload = 1; // Force reload section_list |
| 771 |
} |
} |
| 772 |
} |
} |
| 773 |
} while (ret == LOAD_ARTICLE_COUNT_LIMIT); |
} while (ret == LOAD_ARTICLE_COUNT_LIMIT); |
| 778 |
log_common("Incrementally load %d articles, last_aid = %d\n", load_count, article_block_last_aid()); |
log_common("Incrementally load %d articles, last_aid = %d\n", load_count, article_block_last_aid()); |
| 779 |
} |
} |
| 780 |
|
|
| 781 |
if (SYS_section_list_reload) |
if (SYS_conf_reload) |
| 782 |
{ |
{ |
| 783 |
continue; |
continue; |
| 784 |
} |
} |
| 794 |
|
|
| 795 |
if (ret == ERR_UNKNOWN_SECTION) |
if (ret == ERR_UNKNOWN_SECTION) |
| 796 |
{ |
{ |
| 797 |
SYS_section_list_reload = 1; // Force reload section_list |
SYS_conf_reload = 1; // Force reload section_list |
| 798 |
} |
} |
| 799 |
} |
} |
| 800 |
} while (ret == LOAD_ARTICLE_COUNT_LIMIT); |
} while (ret == LOAD_ARTICLE_COUNT_LIMIT); |
| 804 |
log_common("Proceeded %d article logs, last_mid = %d\n", last_article_op_log_mid - last_mid, last_article_op_log_mid); |
log_common("Proceeded %d article logs, last_mid = %d\n", last_article_op_log_mid - last_mid, last_article_op_log_mid); |
| 805 |
} |
} |
| 806 |
|
|
| 807 |
if (SYS_section_list_reload) |
// Reload user list |
| 808 |
|
if (time(NULL) - tm_user_list_reload >= BBS_user_list_load_interval) |
| 809 |
{ |
{ |
| 810 |
continue; |
if (user_list_pool_reload(0) < 0) |
| 811 |
|
{ |
| 812 |
|
log_error("user_list_pool_reload(all_user) error\n"); |
| 813 |
|
} |
| 814 |
|
|
| 815 |
|
if (user_stat_update() < 0) |
| 816 |
|
{ |
| 817 |
|
log_error("user_stat_update() error\n"); |
| 818 |
|
} |
| 819 |
|
|
| 820 |
|
tm_user_list_reload = time(NULL); |
| 821 |
} |
} |
| 822 |
|
|
| 823 |
for (i = 0; i < BBS_section_list_load_interval && !SYS_server_exit && !SYS_section_list_reload; i++) |
// Reload user online list |
| 824 |
|
if (time(NULL) - tm_user_online_list_reload >= BBS_user_online_list_load_interval) |
| 825 |
|
{ |
| 826 |
|
if (user_list_pool_reload(1) < 0) |
| 827 |
|
{ |
| 828 |
|
log_error("user_list_pool_reload(online_user) error\n"); |
| 829 |
|
} |
| 830 |
|
|
| 831 |
|
tm_user_online_list_reload = time(NULL); |
| 832 |
|
} |
| 833 |
|
|
| 834 |
|
// Wait for BBS_section_list_load_interval seconds |
| 835 |
|
while (!SYS_server_exit && time(NULL) - tm_section_list_reload < BBS_section_list_load_interval) |
| 836 |
{ |
{ |
| 837 |
sleep(1); |
sleep(1); |
| 838 |
} |
} |
| 840 |
|
|
| 841 |
// Child process exit |
// Child process exit |
| 842 |
|
|
| 843 |
|
article_cache_cleanup(); |
| 844 |
|
|
| 845 |
|
// gen_ex_menu cleanup |
| 846 |
|
section_list_ex_menu_set_cleanup(); |
| 847 |
|
|
| 848 |
// Detach data pools shm |
// Detach data pools shm |
| 849 |
detach_section_list_shm(); |
detach_section_list_shm(); |
| 850 |
detach_article_block_shm(); |
detach_article_block_shm(); |
| 851 |
detach_trie_dict_shm(); |
detach_trie_dict_shm(); |
| 852 |
|
detach_user_list_pool_shm(); |
| 853 |
|
|
| 854 |
log_common("Section list loader process exit normally\n"); |
log_common("Section list loader process exit normally\n"); |
| 855 |
log_end(); |
log_end(); |
| 861 |
return 0; |
return 0; |
| 862 |
} |
} |
| 863 |
|
|
| 864 |
int section_list_loader_reload(void) |
int query_section_articles(SECTION_LIST *p_section, int page_id, ARTICLE *p_articles[], |
| 865 |
{ |
int *p_article_count, int *p_page_count, int *p_ontop_start_offset) |
|
if (section_list_loader_pid == 0) |
|
|
{ |
|
|
log_error("section_list_loader not running\n"); |
|
|
return -2; |
|
|
} |
|
|
|
|
|
if (kill(section_list_loader_pid, SIGHUP) < 0) |
|
|
{ |
|
|
log_error("Send SIGTERM signal failed (%d)\n", errno); |
|
|
return -1; |
|
|
} |
|
|
|
|
|
return 0; |
|
|
} |
|
|
|
|
|
int query_section_articles(SECTION_LIST *p_section, int page_id, ARTICLE *p_articles[], int *p_article_count, int *p_page_count) |
|
| 866 |
{ |
{ |
| 867 |
ARTICLE *p_article; |
ARTICLE *p_article; |
| 868 |
ARTICLE *p_next_page_first_article; |
ARTICLE *p_next_page_first_article; |
| 869 |
int ret = 0; |
int ret = 0; |
| 870 |
|
int i; |
| 871 |
|
|
| 872 |
if (p_section == NULL || p_articles == NULL || p_article_count == NULL || p_page_count == NULL) |
if (p_section == NULL || p_articles == NULL || p_article_count == NULL || p_page_count == NULL || p_ontop_start_offset == NULL) |
| 873 |
{ |
{ |
| 874 |
log_error("query_section_articles() NULL pointer error\n"); |
log_error("NULL pointer error\n"); |
| 875 |
return -1; |
return -1; |
| 876 |
} |
} |
| 877 |
|
|
| 882 |
return -2; |
return -2; |
| 883 |
} |
} |
| 884 |
|
|
| 885 |
*p_page_count = p_section->page_count; |
*p_page_count = section_list_page_count_with_ontop(p_section); |
| 886 |
|
*p_article_count = 0; |
| 887 |
|
*p_ontop_start_offset = BBS_article_limit_per_page; |
| 888 |
|
|
| 889 |
if (p_section->visible_article_count == 0) |
if (p_section->visible_article_count == 0) |
| 890 |
{ |
{ |
| 891 |
*p_article_count = 0; |
// empty section |
| 892 |
} |
} |
| 893 |
else if (page_id < 0 || page_id >= p_section->page_count) |
else if (page_id < 0 || page_id >= *p_page_count) |
| 894 |
{ |
{ |
| 895 |
log_error("Invalid page_id=%d, not in range [0, %d)\n", page_id, p_section->page_count); |
log_error("Invalid page_id=%d, not in range [0, %d)\n", page_id, *p_page_count); |
| 896 |
ret = -3; |
ret = -3; |
| 897 |
} |
} |
| 898 |
else |
else |
| 899 |
{ |
{ |
| 900 |
ret = page_id; |
ret = page_id; |
|
p_article = p_section->p_page_first_article[page_id]; |
|
|
p_next_page_first_article = |
|
|
(page_id == p_section->page_count - 1 ? p_section->p_article_head : p_section->p_page_first_article[page_id + 1]); |
|
|
*p_article_count = 0; |
|
| 901 |
|
|
| 902 |
do |
if (page_id <= p_section->page_count - 1) |
| 903 |
{ |
{ |
| 904 |
if (p_article->visible) |
p_article = p_section->p_page_first_article[page_id]; |
| 905 |
|
p_next_page_first_article = |
| 906 |
|
(page_id == p_section->page_count - 1 ? p_section->p_article_head : p_section->p_page_first_article[page_id + 1]); |
| 907 |
|
|
| 908 |
|
do |
| 909 |
{ |
{ |
| 910 |
p_articles[*p_article_count] = p_article; |
if (p_article->visible) |
| 911 |
(*p_article_count)++; |
{ |
| 912 |
|
p_articles[*p_article_count] = p_article; |
| 913 |
|
(*p_article_count)++; |
| 914 |
|
} |
| 915 |
|
p_article = p_article->p_next; |
| 916 |
|
} while (p_article != p_next_page_first_article && (*p_article_count) <= BBS_article_limit_per_page); |
| 917 |
|
|
| 918 |
|
if (*p_article_count != (page_id < p_section->page_count - 1 ? BBS_article_limit_per_page : p_section->last_page_visible_article_count)) |
| 919 |
|
{ |
| 920 |
|
log_error("Inconsistent visible article count %d detected in section %d page %d\n", *p_article_count, p_section->sid, page_id); |
| 921 |
} |
} |
| 922 |
p_article = p_article->p_next; |
} |
|
} while (p_article != p_next_page_first_article && (*p_article_count) <= BBS_article_limit_per_page); |
|
| 923 |
|
|
| 924 |
if (*p_article_count != (page_id < p_section->page_count - 1 ? BBS_article_limit_per_page : p_section->last_page_visible_article_count)) |
*p_ontop_start_offset = *p_article_count; |
| 925 |
|
|
| 926 |
|
// Append ontop articles |
| 927 |
|
if (page_id >= p_section->page_count - 1) |
| 928 |
{ |
{ |
| 929 |
log_error("Inconsistent visible article count %d detected in section %d page %d\n", *p_article_count, p_section->sid, page_id); |
i = (page_id == p_section->page_count - 1 |
| 930 |
|
? 0 |
| 931 |
|
: (page_id - p_section->page_count + 1) * BBS_article_limit_per_page - p_section->last_page_visible_article_count); |
| 932 |
|
while (*p_article_count < BBS_article_limit_per_page && i < p_section->ontop_article_count) |
| 933 |
|
{ |
| 934 |
|
p_articles[(*p_article_count)++] = p_section->p_ontop_articles[i++]; |
| 935 |
|
} |
| 936 |
} |
} |
| 937 |
} |
} |
| 938 |
|
|
| 950 |
int *p_page_id, int *p_visible_offset, int *p_article_count) |
int *p_page_id, int *p_visible_offset, int *p_article_count) |
| 951 |
{ |
{ |
| 952 |
const ARTICLE *p_article = NULL; |
const ARTICLE *p_article = NULL; |
| 953 |
|
const ARTICLE *p_article_last = NULL; |
| 954 |
ARTICLE *p_tmp; |
ARTICLE *p_tmp; |
| 955 |
int32_t aid = 0; |
int32_t aid = 0; |
| 956 |
int page_id = 0; |
int page_id = 0; |
| 960 |
|
|
| 961 |
if (p_section == NULL || p_article_cur == NULL || p_page_id == NULL || p_visible_offset == NULL || p_article_count == NULL) |
if (p_section == NULL || p_article_cur == NULL || p_page_id == NULL || p_visible_offset == NULL || p_article_count == NULL) |
| 962 |
{ |
{ |
| 963 |
log_error("locate_article_in_section() NULL pointer error\n"); |
log_error("NULL pointer error\n"); |
| 964 |
return -1; |
return -1; |
| 965 |
} |
} |
| 966 |
|
|
| 977 |
} |
} |
| 978 |
else if (direction == 1) |
else if (direction == 1) |
| 979 |
{ |
{ |
| 980 |
for (p_article = p_article_cur; step > 0 && p_article->p_topic_next->aid > p_article_cur->aid; p_article = p_article->p_topic_next) |
for (p_article_last = p_article_cur, p_article = p_article_cur->p_topic_next; |
| 981 |
|
step > 0 && p_article->aid > p_article_cur->aid; |
| 982 |
|
p_article = p_article->p_topic_next) |
| 983 |
{ |
{ |
| 984 |
if (p_article->visible) |
if (p_article->visible) |
| 985 |
{ |
{ |
| 986 |
step--; |
step--; |
| 987 |
|
p_article_last = p_article; |
| 988 |
} |
} |
| 989 |
} |
} |
| 990 |
|
p_article = p_article_last; |
| 991 |
|
|
| 992 |
aid = (p_article->aid > p_article_cur->aid && p_article->visible ? p_article->aid : 0); |
aid = (p_article->aid > p_article_cur->aid && p_article->visible ? p_article->aid : 0); |
| 993 |
} |
} |
| 994 |
else if (direction == -1) |
else if (direction == -1) |
| 995 |
{ |
{ |
| 996 |
for (p_article = p_article_cur; step > 0 && p_article->p_topic_prior->aid < p_article_cur->aid; p_article = p_article->p_topic_prior) |
for (p_article_last = p_article_cur, p_article = p_article_cur->p_topic_prior; |
| 997 |
|
step > 0 && p_article->aid < p_article_cur->aid; |
| 998 |
|
p_article = p_article->p_topic_prior) |
| 999 |
{ |
{ |
| 1000 |
if (p_article->visible) |
if (p_article->visible) |
| 1001 |
{ |
{ |
| 1002 |
step--; |
step--; |
| 1003 |
|
p_article_last = p_article; |
| 1004 |
} |
} |
| 1005 |
} |
} |
| 1006 |
|
p_article = p_article_last; |
| 1007 |
|
|
| 1008 |
aid = (p_article->aid < p_article_cur->aid && p_article->visible ? p_article->aid : 0); |
aid = (p_article->aid < p_article_cur->aid && p_article->visible ? p_article->aid : 0); |
| 1009 |
} |
} |
| 1038 |
} |
} |
| 1039 |
p_article = p_article->p_next; |
p_article = p_article->p_next; |
| 1040 |
} |
} |
| 1041 |
|
|
| 1042 |
|
// Include ontop articles |
| 1043 |
|
*p_article_count = section_list_page_article_count_with_ontop(p_section, page_id); |
| 1044 |
} |
} |
| 1045 |
} |
} |
| 1046 |
|
|
| 1053 |
|
|
| 1054 |
return (ret < 0 ? ret : (p_article == NULL ? 0 : 1)); |
return (ret < 0 ? ret : (p_article == NULL ? 0 : 1)); |
| 1055 |
} |
} |
| 1056 |
|
|
| 1057 |
|
int scan_unread_article_in_section(SECTION_LIST *p_section, const ARTICLE *p_article_cur, const ARTICLE **pp_article_unread) |
| 1058 |
|
{ |
| 1059 |
|
ARTICLE *p_article; |
| 1060 |
|
int ret = 0; |
| 1061 |
|
|
| 1062 |
|
if (p_section == NULL || p_article_cur == NULL || pp_article_unread == NULL) |
| 1063 |
|
{ |
| 1064 |
|
log_error("NULL pointer error\n"); |
| 1065 |
|
return -1; |
| 1066 |
|
} |
| 1067 |
|
|
| 1068 |
|
if (p_article_cur->sid != p_section->sid) |
| 1069 |
|
{ |
| 1070 |
|
log_error("Inconsistent SID\n"); |
| 1071 |
|
return -1; |
| 1072 |
|
} |
| 1073 |
|
|
| 1074 |
|
// acquire lock of section |
| 1075 |
|
if ((ret = section_list_rd_lock(p_section)) < 0) |
| 1076 |
|
{ |
| 1077 |
|
log_error("section_list_rd_lock(sid = %d) error\n", p_section->sid); |
| 1078 |
|
return -2; |
| 1079 |
|
} |
| 1080 |
|
|
| 1081 |
|
*pp_article_unread = NULL; |
| 1082 |
|
|
| 1083 |
|
for (p_article = p_article_cur->p_next; p_article != NULL && p_article != p_article_cur; p_article = p_article->p_next) |
| 1084 |
|
{ |
| 1085 |
|
if (p_article->visible && p_article->uid != BBS_priv.uid && !article_view_log_is_viewed(p_article->aid, &BBS_article_view_log)) |
| 1086 |
|
{ |
| 1087 |
|
*pp_article_unread = p_article; |
| 1088 |
|
break; |
| 1089 |
|
} |
| 1090 |
|
} |
| 1091 |
|
|
| 1092 |
|
// release lock of section |
| 1093 |
|
if (section_list_rd_unlock(p_section) < 0) |
| 1094 |
|
{ |
| 1095 |
|
log_error("section_list_rd_unlock(sid = %d) error\n", p_section->sid); |
| 1096 |
|
return -2; |
| 1097 |
|
} |
| 1098 |
|
|
| 1099 |
|
return (p_article != NULL && p_article != p_article_cur ? 1 : 0); |
| 1100 |
|
} |
| 1101 |
|
|
| 1102 |
|
int get_section_ex_menu_set(SECTION_LIST *p_section, MENU_SET *p_ex_menu_set) |
| 1103 |
|
{ |
| 1104 |
|
int ret = 0; |
| 1105 |
|
|
| 1106 |
|
if (p_section == NULL || p_ex_menu_set == NULL) |
| 1107 |
|
{ |
| 1108 |
|
log_error("NULL pointer error\n"); |
| 1109 |
|
return -1; |
| 1110 |
|
} |
| 1111 |
|
|
| 1112 |
|
// acquire lock of section |
| 1113 |
|
if ((ret = section_list_rd_lock(p_section)) < 0) |
| 1114 |
|
{ |
| 1115 |
|
log_error("section_list_rd_lock(sid = %d) error\n", p_section->sid); |
| 1116 |
|
return -2; |
| 1117 |
|
} |
| 1118 |
|
|
| 1119 |
|
memcpy(p_ex_menu_set, &(p_section->ex_menu_set), sizeof(p_section->ex_menu_set)); |
| 1120 |
|
|
| 1121 |
|
// release lock of section |
| 1122 |
|
if (section_list_rd_unlock(p_section) < 0) |
| 1123 |
|
{ |
| 1124 |
|
log_error("section_list_rd_unlock(sid = %d) error\n", p_section->sid); |
| 1125 |
|
ret = -2; |
| 1126 |
|
} |
| 1127 |
|
|
| 1128 |
|
return ret; |
| 1129 |
|
} |