diff --git a/elements/tcpudp/fastudpflows.cc b/elements/tcpudp/fastudpflows.cc index 8160fd4e2a1736147d6844cd7fd89799549b7039..97431b0b01112813913cc58e25213cc53ca9818a 100644 --- a/elements/tcpudp/fastudpflows.cc +++ b/elements/tcpudp/fastudpflows.cc @@ -69,6 +69,7 @@ FastUDPFlows::configure(Vector<String> &conf, ErrorHandler *errh) .read_mp("DSTIP", _dipaddr) .read_mp("FLOWS", _nflows) .read_mp("FLOWSIZE", _flowsize) + .read_or_set("BURST", _burst, 32) .read_or_set("FLOWBURST", _flowburst, 1) .read_or_set("CHECKSUM", _cksum, true) .read_or_set("SEQUENTIAL", _sequential, false) @@ -203,7 +204,7 @@ FastUDPFlows::run_task(Task* t) { } #if HAVE_BATCH if (in_batch_mode) { - const unsigned int max = 32; + const unsigned int max = _burst; PacketBatch *batch; MAKE_BATCH(get_p(), batch, max); if (likely(batch)) { diff --git a/elements/tcpudp/fastudpflows.hh b/elements/tcpudp/fastudpflows.hh index b35f0aedf0250ba4ee621c5f757ebd35a1eb172e..8fe2f0acda104c07d5b26dfe1752d7096b5d9574 100644 --- a/elements/tcpudp/fastudpflows.hh +++ b/elements/tcpudp/fastudpflows.hh @@ -105,6 +105,7 @@ class FastUDPFlows : public BatchElement { unsigned int _nflows; unsigned int _flowsize; unsigned int _flowburst; + unsigned int _burst; bool _cksum; bool _sequential; bool _duplicate;