image/svg+xml
test: order_queue
producer_flow_seq
producer maintains per flow sequence number
flow 0
flow 1
flow 2
flow n
producer0
ordered queue 0
atomic queue 1
worker 0
port n+1
worker 1
worker 2
worker n
port 0
port 1
port 2
port n
expected_flow_seq
per flow expected sequence number
flow 0
flow 1
flow 2
flow n
enqueue ordered flow(step 1)
produce ordered flows(step 0)
dequeue_ordered_flow(step 2)
change to atomic flow and enqueue(step 3)
dequeue_atomic_flow (step 4)