| 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> |
| 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]); |
| 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 |
{ |
{ |
| 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 |
|
|
| 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 |
|
// 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 |
for (i = 0; i < BBS_section_list_load_interval && !SYS_server_exit && !SYS_conf_reload; i++) |
// 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 |
} |
} |
| 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(); |