uint64_t key; /* del */
};
+/* Flag used to temporarily pause data consumption from testpoints. */
int data_consumption_paused;
/*
goto end;
}
+ if (caa_unlikely(data_consumption_paused)) {
+ DBG("Data consumption paused, sleeping...");
+ sleep(1);
+ goto restart;
+ }
+
/*
* If the consumer_data_pipe triggered poll go directly to the
* beginning of the loop to update the array. We want to prioritize