diff options
| author | Anton Tananaev <anton.tananaev@gmail.com> | 2017-01-12 02:37:54 +1300 |
|---|---|---|
| committer | Anton Tananaev <anton.tananaev@gmail.com> | 2017-01-12 01:37:54 +1300 |
| commit | ca8397232467ca70db44b3b3b089409f7e9ee21a (patch) | |
| tree | 20c9c8f40c8a0228b6be608b1f7c7fb2a84a9342 /src/org/traccar | |
| parent | c03df5359224d86c8d1069872ddae52c0c35c225 (diff) | |
| download | trackermap-server-ca8397232467ca70db44b3b3b089409f7e9ee21a.tar.gz trackermap-server-ca8397232467ca70db44b3b3b089409f7e9ee21a.tar.bz2 trackermap-server-ca8397232467ca70db44b3b3b089409f7e9ee21a.zip | |
Avoid sending duplicate acks
Diffstat (limited to 'src/org/traccar')
| -rw-r--r-- | src/org/traccar/protocol/At2000FrameDecoder.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/org/traccar/protocol/At2000FrameDecoder.java b/src/org/traccar/protocol/At2000FrameDecoder.java index 4c849afb7..f87dc3885 100644 --- a/src/org/traccar/protocol/At2000FrameDecoder.java +++ b/src/org/traccar/protocol/At2000FrameDecoder.java @@ -30,6 +30,9 @@ public class At2000FrameDecoder extends FrameDecoder { private boolean firstPacket = true; + private ChannelBuffer currentBuffer; + private int acknowledgedBytes; + private void sendResponse(Channel channel) { if (channel != null) { ChannelBuffer response = ChannelBuffers.directBuffer(ByteOrder.LITTLE_ENDIAN, 2 * BLOCK_LENGTH); @@ -63,7 +66,11 @@ public class At2000FrameDecoder extends FrameDecoder { } if (buf.readableBytes() >= length || buf.readableBytes() % ACK_LENGTH == 0) { - sendResponse(channel); + if (buf != currentBuffer || buf.readableBytes() > acknowledgedBytes) { + sendResponse(channel); + currentBuffer = buf; + acknowledgedBytes = buf.readableBytes(); + } } if (buf.readableBytes() >= length) { |