| 1 |
/*************************************************************************** |
/* SPDX-License-Identifier: GPL-3.0-or-later */ |
| 2 |
section_list_loader.c - description |
/* |
| 3 |
------------------- |
* section_list_loader |
| 4 |
Copyright : (C) 2004-2025 by Leaflet |
* - load and query operations of section articles |
| 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 |
|
|
| 13 |
#include "article_cache.h" |
#include "article_cache.h" |
| 14 |
#include "article_view_log.h" |
#include "article_view_log.h" |
| 30 |
int section_list_loader_pid; |
int section_list_loader_pid; |
| 31 |
int last_article_op_log_mid; |
int last_article_op_log_mid; |
| 32 |
|
|
| 33 |
|
static void loader_proc_sig_usr1_handler(int i) |
| 34 |
|
{ |
| 35 |
|
// Restart log |
| 36 |
|
if (log_restart() < 0) |
| 37 |
|
{ |
| 38 |
|
log_error("Restart logging failed\n"); |
| 39 |
|
} |
| 40 |
|
} |
| 41 |
|
|
| 42 |
int load_section_config_from_db(int update_gen_ex) |
int load_section_config_from_db(int update_gen_ex) |
| 43 |
{ |
{ |
| 44 |
MYSQL *db = NULL; |
MYSQL *db = NULL; |
| 49 |
char master_list[(BBS_username_max_len + 1) * 3 + 1]; |
char master_list[(BBS_username_max_len + 1) * 3 + 1]; |
| 50 |
SECTION_LIST *p_section; |
SECTION_LIST *p_section; |
| 51 |
char ex_menu_conf[FILE_PATH_LEN]; |
char ex_menu_conf[FILE_PATH_LEN]; |
|
MENU_SET ex_menu_set_new; |
|
| 52 |
int ret = 0; |
int ret = 0; |
| 53 |
|
|
| 54 |
db = db_open(); |
db = db_open(); |
| 160 |
{ |
{ |
| 161 |
snprintf(ex_menu_conf, sizeof(ex_menu_conf), "%s/%d", VAR_GEN_EX_MENU_DIR, p_section->sid); |
snprintf(ex_menu_conf, sizeof(ex_menu_conf), "%s/%d", VAR_GEN_EX_MENU_DIR, p_section->sid); |
| 162 |
|
|
| 163 |
ret = load_menu(&ex_menu_set_new, ex_menu_conf); |
if (detach_menu_shm(&(p_section->ex_menu_set)) < 0) |
| 164 |
if (ret < 0) |
{ |
| 165 |
|
log_error("detach_menu_shm(%s) error\n", ex_menu_conf); |
| 166 |
|
} |
| 167 |
|
if (load_menu(&(p_section->ex_menu_set), ex_menu_conf) < 0) |
| 168 |
{ |
{ |
| 169 |
unload_menu(&ex_menu_set_new); |
log_error("load_menu(%s) error\n", ex_menu_conf); |
| 170 |
log_error("load_menu(%s) error: %d\n", ex_menu_conf, ret); |
unload_menu(&(p_section->ex_menu_set)); |
| 171 |
} |
} |
| 172 |
else |
else |
| 173 |
{ |
{ |
| 174 |
if (p_section->ex_menu_tm > 0) |
p_section->ex_menu_set.allow_exit = 1; // Allow exit menu |
|
{ |
|
|
unload_menu(&(p_section->ex_menu_set)); |
|
|
} |
|
|
|
|
|
ex_menu_set_new.allow_exit = 1; // Allow exit menu |
|
|
memcpy(&(p_section->ex_menu_set), &ex_menu_set_new, sizeof(ex_menu_set_new)); |
|
|
|
|
| 175 |
p_section->ex_menu_tm = atol(row[7]); |
p_section->ex_menu_tm = atol(row[7]); |
| 176 |
#ifdef _DEBUG |
log_debug("Loaded gen_ex_menu of section %d [%s]\n", p_section->sid, p_section->sname); |
|
log_common("Loaded gen_ex_menu of section %d [%s]\n", p_section->sid, p_section->sname); |
|
|
#endif |
|
| 177 |
} |
} |
| 178 |
} |
} |
| 179 |
|
|
| 731 |
{ |
{ |
| 732 |
log_error("set signal action of SIGCHLD error: %d\n", errno); |
log_error("set signal action of SIGCHLD error: %d\n", errno); |
| 733 |
} |
} |
| 734 |
|
act.sa_handler = loader_proc_sig_usr1_handler; |
| 735 |
|
if (sigaction(SIGUSR1, &act, NULL) == -1) |
| 736 |
|
{ |
| 737 |
|
log_error("set signal action of SIGUSR1 error: %d\n", errno); |
| 738 |
|
} |
| 739 |
|
|
| 740 |
// Do section data loader periodically |
// Do section data loader periodically |
| 741 |
while (!SYS_server_exit) |
while (!SYS_server_exit) |
| 864 |
return 0; |
return 0; |
| 865 |
} |
} |
| 866 |
|
|
| 867 |
int query_section_articles(SECTION_LIST *p_section, int page_id, ARTICLE *p_articles[], |
int query_section_articles(SECTION_LIST *p_section, int page_id, const ARTICLE *p_articles[], |
| 868 |
int *p_article_count, int *p_page_count, int *p_ontop_start_offset) |
int *p_article_count, int *p_page_count, int *p_ontop_start_offset) |
| 869 |
{ |
{ |
| 870 |
ARTICLE *p_article; |
ARTICLE *p_article; |
| 895 |
} |
} |
| 896 |
else if (page_id < 0 || page_id >= *p_page_count) |
else if (page_id < 0 || page_id >= *p_page_count) |
| 897 |
{ |
{ |
| 898 |
#ifdef _DEBUG |
log_debug("Invalid page_id=%d, not in range [0, %d)\n", page_id, *p_page_count); |
|
log_error("Invalid page_id=%d, not in range [0, %d)\n", page_id, *p_page_count); |
|
|
#endif |
|
| 899 |
ret = -3; |
ret = -3; |
| 900 |
} |
} |
| 901 |
else |
else |
| 1040 |
break; |
break; |
| 1041 |
} |
} |
| 1042 |
} |
} |
| 1043 |
|
|
| 1044 |
p_article = p_article->p_next; |
p_article = p_article->p_next; |
| 1045 |
|
if (p_article == p_section->p_page_first_article[page_id]) |
| 1046 |
|
{ |
| 1047 |
|
log_error("Dead loop detected at page=%d, article_count=%d\n", page_id, *p_article_count); |
| 1048 |
|
break; |
| 1049 |
|
} |
| 1050 |
} |
} |
| 1051 |
|
|
| 1052 |
// Include ontop articles |
// Include ontop articles |
| 1064 |
return (ret < 0 ? ret : (p_article == NULL ? 0 : 1)); |
return (ret < 0 ? ret : (p_article == NULL ? 0 : 1)); |
| 1065 |
} |
} |
| 1066 |
|
|
| 1067 |
|
int last_article_in_section(SECTION_LIST *p_section, const ARTICLE **pp_article) |
| 1068 |
|
{ |
| 1069 |
|
int ret = 0; |
| 1070 |
|
|
| 1071 |
|
const ARTICLE *p_article; |
| 1072 |
|
|
| 1073 |
|
if (p_section == NULL || pp_article == NULL) |
| 1074 |
|
{ |
| 1075 |
|
log_error("NULL pointer error\n"); |
| 1076 |
|
return -1; |
| 1077 |
|
} |
| 1078 |
|
|
| 1079 |
|
*pp_article = NULL; |
| 1080 |
|
|
| 1081 |
|
// acquire lock of section |
| 1082 |
|
if ((ret = section_list_rd_lock(p_section)) < 0) |
| 1083 |
|
{ |
| 1084 |
|
log_error("section_list_rd_lock(sid = %d) error\n", p_section->sid); |
| 1085 |
|
return -2; |
| 1086 |
|
} |
| 1087 |
|
|
| 1088 |
|
for (p_article = p_section->p_article_tail; |
| 1089 |
|
p_article && p_article != p_section->p_article_head && !p_article->visible; |
| 1090 |
|
p_article = p_article->p_prior) |
| 1091 |
|
; |
| 1092 |
|
|
| 1093 |
|
if (p_article && p_article->visible) |
| 1094 |
|
{ |
| 1095 |
|
*pp_article = p_article; |
| 1096 |
|
ret = 1; |
| 1097 |
|
} |
| 1098 |
|
|
| 1099 |
|
// release lock of section |
| 1100 |
|
if (section_list_rd_unlock(p_section) < 0) |
| 1101 |
|
{ |
| 1102 |
|
log_error("section_list_rd_unlock(sid = %d) error\n", p_section->sid); |
| 1103 |
|
ret = -2; |
| 1104 |
|
} |
| 1105 |
|
|
| 1106 |
|
return ret; |
| 1107 |
|
} |
| 1108 |
|
|
| 1109 |
int scan_unread_article_in_section(SECTION_LIST *p_section, const ARTICLE *p_article_cur, const ARTICLE **pp_article_unread) |
int scan_unread_article_in_section(SECTION_LIST *p_section, const ARTICLE *p_article_cur, const ARTICLE **pp_article_unread) |
| 1110 |
{ |
{ |
| 1111 |
ARTICLE *p_article; |
ARTICLE *p_article; |
| 1272 |
} |
} |
| 1273 |
|
|
| 1274 |
int scan_article_in_section_by_title(SECTION_LIST *p_section, const ARTICLE *p_article_cur, |
int scan_article_in_section_by_title(SECTION_LIST *p_section, const ARTICLE *p_article_cur, |
| 1275 |
int direction, const char *title, const ARTICLE **pp_article) |
int direction, const char *title, const ARTICLE **pp_article) |
| 1276 |
{ |
{ |
| 1277 |
ARTICLE *p_article; |
ARTICLE *p_article; |
| 1278 |
int ret = 0; |
int ret = 0; |