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

Diff of /lbbs/src/section_list.c

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

Revision 1.54 by sysadm, Wed Nov 5 03:01:14 2025 UTC Revision 1.60 by sysadm, Mon Nov 17 14:01:13 2025 UTC
# Line 6  Line 6 
6   * Copyright (C) 2004-2025  Leaflet <leaflet@leafok.com>   * Copyright (C) 2004-2025  Leaflet <leaflet@leafok.com>
7   */   */
8    
9    #ifdef HAVE_CONFIG_H
10    #include "config.h"
11    #endif
12    
13  #include "log.h"  #include "log.h"
14  #include "section_list.h"  #include "section_list.h"
15  #include "trie_dict.h"  #include "trie_dict.h"
# Line 21  Line 25 
25  #include <sys/sem.h>  #include <sys/sem.h>
26  #include <sys/shm.h>  #include <sys/shm.h>
27    
28  #ifdef _SEM_SEMUN_UNDEFINED  #if defined(_SEM_SEMUN_UNDEFINED) || defined(__CYGWIN__)
29  union semun  union semun
30  {  {
31          int val;                           /* Value for SETVAL */          int val;                           /* Value for SETVAL */
# Line 30  union semun Line 34  union semun
34          struct seminfo *__buf; /* Buffer for IPC_INFO          struct seminfo *__buf; /* Buffer for IPC_INFO
35                                                            (Linux-specific) */                                                            (Linux-specific) */
36  };  };
37  #endif // #ifdef _SEM_SEMUN_UNDEFINED  #endif // #if defined(_SEM_SEMUN_UNDEFINED)
38    
39  #define SECTION_TRY_LOCK_WAIT_TIME 1 // second  enum _section_list_constant_t
40  #define SECTION_TRY_LOCK_TIMES 10  {
41            SECTION_TRY_LOCK_WAIT_TIME = 1, // second
42            SECTION_TRY_LOCK_TIMES = 10,
43    
44  #define ARTICLE_BLOCK_PER_SHM 1000               // sizeof(ARTICLE_BLOCK) * ARTICLE_BLOCK_PER_SHM is the size of each shm segment to allocate          ARTICLE_BLOCK_PER_SHM = 1000,           // sizeof(ARTICLE_BLOCK) * ARTICLE_BLOCK_PER_SHM is the size of each shm segment to allocate
45  #define ARTICLE_BLOCK_SHM_COUNT_LIMIT 80 // limited by length (8-bit) of proj_id in ftok(path, proj_id)          ARTICLE_BLOCK_SHM_COUNT_LIMIT = 80, // limited by length (8-bit) of proj_id in ftok(path, proj_id)
46  #define ARTICLE_BLOCK_PER_POOL (ARTICLE_BLOCK_PER_SHM * ARTICLE_BLOCK_SHM_COUNT_LIMIT)          ARTICLE_BLOCK_PER_POOL = (ARTICLE_BLOCK_PER_SHM * ARTICLE_BLOCK_SHM_COUNT_LIMIT),
47    
48  #define CALCULATE_PAGE_THRESHOLD 100 // Adjust to tune performance of moving topic between sections          CALCULATE_PAGE_THRESHOLD = 100, // Adjust to tune performance of moving topic between sections
49    
50  #define SID_STR_LEN 5 // 32-bit + NULL          SID_STR_LEN = 5, // 32-bit + NULL
51    };
52    
53  struct article_block_t  struct article_block_t
54  {  {
# Line 233  int set_article_block_shm_readonly(void) Line 240  int set_article_block_shm_readonly(void)
240                  shmid = (p_article_block_pool->shm_pool + i)->shmid;                  shmid = (p_article_block_pool->shm_pool + i)->shmid;
241    
242                  // Remap shared memory in read-only mode                  // Remap shared memory in read-only mode
243    #if defined(__CYGWIN__)
244                    if (shmdt((p_article_block_pool->shm_pool + i)->p_shm) == -1)
245                    {
246                            log_error("shmdt(shmid = %d) error (%d)\n", (p_article_block_pool->shm_pool + i)->shmid, errno);
247                            return -2;
248                    }
249                    p_shm = shmat(shmid, (p_article_block_pool->shm_pool + i)->p_shm, SHM_RDONLY);
250    #else
251                  p_shm = shmat(shmid, (p_article_block_pool->shm_pool + i)->p_shm, SHM_RDONLY | SHM_REMAP);                  p_shm = shmat(shmid, (p_article_block_pool->shm_pool + i)->p_shm, SHM_RDONLY | SHM_REMAP);
252    #endif
253                  if (p_shm == (void *)-1)                  if (p_shm == (void *)-1)
254                  {                  {
255                          log_error("shmat(article_block_pool shmid = %d) error (%d)\n", shmid, errno);                          log_error("shmat(article_block_pool shmid = %d) error (%d)\n", shmid, errno);
# Line 545  int set_section_list_shm_readonly(void) Line 561  int set_section_list_shm_readonly(void)
561          shmid = p_section_list_pool->shmid;          shmid = p_section_list_pool->shmid;
562    
563          // Remap shared memory in read-only mode          // Remap shared memory in read-only mode
564    #if defined(__CYGWIN__)
565            if (shmdt(p_section_list_pool) == -1)
566            {
567                    log_error("shmdt(section_list_pool) error (%d)\n", errno);
568                    return -1;
569            }
570            p_shm = shmat(shmid, p_section_list_pool, SHM_RDONLY);
571    #else
572          p_shm = shmat(shmid, p_section_list_pool, SHM_RDONLY | SHM_REMAP);          p_shm = shmat(shmid, p_section_list_pool, SHM_RDONLY | SHM_REMAP);
573    #endif
574          if (p_shm == (void *)-1)          if (p_shm == (void *)-1)
575          {          {
576                  log_error("shmat(section_list_pool shmid = %d) error (%d)\n", shmid, errno);                  log_error("shmat(section_list_pool shmid = %d) error (%d)\n", shmid, errno);
# Line 1056  int section_list_page_count_with_ontop(S Line 1081  int section_list_page_count_with_ontop(S
1081          }          }
1082    
1083          page_count = p_section->page_count - 1 +          page_count = p_section->page_count - 1 +
1084                                   (p_section->last_page_visible_article_count + p_section->ontop_article_count) / BBS_article_limit_per_page +                                   (p_section->last_page_visible_article_count + p_section->ontop_article_count + BBS_article_limit_per_page - 1) /
1085                                   ((p_section->last_page_visible_article_count + p_section->ontop_article_count) % BBS_article_limit_per_page ? 1 : 0);                                           BBS_article_limit_per_page;
1086    
1087          if (page_count < 0)          if (page_count < 0)
1088          {          {
# Line 1602  int section_list_try_rd_lock(SECTION_LIS Line 1627  int section_list_try_rd_lock(SECTION_LIS
1627  {  {
1628          int index;          int index;
1629          struct sembuf sops[4];          struct sembuf sops[4];
1630    #if !defined(__CYGWIN__)
1631          struct timespec timeout;          struct timespec timeout;
1632    #endif
1633          int ret;          int ret;
1634    
1635          index = get_section_index(p_section);          index = get_section_index(p_section);
# Line 1633  int section_list_try_rd_lock(SECTION_LIS Line 1660  int section_list_try_rd_lock(SECTION_LIS
1660                  sops[3].sem_flg = SEM_UNDO;                        // undo on terminate                  sops[3].sem_flg = SEM_UNDO;                        // undo on terminate
1661          }          }
1662    
1663    #if defined(__CYGWIN__)
1664            ret = semop(p_section_list_pool->semid, sops, (index == BBS_max_section ? 2 : 4));
1665    #else
1666          timeout.tv_sec = wait_sec;          timeout.tv_sec = wait_sec;
1667          timeout.tv_nsec = 0;          timeout.tv_nsec = 0;
1668    
1669          ret = semtimedop(p_section_list_pool->semid, sops, (index == BBS_max_section ? 2 : 4), &timeout);          ret = semtimedop(p_section_list_pool->semid, sops, (index == BBS_max_section ? 2 : 4), &timeout);
1670    #endif
1671          if (ret == -1 && errno != EAGAIN && errno != EINTR)          if (ret == -1 && errno != EAGAIN && errno != EINTR)
1672          {          {
1673                  log_error("semtimedop(index = %d, lock read) error %d\n", index, errno);                  log_error("semop(index = %d, lock read) error %d\n", index, errno);
1674          }          }
1675    
1676          return ret;          return ret;
# Line 1649  int section_list_try_rw_lock(SECTION_LIS Line 1680  int section_list_try_rw_lock(SECTION_LIS
1680  {  {
1681          int index;          int index;
1682          struct sembuf sops[3];          struct sembuf sops[3];
1683    #if !defined(__CYGWIN__)
1684          struct timespec timeout;          struct timespec timeout;
1685    #endif
1686          int ret;          int ret;
1687    
1688          index = get_section_index(p_section);          index = get_section_index(p_section);
# Line 1670  int section_list_try_rw_lock(SECTION_LIS Line 1703  int section_list_try_rw_lock(SECTION_LIS
1703          sops[2].sem_op = 0;                                                        // wait until unlocked          sops[2].sem_op = 0;                                                        // wait until unlocked
1704          sops[2].sem_flg = 0;          sops[2].sem_flg = 0;
1705    
1706    #if defined(__CYGWIN__)
1707            ret = semop(p_section_list_pool->semid, sops, 3);
1708    #else
1709          timeout.tv_sec = wait_sec;          timeout.tv_sec = wait_sec;
1710          timeout.tv_nsec = 0;          timeout.tv_nsec = 0;
1711    
1712          ret = semtimedop(p_section_list_pool->semid, sops, 3, &timeout);          ret = semtimedop(p_section_list_pool->semid, sops, 3, &timeout);
1713    #endif
1714          if (ret == -1 && errno != EAGAIN && errno != EINTR)          if (ret == -1 && errno != EAGAIN && errno != EINTR)
1715          {          {
1716                  log_error("semtimedop(index = %d, lock write) error %d\n", index, errno);                  log_error("semop(index = %d, lock write) error %d\n", index, errno);
1717          }          }
1718    
1719          return ret;          return ret;

Legend:
Removed lines/characters  
Changed lines/characters
  Added lines/characters
webmaster@leafok.com
 ViewVC Help
Powered by ViewVC 1.3.0-beta1