diff options
Diffstat (limited to 'src/org/traccar/protocol')
-rw-r--r-- | src/org/traccar/protocol/EnforaProtocolDecoder.java | 32 | ||||
-rw-r--r-- | src/org/traccar/protocol/XexunFrameDecoder.java | 38 |
2 files changed, 6 insertions, 64 deletions
diff --git a/src/org/traccar/protocol/EnforaProtocolDecoder.java b/src/org/traccar/protocol/EnforaProtocolDecoder.java index 2910108a5..3b41592ea 100644 --- a/src/org/traccar/protocol/EnforaProtocolDecoder.java +++ b/src/org/traccar/protocol/EnforaProtocolDecoder.java @@ -24,6 +24,7 @@ import org.jboss.netty.buffer.ChannelBuffer; import org.jboss.netty.channel.Channel; import org.jboss.netty.channel.ChannelHandlerContext; import org.traccar.GenericProtocolDecoder; +import org.traccar.helper.ChannelBufferTools; import org.traccar.helper.Log; import org.traccar.model.DataManager; import org.traccar.model.Position; @@ -58,35 +59,6 @@ public class EnforaProtocolDecoder extends GenericProtocolDecoder { public static final int IMEI_LENGTH = 15; - // TODO: avoid copy-paste (from XexunFrameDecoder) - private static Integer find( - ChannelBuffer buf, - Integer start, - Integer length, - String subString) { - - int index = start; - boolean match; - - for (; index < length; index++) { - match = true; - - for (int i = 0; i < subString.length(); i++) { - char c = (char) buf.getByte(index + i); - if (c != subString.charAt(i)) { - match = false; - break; - } - } - - if (match) { - return index; - } - } - - return null; - } - /** * Decode message */ @@ -117,7 +89,7 @@ public class EnforaProtocolDecoder extends GenericProtocolDecoder { } // Find GPSMC string - Integer start = find(buf, 0, buf.readableBytes(), "GPRMC"); + Integer start = ChannelBufferTools.find(buf, 0, buf.readableBytes(), "GPRMC"); if (start == null) { // Message does not contain GPS data return null; diff --git a/src/org/traccar/protocol/XexunFrameDecoder.java b/src/org/traccar/protocol/XexunFrameDecoder.java index 39bbc66dc..726ca5e1f 100644 --- a/src/org/traccar/protocol/XexunFrameDecoder.java +++ b/src/org/traccar/protocol/XexunFrameDecoder.java @@ -19,40 +19,10 @@ import org.jboss.netty.buffer.ChannelBuffer; import org.jboss.netty.channel.Channel; import org.jboss.netty.channel.ChannelHandlerContext; import org.jboss.netty.handler.codec.frame.FrameDecoder; +import org.traccar.helper.ChannelBufferTools; public class XexunFrameDecoder extends FrameDecoder { - /** - * Find string in network buffer - */ - private static Integer find( - ChannelBuffer buf, - Integer start, - Integer length, - String subString) { - - int index = start; - boolean match; - - for (; index < length; index++) { - match = true; - - for (int i = 0; i < subString.length(); i++) { - char c = (char) buf.getByte(index + i); - if (c != subString.charAt(i)) { - match = false; - break; - } - } - - if (match) { - return index; - } - } - - return null; - } - protected Object decode( ChannelHandlerContext ctx, Channel channel, @@ -65,19 +35,19 @@ public class XexunFrameDecoder extends FrameDecoder { } // Find start - Integer beginIndex = find(buf, 0, length, "GPRMC"); + Integer beginIndex = ChannelBufferTools.find(buf, 0, length, "GPRMC"); if (beginIndex == null) { return null; } // Find identifier - Integer idIndex = find(buf, beginIndex, length, "imei:"); + Integer idIndex = ChannelBufferTools.find(buf, beginIndex, length, "imei:"); if (idIndex == null) { return null; } // Find end - Integer endIndex = find(buf, idIndex, length, ","); + Integer endIndex = ChannelBufferTools.find(buf, idIndex, length, ","); if (endIndex == null) { return null; } |