Фикс склеивания пакетов
This commit is contained in:
@@ -60,7 +60,7 @@ public class StreamOptimizer {
|
|||||||
if (packetsInRow > 1) {
|
if (packetsInRow > 1) {
|
||||||
compress(start, i);
|
compress(start, i);
|
||||||
|
|
||||||
i++; // продвигаем указатель на следующий после склеенного блок TODO проверить работу этого
|
i = start + 1; // продвигаем указатель на следующий после склеенного блок
|
||||||
}
|
}
|
||||||
start = i;
|
start = i;
|
||||||
packetsInRow = 1;
|
packetsInRow = 1;
|
||||||
|
|||||||
@@ -13,7 +13,12 @@ import static org.junit.jupiter.api.Assertions.*;
|
|||||||
class StreamOptimizerTest {
|
class StreamOptimizerTest {
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testUrldecodeRequests() {
|
void testUnpackGzip() {
|
||||||
|
//TODO
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void testUrldecodeRequests() {
|
||||||
CtfService service = new CtfService();
|
CtfService service = new CtfService();
|
||||||
service.setUrldecodeHttpRequests(true);
|
service.setUrldecodeHttpRequests(true);
|
||||||
|
|
||||||
@@ -27,7 +32,7 @@ class StreamOptimizerTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testMergeAdjacentPackets() {
|
void testMergeAdjacentPackets() {
|
||||||
CtfService service = new CtfService();
|
CtfService service = new CtfService();
|
||||||
service.setMergeAdjacentPackets(true);
|
service.setMergeAdjacentPackets(true);
|
||||||
|
|
||||||
@@ -49,7 +54,9 @@ class StreamOptimizerTest {
|
|||||||
new StreamOptimizer(service, list).optimizeStream();
|
new StreamOptimizer(service, list).optimizeStream();
|
||||||
|
|
||||||
assertEquals(4, list.size());
|
assertEquals(4, list.size());
|
||||||
//TODO
|
assertEquals(2, list.get(1).getContent().length);
|
||||||
|
assertEquals(1, list.get(2).getContent().length);
|
||||||
|
assertEquals(2, list.get(3).getContent().length);
|
||||||
}
|
}
|
||||||
|
|
||||||
private Packet createPacket(int content, boolean incoming) {
|
private Packet createPacket(int content, boolean incoming) {
|
||||||
|
|||||||
Reference in New Issue
Block a user