I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Commit 60e25b98 authored by zzz's avatar zzz
Browse files

dont use stream method to avoid data copy

parent 474909ae
No related branches found
No related tags found
No related merge requests found
package net.i2p.router.transport; package net.i2p.router.transport;
import java.io.ByteArrayInputStream;
import java.io.IOException; import java.io.IOException;
import java.io.OutputStream; import java.io.OutputStream;
import java.io.Writer; import java.io.Writer;
...@@ -110,7 +109,7 @@ public class VMCommSystem extends CommSystemFacade { ...@@ -110,7 +109,7 @@ public class VMCommSystem extends CommSystemFacade {
public void runJob() { public void runJob() {
I2NPMessageHandler handler = new I2NPMessageHandler(_ctx); I2NPMessageHandler handler = new I2NPMessageHandler(_ctx);
try { try {
I2NPMessage msg = handler.readMessage(new ByteArrayInputStream(_msg)); I2NPMessage msg = handler.readMessage(_msg);
int size = _msg.length; int size = _msg.length;
_ctx.profileManager().messageReceived(_from, "vm", 1, size); _ctx.profileManager().messageReceived(_from, "vm", 1, size);
_ctx.statManager().addRateData("transport.receiveMessageSize", size, 1); _ctx.statManager().addRateData("transport.receiveMessageSize", size, 1);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment