Method Submit

internal/proxy/pool.go:80–92

Submit adds a packet to the appropriate shard's queue. Uses client address hash for affinity (same client -> same worker). Returns false if queue is full (backpressure).

(item WorkItem)

// Uses client address hash for affinity (same client -> same worker).
// Returns false if queue is full (backpressure).
func (p *WorkerPool) Submit(item WorkItem) bool {
	idx := hashAddr(item.ClientAddr) % uint32(p.workers)
	select {
	case p.queues[idx] <- item:
		return true
	default:
		atomic.AddUint64(&p.dropped[idx], 1)
		if item.Buffer != nil {
			handler.PutBuffer(item.Buffer)
		}
		return false
	}
}

// Dropped returns total dropped packets across all shards.
func (p *WorkerPool) Dropped() uint64 {