diff options
Diffstat (limited to 'dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/JsonHttpListener.java')
-rw-r--r-- | dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/JsonHttpListener.java | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/JsonHttpListener.java b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/JsonHttpListener.java index 55c09756..cec5dd5f 100644 --- a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/JsonHttpListener.java +++ b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/JsonHttpListener.java @@ -57,7 +57,15 @@ public class JsonHttpListener extends NanoHTTPD { return new Response(Response.Status.BAD_REQUEST, "text/plain; charset=UTF-8", "No Content-Length provided"); - byte[] buffer = session.getInputStream().readNBytes(len); + byte[] buffer = new byte[len]; + int pos = 0; + while (pos < len) { + int ret = session.getInputStream().read(buffer, pos, len - pos); + if (ret <= 0) + return new Response(Response.Status.BAD_REQUEST, "text/plain; charset=UTF-8", + "Request content truncated (" + pos + "/" + len + ")"); + pos += ret; + } TMemoryBuffer inbuffer = new TMemoryBuffer(buffer.length); inbuffer.write(buffer); TProtocol inprotocol = new TJSONProtocol(inbuffer); |