| /net/netfilter/ipvs/ |
| D | ip_vs_sched.c | 61 struct ip_vs_scheduler *sched) in ip_vs_unbind_scheduler() argument
70 if (sched->done_service) in ip_vs_unbind_scheduler()
71 sched->done_service(svc); in ip_vs_unbind_scheduler()
81 struct ip_vs_scheduler *sched; in ip_vs_sched_getbyname() local
87 list_for_each_entry(sched, &ip_vs_schedulers, n_list) { in ip_vs_sched_getbyname()
91 if (sched->module && !try_module_get(sched->module)) { in ip_vs_sched_getbyname()
97 if (strcmp(sched_name, sched->name)==0) { in ip_vs_sched_getbyname()
100 return sched; in ip_vs_sched_getbyname()
102 module_put(sched->module); in ip_vs_sched_getbyname()
115 struct ip_vs_scheduler *sched; in ip_vs_scheduler_get() local
[all …]
|
| D | ip_vs_ctl.c | 876 struct ip_vs_scheduler *sched; in __ip_vs_update_dest() local
948 sched = rcu_dereference_protected(svc->scheduler, 1); in __ip_vs_update_dest()
949 if (sched && sched->add_dest) in __ip_vs_update_dest()
950 sched->add_dest(svc, dest); in __ip_vs_update_dest()
952 sched = rcu_dereference_protected(svc->scheduler, 1); in __ip_vs_update_dest()
953 if (sched && sched->upd_dest) in __ip_vs_update_dest()
954 sched->upd_dest(svc, dest); in __ip_vs_update_dest()
1204 struct ip_vs_scheduler *sched; in __ip_vs_unlink_dest() local
1206 sched = rcu_dereference_protected(svc->scheduler, 1); in __ip_vs_unlink_dest()
1207 if (sched && sched->del_dest) in __ip_vs_unlink_dest()
[all …]
|
| D | ip_vs_core.c | 342 struct ip_vs_scheduler *sched; in ip_vs_sched_persist() local
349 sched = rcu_dereference(svc->scheduler); in ip_vs_sched_persist()
350 if (sched) { in ip_vs_sched_persist()
353 dest = sched->schedule(svc, skb, iph); in ip_vs_sched_persist()
447 struct ip_vs_scheduler *sched; in ip_vs_schedule() local
524 sched = rcu_dereference(svc->scheduler); in ip_vs_schedule()
525 if (sched) { in ip_vs_schedule()
528 dest = sched->schedule(svc, skb, iph); in ip_vs_schedule()
|
| /net/sctp/ |
| D | stream_sched.c | 121 void sctp_sched_ops_register(enum sctp_sched_type sched, in sctp_sched_ops_register() argument
124 sctp_sched_ops[sched] = sched_ops; in sctp_sched_ops_register()
135 enum sctp_sched_type sched) in sctp_sched_set_sched() argument
137 struct sctp_sched_ops *n = sctp_sched_ops[sched]; in sctp_sched_set_sched()
138 struct sctp_sched_ops *old = asoc->outqueue.sched; in sctp_sched_set_sched()
146 if (sched > SCTP_SS_MAX) in sctp_sched_set_sched()
162 asoc->outqueue.sched = n; in sctp_sched_set_sched()
185 asoc->outqueue.sched = &sctp_sched_fcfs; /* Always safe */ in sctp_sched_set_sched()
195 if (asoc->outqueue.sched == sctp_sched_ops[i]) in sctp_sched_get_sched()
215 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value()
[all …]
|
| D | stream.c | 57 struct sctp_sched_ops *sched; in sctp_stream_free_ext() local
62 sched = sctp_sched_ops_from_stream(stream); in sctp_stream_free_ext()
63 sched->free_sid(stream, sid); in sctp_stream_free_ext()
133 struct sctp_sched_ops *sched = sctp_sched_ops_from_stream(stream); in sctp_stream_init() local
145 sched->unsched_all(stream); in sctp_stream_init()
147 sched->sched_all(stream); in sctp_stream_init()
185 struct sctp_sched_ops *sched = sctp_sched_ops_from_stream(stream); in sctp_stream_free() local
188 sched->unsched_all(stream); in sctp_stream_free()
210 struct sctp_sched_ops *sched = sctp_sched_ops_from_stream(stream); in sctp_stream_update() local
212 sched->unsched_all(stream); in sctp_stream_update()
[all …]
|
| D | outqueue.c | 76 return q->sched->dequeue(q); in sctp_outq_dequeue_data()
389 q->sched->unsched_all(&asoc->stream); in sctp_prsctp_prune_unsent()
417 q->sched->sched_all(&asoc->stream); in sctp_prsctp_prune_unsent()
|
| D | sm_sideeffect.c | 1116 asoc->outqueue.sched->enqueue(&asoc->outqueue, msg); in sctp_cmd_send_msg()
|
| /net/sched/ |
| D | sch_taprio.c | 91 static ktime_t sched_base_time(const struct sched_gate_list *sched) in sched_base_time() argument
93 if (!sched) in sched_base_time()
96 return ns_to_ktime(sched->base_time); in sched_base_time()
119 struct sched_gate_list *sched = container_of(head, struct sched_gate_list, rcu); in taprio_free_sched_cb() local
122 list_for_each_entry_safe(entry, n, &sched->entries, list) { in taprio_free_sched_cb()
127 kfree(sched); in taprio_free_sched_cb()
145 static s32 get_cycle_time_elapsed(struct sched_gate_list *sched, ktime_t time) in get_cycle_time_elapsed() argument
150 time_since_sched_start = ktime_sub(time, sched->base_time); in get_cycle_time_elapsed()
151 div_s64_rem(time_since_sched_start, sched->cycle_time, &time_elapsed); in get_cycle_time_elapsed()
156 static ktime_t get_interval_end_time(struct sched_gate_list *sched, in get_interval_end_time() argument
[all …]
|
| D | act_gate.c | 230 struct tcf_gate_params *sched, in parse_gate_list() argument
260 list_add_tail(&entry->list, &sched->entries); in parse_gate_list()
264 sched->num_entries = i; in parse_gate_list()
269 release_entry_list(&sched->entries); in parse_gate_list()
|
| D | sch_hfsc.c | 122 struct hfsc_sched *sched; /* scheduler data */ member
188 struct rb_node **p = &cl->sched->eligible.rb_node; in eltree_insert()
201 rb_insert_color(&cl->el_node, &cl->sched->eligible); in eltree_insert()
207 rb_erase(&cl->el_node, &cl->sched->eligible); in eltree_remove()
1060 cl->sched = q; in hfsc_change_class()
1416 q->root.sched = q; in hfsc_init_qdisc()
|
| D | Kconfig | 95 See the top of <file:net/sched/sch_red.c> for more details.
106 See the top of <file:net/sched/sch_sfb.c> for more details.
117 See the top of <file:net/sched/sch_sfq.c> for more details.
129 See the top of <file:net/sched/sch_teql.c> for more details.
140 See the top of <file:net/sched/sch_tbf.c> for more details.
151 See the top of <file:net/sched/sch_cbs.c> for more details.
162 See the top of <file:net/sched/sch_etf.c> for more details.
173 See the top of <file:net/sched/sch_taprio.c> for more details.
183 (see the top of <file:net/sched/sch_red.c> for details and
|
| /net/ipv6/ |
| D | ip6_flowlabel.c | 152 unsigned long sched = 0; in ip6_fl_gc() local
174 if (!sched || time_before(ttd, sched)) in ip6_fl_gc()
175 sched = ttd; in ip6_fl_gc()
180 if (!sched && atomic_read(&fl_size)) in ip6_fl_gc()
181 sched = now + FL_MAX_LINGER; in ip6_fl_gc()
182 if (sched) { in ip6_fl_gc()
183 mod_timer(&ip6_fl_gc_timer, sched); in ip6_fl_gc()
|
| /net/sunrpc/ |
| D | Makefile | 11 sunrpc-y := clnt.o xprt.o socklib.o xprtsock.o sched.o \
|
| /net/ |
| D | Makefile | 15 obj-y += ethernet/ 802/ sched/ netlink/ bpf/ ethtool/
|
| D | Kconfig | 231 source "net/sched/Kconfig"
|
| /net/unix/ |
| D | af_unix.c | 1435 int sched; in unix_wait_for_peer() local
1440 sched = !sock_flag(other, SOCK_DEAD) && in unix_wait_for_peer()
1446 if (sched) in unix_wait_for_peer()
|