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

OutputStream.write

Browse Source
This commit is contained in:
Zlatin Balevsky
2019-11-08 07:47:11 +00:00
parent d842e3f2f2
commit f95e9450f3
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
core/src/main/groovy/com/muwire/core/connection/ConnectionAcceptor.groovy
View File

@@ -399,7 +399,7 @@ class ConnectionAcceptor {
DataOutputStream dos = new DataOutputStream(os)
if (!json) {
os.write("\r\n")
os.write("\r\n".getBytes(StandardCharsets.US_ASCII))
int size = Math.min(Short.MAX_VALUE * 2, good.size())
good = good.subList(0, size)
dos.writeShort(size)
@@ -414,10 +414,10 @@ class ConnectionAcceptor {
it.persona.write(dos)
}
} else {
dos.write("Json: true\r\n")
dos.write("Good:${good.size()}\r\n")
dos.write("Bad:${bad.size()}\r\n")
dos.write("\r\n")
dos.write("Json: true\r\n".getBytes(StandardCharsets.US_ASCII))
dos.write("Good:${good.size()}\r\n".getBytes(StandardCharsets.US_ASCII))
dos.write("Bad:${bad.size()}\r\n".getBytes(StandardCharsets.US_ASCII))
dos.write("\r\n".getBytes(StandardCharsets.US_ASCII))
good.each {
def obj = [:]

4
core/src/main/groovy/com/muwire/core/trust/TrustSubscriber.groovy
View File

@@ -113,8 +113,8 @@ class TrustSubscriber {
OutputStream os = endpoint.getOutputStream()
InputStream is = endpoint.getInputStream()
os.write("TRUST\r\n".getBytes(StandardCharsets.US_ASCII))
os.write("Json:true\r\n")
os.write("\r\n")
os.write("Json:true\r\n".getBytes(StandardCharsets.US_ASCII))
os.write("\r\n".getBytes(StandardCharsets.US_ASCII))
os.flush()
String codeString = DataUtil.readTillRN(is)