idk/muwire
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix chained request support

Browse Source
This commit is contained in:
Zlatin Balevsky
2019-05-28 22:51:53 +01:00
parent 960daa2b9f
commit e131a21c6f
1 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
core/src/main/groovy/com/muwire/core/upload/UploadManager.groovy
View File

@@ -22,9 +22,21 @@ public class UploadManager {
} }
public void processEndpoint(Endpoint e) throws IOException { public void processEndpoint(Endpoint e) throws IOException {
byte [] infoHashStringBytes = new byte[44]
DataInputStream dis = new DataInputStream(e.getInputStream())
boolean first = true
while(true) { while(true) {
byte [] infoHashStringBytes = new byte[44] if (first)
DataInputStream dis = new DataInputStream(e.getInputStream()) first = false
else {
byte[] get = new byte[4]
dis.readFully(get)
if (get != "GET ".getBytes(StandardCharsets.US_ASCII)) {
log.warning("received a method other than GET on subsequent call")
e.close()
return
}
}
dis.readFully(infoHashStringBytes) dis.readFully(infoHashStringBytes)
String infoHashString = new String(infoHashStringBytes, StandardCharsets.US_ASCII) String infoHashString = new String(infoHashStringBytes, StandardCharsets.US_ASCII)
log.info("Responding to upload request for root $infoHashString") log.info("Responding to upload request for root $infoHashString")