| /net/mptcp/ |
| A D | sched.c | 57 ret = sched; in mptcp_sched_find() 133 if (!sched) in mptcp_init_sched() 136 if (!bpf_try_module_get(sched, sched->owner)) in mptcp_init_sched() 139 msk->sched = sched; in mptcp_init_sched() 150 struct mptcp_sched_ops *sched = msk->sched; in mptcp_release_sched() local 152 if (!sched) in mptcp_release_sched() 155 msk->sched = NULL; in mptcp_release_sched() 156 if (sched->release) in mptcp_release_sched() 159 bpf_module_put(sched, sched->owner); in mptcp_release_sched() 190 if (msk->sched == &mptcp_sched_default || !msk->sched) in mptcp_sched_get_send() [all …]
|
| A D | ctrl.c | 116 struct mptcp_sched_ops *sched; in mptcp_set_scheduler() local 120 sched = mptcp_sched_find(name); in mptcp_set_scheduler() 121 if (sched) in mptcp_set_scheduler()
|
| A D | Makefile | 5 mib.o pm_netlink.o sockopt.o pm_userspace.o fastopen.o sched.o \
|
| A D | protocol.h | 342 struct mptcp_sched_ops *sched; member 761 int mptcp_validate_scheduler(struct mptcp_sched_ops *sched); 762 int mptcp_register_scheduler(struct mptcp_sched_ops *sched); 763 void mptcp_unregister_scheduler(struct mptcp_sched_ops *sched); 766 struct mptcp_sched_ops *sched);
|
| A D | protocol.c | 3283 mptcp_init_sched(msk, mptcp_sk(sk)->sched); in mptcp_sk_clone_init()
|
| /net/netfilter/ipvs/ |
| A D | ip_vs_sched.c | 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 91 if (sched->module && !try_module_get(sched->module)) { 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 125 if (sched == NULL) { in ip_vs_scheduler_get() 130 return sched; in ip_vs_scheduler_get() 146 char *sched_name = sched ? sched->name : "none"; in ip_vs_scheduler_err() [all …]
|
| A D | ip_vs_ctl.c | 1044 if (sched && sched->add_dest) in __ip_vs_update_dest() 1048 if (sched && sched->upd_dest) in __ip_vs_update_dest() 1294 if (sched && sched->del_dest) in __ip_vs_unlink_dest() 1384 if (!sched) { in ip_vs_add_service() 1452 if (sched) { in ip_vs_add_service() 1456 sched = NULL; in ip_vs_add_service() 1530 if (!sched) { in ip_vs_edit_service() 1569 if (sched) { in ip_vs_edit_service() 2414 char *sched_name = sched ? sched->name : "none"; in ip_vs_info_seq_show() 2850 sched_name = sched ? sched->name : "none"; in ip_vs_copy_service() [all …]
|
| A 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/ |
| A D | stream_sched.c | 119 sctp_sched_ops[sched] = sched_ops; in sctp_sched_ops_register() 137 sched->unsched_all(stream); in sctp_sched_free_sched() 142 sched->free_sid(stream, i); in sctp_sched_free_sched() 149 enum sctp_sched_type sched) in sctp_sched_set_sched() argument 157 if (sched > SCTP_SS_MAX) in sctp_sched_set_sched() 160 n = sctp_sched_ops[sched]; in sctp_sched_set_sched() 167 asoc->outqueue.sched = n; in sctp_sched_set_sched() 200 if (asoc->outqueue.sched == sctp_sched_ops[i]) in sctp_sched_get_sched() 253 q->sched->dequeue_done(q, ch); in sctp_sched_dequeue_done() 270 return sched->init_sid(stream, sid, gfp); in sctp_sched_init_sid() [all …]
|
| A 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 …]
|
| A 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()
|
| A D | sm_sideeffect.c | 1121 asoc->outqueue.sched->enqueue(&asoc->outqueue, msg); in sctp_cmd_send_msg()
|
| /net/sched/ |
| A D | sch_taprio.c | 172 if (!sched) in sched_base_time() 206 kfree(sched); in taprio_free_sched_cb() 288 if (sched->max_open_gate_duration[tc] == sched->cycle_time) { in taprio_update_queue_max_sdu() 314 sched->max_sdu[tc] = 0; in taprio_update_queue_max_sdu() 347 if (!sched) in find_entry_to_transmit() 350 cycle = sched->cycle_time; in find_entry_to_transmit() 491 if (!sched || ktime_before(minimum_time, sched->base_time)) { in get_packet_txtime() 517 sched = admin; in get_packet_txtime() 554 if (sched && skb->len > sched->max_frm_len[tc]) in taprio_skb_exceeds_queue_max_sdu() 1121 sched->num_entries = i; in parse_sched_list() [all …]
|
| A D | act_gate.c | 229 struct tcf_gate_params *sched, in parse_gate_list() argument 259 list_add_tail(&entry->list, &sched->entries); in parse_gate_list() 263 sched->num_entries = i; in parse_gate_list() 268 release_entry_list(&sched->entries); in parse_gate_list()
|
| A D | sch_hfsc.c | 121 struct hfsc_sched *sched; /* scheduler data */ member 192 struct rb_node **p = &cl->sched->eligible.rb_node; in eltree_insert() 205 rb_insert_color(&cl->el_node, &cl->sched->eligible); in eltree_insert() 212 rb_erase(&cl->el_node, &cl->sched->eligible); in eltree_remove() 1058 cl->sched = q; in hfsc_change_class() 1419 q->root.sched = q; in hfsc_init_qdisc()
|
| A 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. 179 See the top of <file:net/sched/sch_taprio.c> for more details. 189 (see the top of <file:net/sched/sch_red.c> for details and
|
| /net/ipv6/ |
| A 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/ |
| A D | Makefile | 11 sunrpc-y := clnt.o xprt.o socklib.o xprtsock.o sched.o \
|
| /net/ |
| A D | Makefile | 15 obj-y += ethernet/ 802/ sched/ netlink/ bpf/ ethtool/
|
| A D | Kconfig | 269 source "net/sched/Kconfig"
|
| /net/unix/ |
| A D | af_unix.c | 1627 int sched; in unix_wait_for_peer() local 1632 sched = !sock_flag(other, SOCK_DEAD) && in unix_wait_for_peer() 1638 if (sched) in unix_wait_for_peer()
|