1
0
Fork 1
mirror of https://gitlab.com/mangadex-pub/mangadex_at_home.git synced 2024-01-19 02:48:37 +00:00

More fixes

This commit is contained in:
carbotaniuman 2021-01-27 13:33:28 -06:00
parent 351e3601a4
commit 60f711cf46
3 changed files with 13 additions and 6 deletions

View file

@ -17,6 +17,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
### Security ### Security
## [2.0.0-rc6] - 2021-01-27
### Fixed
- [2021-01-27] Upped max threadpool size [@carbotaniuman].
## [2.0.0-rc5] - 2021-01-27 ## [2.0.0-rc5] - 2021-01-27
### Changed ### Changed
- [2021-01-27] Minor code tweaks [@carbotaniuman]. - [2021-01-27] Minor code tweaks [@carbotaniuman].
@ -312,7 +316,8 @@ This release contains many breaking changes! Of note are the changes to the cach
### Fixed ### Fixed
- [2020-06-11] Tweaked logging configuration to reduce log file sizes by [@carbotaniuman]. - [2020-06-11] Tweaked logging configuration to reduce log file sizes by [@carbotaniuman].
[Unreleased]: https://gitlab.com/mangadex/mangadex_at_home/-/compare/2.0.0-rc5...HEAD [Unreleased]: https://gitlab.com/mangadex/mangadex_at_home/-/compare/2.0.0-rc6...HEAD
[2.0.0-rc6]: https://gitlab.com/mangadex/mangadex_at_home/-/compare/2.0.0-rc5...2.0.0-rc6
[2.0.0-rc5]: https://gitlab.com/mangadex/mangadex_at_home/-/compare/2.0.0-rc4...2.0.0-rc5 [2.0.0-rc5]: https://gitlab.com/mangadex/mangadex_at_home/-/compare/2.0.0-rc4...2.0.0-rc5
[2.0.0-rc4]: https://gitlab.com/mangadex/mangadex_at_home/-/compare/2.0.0-rc3...2.0.0-rc4 [2.0.0-rc4]: https://gitlab.com/mangadex/mangadex_at_home/-/compare/2.0.0-rc3...2.0.0-rc4
[2.0.0-rc3]: https://gitlab.com/mangadex/mangadex_at_home/-/compare/2.0.0-rc2...2.0.0-rc3 [2.0.0-rc3]: https://gitlab.com/mangadex/mangadex_at_home/-/compare/2.0.0-rc2...2.0.0-rc3

View file

@ -108,9 +108,11 @@ sealed class NettyTransport(threads: Int) {
val name = SystemPropertyUtil.get("os.name").toLowerCase(Locale.UK).trim { it <= ' ' } val name = SystemPropertyUtil.get("os.name").toLowerCase(Locale.UK).trim { it <= ' ' }
val threadsToUse = if (threads == 0) defaultNumThreads() else threads val threadsToUse = if (threads == 0) defaultNumThreads() else threads
LOGGER.info { "Choosing a transport using $threadsToUse" }
if (name.startsWith("linux")) { if (name.startsWith("linux")) {
if (IOUring.isAvailable()) { if (IOUring.isAvailable()) {
LOGGER.info("Using IOUring transport") LOGGER.info { "Using IOUring transport" }
return IOUringTransport(threadsToUse) return IOUringTransport(threadsToUse)
} else { } else {
LOGGER.info(IOUring.unavailabilityCause()) { LOGGER.info(IOUring.unavailabilityCause()) {
@ -119,7 +121,7 @@ sealed class NettyTransport(threads: Int) {
} }
if (Epoll.isAvailable()) { if (Epoll.isAvailable()) {
LOGGER.info("Using Epoll transport") LOGGER.info { "Using Epoll transport" }
return EpollTransport(threadsToUse) return EpollTransport(threadsToUse)
} else { } else {
LOGGER.info(Epoll.unavailabilityCause()) { LOGGER.info(Epoll.unavailabilityCause()) {
@ -128,7 +130,7 @@ sealed class NettyTransport(threads: Int) {
} }
} }
LOGGER.info("Using Nio transport") LOGGER.info { "Using Nio transport" }
return NioTransport(threadsToUse) return NioTransport(threadsToUse)
} }
} }

View file

@ -249,8 +249,8 @@ fun getServer(
) )
.setConnectionManager( .setConnectionManager(
PoolingHttpClientConnectionManagerBuilder.create() PoolingHttpClientConnectionManagerBuilder.create()
.setMaxConnTotal(3000) .setMaxConnTotal(500)
.setMaxConnPerRoute(100) .setMaxConnPerRoute(500)
.build() .build()
) )
.build() .build()