Lines Matching refs:t
235 #define if_lock(t) mutex_lock(&(t->if_lock)); argument
236 #define if_unlock(t) mutex_unlock(&(t->if_lock)); argument
478 static int pktgen_remove_device(struct pktgen_thread *t, struct pktgen_dev *i);
479 static int pktgen_add_device(struct pktgen_thread *t, const char *ifname);
480 static struct pktgen_dev *pktgen_find_dev(struct pktgen_thread *t,
487 static void pktgen_stop(struct pktgen_thread *t);
1826 struct pktgen_thread *t = seq->private; in pktgen_thread_show() local
1829 BUG_ON(!t); in pktgen_thread_show()
1834 list_for_each_entry_rcu(pkt_dev, &t->if_list, list) in pktgen_thread_show()
1840 list_for_each_entry_rcu(pkt_dev, &t->if_list, list) in pktgen_thread_show()
1844 if (t->result[0]) in pktgen_thread_show()
1845 seq_printf(seq, "\nResult: %s\n", t->result); in pktgen_thread_show()
1859 struct pktgen_thread *t = seq->private; in pktgen_thread_write() local
1897 if (!t) { in pktgen_thread_write()
1903 pg_result = &(t->result[0]); in pktgen_thread_write()
1917 ret = pktgen_add_device(t, f); in pktgen_thread_write()
1929 t->control |= T_REMDEVALL; in pktgen_thread_write()
1965 struct pktgen_thread *t; in __pktgen_NN_threads() local
1969 list_for_each_entry(t, &pn->pktgen_threads, th_list) { in __pktgen_NN_threads()
1970 pkt_dev = pktgen_find_dev(t, ifname, exact); in __pktgen_NN_threads()
1974 t->control |= T_REMDEV; in __pktgen_NN_threads()
2019 struct pktgen_thread *t; in pktgen_change_name() local
2023 list_for_each_entry(t, &pn->pktgen_threads, th_list) { in pktgen_change_name()
2026 if_lock(t); in pktgen_change_name()
2027 list_for_each_entry(pkt_dev, &t->if_list, list) { in pktgen_change_name()
2042 if_unlock(t); in pktgen_change_name()
2263 struct hrtimer_sleeper t; in spin() local
2265 hrtimer_init_sleeper_on_stack(&t, CLOCK_MONOTONIC, HRTIMER_MODE_ABS); in spin()
2266 hrtimer_set_expires(&t.timer, spin_until); in spin()
2268 remaining = ktime_to_ns(hrtimer_expires_remaining(&t.timer)); in spin()
2281 hrtimer_sleeper_start_expires(&t, HRTIMER_MODE_ABS); in spin()
2283 if (likely(t.task)) in spin()
2286 hrtimer_cancel(&t.timer); in spin()
2287 } while (t.task && pkt_dev->running && !signal_pending(current)); in spin()
2295 destroy_hrtimer_on_stack(&t.timer); in spin()
2379 __u16 t; in set_cur_queue_map() local
2381 t = prandom_u32() % in set_cur_queue_map()
2386 t = pkt_dev->cur_queue_map + 1; in set_cur_queue_map()
2387 if (t > pkt_dev->queue_map_max) in set_cur_queue_map()
2388 t = pkt_dev->queue_map_min; in set_cur_queue_map()
2390 pkt_dev->cur_queue_map = t; in set_cur_queue_map()
2508 __u32 t; in mod_cur_headers() local
2510 t = prandom_u32() % (imx - imn) + imn; in mod_cur_headers()
2512 t = ntohl(pkt_dev->cur_saddr); in mod_cur_headers()
2513 t++; in mod_cur_headers()
2514 if (t > imx) in mod_cur_headers()
2515 t = imn; in mod_cur_headers()
2518 pkt_dev->cur_saddr = htonl(t); in mod_cur_headers()
2527 __u32 t; in mod_cur_headers() local
2532 t = prandom_u32() % in mod_cur_headers()
2534 s = htonl(t); in mod_cur_headers()
2542 t = ntohl(pkt_dev->cur_daddr); in mod_cur_headers()
2543 t++; in mod_cur_headers()
2544 if (t > imx) { in mod_cur_headers()
2545 t = imn; in mod_cur_headers()
2547 pkt_dev->cur_daddr = htonl(t); in mod_cur_headers()
2578 __u32 t; in mod_cur_headers() local
2580 t = prandom_u32() % in mod_cur_headers()
2584 t = pkt_dev->cur_pkt_size + 1; in mod_cur_headers()
2585 if (t > pkt_dev->max_pkt_size) in mod_cur_headers()
2586 t = pkt_dev->min_pkt_size; in mod_cur_headers()
2588 pkt_dev->cur_pkt_size = t; in mod_cur_headers()
2591 __u32 t = prandom_u32() % IMIX_PRECISION; in mod_cur_headers() local
2592 __u8 entry_index = pkt_dev->imix_distribution[t]; in mod_cur_headers()
3137 static void pktgen_run(struct pktgen_thread *t) in pktgen_run() argument
3145 list_for_each_entry_rcu(pkt_dev, &t->if_list, list) { in pktgen_run()
3167 t->control &= ~(T_STOP); in pktgen_run()
3172 struct pktgen_thread *t; in pktgen_handle_all_threads() local
3176 list_for_each_entry(t, &pn->pktgen_threads, th_list) in pktgen_handle_all_threads()
3177 t->control |= (flags); in pktgen_handle_all_threads()
3189 static int thread_is_running(const struct pktgen_thread *t) in thread_is_running() argument
3194 list_for_each_entry_rcu(pkt_dev, &t->if_list, list) in thread_is_running()
3203 static int pktgen_wait_thread_run(struct pktgen_thread *t) in pktgen_wait_thread_run() argument
3205 while (thread_is_running(t)) { in pktgen_wait_thread_run()
3225 struct pktgen_thread *t; in pktgen_wait_all_threads_run() local
3234 list_for_each_entry(t, &pn->pktgen_threads, th_list) { in pktgen_wait_all_threads_run()
3235 sig = pktgen_wait_thread_run(t); in pktgen_wait_all_threads_run()
3241 list_for_each_entry(t, &pn->pktgen_threads, th_list) in pktgen_wait_all_threads_run()
3242 t->control |= (T_STOP); in pktgen_wait_all_threads_run()
3335 static struct pktgen_dev *next_to_run(struct pktgen_thread *t) in next_to_run() argument
3340 list_for_each_entry_rcu(pkt_dev, &t->if_list, list) { in next_to_run()
3353 static void pktgen_stop(struct pktgen_thread *t) in pktgen_stop() argument
3361 list_for_each_entry_rcu(pkt_dev, &t->if_list, list) { in pktgen_stop()
3372 static void pktgen_rem_one_if(struct pktgen_thread *t) in pktgen_rem_one_if() argument
3379 list_for_each_safe(q, n, &t->if_list) { in pktgen_rem_one_if()
3388 pktgen_remove_device(t, cur); in pktgen_rem_one_if()
3394 static void pktgen_rem_all_ifs(struct pktgen_thread *t) in pktgen_rem_all_ifs() argument
3403 list_for_each_safe(q, n, &t->if_list) { in pktgen_rem_all_ifs()
3409 pktgen_remove_device(t, cur); in pktgen_rem_all_ifs()
3413 static void pktgen_rem_thread(struct pktgen_thread *t) in pktgen_rem_thread() argument
3416 remove_proc_entry(t->tsk->comm, t->net->proc_dir); in pktgen_rem_thread()
3605 struct pktgen_thread *t = arg; in pktgen_thread_worker() local
3607 int cpu = t->cpu; in pktgen_thread_worker()
3611 init_waitqueue_head(&t->queue); in pktgen_thread_worker()
3612 complete(&t->start_done); in pktgen_thread_worker()
3619 pkt_dev = next_to_run(t); in pktgen_thread_worker()
3621 if (unlikely(!pkt_dev && t->control == 0)) { in pktgen_thread_worker()
3622 if (t->net->pktgen_exiting) in pktgen_thread_worker()
3624 wait_event_interruptible_timeout(t->queue, in pktgen_thread_worker()
3625 t->control != 0, in pktgen_thread_worker()
3640 if (t->control & T_STOP) { in pktgen_thread_worker()
3641 pktgen_stop(t); in pktgen_thread_worker()
3642 t->control &= ~(T_STOP); in pktgen_thread_worker()
3645 if (t->control & T_RUN) { in pktgen_thread_worker()
3646 pktgen_run(t); in pktgen_thread_worker()
3647 t->control &= ~(T_RUN); in pktgen_thread_worker()
3650 if (t->control & T_REMDEVALL) { in pktgen_thread_worker()
3651 pktgen_rem_all_ifs(t); in pktgen_thread_worker()
3652 t->control &= ~(T_REMDEVALL); in pktgen_thread_worker()
3655 if (t->control & T_REMDEV) { in pktgen_thread_worker()
3656 pktgen_rem_one_if(t); in pktgen_thread_worker()
3657 t->control &= ~(T_REMDEV); in pktgen_thread_worker()
3663 pr_debug("%s stopping all device\n", t->tsk->comm); in pktgen_thread_worker()
3664 pktgen_stop(t); in pktgen_thread_worker()
3666 pr_debug("%s removing all device\n", t->tsk->comm); in pktgen_thread_worker()
3667 pktgen_rem_all_ifs(t); in pktgen_thread_worker()
3669 pr_debug("%s removing thread\n", t->tsk->comm); in pktgen_thread_worker()
3670 pktgen_rem_thread(t); in pktgen_thread_worker()
3675 static struct pktgen_dev *pktgen_find_dev(struct pktgen_thread *t, in pktgen_find_dev() argument
3682 list_for_each_entry_rcu(p, &t->if_list, list) in pktgen_find_dev()
3701 static int add_dev_to_thread(struct pktgen_thread *t, in add_dev_to_thread() argument
3712 if_lock(t); in add_dev_to_thread()
3721 pkt_dev->pg_thread = t; in add_dev_to_thread()
3722 list_add_rcu(&pkt_dev->list, &t->if_list); in add_dev_to_thread()
3725 if_unlock(t); in add_dev_to_thread()
3731 static int pktgen_add_device(struct pktgen_thread *t, const char *ifname) in pktgen_add_device() argument
3735 int node = cpu_to_node(t->cpu); in pktgen_add_device()
3739 pkt_dev = __pktgen_NN_threads(t->net, ifname, FIND); in pktgen_add_device()
3776 err = pktgen_setup_dev(t->net, pkt_dev, ifname); in pktgen_add_device()
3782 pkt_dev->entry = proc_create_data(ifname, 0600, t->net->proc_dir, in pktgen_add_device()
3806 return add_dev_to_thread(t, pkt_dev); in pktgen_add_device()
3820 struct pktgen_thread *t; in pktgen_create_thread() local
3824 t = kzalloc_node(sizeof(struct pktgen_thread), GFP_KERNEL, in pktgen_create_thread()
3826 if (!t) { in pktgen_create_thread()
3831 mutex_init(&t->if_lock); in pktgen_create_thread()
3832 t->cpu = cpu; in pktgen_create_thread()
3834 INIT_LIST_HEAD(&t->if_list); in pktgen_create_thread()
3836 list_add_tail(&t->th_list, &pn->pktgen_threads); in pktgen_create_thread()
3837 init_completion(&t->start_done); in pktgen_create_thread()
3840 t, in pktgen_create_thread()
3844 pr_err("kthread_create_on_node() failed for cpu %d\n", t->cpu); in pktgen_create_thread()
3845 list_del(&t->th_list); in pktgen_create_thread()
3846 kfree(t); in pktgen_create_thread()
3850 t->tsk = p; in pktgen_create_thread()
3852 pe = proc_create_data(t->tsk->comm, 0600, pn->proc_dir, in pktgen_create_thread()
3853 &pktgen_thread_proc_ops, t); in pktgen_create_thread()
3856 PG_PROC_DIR, t->tsk->comm); in pktgen_create_thread()
3858 list_del(&t->th_list); in pktgen_create_thread()
3859 kfree(t); in pktgen_create_thread()
3863 t->net = pn; in pktgen_create_thread()
3866 wait_for_completion(&t->start_done); in pktgen_create_thread()
3874 static void _rem_dev_from_if_list(struct pktgen_thread *t, in _rem_dev_from_if_list() argument
3880 if_lock(t); in _rem_dev_from_if_list()
3881 list_for_each_safe(q, n, &t->if_list) { in _rem_dev_from_if_list()
3886 if_unlock(t); in _rem_dev_from_if_list()
3889 static int pktgen_remove_device(struct pktgen_thread *t, in pktgen_remove_device() argument
3912 _rem_dev_from_if_list(t, pkt_dev); in pktgen_remove_device()
3972 struct pktgen_thread *t; in pg_net_exit() local
3984 t = list_entry(q, struct pktgen_thread, th_list); in pg_net_exit()
3985 list_del(&t->th_list); in pg_net_exit()
3986 kthread_stop(t->tsk); in pg_net_exit()
3987 put_task_struct(t->tsk); in pg_net_exit()
3988 kfree(t); in pg_net_exit()