/[LeafOK_CVS]/lbbs/src/section_list_loader.c
ViewVC logotype

Annotation of /lbbs/src/section_list_loader.c

Parent Directory Parent Directory | Revision Log Revision Log

Revision 1.47 - (hide annotations)
Wed Oct 8 03:34:40 2025 UTC (5 months, 1 week ago) by sysadm
Branch: MAIN
Changes since 1.46: +0 -4 lines
Content type: text/x-csrc 
Fix bug
1 sysadm 1.1 /***************************************************************************
2     section_list_loader.c - description
3     -------------------
4     Copyright : (C) 2004-2025 by Leaflet
5     Email : leaflet@leafok.com
6     ***************************************************************************/
7    
8     /***************************************************************************
9     * *
10     * This program is free software; you can redistribute it and/or modify *
11     * it under the terms of the GNU General Public License as published by *
12     * the Free Software Foundation; either version 3 of the License, or *
13     * (at your option) any later version. *
14     * *
15     ***************************************************************************/
16    
17 sysadm 1.11 #include "article_cache.h"
18 sysadm 1.44 #include "article_view_log.h"
19 sysadm 1.19 #include "bbs.h"
20 sysadm 1.30 #include "database.h"
21 sysadm 1.39 #include "ip_mask.h"
22 sysadm 1.1 #include "log.h"
23 sysadm 1.4 #include "menu.h"
24 sysadm 1.30 #include "section_list_loader.h"
25 sysadm 1.45 #include "user_priv.h"
26 sysadm 1.1 #include <errno.h>
27 sysadm 1.4 #include <signal.h>
28 sysadm 1.29 #include <stdio.h>
29 sysadm 1.1 #include <stdlib.h>
30 sysadm 1.22 #include <string.h>
31 sysadm 1.4 #include <unistd.h>
32    
33 sysadm 1.5 int section_list_loader_pid;
34     int last_article_op_log_mid;
35 sysadm 1.1
36 sysadm 1.38 int load_section_config_from_db(int update_gen_ex)
37 sysadm 1.1 {
38 sysadm 1.23 MYSQL *db = NULL;
39     MYSQL_RES *rs = NULL, *rs2 = NULL;
40 sysadm 1.1 MYSQL_ROW row, row2;
41     char sql[SQL_BUFFER_LEN];
42     int32_t sid;
43 sysadm 1.8 char master_list[(BBS_username_max_len + 1) * 3 + 1];
44 sysadm 1.1 SECTION_LIST *p_section;
45 sysadm 1.34 char ex_menu_conf[FILE_PATH_LEN];
46     MENU_SET ex_menu_set_new;
47 sysadm 1.23 int ret = 0;
48 sysadm 1.1
49 sysadm 1.2 db = db_open();
50     if (db == NULL)
51     {
52     log_error("db_open() error: %s\n", mysql_error(db));
53 sysadm 1.23 ret = -1;
54     goto cleanup;
55 sysadm 1.2 }
56    
57 sysadm 1.1 snprintf(sql, sizeof(sql),
58 sysadm 1.2 "SELECT section_config.SID, sname, section_config.title, section_config.CID, "
59 sysadm 1.34 "read_user_level, write_user_level, section_config.enable * section_class.enable AS enable, "
60     "UNIX_TIMESTAMP(ex_menu_tm) AS ex_menu_tm "
61 sysadm 1.2 "FROM section_config INNER JOIN section_class ON section_config.CID = section_class.CID "
62 sysadm 1.1 "ORDER BY section_config.SID");
63    
64     if (mysql_query(db, sql) != 0)
65     {
66     log_error("Query section_list error: %s\n", mysql_error(db));
67 sysadm 1.23 ret = -2;
68     goto cleanup;
69 sysadm 1.1 }
70     if ((rs = mysql_store_result(db)) == NULL)
71     {
72     log_error("Get section_list data failed\n");
73 sysadm 1.23 ret = -2;
74     goto cleanup;
75 sysadm 1.1 }
76 sysadm 1.2
77     ret = 0;
78 sysadm 1.1 while ((row = mysql_fetch_row(rs)))
79     {
80     sid = atoi(row[0]);
81    
82     // Query section master
83     snprintf(sql, sizeof(sql),
84     "SELECT username FROM section_master "
85     "INNER JOIN user_list ON section_master.UID = user_list.UID "
86     "WHERE SID = %d AND section_master.enable AND (NOW() BETWEEN begin_dt AND end_dt) "
87 sysadm 1.8 "ORDER BY major DESC, begin_dt ASC LIMIT 3",
88 sysadm 1.1 sid);
89    
90     if (mysql_query(db, sql) != 0)
91     {
92     log_error("Query section_master error: %s\n", mysql_error(db));
93 sysadm 1.2 ret = -3;
94     break;
95 sysadm 1.1 }
96     if ((rs2 = mysql_store_result(db)) == NULL)
97     {
98     log_error("Get section_master data failed\n");
99 sysadm 1.2 ret = -3;
100     break;
101 sysadm 1.1 }
102 sysadm 1.8
103     master_list[0] = '\0';
104     while ((row2 = mysql_fetch_row(rs2)))
105 sysadm 1.1 {
106 sysadm 1.8 strncat(master_list, row2[0], sizeof(master_list) - 1 - strnlen(master_list, sizeof(master_list)));
107     strncat(master_list, " ", sizeof(master_list) - 1 - strnlen(master_list, sizeof(master_list)));
108 sysadm 1.1 }
109     mysql_free_result(rs2);
110 sysadm 1.23 rs2 = NULL;
111 sysadm 1.1
112     p_section = section_list_find_by_sid(sid);
113    
114     if (p_section == NULL)
115     {
116 sysadm 1.8 p_section = section_list_create(sid, row[1], row[2], master_list);
117 sysadm 1.1 if (p_section == NULL)
118     {
119 sysadm 1.2 log_error("section_list_create() error: load new section sid = %d sname = %s\n", sid, row[1]);
120     ret = -4;
121 sysadm 1.1 break;
122     }
123    
124     // acquire rw lock
125     ret = section_list_rw_lock(p_section);
126     if (ret < 0)
127     {
128     break;
129     }
130     }
131     else
132     {
133     // acquire rw lock
134     ret = section_list_rw_lock(p_section);
135     if (ret < 0)
136     {
137     break;
138     }
139    
140 sysadm 1.35 strncpy(p_section->sname, row[1], sizeof(p_section->sname) - 1);
141 sysadm 1.1 p_section->sname[sizeof(p_section->sname) - 1] = '\0';
142 sysadm 1.35 strncpy(p_section->stitle, row[2], sizeof(p_section->stitle) - 1);
143 sysadm 1.1 p_section->stitle[sizeof(p_section->stitle) - 1] = '\0';
144 sysadm 1.8 strncpy(p_section->master_list, master_list, sizeof(p_section->master_list) - 1);
145     p_section->master_list[sizeof(p_section->master_list) - 1] = '\0';
146 sysadm 1.1 }
147    
148     p_section->class_id = atoi(row[3]);
149     p_section->read_user_level = atoi(row[4]);
150     p_section->write_user_level = atoi(row[5]);
151     p_section->enable = (int8_t)atoi(row[6]);
152    
153 sysadm 1.34 // Update gen_ex menu set
154 sysadm 1.46 if (update_gen_ex && p_section->enable && atol(row[7] == NULL ? "0" : row[7]) > p_section->ex_menu_tm)
155 sysadm 1.34 {
156     snprintf(ex_menu_conf, sizeof(ex_menu_conf), "%s/%d", VAR_GEN_EX_MENU_DIR, p_section->sid);
157    
158 sysadm 1.38 ret = load_menu(&ex_menu_set_new, ex_menu_conf);
159 sysadm 1.34 if (ret < 0)
160     {
161 sysadm 1.38 unload_menu(&ex_menu_set_new);
162     log_error("load_menu(%s) error: %d\n", ex_menu_conf, ret);
163 sysadm 1.34 }
164     else
165     {
166 sysadm 1.38 if (p_section->ex_menu_tm > 0)
167 sysadm 1.34 {
168 sysadm 1.38 unload_menu(&(p_section->ex_menu_set));
169 sysadm 1.34 }
170    
171 sysadm 1.38 ex_menu_set_new.allow_exit = 1; // Allow exit menu
172     memcpy(&(p_section->ex_menu_set), &ex_menu_set_new, sizeof(ex_menu_set_new));
173 sysadm 1.34
174 sysadm 1.38 p_section->ex_menu_tm = atol(row[7]);
175 sysadm 1.34 #ifdef _DEBUG
176 sysadm 1.38 log_common("Loaded gen_ex_menu of section %d [%s]\n", p_section->sid, p_section->sname);
177 sysadm 1.34 #endif
178     }
179     }
180    
181 sysadm 1.1 // release rw lock
182     ret = section_list_rw_unlock(p_section);
183     if (ret < 0)
184     {
185     break;
186     }
187     }
188 sysadm 1.23
189     cleanup:
190 sysadm 1.31 mysql_free_result(rs2);
191 sysadm 1.1 mysql_free_result(rs);
192 sysadm 1.2 mysql_close(db);
193    
194     return ret;
195 sysadm 1.1 }
196 sysadm 1.3
197 sysadm 1.9 int append_articles_from_db(int32_t start_aid, int global_lock, int article_count_limit)
198 sysadm 1.3 {
199 sysadm 1.23 MYSQL *db = NULL;
200     MYSQL_RES *rs = NULL;
201 sysadm 1.3 MYSQL_ROW row;
202     char sql[SQL_BUFFER_LEN];
203     ARTICLE article;
204 sysadm 1.5 ARTICLE *p_topic;
205 sysadm 1.3 SECTION_LIST *p_section = NULL;
206     int32_t last_sid = 0;
207 sysadm 1.16 char sub_ip[IP_ADDR_LEN];
208 sysadm 1.9 int article_count = 0;
209 sysadm 1.3 int ret = 0;
210     int i;
211    
212     db = db_open();
213     if (db == NULL)
214     {
215     log_error("db_open() error: %s\n", mysql_error(db));
216 sysadm 1.23 ret = -1;
217     goto cleanup;
218 sysadm 1.3 }
219    
220     snprintf(sql, sizeof(sql),
221 sysadm 1.11 "SELECT bbs.AID, TID, SID, bbs.CID, UID, visible, excerption, ontop, `lock`, "
222     "transship, username, nickname, title, UNIX_TIMESTAMP(sub_dt) AS sub_dt, "
223 sysadm 1.16 "sub_ip, bbs_content.content "
224 sysadm 1.11 "FROM bbs INNER JOIN bbs_content ON bbs.CID = bbs_content.CID "
225     "WHERE bbs.AID >= %d ORDER BY bbs.AID LIMIT %d",
226 sysadm 1.9 start_aid, article_count_limit);
227 sysadm 1.3
228     if (mysql_query(db, sql) != 0)
229     {
230     log_error("Query article list error: %s\n", mysql_error(db));
231 sysadm 1.23 ret = -2;
232     goto cleanup;
233 sysadm 1.3 }
234 sysadm 1.11 if ((rs = mysql_use_result(db)) == NULL)
235 sysadm 1.3 {
236     log_error("Get article list data failed\n");
237 sysadm 1.23 ret = -2;
238     goto cleanup;
239 sysadm 1.3 }
240    
241     // acquire global lock
242 sysadm 1.23 if (global_lock && (ret = section_list_rw_lock(NULL)) < 0)
243 sysadm 1.3 {
244 sysadm 1.23 log_error("section_list_rw_lock(sid = 0) error\n");
245     goto cleanup;
246 sysadm 1.3 }
247    
248     while ((row = mysql_fetch_row(rs)))
249     {
250 sysadm 1.22 memset(&article, 0, sizeof(ARTICLE));
251 sysadm 1.3
252     // copy data of article
253     i = 0;
254    
255     article.aid = atoi(row[i++]);
256     article.tid = atoi(row[i++]);
257     article.sid = atoi(row[i++]);
258     article.cid = atoi(row[i++]);
259     article.uid = atoi(row[i++]);
260     article.visible = (int8_t)atoi(row[i++]);
261     article.excerption = (int8_t)atoi(row[i++]);
262     article.ontop = (int8_t)atoi(row[i++]);
263     article.lock = (int8_t)atoi(row[i++]);
264 sysadm 1.5 article.transship = (int8_t)atoi(row[i++]);
265 sysadm 1.3
266     strncpy(article.username, row[i++], sizeof(article.username) - 1);
267     article.username[sizeof(article.username) - 1] = '\0';
268     strncpy(article.nickname, row[i++], sizeof(article.nickname) - 1);
269     article.nickname[sizeof(article.nickname) - 1] = '\0';
270     strncpy(article.title, row[i++], sizeof(article.title) - 1);
271     article.title[sizeof(article.title) - 1] = '\0';
272    
273     article.sub_dt = atol(row[i++]);
274    
275 sysadm 1.16 strncpy(sub_ip, row[i++], sizeof(sub_ip) - 1);
276     sub_ip[sizeof(sub_ip) - 1] = '\0';
277     ip_mask(sub_ip, 1, '*');
278    
279 sysadm 1.3 // release lock of last section if different from current one
280     if (!global_lock && article.sid != last_sid && last_sid != 0)
281     {
282     if ((ret = section_list_rw_unlock(p_section)) < 0)
283     {
284 sysadm 1.11 log_error("section_list_rw_unlock(sid=%d) error\n", p_section->sid);
285 sysadm 1.3 break;
286     }
287     }
288    
289     if ((p_section = section_list_find_by_sid(article.sid)) == NULL)
290     {
291     log_error("section_list_find_by_sid(%d) error: unknown section, try reloading section config\n", article.sid);
292 sysadm 1.4 ret = ERR_UNKNOWN_SECTION; // Unknown section found
293 sysadm 1.3 break;
294     }
295    
296 sysadm 1.5 if (article.visible != 0 && article.tid != 0)
297     {
298     // Check if topic article is visible
299     p_topic = article_block_find_by_aid(article.tid);
300     if (p_topic == NULL || p_topic->visible == 0)
301     {
302     // log_error("Set article (aid = %d) as invisible due to invisible or non-existing topic head\n", article.aid);
303     article.tid = 0;
304     article.visible = 0;
305     }
306     }
307    
308 sysadm 1.3 // acquire lock of current section if different from last one
309     if (!global_lock && article.sid != last_sid)
310     {
311 sysadm 1.4 if ((ret = section_list_rw_lock(p_section)) < 0)
312 sysadm 1.3 {
313 sysadm 1.11 log_error("section_list_rw_lock(sid=0) error\n");
314 sysadm 1.3 break;
315     }
316     }
317    
318     // append article to section list
319     last_sid = article.sid;
320    
321     if (section_list_append_article(p_section, &article) < 0)
322     {
323 sysadm 1.11 log_error("section_list_append_article(sid=%d, aid=%d) error\n",
324 sysadm 1.3 p_section->sid, article.aid);
325     ret = -3;
326     break;
327     }
328 sysadm 1.9
329     article_count++;
330    
331 sysadm 1.16 if (article_cache_generate(VAR_ARTICLE_CACHE_DIR, &article, p_section, row[i++], sub_ip, 0) < 0)
332 sysadm 1.11 {
333     log_error("article_cache_generate(aid=%d, cid=%d) error\n", article.aid, article.cid);
334     ret = -4;
335     break;
336     }
337 sysadm 1.3 }
338    
339     // release lock of last section
340     if (!global_lock && last_sid != 0)
341     {
342     if ((ret = section_list_rw_unlock(p_section)) < 0)
343     {
344 sysadm 1.11 log_error("section_list_rw_unlock(sid=%d) error\n", p_section->sid);
345 sysadm 1.3 }
346     }
347    
348     // release global lock
349 sysadm 1.23 if (global_lock && (ret = section_list_rw_unlock(NULL)) < 0)
350 sysadm 1.3 {
351 sysadm 1.23 log_error("section_list_rw_unlock(sid=0) error\n");
352 sysadm 1.3 }
353    
354     cleanup:
355     mysql_free_result(rs);
356     mysql_close(db);
357    
358 sysadm 1.31 article_cache_cleanup();
359    
360 sysadm 1.9 return (ret < 0 ? ret : article_count);
361 sysadm 1.3 }
362 sysadm 1.4
363 sysadm 1.5 int set_last_article_op_log_from_db(void)
364     {
365 sysadm 1.23 MYSQL *db = NULL;
366     MYSQL_RES *rs = NULL;
367 sysadm 1.5 MYSQL_ROW row;
368     char sql[SQL_BUFFER_LEN];
369 sysadm 1.23 int ret = 0;
370 sysadm 1.5
371     db = db_open();
372     if (db == NULL)
373     {
374     log_error("db_open() error: %s\n", mysql_error(db));
375 sysadm 1.23 ret = -1;
376     goto cleanup;
377 sysadm 1.5 }
378    
379     snprintf(sql, sizeof(sql),
380     "SELECT MID FROM bbs_article_op ORDER BY MID DESC LIMIT 1");
381    
382     if (mysql_query(db, sql) != 0)
383     {
384     log_error("Query article op error: %s\n", mysql_error(db));
385 sysadm 1.23 ret = -2;
386     goto cleanup;
387 sysadm 1.5 }
388     if ((rs = mysql_store_result(db)) == NULL)
389     {
390     log_error("Get article op data failed\n");
391 sysadm 1.23 ret = -2;
392     goto cleanup;
393 sysadm 1.5 }
394    
395     if ((row = mysql_fetch_row(rs)))
396     {
397     last_article_op_log_mid = atoi(row[0]);
398     }
399    
400 sysadm 1.23 cleanup:
401 sysadm 1.5 mysql_free_result(rs);
402     mysql_close(db);
403    
404 sysadm 1.23 return (ret < 0 ? ret : last_article_op_log_mid);
405 sysadm 1.5 }
406    
407 sysadm 1.9 int apply_article_op_log_from_db(int op_count_limit)
408 sysadm 1.5 {
409 sysadm 1.23 MYSQL *db = NULL;
410     MYSQL_RES *rs = NULL, *rs2 = NULL;
411 sysadm 1.5 MYSQL_ROW row, row2;
412     char sql[SQL_BUFFER_LEN];
413     ARTICLE *p_article;
414     SECTION_LIST *p_section = NULL;
415     SECTION_LIST *p_section_dest;
416 sysadm 1.16 char sub_ip[IP_ADDR_LEN];
417 sysadm 1.5 int32_t last_sid = 0;
418     int32_t sid_dest;
419 sysadm 1.9 int op_count = 0;
420 sysadm 1.5 int ret = 0;
421    
422     db = db_open();
423     if (db == NULL)
424     {
425     log_error("db_open() error: %s\n", mysql_error(db));
426 sysadm 1.23 ret = -1;
427     goto cleanup;
428 sysadm 1.5 }
429    
430     snprintf(sql, sizeof(sql),
431     "SELECT MID, AID, type FROM bbs_article_op "
432 sysadm 1.9 "WHERE MID > %d AND type NOT IN ('A') "
433     "ORDER BY MID LIMIT %d",
434     last_article_op_log_mid, op_count_limit);
435 sysadm 1.5
436     if (mysql_query(db, sql) != 0)
437     {
438     log_error("Query article log error: %s\n", mysql_error(db));
439 sysadm 1.23 ret = -2;
440     goto cleanup;
441 sysadm 1.5 }
442     if ((rs = mysql_store_result(db)) == NULL)
443     {
444     log_error("Get article log data failed\n");
445 sysadm 1.23 ret = -2;
446     goto cleanup;
447 sysadm 1.5 }
448    
449     while ((row = mysql_fetch_row(rs)))
450     {
451     p_article = article_block_find_by_aid(atoi(row[1]));
452     if (p_article == NULL) // related article has not been appended yet
453     {
454     ret = -2;
455     break;
456     }
457    
458     // release lock of last section if different from current one
459     if (p_article->sid != last_sid && last_sid != 0)
460     {
461     if ((ret = section_list_rw_unlock(p_section)) < 0)
462     {
463     log_error("section_list_rw_unlock(sid = %d) error\n", p_section->sid);
464     break;
465     }
466     }
467    
468     if ((p_section = section_list_find_by_sid(p_article->sid)) == NULL)
469     {
470     log_error("section_list_find_by_sid(%d) error: unknown section, try reloading section config\n", p_article->sid);
471     ret = ERR_UNKNOWN_SECTION; // Unknown section found
472     break;
473     }
474    
475     // acquire lock of current section if different from last one
476     if (p_article->sid != last_sid)
477     {
478     if ((ret = section_list_rw_lock(p_section)) < 0)
479     {
480     log_error("section_list_rw_lock(sid = 0) error\n");
481     break;
482     }
483     }
484    
485     last_sid = p_article->sid;
486    
487     switch (row[2][0])
488     {
489     case 'A': // Add article
490     log_error("Operation type=A should not be found\n");
491     break;
492     case 'D': // Delete article
493     case 'X': // Delete article by Admin
494 sysadm 1.20 if (section_list_set_article_visible(p_section, atoi(row[1]), 0) < 0)
495 sysadm 1.5 {
496 sysadm 1.20 log_error("section_list_set_article_visible(sid=%d, aid=%d, visible=0) error\n", p_section->sid, atoi(row[1]));
497     }
498     if (section_list_calculate_page(p_section, atoi(row[1])) < 0)
499     {
500     log_error("section_list_calculate_page(aid=%d) error\n", atoi(row[1]));
501 sysadm 1.5 }
502     break;
503     case 'S': // Restore article
504 sysadm 1.20 if (section_list_set_article_visible(p_section, atoi(row[1]), 1) < 0)
505     {
506     log_error("section_list_set_article_visible(sid=%d, aid=%d, visible=1) error\n", p_section->sid, atoi(row[1]));
507     }
508     if (section_list_calculate_page(p_section, atoi(row[1])) < 0)
509     {
510     log_error("section_list_calculate_page(aid=%d) error\n", atoi(row[1]));
511     }
512 sysadm 1.5 break;
513     case 'L': // Lock article
514     p_article->lock = 1;
515     break;
516     case 'U': // Unlock article
517     p_article->lock = 0;
518     break;
519     case 'M': // Modify article
520 sysadm 1.9 snprintf(sql, sizeof(sql),
521 sysadm 1.16 "SELECT bbs.CID, sub_ip, bbs_content.content "
522 sysadm 1.11 "FROM bbs INNER JOIN bbs_content ON bbs.CID = bbs_content.CID "
523     "WHERE bbs.AID = %d",
524 sysadm 1.9 p_article->aid);
525    
526     if (mysql_query(db, sql) != 0)
527     {
528     log_error("Query article error: %s\n", mysql_error(db));
529     ret = -3;
530     break;
531     }
532 sysadm 1.12 if ((rs2 = mysql_use_result(db)) == NULL)
533 sysadm 1.9 {
534     log_error("Get article data failed\n");
535     ret = -3;
536     break;
537     }
538     if ((row2 = mysql_fetch_row(rs2)))
539     {
540     p_article->cid = atoi(row2[0]);
541 sysadm 1.11
542 sysadm 1.16 strncpy(sub_ip, row2[1], sizeof(sub_ip) - 1);
543     sub_ip[sizeof(sub_ip) - 1] = '\0';
544     ip_mask(sub_ip, 1, '*');
545    
546     if (article_cache_generate(VAR_ARTICLE_CACHE_DIR, p_article, p_section, row2[2], sub_ip, 0) < 0)
547 sysadm 1.11 {
548     log_error("article_cache_generate(aid=%d, cid=%d) error\n", p_article->aid, p_article->cid);
549     ret = -4;
550     }
551 sysadm 1.9 }
552     else
553     {
554     p_article->cid = 0;
555     ret = -4;
556     }
557     mysql_free_result(rs2);
558 sysadm 1.23 rs2 = NULL;
559 sysadm 1.21
560     p_article->excerption = 0; // Set excerption = 0 implicitly in case of rare condition
561 sysadm 1.5 break;
562     case 'T': // Move article
563     snprintf(sql, sizeof(sql),
564     "SELECT SID FROM bbs WHERE AID = %d",
565     p_article->aid);
566    
567     if (mysql_query(db, sql) != 0)
568     {
569     log_error("Query article error: %s\n", mysql_error(db));
570     ret = -3;
571     break;
572     }
573     if ((rs2 = mysql_store_result(db)) == NULL)
574     {
575     log_error("Get article data failed\n");
576     ret = -3;
577     break;
578     }
579     if ((row2 = mysql_fetch_row(rs2)))
580     {
581     sid_dest = atoi(row2[0]);
582     }
583     else
584     {
585     sid_dest = 0;
586     ret = -4;
587     }
588     mysql_free_result(rs2);
589 sysadm 1.23 rs2 = NULL;
590 sysadm 1.5
591     if (sid_dest > 0 && sid_dest != p_article->sid)
592     {
593     p_section_dest = section_list_find_by_sid(sid_dest);
594     if (p_section_dest == NULL)
595     {
596     ret = ERR_UNKNOWN_SECTION;
597     break;
598     }
599 sysadm 1.6 // acquire lock of dest section
600     if ((ret = section_list_rw_lock(p_section_dest)) < 0)
601     {
602     log_error("section_list_rw_lock(sid = %d) error\n", p_section_dest);
603     break;
604     }
605 sysadm 1.5 // Move topic
606     if ((ret = section_list_move_topic(p_section, p_section_dest, p_article->aid)) < 0)
607     {
608 sysadm 1.6 log_error("section_list_move_topic(src_sid=%d, dest_sid=%d, aid=%d) error (%d), retry in the next loop\n",
609     p_section->sid, p_section_dest->sid, p_article->aid, ret);
610     }
611     // release lock of dest section
612     if (section_list_rw_unlock(p_section_dest) < 0)
613     {
614     log_error("section_list_rw_unlock(sid = %d) error\n", p_section_dest);
615     ret = -1;
616 sysadm 1.5 }
617     }
618     break;
619     case 'E': // Set article as excerption
620     p_article->excerption = 1;
621     break;
622     case 'O': // Unset article as excerption
623     p_article->excerption = 0;
624     break;
625     case 'F': // Set article on top
626     case 'V': // Unset article on top
627 sysadm 1.32 p_article->ontop = (row[2][0] == 'F' ? 1 : 0);
628     if (section_list_update_article_ontop(p_section, p_article) < 0)
629     {
630     log_error("section_list_update_article_ontop(sid=%d, aid=%d) error\n",
631     p_section->sid, p_article->aid);
632     }
633 sysadm 1.5 break;
634     case 'Z': // Set article as trnasship
635     p_article->transship = 1;
636     break;
637     default:
638     // log_error("Operation type=%s unknown, mid=%s\n", row[2], row[0]);
639     break;
640     }
641    
642     if (ret < 0)
643     {
644     break;
645     }
646    
647     // Update MID with last successfully proceeded article_op_log
648     last_article_op_log_mid = atoi(row[0]);
649 sysadm 1.9
650     op_count++;
651 sysadm 1.5 }
652    
653     // release lock of last section
654     if (last_sid != 0)
655     {
656     if ((ret = section_list_rw_unlock(p_section)) < 0)
657     {
658     log_error("section_list_rw_unlock(sid = %d) error\n", p_section->sid);
659     }
660     }
661    
662 sysadm 1.23 cleanup:
663     mysql_free_result(rs2);
664 sysadm 1.5 mysql_free_result(rs);
665     mysql_close(db);
666    
667 sysadm 1.9 return (ret < 0 ? ret : op_count);
668 sysadm 1.5 }
669    
670 sysadm 1.39 static void section_list_ex_menu_set_cleanup(void)
671     {
672     int i;
673    
674     for (i = 0; i < p_section_list_pool->section_count; i++)
675     {
676     if (p_section_list_pool->sections[i].ex_menu_tm > 0)
677     {
678     unload_menu(&(p_section_list_pool->sections[i].ex_menu_set));
679     }
680     }
681     }
682    
683 sysadm 1.4 int section_list_loader_launch(void)
684     {
685 sysadm 1.34 struct sigaction act = {0};
686 sysadm 1.4 int pid;
687     int ret;
688     int32_t last_aid;
689     int article_count;
690     int load_count;
691 sysadm 1.5 int last_mid;
692 sysadm 1.4 int i;
693    
694     if (section_list_loader_pid != 0)
695     {
696     log_error("section_list_loader already running, pid = %d\n", section_list_loader_pid);
697     return -2;
698     }
699    
700     pid = fork();
701    
702     if (pid > 0) // Parent process
703     {
704     SYS_child_process_count++;
705     section_list_loader_pid = pid;
706 sysadm 1.18 log_common("Section list loader process (pid = %d) start\n", pid);
707 sysadm 1.4 return 0;
708     }
709     else if (pid < 0) // Error
710     {
711     log_error("fork() error (%d)\n", errno);
712     return -1;
713     }
714    
715     // Child process
716     SYS_child_process_count = 0;
717    
718     // Detach menu in shared memory
719 sysadm 1.36 detach_menu_shm(&bbs_menu);
720 sysadm 1.4
721 sysadm 1.34 // Set signal handler
722     act.sa_handler = SIG_DFL;
723 sysadm 1.38 if (sigaction(SIGHUP, &act, NULL) == -1)
724     {
725     log_error("set signal action of SIGHUP error: %d\n", errno);
726     }
727     act.sa_handler = SIG_DFL;
728 sysadm 1.34 if (sigaction(SIGCHLD, &act, NULL) == -1)
729     {
730     log_error("set signal action of SIGCHLD error: %d\n", errno);
731     }
732    
733 sysadm 1.4 // Do section data loader periodically
734     while (!SYS_server_exit)
735     {
736 sysadm 1.38 if (SYS_conf_reload)
737 sysadm 1.4 {
738 sysadm 1.38 SYS_conf_reload = 0;
739 sysadm 1.4
740     // Load section config
741 sysadm 1.38 if (load_section_config_from_db(0) < 0)
742 sysadm 1.4 {
743 sysadm 1.38 log_error("load_section_config_from_db(0) error\n");
744 sysadm 1.4 }
745     else
746     {
747 sysadm 1.27 log_common("Reload section config successfully\n");
748 sysadm 1.4 }
749     }
750    
751     // Load section articles
752     article_count = article_block_article_count();
753    
754 sysadm 1.9 do
755 sysadm 1.4 {
756 sysadm 1.9 last_aid = article_block_last_aid();
757 sysadm 1.4
758 sysadm 1.9 if ((ret = append_articles_from_db(last_aid + 1, 0, LOAD_ARTICLE_COUNT_LIMIT)) < 0)
759 sysadm 1.4 {
760 sysadm 1.9 log_error("append_articles_from_db(%d, 0, %d) error\n", last_aid + 1, LOAD_ARTICLE_COUNT_LIMIT);
761    
762     if (ret == ERR_UNKNOWN_SECTION)
763     {
764 sysadm 1.38 SYS_conf_reload = 1; // Force reload section_list
765 sysadm 1.9 }
766 sysadm 1.4 }
767 sysadm 1.9 } while (ret == LOAD_ARTICLE_COUNT_LIMIT);
768 sysadm 1.5
769     load_count = article_block_article_count() - article_count;
770     if (load_count > 0)
771     {
772 sysadm 1.17 log_common("Incrementally load %d articles, last_aid = %d\n", load_count, article_block_last_aid());
773 sysadm 1.5 }
774    
775 sysadm 1.38 if (SYS_conf_reload)
776 sysadm 1.5 {
777     continue;
778     }
779    
780     // Load article_op log
781     last_mid = last_article_op_log_mid;
782    
783 sysadm 1.9 do
784 sysadm 1.4 {
785 sysadm 1.9 if ((ret = apply_article_op_log_from_db(LOAD_ARTICLE_COUNT_LIMIT)) < 0)
786     {
787     log_error("apply_article_op_log_from_db() error\n");
788 sysadm 1.4
789 sysadm 1.9 if (ret == ERR_UNKNOWN_SECTION)
790     {
791 sysadm 1.38 SYS_conf_reload = 1; // Force reload section_list
792 sysadm 1.9 }
793 sysadm 1.4 }
794 sysadm 1.9 } while (ret == LOAD_ARTICLE_COUNT_LIMIT);
795 sysadm 1.4
796 sysadm 1.5 if (last_article_op_log_mid > last_mid)
797     {
798 sysadm 1.17 log_common("Proceeded %d article logs, last_mid = %d\n", last_article_op_log_mid - last_mid, last_article_op_log_mid);
799 sysadm 1.5 }
800    
801 sysadm 1.38 if (SYS_conf_reload)
802 sysadm 1.5 {
803     continue;
804     }
805    
806 sysadm 1.38 for (i = 0; i < BBS_section_list_load_interval && !SYS_server_exit && !SYS_conf_reload; i++)
807 sysadm 1.5 {
808     sleep(1);
809 sysadm 1.4 }
810     }
811    
812     // Child process exit
813    
814 sysadm 1.31 article_cache_cleanup();
815    
816 sysadm 1.34 // gen_ex_menu cleanup
817     section_list_ex_menu_set_cleanup();
818 sysadm 1.37
819 sysadm 1.4 // Detach data pools shm
820     detach_section_list_shm();
821     detach_article_block_shm();
822     detach_trie_dict_shm();
823    
824 sysadm 1.17 log_common("Section list loader process exit normally\n");
825 sysadm 1.4 log_end();
826    
827     section_list_loader_pid = 0;
828    
829     _exit(0);
830    
831     return 0;
832     }
833    
834 sysadm 1.33 int query_section_articles(SECTION_LIST *p_section, int page_id, ARTICLE *p_articles[],
835     int *p_article_count, int *p_page_count, int *p_ontop_start_offset)
836 sysadm 1.7 {
837     ARTICLE *p_article;
838     ARTICLE *p_next_page_first_article;
839     int ret = 0;
840 sysadm 1.32 int i;
841 sysadm 1.7
842 sysadm 1.33 if (p_section == NULL || p_articles == NULL || p_article_count == NULL || p_page_count == NULL || p_ontop_start_offset == NULL)
843 sysadm 1.7 {
844 sysadm 1.34 log_error("NULL pointer error\n");
845 sysadm 1.7 return -1;
846     }
847    
848     // acquire lock of section
849     if ((ret = section_list_rd_lock(p_section)) < 0)
850     {
851     log_error("section_list_rd_lock(sid = %d) error\n", p_section->sid);
852     return -2;
853     }
854    
855 sysadm 1.32 *p_page_count = section_list_page_count_with_ontop(p_section);
856     *p_article_count = 0;
857 sysadm 1.33 *p_ontop_start_offset = BBS_article_limit_per_page;
858 sysadm 1.10
859 sysadm 1.9 if (p_section->visible_article_count == 0)
860     {
861 sysadm 1.32 // empty section
862 sysadm 1.9 }
863 sysadm 1.32 else if (page_id < 0 || page_id >= *p_page_count)
864 sysadm 1.7 {
865 sysadm 1.32 log_error("Invalid page_id=%d, not in range [0, %d)\n", page_id, *p_page_count);
866 sysadm 1.7 ret = -3;
867     }
868     else
869     {
870     ret = page_id;
871    
872 sysadm 1.32 if (page_id <= p_section->page_count - 1)
873 sysadm 1.7 {
874 sysadm 1.32 p_article = p_section->p_page_first_article[page_id];
875     p_next_page_first_article =
876     (page_id == p_section->page_count - 1 ? p_section->p_article_head : p_section->p_page_first_article[page_id + 1]);
877    
878     do
879     {
880     if (p_article->visible)
881     {
882     p_articles[*p_article_count] = p_article;
883     (*p_article_count)++;
884     }
885     p_article = p_article->p_next;
886     } while (p_article != p_next_page_first_article && (*p_article_count) <= BBS_article_limit_per_page);
887    
888     if (*p_article_count != (page_id < p_section->page_count - 1 ? BBS_article_limit_per_page : p_section->last_page_visible_article_count))
889 sysadm 1.7 {
890 sysadm 1.32 log_error("Inconsistent visible article count %d detected in section %d page %d\n", *p_article_count, p_section->sid, page_id);
891 sysadm 1.7 }
892 sysadm 1.32 }
893 sysadm 1.8
894 sysadm 1.33 *p_ontop_start_offset = *p_article_count;
895    
896 sysadm 1.32 // Append ontop articles
897     if (page_id >= p_section->page_count - 1)
898 sysadm 1.8 {
899 sysadm 1.32 i = (page_id == p_section->page_count - 1
900     ? 0
901     : (page_id - p_section->page_count + 1) * BBS_article_limit_per_page - p_section->last_page_visible_article_count);
902     while (*p_article_count < BBS_article_limit_per_page && i < p_section->ontop_article_count)
903     {
904     p_articles[(*p_article_count)++] = p_section->p_ontop_articles[i++];
905     }
906 sysadm 1.8 }
907 sysadm 1.7 }
908    
909     // release lock of section
910 sysadm 1.8 if (section_list_rd_unlock(p_section) < 0)
911 sysadm 1.7 {
912     log_error("section_list_rd_unlock(sid = %d) error\n", p_section->sid);
913     ret = -2;
914     }
915    
916     return ret;
917     }
918 sysadm 1.14
919 sysadm 1.24 int locate_article_in_section(SECTION_LIST *p_section, const ARTICLE *p_article_cur, int direction, int step,
920 sysadm 1.15 int *p_page_id, int *p_visible_offset, int *p_article_count)
921 sysadm 1.14 {
922 sysadm 1.15 const ARTICLE *p_article = NULL;
923 sysadm 1.40 const ARTICLE *p_article_last = NULL;
924 sysadm 1.15 ARTICLE *p_tmp;
925 sysadm 1.14 int32_t aid = 0;
926 sysadm 1.24 int page_id = 0;
927     int offset = 0;
928 sysadm 1.14 int ret = 0;
929 sysadm 1.15 int i;
930 sysadm 1.14
931 sysadm 1.15 if (p_section == NULL || p_article_cur == NULL || p_page_id == NULL || p_visible_offset == NULL || p_article_count == NULL)
932 sysadm 1.14 {
933 sysadm 1.34 log_error("NULL pointer error\n");
934 sysadm 1.14 return -1;
935     }
936    
937     // acquire lock of section
938     if ((ret = section_list_rd_lock(p_section)) < 0)
939     {
940     log_error("section_list_rd_lock(sid = %d) error\n", p_section->sid);
941     return -2;
942     }
943    
944     if (direction == 0)
945     {
946     aid = p_article_cur->aid;
947     }
948     else if (direction == 1)
949     {
950 sysadm 1.43 for (p_article_last = p_article_cur, p_article = p_article_cur->p_topic_next;
951     step > 0 && p_article->aid > p_article_cur->aid;
952 sysadm 1.40 p_article = p_article->p_topic_next)
953 sysadm 1.14 {
954 sysadm 1.24 if (p_article->visible)
955     {
956     step--;
957 sysadm 1.40 p_article_last = p_article;
958 sysadm 1.24 }
959     }
960 sysadm 1.43 p_article = p_article_last;
961 sysadm 1.15
962 sysadm 1.25 aid = (p_article->aid > p_article_cur->aid && p_article->visible ? p_article->aid : 0);
963 sysadm 1.14 }
964     else if (direction == -1)
965     {
966 sysadm 1.43 for (p_article_last = p_article_cur, p_article = p_article_cur->p_topic_prior;
967     step > 0 && p_article->aid < p_article_cur->aid;
968 sysadm 1.40 p_article = p_article->p_topic_prior)
969 sysadm 1.14 {
970 sysadm 1.24 if (p_article->visible)
971     {
972     step--;
973 sysadm 1.40 p_article_last = p_article;
974 sysadm 1.24 }
975     }
976 sysadm 1.43 p_article = p_article_last;
977 sysadm 1.15
978 sysadm 1.25 aid = (p_article->aid < p_article_cur->aid && p_article->visible ? p_article->aid : 0);
979 sysadm 1.14 }
980    
981 sysadm 1.15 p_article = NULL;
982    
983 sysadm 1.14 if (aid > 0)
984     {
985 sysadm 1.15 p_article = section_list_find_article_with_offset(p_section, aid, &page_id, &offset, &p_tmp);
986 sysadm 1.14 if (p_article != NULL)
987     {
988 sysadm 1.15 *p_article_count = (page_id == p_section->page_count - 1 ? p_section->last_page_visible_article_count : BBS_article_limit_per_page);
989    
990     p_article = p_section->p_page_first_article[page_id];
991 sysadm 1.25 for (i = 0; i < *p_article_count && p_article != NULL;)
992 sysadm 1.15 {
993     if (p_article->visible)
994     {
995     if (p_article->aid == aid)
996     {
997     *p_page_id = page_id;
998     *p_visible_offset = i;
999     break;
1000     }
1001     i++;
1002     if (i >= *p_article_count)
1003     {
1004     log_error("Visible article (aid=%d) not found in page %d\n", aid, page_id);
1005     p_article = NULL;
1006 sysadm 1.25 break;
1007 sysadm 1.15 }
1008     }
1009     p_article = p_article->p_next;
1010     }
1011 sysadm 1.32
1012     // Include ontop articles
1013     *p_article_count = section_list_page_article_count_with_ontop(p_section, page_id);
1014 sysadm 1.14 }
1015     }
1016    
1017     // release lock of section
1018     if (section_list_rd_unlock(p_section) < 0)
1019     {
1020     log_error("section_list_rd_unlock(sid = %d) error\n", p_section->sid);
1021     ret = -2;
1022     }
1023    
1024     return (ret < 0 ? ret : (p_article == NULL ? 0 : 1));
1025     }
1026 sysadm 1.34
1027 sysadm 1.44 int scan_unread_article_in_section(SECTION_LIST *p_section, const ARTICLE *p_article_cur, const ARTICLE **pp_article_unread)
1028     {
1029     ARTICLE *p_article;
1030     int ret = 0;
1031    
1032     if (p_section == NULL || p_article_cur == NULL || pp_article_unread == NULL)
1033     {
1034     log_error("NULL pointer error\n");
1035     return -1;
1036     }
1037    
1038     if (p_article_cur->sid != p_section->sid)
1039     {
1040     log_error("Inconsistent SID\n");
1041     return -1;
1042     }
1043    
1044     // acquire lock of section
1045     if ((ret = section_list_rd_lock(p_section)) < 0)
1046     {
1047     log_error("section_list_rd_lock(sid = %d) error\n", p_section->sid);
1048     return -2;
1049     }
1050    
1051     *pp_article_unread = NULL;
1052    
1053     for (p_article = p_article_cur->p_next; p_article != NULL && p_article != p_article_cur; p_article = p_article->p_next)
1054     {
1055 sysadm 1.45 if (p_article->visible && p_article->uid != BBS_priv.uid && !article_view_log_is_viewed(p_article->aid, &BBS_article_view_log))
1056 sysadm 1.44 {
1057     *pp_article_unread = p_article;
1058     break;
1059     }
1060     }
1061    
1062     // release lock of section
1063     if (section_list_rd_unlock(p_section) < 0)
1064     {
1065     log_error("section_list_rd_unlock(sid = %d) error\n", p_section->sid);
1066     return -2;
1067     }
1068    
1069     return (p_article != NULL && p_article != p_article_cur ? 1 : 0);
1070     }
1071    
1072 sysadm 1.34 int get_section_ex_menu_set(SECTION_LIST *p_section, MENU_SET *p_ex_menu_set)
1073     {
1074     int ret = 0;
1075    
1076     if (p_section == NULL || p_ex_menu_set == NULL)
1077     {
1078     log_error("NULL pointer error\n");
1079     return -1;
1080     }
1081    
1082     // acquire lock of section
1083     if ((ret = section_list_rd_lock(p_section)) < 0)
1084     {
1085     log_error("section_list_rd_lock(sid = %d) error\n", p_section->sid);
1086     return -2;
1087     }
1088    
1089     memcpy(p_ex_menu_set, &(p_section->ex_menu_set), sizeof(p_section->ex_menu_set));
1090    
1091     // release lock of section
1092     if (section_list_rd_unlock(p_section) < 0)
1093     {
1094     log_error("section_list_rd_unlock(sid = %d) error\n", p_section->sid);
1095     ret = -2;
1096     }
1097    
1098     return ret;
1099     }
webmaster@leafok.com
 ViewVC Help
Powered by ViewVC 1.3.0-beta1