MAX_FLOWS
if (!CIRC_SPACE(req->setup_head, clear_tail, MAX_FLOWS) ||
CIRC_CNT(req->setup_head, clear_tail, MAX_FLOWS) >=
req->setup_head = (req->setup_head + 1) & (MAX_FLOWS - 1);
if (!CIRC_CNT(req->setup_head, req->clear_tail, MAX_FLOWS))
req->clear_tail = (req->clear_tail + 1) & (MAX_FLOWS - 1);
while (CIRC_CNT(req->setup_head, req->clear_tail, MAX_FLOWS)) {
flows = kmalloc_node(MAX_FLOWS * sizeof(*flows), gfp,
for (i = 0; i < MAX_FLOWS; i++) {
for ( ; CIRC_CNT(head, tail, MAX_FLOWS);
tail = CIRC_NEXT(tail, MAX_FLOWS)) {
req->flow_idx = (req->flow_idx + 1) & (MAX_FLOWS - 1);
req->setup_head = (req->setup_head + 1) & (MAX_FLOWS - 1);
if (CIRC_CNT(req->flow_idx, req->clear_tail, MAX_FLOWS)) {
MAX_FLOWS);
MAX_FLOWS);
MAX_FLOWS)) {
MAX_FLOWS);
(MAX_FLOWS - 1);
fidx = CIRC_NEXT(fidx, MAX_FLOWS);
for (; CIRC_CNT(req->setup_head, fidx, MAX_FLOWS);
fidx = CIRC_NEXT(fidx, MAX_FLOWS)) {
MAX_FLOWS)) {
to_seg = MAX_FLOWS >> 1;
req->flow_idx = CIRC_NEXT(req->flow_idx, MAX_FLOWS);
req->flow_idx = CIRC_NEXT(req->flow_idx, MAX_FLOWS);
if (!CIRC_CNT(req->setup_head, req->flow_idx, MAX_FLOWS))
if (!CIRC_SPACE(req->setup_head, req->acked_tail, MAX_FLOWS))
req->setup_head = CIRC_NEXT(req->setup_head, MAX_FLOWS);
req->acked_tail = CIRC_NEXT(req->acked_tail, MAX_FLOWS);
MAX_FLOWS);
fidx = CIRC_NEXT(fidx, MAX_FLOWS)) {
MAX_FLOWS);
flow_idx = CIRC_NEXT(flow_idx, MAX_FLOWS)) {
MAX_FLOWS);
MAX_FLOWS))
MAX_FLOWS));
MAX_FLOWS);
flow = CIRC_PREV(req->acked_tail, MAX_FLOWS);
PUT_TXQVAL_U32(MAX_FLOWS, max_flows);
static int ntuple_ids[MAX_FLOWS] = { -1, -1, -1, -1, -1, -1, -1, -1, };
for (flow_idx = 0; flow_idx < MAX_FLOWS; flow_idx++)
if (flow_idx == MAX_FLOWS) {
for (i = 0; i < MAX_FLOWS; i++) {