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

tabs -> spaces

Browse Source
This commit is contained in:
Zlatin Balevsky
2019-07-05 16:22:34 +01:00
parent 39808302df
commit 94bb7022eb
71 changed files with 3652 additions and 3652 deletions
Download Patch File Download Diff File Expand all files Collapse all files

74
pinger/src/main/groovy/com/muwire/pinger/Pinger.groovy
View File

@ -34,52 +34,52 @@ public class Pinger {
def session = i2pClient.createSession(bais, props)
session.addMuxedSessionListener(new Listener(),
I2PSession.PROTO_DATAGRAM, I2PSession.PORT_ANY)
session.addMuxedSessionListener(new Listener(),
I2PSession.PROTO_DATAGRAM, I2PSession.PORT_ANY)
session.connect()
def maker = new I2PDatagramMaker(session)
payload = maker.makeI2PDatagram(payload)
session.sendMessage(target, payload, I2PSession.PROTO_DATAGRAM, 0, 0)
println "Sent message, going to sleep"
Thread.sleep(Integer.MAX_VALUE)
println "Sent message, going to sleep"
Thread.sleep(Integer.MAX_VALUE)
}
static class Listener implements I2PSessionMuxedListener {
static class Listener implements I2PSessionMuxedListener {
@Override
public void messageAvailable(I2PSession session, int msgId, long size) {
}
@Override
public void messageAvailable(I2PSession session, int msgId, long size) {
}
@Override
public void messageAvailable(I2PSession session, int msgId, long size, int proto, int fromport, int toport) {
def payload = session.receiveMessage(msgId)
def dissector = new I2PDatagramDissector()
try {
dissector.loadI2PDatagram(payload)
def sender = dissector.getSender().toBase32()
payload = new String(dissector.getPayload())
println "From $sender received $payload"
} catch (Exception e) {
e.printStackTrace()
}
}
@Override
public void messageAvailable(I2PSession session, int msgId, long size, int proto, int fromport, int toport) {
def payload = session.receiveMessage(msgId)
def dissector = new I2PDatagramDissector()
try {
dissector.loadI2PDatagram(payload)
def sender = dissector.getSender().toBase32()
payload = new String(dissector.getPayload())
println "From $sender received $payload"
} catch (Exception e) {
e.printStackTrace()
}
}
@Override
public void reportAbuse(I2PSession session, int severity) {
println "abuse $severity"
}
@Override
public void reportAbuse(I2PSession session, int severity) {
println "abuse $severity"
}
@Override
public void disconnected(I2PSession session) {
println "disconnected"
}
@Override
public void disconnected(I2PSession session) {
println "disconnected"
}
@Override
public void errorOccurred(I2PSession session, String message, Throwable error) {
println "Error $message $error"
}
}
@Override
public void errorOccurred(I2PSession session, String message, Throwable error) {
println "Error $message $error"
}
}
}