| 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" |
#include "user_priv.h" |
| 27 |
#include <errno.h> |
#include <errno.h> |
| 28 |
#include <signal.h> |
#include <signal.h> |
| 110 |
mysql_free_result(rs2); |
mysql_free_result(rs2); |
| 111 |
rs2 = NULL; |
rs2 = NULL; |
| 112 |
|
|
| 113 |
p_section = section_list_find_by_sid(sid, NULL); |
p_section = section_list_find_by_sid(sid); |
| 114 |
|
|
| 115 |
if (p_section == NULL) |
if (p_section == NULL) |
| 116 |
{ |
{ |
| 138 |
break; |
break; |
| 139 |
} |
} |
| 140 |
|
|
| 141 |
strncpy(p_section->sname, row[1], 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[2], 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]); |
| 287 |
} |
} |
| 288 |
} |
} |
| 289 |
|
|
| 290 |
if ((p_section = section_list_find_by_sid(article.sid, NULL)) == NULL) |
if ((p_section = section_list_find_by_sid(article.sid)) == NULL) |
| 291 |
{ |
{ |
| 292 |
log_error("section_list_find_by_sid(%d) error: unknown section, try reloading section config\n", article.sid); |
log_error("section_list_find_by_sid(%d) error: unknown section, try reloading section config\n", article.sid); |
| 293 |
ret = ERR_UNKNOWN_SECTION; // Unknown section found |
ret = ERR_UNKNOWN_SECTION; // Unknown section found |
| 466 |
} |
} |
| 467 |
} |
} |
| 468 |
|
|
| 469 |
if ((p_section = section_list_find_by_sid(p_article->sid, NULL)) == NULL) |
if ((p_section = section_list_find_by_sid(p_article->sid)) == NULL) |
| 470 |
{ |
{ |
| 471 |
log_error("section_list_find_by_sid(%d) error: unknown section, try reloading section config\n", p_article->sid); |
log_error("section_list_find_by_sid(%d) error: unknown section, try reloading section config\n", p_article->sid); |
| 472 |
ret = ERR_UNKNOWN_SECTION; // Unknown section found |
ret = ERR_UNKNOWN_SECTION; // Unknown section found |
| 591 |
|
|
| 592 |
if (sid_dest > 0 && sid_dest != p_article->sid) |
if (sid_dest > 0 && sid_dest != p_article->sid) |
| 593 |
{ |
{ |
| 594 |
p_section_dest = section_list_find_by_sid(sid_dest, NULL); |
p_section_dest = section_list_find_by_sid(sid_dest); |
| 595 |
if (p_section_dest == NULL) |
if (p_section_dest == NULL) |
| 596 |
{ |
{ |
| 597 |
ret = ERR_UNKNOWN_SECTION; |
ret = ERR_UNKNOWN_SECTION; |
| 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 = 0; |
| 695 |
|
time_t tm_user_online_list_reload = 0; |
| 696 |
|
|
| 697 |
if (section_list_loader_pid != 0) |
if (section_list_loader_pid != 0) |
| 698 |
{ |
{ |
| 737 |
// Do section data loader periodically |
// Do section data loader periodically |
| 738 |
while (!SYS_server_exit) |
while (!SYS_server_exit) |
| 739 |
{ |
{ |
| 740 |
|
tm_section_list_reload = time(NULL); |
| 741 |
|
|
| 742 |
if (SYS_conf_reload) |
if (SYS_conf_reload) |
| 743 |
{ |
{ |
| 744 |
SYS_conf_reload = 0; |
SYS_conf_reload = 0; |
| 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_conf_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 |
|
tm_user_list_reload = time(NULL); |
| 815 |
|
} |
| 816 |
|
|
| 817 |
|
// Reload user online list |
| 818 |
|
if (time(NULL) - tm_user_online_list_reload >= BBS_user_online_list_load_interval) |
| 819 |
|
{ |
| 820 |
|
if (user_list_pool_reload(1) < 0) |
| 821 |
|
{ |
| 822 |
|
log_error("user_list_pool_reload(online_user) error\n"); |
| 823 |
|
} |
| 824 |
|
tm_user_online_list_reload = time(NULL); |
| 825 |
} |
} |
| 826 |
|
|
| 827 |
for (i = 0; i < BBS_section_list_load_interval && !SYS_server_exit && !SYS_conf_reload; i++) |
// Wait for BBS_section_list_load_interval seconds |
| 828 |
|
while (!SYS_server_exit && time(NULL) - tm_section_list_reload < BBS_section_list_load_interval) |
| 829 |
{ |
{ |
| 830 |
sleep(1); |
sleep(1); |
| 831 |
} |
} |
| 842 |
detach_section_list_shm(); |
detach_section_list_shm(); |
| 843 |
detach_article_block_shm(); |
detach_article_block_shm(); |
| 844 |
detach_trie_dict_shm(); |
detach_trie_dict_shm(); |
| 845 |
|
detach_user_list_pool_shm(); |
| 846 |
|
|
| 847 |
log_common("Section list loader process exit normally\n"); |
log_common("Section list loader process exit normally\n"); |
| 848 |
log_end(); |
log_end(); |