Commit 12bcce8d authored by guruhegde's avatar guruhegde

Update test case and test file

parent d957cce9
...@@ -252,7 +252,7 @@ TEST_CASE("input parameter struct type") { ...@@ -252,7 +252,7 @@ TEST_CASE("input parameter struct type") {
TEST_CASE("make fast_flows_packet fn as batched form") { TEST_CASE("make fast_flows_packet fn as batched form") {
std::string filePrefix = "fast_flows"; std::string filePrefix = "fast_flows";
auto M = parseIR(filePrefix + string(".ll"), input_dir); auto M = parseIR(generateIR(filePrefix + string(".c"), input_dir, true), input_dir);
REQUIRE(M != nullptr); REQUIRE(M != nullptr);
M->setSourceFileName(filePrefix + string("_batch.ll")); M->setSourceFileName(filePrefix + string("_batch.ll"));
{ {
......
...@@ -70,7 +70,7 @@ int main() { ...@@ -70,7 +70,7 @@ int main() {
for (int i = 0; i < batch_size; ++i) { for (int i = 0; i < batch_size; ++i) {
if (aptr[i]->field1 != 1 && aptr[i]->field2 != 2) { if (aptr[i]->field1 != 1 && aptr[i]->field2 != 2) {
rc--; return rc; rc--; break;
} }
} }
for (int i = 0; i < batch_size; ++i) { for (int i = 0; i < batch_size; ++i) {
......
...@@ -281,7 +281,7 @@ void fast_flows_packet_pfbufs(struct dataplane_context *ctx, ...@@ -281,7 +281,7 @@ void fast_flows_packet_pfbufs(struct dataplane_context *ctx,
/* Received packet */ /* Received packet */
int fast_flows_packet(struct dataplane_context *ctx, int fast_flows_packet(struct dataplane_context *ctx,
struct network_buf_handle *nbh BATCH_ARG, void *fsp BATCH_ARG, struct tcp_opts *opts BATCH_ARG, struct network_buf_handle *nbh BATCH_ARG, void *fsp BATCH_ARG, struct tcp_opts opts BATCH_ARG,
uint32_t ts) TAS_BLOCK_PREDICATION uint32_t ts) TAS_BLOCK_PREDICATION
{ {
struct pkt_tcp *p; struct pkt_tcp *p;
...@@ -493,11 +493,11 @@ int fast_flows_packet(struct dataplane_context *ctx, ...@@ -493,11 +493,11 @@ int fast_flows_packet(struct dataplane_context *ctx,
#endif #endif
/* update rtt estimate */ /* update rtt estimate */
fs->tx_next_ts = f_beui32(opts->ts->ts_val); fs->tx_next_ts = f_beui32(opts.ts->ts_val);
if (LIKELY((TCPH_FLAGS(&p->tcp) & TCP_ACK) == TCP_ACK && if (LIKELY((TCPH_FLAGS(&p->tcp) & TCP_ACK) == TCP_ACK &&
f_beui32(opts->ts->ts_ecr) != 0)) f_beui32(opts.ts->ts_ecr) != 0))
{ {
rtt = ts - f_beui32(opts->ts->ts_ecr); rtt = ts - f_beui32(opts.ts->ts_ecr);
if (rtt < TCP_MAX_RTT) { if (rtt < TCP_MAX_RTT) {
if (LIKELY(fs->rtt_est != 0)) { if (LIKELY(fs->rtt_est != 0)) {
fs->rtt_est = (fs->rtt_est * 7 + rtt) / 8; fs->rtt_est = (fs->rtt_est * 7 + rtt) / 8;
...@@ -635,7 +635,7 @@ unlock: ...@@ -635,7 +635,7 @@ unlock:
/* if we need to send an ack, also send packet to TX pipeline to do so */ /* if we need to send an ack, also send packet to TX pipeline to do so */
if (trigger_ack) { if (trigger_ack) {
flow_tx_ack(ctx, fs->tx_next_seq, fs->rx_next_seq, fs->rx_avail, flow_tx_ack(ctx, fs->tx_next_seq, fs->rx_next_seq, fs->rx_avail,
fs->tx_next_ts, ts, nbh, opts->ts); fs->tx_next_ts, ts, nbh, opts.ts);
} }
fs_unlock(fs); fs_unlock(fs);
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment