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

outgoing connections are never to leafs

Browse Source
This commit is contained in:
Zlatin Balevsky
2018-07-26 18:43:09 +01:00
parent 3b616b8947
commit 7c0f5b4e88
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/main/groovy/com/muwire/core/connection/ConnectionEstablisher.groovy
View File

@@ -118,7 +118,7 @@ class ConnectionEstablisher {
private void fail(Endpoint endpoint) { private void fail(Endpoint endpoint) {
endpoint.close() endpoint.close()
eventBus.publish(new ConnectionEvent(endpoint: endpoint, incoming: false, status: ConnectionAttemptStatus.FAILED)) eventBus.publish(new ConnectionEvent(endpoint: endpoint, incoming: false, leaf: false, status: ConnectionAttemptStatus.FAILED))
} }
private void readK(Endpoint e) { private void readK(Endpoint e) {
@@ -133,7 +133,7 @@ class ConnectionEstablisher {
// wrap into deflater / inflater streams and publish // wrap into deflater / inflater streams and publish
def wrapped = new Endpoint(e.destination, new InflaterInputStream(e.inputStream), new DeflaterOutputStream(e.outputStream)) def wrapped = new Endpoint(e.destination, new InflaterInputStream(e.inputStream), new DeflaterOutputStream(e.outputStream))
eventBus.publish(new ConnectionEvent(endpoint: wrapped, incoming: false, status: ConnectionAttemptStatus.SUCCESSFUL)) eventBus.publish(new ConnectionEvent(endpoint: wrapped, incoming: false, leaf: false, status: ConnectionAttemptStatus.SUCCESSFUL))
} }
private void readEJECT(Endpoint e) { private void readEJECT(Endpoint e) {
@@ -149,7 +149,7 @@ class ConnectionEstablisher {
log.info("connection to ${e.destination.toBase32()} rejected") log.info("connection to ${e.destination.toBase32()} rejected")
eventBus.publish(new ConnectionEvent(endpoint: e, incoming: false, status: ConnectionAttemptStatus.REJECTED)) eventBus.publish(new ConnectionEvent(endpoint: e, incoming: false, leaf: false, status: ConnectionAttemptStatus.REJECTED))
try { try {
DataInputStream dais = new DataInputStream(e.inputStream) DataInputStream dais = new DataInputStream(e.inputStream)
int payloadSize = dais.readUnsignedShort() int payloadSize = dais.readUnsignedShort()