terribleplan/mangadex_at_home
1
0
Fork 0
forked from gitlab-com-mangadex-pub/mangadex_at_home
Code Issues Pull requests Releases Wiki Activity

Rc12 bonanza - fix hourly refresh bug, bump version number

Browse source
This commit is contained in:
carbotaniuman 2020-06-11 22:02:59 -05:00
parent fede53f570
commit 07ff969422
3 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
build.gradle
View file

@ -7,7 +7,7 @@ plugins {
} }
group = "com.mangadex" group = "com.mangadex"
version = "1.0.0-rc10" version = "1.0.0-rc12"
mainClassName = "mdnet.base.MangaDexClient" mainClassName = "mdnet.base.MangaDexClient"
repositories { repositories {

10
src/main/java/mdnet/base/MangaDexClient.java
View file

@ -84,6 +84,11 @@ public class MangaDexClient {
counter.set(num + 1); counter.set(num + 1);
} }
// if the server is offline then don't try and refresh certs
if (engine == null) {
return;
}
if (clientSettings.getMaxBandwidthMibPerHour() != 0 && clientSettings.getMaxBandwidthMibPerHour() * 1024 if (clientSettings.getMaxBandwidthMibPerHour() != 0 && clientSettings.getMaxBandwidthMibPerHour() * 1024
* 1024 /* MiB to bytes */ < statistics.get().getBytesSent().get()) { * 1024 /* MiB to bytes */ < statistics.get().getBytesSent().get()) {
if (LOGGER.isInfoEnabled()) { if (LOGGER.isInfoEnabled()) {
@ -95,11 +100,6 @@ public class MangaDexClient {
} }
} }
// if the server is offline then don't try and refresh certs
if (engine == null) {
return;
}
ServerSettings n = serverHandler.pingControl(serverSettings); ServerSettings n = serverHandler.pingControl(serverSettings);
if (LOGGER.isInfoEnabled()) { if (LOGGER.isInfoEnabled()) {

6
src/main/kotlin/mdnet/base/Application.kt
View file

@ -39,7 +39,6 @@ import javax.crypto.CipherOutputStream
import javax.crypto.spec.SecretKeySpec import javax.crypto.spec.SecretKeySpec
private val LOGGER = LoggerFactory.getLogger("Application") private val LOGGER = LoggerFactory.getLogger("Application")
private val THREADS_TO_ALLOCATE = 65535 // Have it at the maximum open sockets a user can have in most modern OSes. No reason to limit this, just limit it at the Netty side.
fun getServer(cache: DiskLruCache, serverSettings: ServerSettings, clientSettings: ClientSettings, statistics: AtomicReference<Statistics>): Http4kServer { fun getServer(cache: DiskLruCache, serverSettings: ServerSettings, clientSettings: ClientSettings, statistics: AtomicReference<Statistics>): Http4kServer {
val executor = Executors.newCachedThreadPool() val executor = Executors.newCachedThreadPool()
@ -55,8 +54,9 @@ fun getServer(cache: DiskLruCache, serverSettings: ServerSettings, clientSetting
.setSocketTimeout(3000) .setSocketTimeout(3000)
.setConnectionRequestTimeout(3000) .setConnectionRequestTimeout(3000)
.build()) .build())
.setMaxConnTotal(THREADS_TO_ALLOCATE) .setMaxConnTotal(65535)
.setMaxConnPerRoute(THREADS_TO_ALLOCATE) .setMaxConnPerRoute(65535)
// Have it at the maximum open sockets a user can have in most modern OSes. No reason to limit this, just limit it at the Netty side.
.build()) .build())
val app = { dataSaver: Boolean -> val app = { dataSaver: Boolean ->