diff options
| author | adrian <adrian@FreeBSD.org> | 2015-02-24 22:17:12 +0000 |
|---|---|---|
| committer | adrian <adrian@FreeBSD.org> | 2015-02-24 22:17:12 +0000 |
| commit | fb45b18a632431fb6067cb119924327d6aaf2783 (patch) | |
| tree | 52cfef9e898c544e5b26d56688d32929fb19abe7 /sys/dev/ixl | |
| parent | 3903a681113acec3726f42bff3025abf877608e5 (diff) | |
| download | FreeBSD-src-fb45b18a632431fb6067cb119924327d6aaf2783.zip FreeBSD-src-fb45b18a632431fb6067cb119924327d6aaf2783.tar.gz | |
Change uses of taskqueue_start_threads_pinned() -> taskqueue_start_threads_cpuset()
Differential Revision: https://reviews.freebsd.org/D1897
Reviewed by: jfv
Diffstat (limited to 'sys/dev/ixl')
| -rwxr-xr-x | sys/dev/ixl/if_ixl.c | 9 | ||||
| -rw-r--r-- | sys/dev/ixl/if_ixlv.c | 9 |
2 files changed, 14 insertions, 4 deletions
diff --git a/sys/dev/ixl/if_ixl.c b/sys/dev/ixl/if_ixl.c index ca34f62..61aef44 100755 --- a/sys/dev/ixl/if_ixl.c +++ b/sys/dev/ixl/if_ixl.c @@ -1880,6 +1880,9 @@ ixl_assign_vsi_msix(struct ixl_pf *pf) struct ixl_queue *que = vsi->queues; struct tx_ring *txr; int error, rid, vector = 0; +#ifdef RSS + cpuset_t cpu_mask; +#endif /* Admin Que is vector 0*/ rid = vector + 1; @@ -1942,8 +1945,10 @@ ixl_assign_vsi_msix(struct ixl_pf *pf) que->tq = taskqueue_create_fast("ixl_que", M_NOWAIT, taskqueue_thread_enqueue, &que->tq); #ifdef RSS - taskqueue_start_threads_pinned(&que->tq, 1, PI_NET, - cpu_id, "%s (bucket %d)", + CPU_ZERO(&cpu_mask); + CPU_SET(cpu_id, &cpu_mask); + taskqueue_start_threads_cpuset(&que->tq, 1, PI_NET, + &cpu_mask, "%s (bucket %d)", device_get_nameunit(dev), cpu_id); #else taskqueue_start_threads(&que->tq, 1, PI_NET, diff --git a/sys/dev/ixl/if_ixlv.c b/sys/dev/ixl/if_ixlv.c index f1e106e..836853f 100644 --- a/sys/dev/ixl/if_ixlv.c +++ b/sys/dev/ixl/if_ixlv.c @@ -1382,6 +1382,9 @@ ixlv_assign_msix(struct ixlv_sc *sc) struct ixl_queue *que = vsi->queues; struct tx_ring *txr; int error, rid, vector = 1; +#ifdef RSS + cpuset_t cpu_mask; +#endif for (int i = 0; i < vsi->num_queues; i++, vector++, que++) { int cpu_id = i; @@ -1416,8 +1419,10 @@ ixlv_assign_msix(struct ixlv_sc *sc) que->tq = taskqueue_create_fast("ixlv_que", M_NOWAIT, taskqueue_thread_enqueue, &que->tq); #ifdef RSS - taskqueue_start_threads_pinned(&que->tq, 1, PI_NET, - cpu_id, "%s (bucket %d)", + CPU_ZERO(&cpu_mask); + CPU_SET(cpu_id, &cpu_mask); + taskqueue_start_threads_cpuset(&que->tq, 1, PI_NET, + &cpu_mask, "%s (bucket %d)", device_get_nameunit(dev), cpu_id); #else taskqueue_start_threads(&que->tq, 1, PI_NET, |
