| 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" |
| 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 */ |
| 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 |
enum _section_list_constant_t |
enum _section_list_constant_t |
| 40 |
{ |
{ |
| 225 |
|
|
| 226 |
int set_article_block_shm_readonly(void) |
int set_article_block_shm_readonly(void) |
| 227 |
{ |
{ |
| 228 |
|
#ifndef __CYGWIN__ |
| 229 |
int shmid; |
int shmid; |
| 230 |
void *p_shm; |
void *p_shm; |
| 231 |
int i; |
int i; |
| 248 |
return -2; |
return -2; |
| 249 |
} |
} |
| 250 |
} |
} |
| 251 |
|
#endif |
| 252 |
|
|
| 253 |
return 0; |
return 0; |
| 254 |
} |
} |
| 542 |
|
|
| 543 |
int set_section_list_shm_readonly(void) |
int set_section_list_shm_readonly(void) |
| 544 |
{ |
{ |
| 545 |
|
#ifndef __CYGWIN__ |
| 546 |
int shmid; |
int shmid; |
| 547 |
void *p_shm; |
void *p_shm; |
| 548 |
|
|
| 563 |
} |
} |
| 564 |
|
|
| 565 |
p_section_list_pool = p_shm; |
p_section_list_pool = p_shm; |
| 566 |
|
#endif |
| 567 |
|
|
| 568 |
return 0; |
return 0; |
| 569 |
} |
} |
| 1067 |
} |
} |
| 1068 |
|
|
| 1069 |
page_count = p_section->page_count - 1 + |
page_count = p_section->page_count - 1 + |
| 1070 |
(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) / |
| 1071 |
((p_section->last_page_visible_article_count + p_section->ontop_article_count) % BBS_article_limit_per_page ? 1 : 0); |
BBS_article_limit_per_page; |
| 1072 |
|
|
| 1073 |
if (page_count < 0) |
if (page_count < 0) |
| 1074 |
{ |
{ |
| 1613 |
{ |
{ |
| 1614 |
int index; |
int index; |
| 1615 |
struct sembuf sops[4]; |
struct sembuf sops[4]; |
| 1616 |
|
#ifndef __CYGWIN__ |
| 1617 |
struct timespec timeout; |
struct timespec timeout; |
| 1618 |
|
#endif |
| 1619 |
int ret; |
int ret; |
| 1620 |
|
|
| 1621 |
index = get_section_index(p_section); |
index = get_section_index(p_section); |
| 1646 |
sops[3].sem_flg = SEM_UNDO; // undo on terminate |
sops[3].sem_flg = SEM_UNDO; // undo on terminate |
| 1647 |
} |
} |
| 1648 |
|
|
| 1649 |
|
#ifdef __CYGWIN__ |
| 1650 |
|
ret = semop(p_section_list_pool->semid, sops, (index == BBS_max_section ? 2 : 4)); |
| 1651 |
|
#else |
| 1652 |
timeout.tv_sec = wait_sec; |
timeout.tv_sec = wait_sec; |
| 1653 |
timeout.tv_nsec = 0; |
timeout.tv_nsec = 0; |
| 1654 |
|
|
| 1655 |
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); |
| 1656 |
|
#endif |
| 1657 |
if (ret == -1 && errno != EAGAIN && errno != EINTR) |
if (ret == -1 && errno != EAGAIN && errno != EINTR) |
| 1658 |
{ |
{ |
| 1659 |
log_error("semtimedop(index = %d, lock read) error %d\n", index, errno); |
log_error("semop(index = %d, lock read) error %d\n", index, errno); |
| 1660 |
} |
} |
| 1661 |
|
|
| 1662 |
return ret; |
return ret; |
| 1666 |
{ |
{ |
| 1667 |
int index; |
int index; |
| 1668 |
struct sembuf sops[3]; |
struct sembuf sops[3]; |
| 1669 |
|
#ifndef __CYGWIN__ |
| 1670 |
struct timespec timeout; |
struct timespec timeout; |
| 1671 |
|
#endif |
| 1672 |
int ret; |
int ret; |
| 1673 |
|
|
| 1674 |
index = get_section_index(p_section); |
index = get_section_index(p_section); |
| 1689 |
sops[2].sem_op = 0; // wait until unlocked |
sops[2].sem_op = 0; // wait until unlocked |
| 1690 |
sops[2].sem_flg = 0; |
sops[2].sem_flg = 0; |
| 1691 |
|
|
| 1692 |
|
#ifdef __CYGWIN__ |
| 1693 |
|
ret = semop(p_section_list_pool->semid, sops, 3); |
| 1694 |
|
#else |
| 1695 |
timeout.tv_sec = wait_sec; |
timeout.tv_sec = wait_sec; |
| 1696 |
timeout.tv_nsec = 0; |
timeout.tv_nsec = 0; |
| 1697 |
|
|
| 1698 |
ret = semtimedop(p_section_list_pool->semid, sops, 3, &timeout); |
ret = semtimedop(p_section_list_pool->semid, sops, 3, &timeout); |
| 1699 |
|
#endif |
| 1700 |
if (ret == -1 && errno != EAGAIN && errno != EINTR) |
if (ret == -1 && errno != EAGAIN && errno != EINTR) |
| 1701 |
{ |
{ |
| 1702 |
log_error("semtimedop(index = %d, lock write) error %d\n", index, errno); |
log_error("semop(index = %d, lock write) error %d\n", index, errno); |
| 1703 |
} |
} |
| 1704 |
|
|
| 1705 |
return ret; |
return ret; |