Sha256: cdc824727b847782d886c25324e10f0bc5c5aa3ed0805a1af1b9b2e3af84e89f
Contents?: true
Size: 1.53 KB
Versions: 8
Compression:
Stored size: 1.53 KB
Contents
package http_parser.lolevel;
import java.nio.*;
import static http_parser.lolevel.Util.*;
public class TestNoOverflowLongBody {
public static void test (http_parser.ParserType type, int len) {
HTTPParser parser = new HTTPParser(type);
ByteBuffer buf = getBytes(type, len);
int buflen = buf.limit();
parser.execute(Util.SETTINGS_NULL, buf);
check(buflen == buf.position());
buf = buffer("a");
buflen = buf.limit();
for (int i = 0; i!= len; ++i) {
parser.execute(Util.SETTINGS_NULL, buf);
check(buflen == buf.position());
buf.rewind();
}
buf = getBytes(type, len);
buflen = buf.limit();
parser.execute(Util.SETTINGS_NULL, buf);
check(buflen == buf.position());
}
static ByteBuffer getBytes (http_parser.ParserType type, int length) {
if (http_parser.ParserType.HTTP_BOTH == type) {
throw new RuntimeException("only HTTP_REQUEST and HTTP_RESPONSE");
}
String template = "%s\r\nConnection: Keep-Alive\r\nContent-Length: %d\r\n\r\n";
String str = null;
if (http_parser.ParserType.HTTP_REQUEST == type) {
str = String.format(template, "GET / HTTP/1.1", length);
} else {
str = String.format(template, "HTTP/1.0 200 OK", length);
}
return buffer(str);
}
public static void test () {
test(http_parser.ParserType.HTTP_REQUEST, 1000);
test(http_parser.ParserType.HTTP_REQUEST, 100000);
test(http_parser.ParserType.HTTP_RESPONSE, 1000);
test(http_parser.ParserType.HTTP_RESPONSE, 100000);
}
}
Version data entries
8 entries across 8 versions & 1 rubygems