synchronize datagram maker in I2PSinks
This commit is contained in:
@ -37,9 +37,11 @@ public class I2PSink implements Sink {
|
||||
//System.out.print("w");
|
||||
// create payload
|
||||
byte[] payload;
|
||||
if(!this.raw)
|
||||
if(!this.raw) {
|
||||
synchronized(this.maker) {
|
||||
payload = this.maker.makeI2PDatagram(data);
|
||||
else
|
||||
}
|
||||
} else
|
||||
payload = data;
|
||||
|
||||
// send message
|
||||
|
@ -35,9 +35,11 @@ public class I2PSinkAnywhere implements Sink {
|
||||
public synchronized void send(Destination to, byte[] data) {
|
||||
// create payload
|
||||
byte[] payload;
|
||||
if(!this.raw)
|
||||
if(!this.raw) {
|
||||
synchronized(this.maker) {
|
||||
payload = this.maker.makeI2PDatagram(data);
|
||||
else
|
||||
}
|
||||
} else
|
||||
payload = data;
|
||||
|
||||
// send message
|
||||
|
Reference in New Issue
Block a user