Browse Source

Merge branch 'master' of github.com:mrniko/netty-socketio

master
Nikita 9 years ago
parent
commit
213cf8ee9e
  1. 4
      README.md
  2. 6
      src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java

4
README.md

@ -1,4 +1,6 @@
#Netty-socketio Overview
Netty-socketio Overview
===
[![Maven Central](https://img.shields.io/maven-central/v/com.corundumstudio.socketio/netty-socketio.svg?style=flat-square)](https://maven-badges.herokuapp.com/maven-central/com.corundumstudio.socketio/netty-socketio/)
This project is an open-source Java implementation of [Socket.IO](http://socket.io/) server. Based on [Netty](http://netty.io/) server framework.

6
src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java

@ -252,7 +252,11 @@ public class PacketDecoder {
ByteBuf scanValue = Unpooled.copiedBuffer("{\"_placeholder\":true,\"num\":" + i + "}", CharsetUtil.UTF_8);
int pos = PacketEncoder.find(source, scanValue);
if (pos == -1) {
throw new IllegalStateException("Can't find attachment by index: " + i + " in packet source");
scanValue = Unpooled.copiedBuffer("{\"num\":" + i + ",\"_placeholder\":true}", CharsetUtil.UTF_8);
pos = PacketEncoder.find(source, scanValue);
if (pos == -1) {
throw new IllegalStateException("Can't find attachment by index: " + i + " in packet source");
}
}
ByteBuf prefixBuf = source.slice(source.readerIndex(), pos - source.readerIndex());

Loading…
Cancel
Save