| /net/sched/ |
| D | sch_hfsc.c | 186 eltree_insert(struct hfsc_class *cl) in eltree_insert() argument
188 struct rb_node **p = &cl->sched->eligible.rb_node; in eltree_insert()
195 if (cl->cl_e >= cl1->cl_e) in eltree_insert()
200 rb_link_node(&cl->el_node, parent, p); in eltree_insert()
201 rb_insert_color(&cl->el_node, &cl->sched->eligible); in eltree_insert()
205 eltree_remove(struct hfsc_class *cl) in eltree_remove() argument
207 rb_erase(&cl->el_node, &cl->sched->eligible); in eltree_remove()
211 eltree_update(struct hfsc_class *cl) in eltree_update() argument
213 eltree_remove(cl); in eltree_update()
214 eltree_insert(cl); in eltree_update()
[all …]
|
| D | sch_cbq.c | 163 #define L2T(cl, len) qdisc_l2t((cl)->R_tab, len) argument
181 struct cbq_class *cl; in cbq_reclassify() local
183 for (cl = this->tparent; cl; cl = cl->tparent) { in cbq_reclassify()
184 struct cbq_class *new = cl->defaults[TC_PRIO_BESTEFFORT]; in cbq_reclassify()
210 struct cbq_class *cl = NULL; in cbq_classify() local
219 (cl = cbq_class_lookup(q, prio)) != NULL) in cbq_classify()
220 return cl; in cbq_classify()
237 cl = (void *)res.class; in cbq_classify()
238 if (!cl) { in cbq_classify()
240 cl = cbq_class_lookup(q, res.classid); in cbq_classify()
[all …]
|
| D | sch_htb.c | 220 struct htb_class *cl; in htb_classify() local
231 cl = htb_find(skb->priority, sch); in htb_classify()
232 if (cl) { in htb_classify()
233 if (cl->level == 0) in htb_classify()
234 return cl; in htb_classify()
236 tcf = rcu_dereference_bh(cl->filter_list); in htb_classify()
254 cl = (void *)res.class; in htb_classify()
255 if (!cl) { in htb_classify()
258 cl = htb_find(res.classid, sch); in htb_classify()
259 if (!cl) in htb_classify()
[all …]
|
| D | sch_drr.c | 59 struct drr_class *cl = (struct drr_class *)*arg; in drr_change_class() local
84 if (cl != NULL) { in drr_change_class()
86 err = gen_replace_estimator(&cl->bstats, NULL, in drr_change_class()
87 &cl->rate_est, in drr_change_class()
99 cl->quantum = quantum; in drr_change_class()
105 cl = kzalloc(sizeof(struct drr_class), GFP_KERNEL); in drr_change_class()
106 if (cl == NULL) in drr_change_class()
109 cl->common.classid = classid; in drr_change_class()
110 cl->quantum = quantum; in drr_change_class()
111 cl->qdisc = qdisc_create_dflt(sch->dev_queue, in drr_change_class()
[all …]
|
| D | sch_qfq.c | 319 struct qfq_class *cl) in qfq_add_to_agg() argument
321 cl->agg = agg; in qfq_add_to_agg()
324 if (cl->qdisc->q.qlen > 0) { /* adding an active class */ in qfq_add_to_agg()
325 list_add_tail(&cl->alist, &agg->active); in qfq_add_to_agg()
327 cl && q->in_serv_agg != agg) /* agg was inactive */ in qfq_add_to_agg()
347 static void qfq_deactivate_class(struct qfq_sched *q, struct qfq_class *cl) in qfq_deactivate_class() argument
349 struct qfq_aggregate *agg = cl->agg; in qfq_deactivate_class()
352 list_del(&cl->alist); /* remove from RR queue of the aggregate */ in qfq_deactivate_class()
358 static void qfq_rm_from_agg(struct qfq_sched *q, struct qfq_class *cl) in qfq_rm_from_agg() argument
360 struct qfq_aggregate *agg = cl->agg; in qfq_rm_from_agg()
[all …]
|
| D | sch_ets.c | 97 static u32 ets_class_id(struct Qdisc *sch, const struct ets_class *cl) in ets_class_id() argument
100 int band = cl - q->classes; in ets_class_id()
190 static bool ets_class_is_strict(struct ets_sched *q, const struct ets_class *cl) in ets_class_is_strict() argument
192 unsigned int band = cl - q->classes; in ets_class_is_strict()
201 struct ets_class *cl = ets_class_from_arg(sch, *arg); in ets_class_change() local
211 if (!cl) { in ets_class_change()
229 if (ets_class_is_strict(q, cl)) { in ets_class_change()
240 cl->quantum = quantum; in ets_class_change()
251 struct ets_class *cl = ets_class_from_arg(sch, arg); in ets_class_graft() local
255 ets_class_id(sch, cl), NULL); in ets_class_graft()
[all …]
|
| D | sch_mq.c | 197 static struct netdev_queue *mq_queue_get(struct Qdisc *sch, unsigned long cl) in mq_queue_get() argument
200 unsigned long ntx = cl - 1; in mq_queue_get()
213 static int mq_graft(struct Qdisc *sch, unsigned long cl, struct Qdisc *new, in mq_graft() argument
216 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_graft()
230 graft_offload.graft_params.queue = cl - 1; in mq_graft()
239 static struct Qdisc *mq_leaf(struct Qdisc *sch, unsigned long cl) in mq_leaf() argument
241 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_leaf()
255 static int mq_dump_class(struct Qdisc *sch, unsigned long cl, in mq_dump_class() argument
258 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_dump_class()
261 tcm->tcm_handle |= TC_H_MIN(cl); in mq_dump_class()
[all …]
|
| D | sch_api.c | 336 unsigned long cl; in qdisc_leaf() local
341 cl = cops->find(p, classid); in qdisc_leaf()
343 if (cl == 0) in qdisc_leaf()
345 return cops->leaf(p, cl); in qdisc_leaf()
676 struct Qdisc_class_common *cl; in qdisc_class_hash_grow() local
696 hlist_for_each_entry_safe(cl, next, &ohash[i], hnode) { in qdisc_class_hash_grow()
697 h = qdisc_class_hash(cl->classid, nmask); in qdisc_class_hash_grow()
698 hlist_add_head(&cl->hnode, &nhash[h]); in qdisc_class_hash_grow()
731 struct Qdisc_class_common *cl) in qdisc_class_hash_insert() argument
735 INIT_HLIST_NODE(&cl->hnode); in qdisc_class_hash_insert()
[all …]
|
| D | sch_mqprio.c | 374 unsigned long cl) in mqprio_queue_get() argument
377 unsigned long ntx = cl - 1; in mqprio_queue_get()
384 static int mqprio_graft(struct Qdisc *sch, unsigned long cl, struct Qdisc *new, in mqprio_graft() argument
388 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); in mqprio_graft()
523 static struct Qdisc *mqprio_leaf(struct Qdisc *sch, unsigned long cl) in mqprio_leaf() argument
525 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); in mqprio_leaf()
552 static int mqprio_dump_class(struct Qdisc *sch, unsigned long cl, in mqprio_dump_class() argument
555 if (cl < TC_H_MIN_PRIORITY) { in mqprio_dump_class()
556 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); in mqprio_dump_class()
558 int tc = netdev_txq_to_tc(dev, cl - 1); in mqprio_dump_class()
[all …]
|
| D | sch_multiq.c | 319 static void multiq_unbind(struct Qdisc *q, unsigned long cl) in multiq_unbind() argument
323 static int multiq_dump_class(struct Qdisc *sch, unsigned long cl, in multiq_dump_class() argument
328 tcm->tcm_handle |= TC_H_MIN(cl); in multiq_dump_class()
329 tcm->tcm_info = q->queues[cl - 1]->handle; in multiq_dump_class()
333 static int multiq_dump_class_stats(struct Qdisc *sch, unsigned long cl, in multiq_dump_class_stats() argument
339 cl_q = q->queues[cl - 1]; in multiq_dump_class_stats()
369 static struct tcf_block *multiq_tcf_block(struct Qdisc *sch, unsigned long cl, in multiq_tcf_block() argument
374 if (cl) in multiq_tcf_block()
|
| D | sch_prio.c | 341 static void prio_unbind(struct Qdisc *q, unsigned long cl) in prio_unbind() argument
345 static int prio_dump_class(struct Qdisc *sch, unsigned long cl, struct sk_buff *skb, in prio_dump_class() argument
350 tcm->tcm_handle |= TC_H_MIN(cl); in prio_dump_class()
351 tcm->tcm_info = q->queues[cl-1]->handle; in prio_dump_class()
355 static int prio_dump_class_stats(struct Qdisc *sch, unsigned long cl, in prio_dump_class_stats() argument
361 cl_q = q->queues[cl - 1]; in prio_dump_class_stats()
391 static struct tcf_block *prio_tcf_block(struct Qdisc *sch, unsigned long cl, in prio_tcf_block() argument
396 if (cl) in prio_tcf_block()
|
| D | sch_atm.c | 105 static struct Qdisc *atm_tc_leaf(struct Qdisc *sch, unsigned long cl) in atm_tc_leaf() argument
107 struct atm_flow_data *flow = (struct atm_flow_data *)cl; in atm_tc_leaf()
143 static void atm_tc_put(struct Qdisc *sch, unsigned long cl) in atm_tc_put() argument
146 struct atm_flow_data *flow = (struct atm_flow_data *)cl; in atm_tc_put()
271 unsigned long cl; in atm_tc_change() local
275 cl = atm_tc_find(sch, classid); in atm_tc_change()
276 if (!cl) in atm_tc_change()
366 static struct tcf_block *atm_tc_tcf_block(struct Qdisc *sch, unsigned long cl, in atm_tc_tcf_block() argument
370 struct atm_flow_data *flow = (struct atm_flow_data *)cl; in atm_tc_tcf_block()
603 static int atm_tc_dump_class(struct Qdisc *sch, unsigned long cl, in atm_tc_dump_class() argument
[all …]
|
| D | sch_dsmark.c | 104 static void dsmark_unbind_filter(struct Qdisc *sch, unsigned long cl) in dsmark_unbind_filter() argument
192 static struct tcf_block *dsmark_tcf_block(struct Qdisc *sch, unsigned long cl, in dsmark_tcf_block() argument
426 static int dsmark_dump_class(struct Qdisc *sch, unsigned long cl, in dsmark_dump_class() argument
432 pr_debug("%s(sch %p,[qdisc %p],class %ld\n", __func__, sch, p, cl); in dsmark_dump_class()
434 if (!dsmark_valid_index(p, cl)) in dsmark_dump_class()
437 tcm->tcm_handle = TC_H_MAKE(TC_H_MAJ(sch->handle), cl - 1); in dsmark_dump_class()
443 if (nla_put_u8(skb, TCA_DSMARK_MASK, p->mv[cl - 1].mask) || in dsmark_dump_class()
444 nla_put_u8(skb, TCA_DSMARK_VALUE, p->mv[cl - 1].value)) in dsmark_dump_class()
|
| D | sch_skbprio.c | 243 static int skbprio_dump_class(struct Qdisc *sch, unsigned long cl, in skbprio_dump_class() argument
246 tcm->tcm_handle |= TC_H_MIN(cl); in skbprio_dump_class()
250 static int skbprio_dump_class_stats(struct Qdisc *sch, unsigned long cl, in skbprio_dump_class_stats() argument
254 if (gnet_stats_copy_queue(d, NULL, &q->qstats[cl - 1], in skbprio_dump_class_stats()
255 q->qstats[cl - 1].qlen) < 0) in skbprio_dump_class_stats()
|
| D | sch_ingress.c | 39 static void ingress_unbind_filter(struct Qdisc *sch, unsigned long cl) in ingress_unbind_filter() argument
47 static struct tcf_block *ingress_tcf_block(struct Qdisc *sch, unsigned long cl, in ingress_tcf_block() argument
178 static struct tcf_block *clsact_tcf_block(struct Qdisc *sch, unsigned long cl, in clsact_tcf_block() argument
183 switch (cl) { in clsact_tcf_block()
|
| D | cls_api.c | 1100 static int __tcf_qdisc_cl_find(struct Qdisc *q, u32 parent, unsigned long *cl, in __tcf_qdisc_cl_find() argument
1110 *cl = cops->find(q, parent); in __tcf_qdisc_cl_find()
1111 if (*cl == 0) { in __tcf_qdisc_cl_find()
1121 unsigned long cl, int ifindex, in __tcf_block_find() argument
1136 block = cops->tcf_block(q, cl, extack); in __tcf_block_find()
1195 u32 *parent, unsigned long *cl, in tcf_block_find() argument
1208 err = __tcf_qdisc_cl_find(*q, *parent, cl, ifindex, extack); in tcf_block_find()
1212 block = __tcf_block_find(net, *q, *cl, ifindex, block_index, extack); in tcf_block_find()
1954 unsigned long cl; in tc_new_tfilter() local
1978 cl = 0; in tc_new_tfilter()
[all …]
|
| D | sch_fq_codel.c | 599 static void fq_codel_unbind(struct Qdisc *q, unsigned long cl) in fq_codel_unbind() argument
603 static struct tcf_block *fq_codel_tcf_block(struct Qdisc *sch, unsigned long cl, in fq_codel_tcf_block() argument
608 if (cl) in fq_codel_tcf_block()
613 static int fq_codel_dump_class(struct Qdisc *sch, unsigned long cl, in fq_codel_dump_class() argument
616 tcm->tcm_handle |= TC_H_MIN(cl); in fq_codel_dump_class()
620 static int fq_codel_dump_class_stats(struct Qdisc *sch, unsigned long cl, in fq_codel_dump_class_stats() argument
624 u32 idx = cl - 1; in fq_codel_dump_class_stats()
|
| D | sch_taprio.c | 1785 unsigned long cl) in taprio_queue_get() argument
1788 unsigned long ntx = cl - 1; in taprio_queue_get()
1796 static int taprio_graft(struct Qdisc *sch, unsigned long cl, in taprio_graft() argument
1802 struct netdev_queue *dev_queue = taprio_queue_get(sch, cl); in taprio_graft()
1813 *old = q->qdiscs[cl - 1]; in taprio_graft()
1814 q->qdiscs[cl - 1] = new; in taprio_graft()
1962 static struct Qdisc *taprio_leaf(struct Qdisc *sch, unsigned long cl) in taprio_leaf() argument
1964 struct netdev_queue *dev_queue = taprio_queue_get(sch, cl); in taprio_leaf()
1981 static int taprio_dump_class(struct Qdisc *sch, unsigned long cl, in taprio_dump_class() argument
1984 struct netdev_queue *dev_queue = taprio_queue_get(sch, cl); in taprio_dump_class()
[all …]
|
| /net/bluetooth/bnep/ |
| D | sock.c | 54 struct bnep_connlist_req cl; in do_bnep_sock_ioctl() local
101 if (copy_from_user(&cl, argp, sizeof(cl))) in do_bnep_sock_ioctl()
104 if (cl.cnum <= 0) in do_bnep_sock_ioctl()
107 err = bnep_get_connlist(&cl); in do_bnep_sock_ioctl()
108 if (!err && copy_to_user(argp, &cl, sizeof(cl))) in do_bnep_sock_ioctl()
146 struct bnep_connlist_req cl; in bnep_sock_compat_ioctl() local
151 if (get_user(cl.cnum, p) || get_user(uci, p + 1)) in bnep_sock_compat_ioctl()
154 cl.ci = compat_ptr(uci); in bnep_sock_compat_ioctl()
156 if (cl.cnum <= 0) in bnep_sock_compat_ioctl()
159 err = bnep_get_connlist(&cl); in bnep_sock_compat_ioctl()
[all …]
|
| /net/bluetooth/cmtp/ |
| D | sock.c | 70 struct cmtp_connlist_req cl; in do_cmtp_sock_ioctl() local
113 if (copy_from_user(&cl, argp, sizeof(cl))) in do_cmtp_sock_ioctl()
116 if (cl.cnum <= 0) in do_cmtp_sock_ioctl()
119 err = cmtp_get_connlist(&cl); in do_cmtp_sock_ioctl()
120 if (!err && copy_to_user(argp, &cl, sizeof(cl))) in do_cmtp_sock_ioctl()
149 struct cmtp_connlist_req cl; in cmtp_sock_compat_ioctl() local
154 if (get_user(cl.cnum, p) || get_user(uci, p + 1)) in cmtp_sock_compat_ioctl()
157 cl.ci = compat_ptr(uci); in cmtp_sock_compat_ioctl()
159 if (cl.cnum <= 0) in cmtp_sock_compat_ioctl()
162 err = cmtp_get_connlist(&cl); in cmtp_sock_compat_ioctl()
[all …]
|
| /net/bluetooth/hidp/ |
| D | sock.c | 53 struct hidp_connlist_req cl; in do_hidp_sock_ioctl() local
99 if (copy_from_user(&cl, argp, sizeof(cl))) in do_hidp_sock_ioctl()
102 if (cl.cnum <= 0) in do_hidp_sock_ioctl()
105 err = hidp_get_connlist(&cl); in do_hidp_sock_ioctl()
106 if (!err && copy_to_user(argp, &cl, sizeof(cl))) in do_hidp_sock_ioctl()
153 struct hidp_connlist_req cl; in hidp_sock_compat_ioctl() local
157 if (get_user(cl.cnum, p) || get_user(uci, p + 1)) in hidp_sock_compat_ioctl()
160 cl.ci = compat_ptr(uci); in hidp_sock_compat_ioctl()
162 if (cl.cnum <= 0) in hidp_sock_compat_ioctl()
165 err = hidp_get_connlist(&cl); in hidp_sock_compat_ioctl()
[all …]
|
| /net/bluetooth/ |
| D | a2mp.c | 92 static void __a2mp_add_cl(struct amp_mgr *mgr, struct a2mp_cl *cl) in __a2mp_add_cl() argument
97 cl[0].id = AMP_ID_BREDR; in __a2mp_add_cl()
98 cl[0].type = AMP_TYPE_BREDR; in __a2mp_add_cl()
99 cl[0].status = AMP_STATUS_BLUETOOTH_ONLY; in __a2mp_add_cl()
103 cl[i].id = hdev->id; in __a2mp_add_cl()
104 cl[i].type = hdev->amp_type; in __a2mp_add_cl()
106 cl[i].status = hdev->amp_status; in __a2mp_add_cl()
108 cl[i].status = AMP_STATUS_POWERED_DOWN; in __a2mp_add_cl()
170 len = struct_size(rsp, cl, num_ctrl); in a2mp_discover_req()
180 __a2mp_add_cl(mgr, rsp->cl); in a2mp_discover_req()
[all …]
|
| /net/netfilter/ipvs/ |
| D | ip_vs_wrr.c | 61 struct ip_vs_dest *cl; /* current dest or head */ member
117 mark->cl = list_entry(&svc->destinations, struct ip_vs_dest, n_list); in ip_vs_wrr_init_svc()
144 mark->cl = list_entry(&svc->destinations, struct ip_vs_dest, n_list); in ip_vs_wrr_dest_changed()
170 dest = mark->cl; in ip_vs_wrr_schedule()
218 mark->cl = dest; in ip_vs_wrr_schedule()
225 mark->cl = dest; in ip_vs_wrr_schedule()
231 mark->cl = dest; in ip_vs_wrr_schedule()
|
| /net/openvswitch/ |
| D | conntrack.c | 167 struct nf_conn_labels *cl = ct ? nf_ct_labels_find(ct) : NULL; in ovs_ct_get_labels() local
169 if (cl) in ovs_ct_get_labels()
170 memcpy(labels, cl->bits, OVS_CT_LABELS_LEN); in ovs_ct_get_labels()
357 struct nf_conn_labels *cl; in ovs_ct_get_conn_labels() local
359 cl = nf_ct_labels_find(ct); in ovs_ct_get_conn_labels()
360 if (!cl) { in ovs_ct_get_conn_labels()
362 cl = nf_ct_labels_find(ct); in ovs_ct_get_conn_labels()
365 return cl; in ovs_ct_get_conn_labels()
376 struct nf_conn_labels *cl, *master_cl; in ovs_ct_init_labels() local
385 cl = ovs_ct_get_conn_labels(ct); in ovs_ct_init_labels()
[all …]
|
| /net/9p/ |
| D | trans_fd.c | 975 struct sockaddr_in cl; in p9_bind_privport() local
978 memset(&cl, 0, sizeof(cl)); in p9_bind_privport()
979 cl.sin_family = AF_INET; in p9_bind_privport()
980 cl.sin_addr.s_addr = htonl(INADDR_ANY); in p9_bind_privport()
982 cl.sin_port = htons((ushort)port); in p9_bind_privport()
983 err = kernel_bind(sock, (struct sockaddr *)&cl, sizeof(cl)); in p9_bind_privport()
|