From 83950473869967a3e7384d456cfe09a5d8e800b6 Mon Sep 17 00:00:00 2001 From: Zlatin Balevsky Date: Sat, 19 Oct 2019 17:59:08 +0100 Subject: [PATCH] compress results in browse connections --- .../com/muwire/core/connection/ConnectionAcceptor.groovy | 3 ++- .../main/groovy/com/muwire/core/search/BrowseManager.groovy | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/core/src/main/groovy/com/muwire/core/connection/ConnectionAcceptor.groovy b/core/src/main/groovy/com/muwire/core/connection/ConnectionAcceptor.groovy index d1591c27..c00902d1 100644 --- a/core/src/main/groovy/com/muwire/core/connection/ConnectionAcceptor.groovy +++ b/core/src/main/groovy/com/muwire/core/connection/ConnectionAcceptor.groovy @@ -5,6 +5,7 @@ import java.util.concurrent.ExecutorService import java.util.concurrent.Executors import java.util.logging.Level import java.util.zip.DeflaterOutputStream +import java.util.zip.GZIPOutputStream import java.util.zip.InflaterInputStream import com.muwire.core.EventBus @@ -279,7 +280,7 @@ class ConnectionAcceptor { os.write("Count: ${sharedFiles.size()}\r\n\r\n".getBytes(StandardCharsets.US_ASCII)) - DataOutputStream dos = new DataOutputStream(os) + DataOutputStream dos = new DataOutputStream(new GZIPOutputStream(os)) JsonOutput jsonOutput = new JsonOutput() sharedFiles.each { def obj = ResultsSender.sharedFileToObj(it, false) diff --git a/core/src/main/groovy/com/muwire/core/search/BrowseManager.groovy b/core/src/main/groovy/com/muwire/core/search/BrowseManager.groovy index 88fa1e83..f2d50401 100644 --- a/core/src/main/groovy/com/muwire/core/search/BrowseManager.groovy +++ b/core/src/main/groovy/com/muwire/core/search/BrowseManager.groovy @@ -13,6 +13,7 @@ import java.nio.charset.StandardCharsets import java.util.concurrent.Executor import java.util.concurrent.Executors import java.util.logging.Level +import java.util.zip.GZIPInputStream @Log class BrowseManager { @@ -62,7 +63,7 @@ class BrowseManager { eventBus.publish(new BrowseStatusEvent(status : BrowseStatus.FETCHING)) JsonSlurper slurper = new JsonSlurper() - DataInputStream dis = new DataInputStream(is) + DataInputStream dis = new DataInputStream(new GZIPInputStream(is)) UUID uuid = UUID.randomUUID() for (int i = 0; i < results; i++) { int size = dis.readUnsignedShort()