/net/dsa/ |
D | port.c | 16 static int dsa_port_notify(const struct dsa_port *dp, unsigned long e, void *v) in dsa_port_notify() argument 18 struct raw_notifier_head *nh = &dp->ds->dst->nh; in dsa_port_notify() 26 int dsa_port_set_state(struct dsa_port *dp, u8 state, in dsa_port_set_state() argument 29 struct dsa_switch *ds = dp->ds; in dsa_port_set_state() 30 int port = dp->index; in dsa_port_set_state() 44 if ((dp->stp_state == BR_STATE_LEARNING || in dsa_port_set_state() 45 dp->stp_state == BR_STATE_FORWARDING) && in dsa_port_set_state() 52 dp->stp_state = state; in dsa_port_set_state() 57 static void dsa_port_set_state_now(struct dsa_port *dp, u8 state) in dsa_port_set_state_now() argument 61 err = dsa_port_set_state(dp, state, NULL); in dsa_port_set_state_now() [all …]
|
D | dsa2.c | 106 static bool dsa_port_is_user(struct dsa_port *dp) in dsa_port_is_user() argument 108 return dp->type == DSA_PORT_TYPE_USER; in dsa_port_is_user() 115 struct dsa_port *dp; in dsa_tree_find_port_by_node() local 124 dp = &ds->ports[port]; in dsa_tree_find_port_by_node() 126 if (dp->dn == dn) in dsa_tree_find_port_by_node() 127 return dp; in dsa_tree_find_port_by_node() 134 static bool dsa_port_setup_routing_table(struct dsa_port *dp) in dsa_port_setup_routing_table() argument 136 struct dsa_switch *ds = dp->ds; in dsa_port_setup_routing_table() 138 struct device_node *dn = dp->dn; in dsa_port_setup_routing_table() 150 ds->rtable[link_dp->ds->index] = dp->index; in dsa_port_setup_routing_table() [all …]
|
D | slave.c | 70 struct dsa_port *dp = dsa_slave_to_port(dev); in dsa_slave_open() local 93 err = dsa_port_enable(dp, dev->phydev); in dsa_slave_open() 97 phylink_start(dp->pl); in dsa_slave_open() 117 struct dsa_port *dp = dsa_slave_to_port(dev); in dsa_slave_close() local 119 cancel_work_sync(&dp->xmit_work); in dsa_slave_close() 120 skb_queue_purge(&dp->xmit_queue); in dsa_slave_close() 122 phylink_stop(dp->pl); in dsa_slave_close() 124 dsa_port_disable(dp); in dsa_slave_close() 243 struct dsa_port *dp = dsa_slave_to_port(dev); in dsa_slave_fdb_dump() local 252 err = dsa_port_fdb_dump(dp, dsa_slave_port_fdb_do_dump, &dump); in dsa_slave_fdb_dump() [all …]
|
D | dsa_priv.h | 72 struct dsa_port *dp; member 129 int dsa_port_set_state(struct dsa_port *dp, u8 state, 131 int dsa_port_enable(struct dsa_port *dp, struct phy_device *phy); 132 void dsa_port_disable(struct dsa_port *dp); 133 int dsa_port_bridge_join(struct dsa_port *dp, struct net_device *br); 134 void dsa_port_bridge_leave(struct dsa_port *dp, struct net_device *br); 135 int dsa_port_vlan_filtering(struct dsa_port *dp, bool vlan_filtering, 137 int dsa_port_ageing_time(struct dsa_port *dp, clock_t ageing_clock, 139 int dsa_port_fdb_add(struct dsa_port *dp, const unsigned char *addr, 141 int dsa_port_fdb_del(struct dsa_port *dp, const unsigned char *addr, [all …]
|
D | tag_sja1105.c | 89 struct dsa_port *dp = dsa_slave_to_port(netdev); in sja1105_xmit() local 90 struct dsa_switch *ds = dp->ds; in sja1105_xmit() 91 u16 tx_vid = dsa_8021q_tx_vid(ds, dp->index); in sja1105_xmit() 107 if (dsa_port_is_vlan_filtering(dp)) in sja1105_xmit() 151 struct dsa_port *dp; in sja1105_rcv_meta_state_machine() local 153 dp = dsa_slave_to_port(skb->dev); in sja1105_rcv_meta_state_machine() 154 sp = dp->priv; in sja1105_rcv_meta_state_machine() 169 dev_err_ratelimited(dp->ds->dev, in sja1105_rcv_meta_state_machine() 209 dev_err_ratelimited(dp->ds->dev, in sja1105_rcv_meta_state_machine() 216 dev_err_ratelimited(dp->ds->dev, in sja1105_rcv_meta_state_machine()
|
D | tag_lan9303.c | 48 static int lan9303_xmit_use_arl(struct dsa_port *dp, u8 *dest_addr) in lan9303_xmit_use_arl() argument 50 struct lan9303 *chip = dp->ds->priv; in lan9303_xmit_use_arl() 57 struct dsa_port *dp = dsa_slave_to_port(dev); in lan9303_xmit() local 77 lan9303_tag[1] = lan9303_xmit_use_arl(dp, skb->data) ? in lan9303_xmit() 79 dp->index | LAN9303_TAG_TX_STP_OVERRIDE; in lan9303_xmit()
|
D | tag_dsa.c | 17 struct dsa_port *dp = dsa_slave_to_port(dev); in dsa_xmit() local 33 dsa_header[0] = 0x60 | dp->ds->index; in dsa_xmit() 34 dsa_header[1] = dp->index << 3; in dsa_xmit() 54 dsa_header[0] = 0x40 | dp->ds->index; in dsa_xmit() 55 dsa_header[1] = dp->index << 3; in dsa_xmit()
|
D | tag_edsa.c | 18 struct dsa_port *dp = dsa_slave_to_port(dev); in edsa_xmit() local 42 edsa_header[4] = 0x60 | dp->ds->index; in edsa_xmit() 43 edsa_header[5] = dp->index << 3; in edsa_xmit() 67 edsa_header[4] = 0x40 | dp->ds->index; in edsa_xmit() 68 edsa_header[5] = dp->index << 3; in edsa_xmit()
|
/net/openvswitch/ |
D | datapath.c | 124 static int queue_gso_packets(struct datapath *dp, struct sk_buff *, 128 static int queue_userspace_packet(struct datapath *dp, struct sk_buff *, 134 const char *ovs_dp_name(const struct datapath *dp) in ovs_dp_name() argument 136 struct vport *vport = ovs_vport_ovsl_rcu(dp, OVSP_LOCAL); in ovs_dp_name() 140 static int get_dpifindex(const struct datapath *dp) in get_dpifindex() argument 147 local = ovs_vport_rcu(dp, OVSP_LOCAL); in get_dpifindex() 160 struct datapath *dp = container_of(rcu, struct datapath, rcu); in destroy_dp_rcu() local 162 ovs_flow_tbl_destroy(&dp->table); in destroy_dp_rcu() 163 free_percpu(dp->stats_percpu); in destroy_dp_rcu() 164 kfree(dp->ports); in destroy_dp_rcu() [all …]
|
D | datapath.h | 158 static inline struct net *ovs_dp_get_net(const struct datapath *dp) in ovs_dp_get_net() argument 160 return read_pnet(&dp->net); in ovs_dp_get_net() 163 static inline void ovs_dp_set_net(struct datapath *dp, struct net *net) in ovs_dp_set_net() argument 165 write_pnet(&dp->net, net); in ovs_dp_set_net() 168 struct vport *ovs_lookup_vport(const struct datapath *dp, u16 port_no); 170 static inline struct vport *ovs_vport_rcu(const struct datapath *dp, int port_no) in ovs_vport_rcu() argument 173 return ovs_lookup_vport(dp, port_no); in ovs_vport_rcu() 176 static inline struct vport *ovs_vport_ovsl_rcu(const struct datapath *dp, int port_no) in ovs_vport_ovsl_rcu() argument 179 return ovs_lookup_vport(dp, port_no); in ovs_vport_ovsl_rcu() 182 static inline struct vport *ovs_vport_ovsl(const struct datapath *dp, int port_no) in ovs_vport_ovsl() argument [all …]
|
D | meter.c | 50 static struct hlist_head *meter_hash_bucket(const struct datapath *dp, in meter_hash_bucket() argument 53 return &dp->meters[meter_id & (METER_HASH_BUCKETS - 1)]; in meter_hash_bucket() 57 static struct dp_meter *lookup_meter(const struct datapath *dp, in lookup_meter() argument 63 head = meter_hash_bucket(dp, meter_id); in lookup_meter() 71 static void attach_meter(struct datapath *dp, struct dp_meter *meter) in attach_meter() argument 73 struct hlist_head *head = meter_hash_bucket(dp, meter->id); in attach_meter() 275 struct datapath *dp; in ovs_meter_cmd_set() local 296 dp = get_dp(sock_net(skb->sk), ovs_header->dp_ifindex); in ovs_meter_cmd_set() 297 if (!dp) { in ovs_meter_cmd_set() 305 old_meter = lookup_meter(dp, meter_id); in ovs_meter_cmd_set() [all …]
|
D | dp_notify.c | 17 struct datapath *dp; in dp_detach_port_notify() local 19 dp = vport->dp; in dp_detach_port_notify() 20 notify = ovs_vport_cmd_build_info(vport, ovs_dp_get_net(dp), in dp_detach_port_notify() 24 genl_set_err(&dp_vport_genl_family, ovs_dp_get_net(dp), 0, in dp_detach_port_notify() 30 ovs_dp_get_net(dp), notify, 0, in dp_detach_port_notify() 37 struct datapath *dp; in ovs_dp_notify_wq() local 40 list_for_each_entry(dp, &ovs_net->dps, list_node) { in ovs_dp_notify_wq() 47 hlist_for_each_entry_safe(vport, n, &dp->ports[i], dp_hash_node) { in ovs_dp_notify_wq()
|
D | actions.c | 153 static int clone_execute(struct datapath *dp, struct sk_buff *skb, 159 static int do_execute_actions(struct datapath *dp, struct sk_buff *skb, 879 static void do_output(struct datapath *dp, struct sk_buff *skb, int out_port, in do_output() argument 882 struct vport *vport = ovs_vport_rcu(dp, out_port); in do_output() 899 struct net *net = read_pnet(&dp->net); in do_output() 910 static int output_userspace(struct datapath *dp, struct sk_buff *skb, in output_userspace() argument 938 vport = ovs_vport_rcu(dp, nla_get_u32(a)); in output_userspace() 960 return ovs_dp_upcall(dp, skb, key, &upcall, cutlen); in output_userspace() 967 static int sample(struct datapath *dp, struct sk_buff *skb, in sample() argument 990 return clone_execute(dp, skb, key, 0, actions, rem, last, in sample() [all …]
|
/net/dccp/ |
D | input.c | 172 const struct dccp_sock *dp = dccp_sk(sk); in dccp_deliver_input_to_ccids() local 176 ccid_hc_rx_packet_recv(dp->dccps_hc_rx_ccid, sk, skb); in dccp_deliver_input_to_ccids() 182 ccid_hc_tx_packet_recv(dp->dccps_hc_tx_ccid, sk, skb); in dccp_deliver_input_to_ccids() 188 struct dccp_sock *dp = dccp_sk(sk); in dccp_check_seqno() local 206 if (between48(ackno, dp->dccps_awl, dp->dccps_awh) && in dccp_check_seqno() 207 dccp_delta_seqno(dp->dccps_swl, seqno) >= 0) in dccp_check_seqno() 224 lswl = dp->dccps_swl; in dccp_check_seqno() 225 lawl = dp->dccps_awl; in dccp_check_seqno() 230 lswl = ADD48(dp->dccps_gsr, 1); in dccp_check_seqno() 231 lawl = dp->dccps_gar; in dccp_check_seqno() [all …]
|
D | proto.c | 176 struct dccp_sock *dp = dccp_sk(sk); in dccp_sk_destruct() local 178 ccid_hc_tx_delete(dp->dccps_hc_tx_ccid, sk); in dccp_sk_destruct() 179 dp->dccps_hc_tx_ccid = NULL; in dccp_sk_destruct() 185 struct dccp_sock *dp = dccp_sk(sk); in dccp_init_sock() local 194 dp->dccps_mss_cache = 536; in dccp_init_sock() 195 dp->dccps_rate_last = jiffies; in dccp_init_sock() 196 dp->dccps_role = DCCP_ROLE_UNDEFINED; in dccp_init_sock() 197 dp->dccps_service = DCCP_SERVICE_CODE_IS_ABSENT; in dccp_init_sock() 198 dp->dccps_tx_qlen = sysctl_dccp_tx_qlen; in dccp_init_sock() 202 INIT_LIST_HEAD(&dp->dccps_featneg); in dccp_init_sock() [all …]
|
D | output.c | 47 struct dccp_sock *dp = dccp_sk(sk); in dccp_transmit_skb() local 55 u64 ackno = dp->dccps_gsr; in dccp_transmit_skb() 60 dcb->dccpd_seq = ADD48(dp->dccps_gss, 1); in dccp_transmit_skb() 74 dcb->dccpd_seq = dp->dccps_iss; in dccp_transmit_skb() 106 dh->dccph_cscov = dp->dccps_pcslen; in dccp_transmit_skb() 111 dccp_hdr_set_seq(dh, dp->dccps_gss); in dccp_transmit_skb() 118 dp->dccps_service; in dccp_transmit_skb() 123 dp->dccps_awl = dp->dccps_iss; in dccp_transmit_skb() 150 static u32 dccp_determine_ccmps(const struct dccp_sock *dp) in dccp_determine_ccmps() argument 152 const struct ccid *tx_ccid = dp->dccps_hc_tx_ccid; in dccp_determine_ccmps() [all …]
|
D | dccp.h | 265 int dccp_reqsk_init(struct request_sock *rq, struct dccp_sock const *dp, 330 const struct dccp_sock *dp = dccp_sk(sk); in dccp_bad_service_code() local 332 if (dp->dccps_service == service) in dccp_bad_service_code() 334 return !dccp_list_has_service(dp->dccps_service_list, service); in dccp_bad_service_code() 419 struct dccp_sock *dp = dccp_sk(sk); in dccp_update_gsr() local 421 if (after48(seq, dp->dccps_gsr)) in dccp_update_gsr() 422 dp->dccps_gsr = seq; in dccp_update_gsr() 424 dp->dccps_swl = SUB48(ADD48(dp->dccps_gsr, 1), dp->dccps_r_seq_win / 4); in dccp_update_gsr() 440 if (before48(dp->dccps_swl, dp->dccps_isr)) in dccp_update_gsr() 441 dp->dccps_swl = dp->dccps_isr; in dccp_update_gsr() [all …]
|
D | options.c | 50 struct dccp_sock *dp = dccp_sk(sk); in dccp_parse_options() local 57 struct dccp_options_received *opt_recv = &dp->dccps_options_received; in dccp_parse_options() 148 dp->dccps_timestamp_echo = ntohl(opt_val); in dccp_parse_options() 149 dp->dccps_timestamp_time = dccp_timestamp(); in dccp_parse_options() 214 if (ccid_hc_rx_parse_options(dp->dccps_hc_rx_ccid, sk, in dccp_parse_options() 229 if (ccid_hc_tx_parse_options(dp->dccps_hc_tx_ccid, sk, in dccp_parse_options() 310 struct dccp_sock *dp = dccp_sk(sk); in dccp_insert_option_ndp() local 311 u64 ndp = dp->dccps_ndp_count; in dccp_insert_option_ndp() 314 ++dp->dccps_ndp_count; in dccp_insert_option_ndp() 316 dp->dccps_ndp_count = 0; in dccp_insert_option_ndp() [all …]
|
D | feat.c | 38 struct dccp_sock *dp = dccp_sk(sk); in dccp_hdlr_ccid() local 45 ccid_hc_rx_delete(dp->dccps_hc_rx_ccid, sk); in dccp_hdlr_ccid() 46 dp->dccps_hc_rx_ccid = new_ccid; in dccp_hdlr_ccid() 48 ccid_hc_tx_delete(dp->dccps_hc_tx_ccid, sk); in dccp_hdlr_ccid() 49 dp->dccps_hc_tx_ccid = new_ccid; in dccp_hdlr_ccid() 56 struct dccp_sock *dp = dccp_sk(sk); in dccp_hdlr_seq_win() local 59 dp->dccps_r_seq_win = seq_win; in dccp_hdlr_seq_win() 61 dccp_update_gsr(sk, dp->dccps_gsr); in dccp_hdlr_seq_win() 63 dp->dccps_l_seq_win = seq_win; in dccp_hdlr_seq_win() 65 dccp_update_gss(sk, dp->dccps_gss); in dccp_hdlr_seq_win() [all …]
|
D | diag.c | 18 struct dccp_sock *dp = dccp_sk(sk); in dccp_get_info() local 29 if (dp->dccps_hc_rx_ackvec != NULL) in dccp_get_info() 32 if (dp->dccps_hc_rx_ccid != NULL) in dccp_get_info() 33 ccid_hc_rx_get_info(dp->dccps_hc_rx_ccid, sk, info); in dccp_get_info() 35 if (dp->dccps_hc_tx_ccid != NULL) in dccp_get_info() 36 ccid_hc_tx_get_info(dp->dccps_hc_tx_ccid, sk, info); in dccp_get_info()
|
D | timer.c | 236 struct dccp_sock *dp = from_timer(dp, t, dccps_xmit_timer); in dccp_write_xmit_timer() local 237 struct sock *sk = &dp->dccps_inet_connection.icsk_inet.sk; in dccp_write_xmit_timer() 244 struct dccp_sock *dp = dccp_sk(sk); in dccp_init_xmit_timers() local 246 tasklet_init(&dp->dccps_xmitlet, dccp_write_xmitlet, (unsigned long)sk); in dccp_init_xmit_timers() 247 timer_setup(&dp->dccps_xmit_timer, dccp_write_xmit_timer, 0); in dccp_init_xmit_timers()
|
/net/rds/ |
D | ib_cm.c | 101 const union rds_ib_conn_priv *dp = NULL; in rds_ib_cm_connect_complete() local 109 dp = event->param.conn.private_data; in rds_ib_cm_connect_complete() 113 major = dp->ricp_v6.dp_protocol_major; in rds_ib_cm_connect_complete() 114 minor = dp->ricp_v6.dp_protocol_minor; in rds_ib_cm_connect_complete() 115 credit = dp->ricp_v6.dp_credit; in rds_ib_cm_connect_complete() 121 ack_seq = get_unaligned(&dp->ricp_v6.dp_ack_seq); in rds_ib_cm_connect_complete() 125 major = dp->ricp_v4.dp_protocol_major; in rds_ib_cm_connect_complete() 126 minor = dp->ricp_v4.dp_protocol_minor; in rds_ib_cm_connect_complete() 127 credit = dp->ricp_v4.dp_credit; in rds_ib_cm_connect_complete() 128 ack_seq = get_unaligned(&dp->ricp_v4.dp_ack_seq); in rds_ib_cm_connect_complete() [all …]
|
/net/ax25/ |
D | ax25_in.c | 189 ax25_digi dp, reverse_dp; in ax25_rcv() local 206 if (ax25_addr_parse(skb->data, skb->len, &src, &dest, &dp, &type, &dama) == NULL) in ax25_rcv() 212 if (dp.lastrepeat + 1 < dp.ndigi) /* Not yet digipeated completely */ in ax25_rcv() 213 next_digi = &dp.calls[dp.lastrepeat + 1]; in ax25_rcv() 218 skb_pull(skb, ax25_addr_size(&dp)); in ax25_rcv() 221 if (ax25cmp(&dest, dev_addr) == 0 && dp.lastrepeat + 1 == dp.ndigi) in ax25_rcv() 225 if (!mine && ax25_listen_mine(&dest, dev) && dp.lastrepeat + 1 == dp.ndigi) in ax25_rcv() 229 if ((*skb->data & ~0x10) == AX25_UI && dp.lastrepeat + 1 == dp.ndigi) { in ax25_rcv() 301 ax25_digi_invert(&dp, &reverse_dp); in ax25_rcv() 328 ax25_return_dm(dev, &src, &dest, &dp); in ax25_rcv() [all …]
|
/net/dccp/ccids/ |
D | ccid2.c | 237 struct dccp_sock *dp = dccp_sk(sk); in ccid2_hc_tx_packet_sent() local 265 hc->tx_seqh->ccid2s_seq = dp->dccps_gss; in ccid2_hc_tx_packet_sent() 315 if (dp->dccps_l_ack_ratio > 1) { in ccid2_hc_tx_packet_sent() 317 int denom = dp->dccps_l_ack_ratio * dp->dccps_l_ack_ratio - in ccid2_hc_tx_packet_sent() 318 dp->dccps_l_ack_ratio; in ccid2_hc_tx_packet_sent() 323 ccid2_change_l_ack_ratio(sk, dp->dccps_l_ack_ratio - 1); in ccid2_hc_tx_packet_sent() 433 struct dccp_sock *dp = dccp_sk(sk); in ccid2_new_ack() local 434 int r_seq_used = hc->tx_cwnd / dp->dccps_l_ack_ratio; in ccid2_new_ack() 436 if (hc->tx_cwnd < dp->dccps_l_seq_win && in ccid2_new_ack() 437 r_seq_used < dp->dccps_r_seq_win) { in ccid2_new_ack() [all …]
|
/net/sched/ |
D | sch_gred.c | 170 u16 dp = tc_index_to_dp(skb); in gred_enqueue() local 172 if (dp >= t->DPs || (q = t->tab[dp]) == NULL) { in gred_enqueue() 173 dp = t->def; in gred_enqueue() 175 q = t->tab[dp]; in gred_enqueue() 190 skb->tc_index = (skb->tc_index & ~GRED_VQ_MASK) | dp; in gred_enqueue() 269 u16 dp = tc_index_to_dp(skb); in gred_dequeue() local 271 if (dp >= t->DPs || (q = t->tab[dp]) == NULL) { in gred_dequeue() 474 static inline int gred_change_vq(struct Qdisc *sch, int dp, in gred_change_vq() argument 481 struct gred_sched_data *q = table->tab[dp]; in gred_change_vq() 489 table->tab[dp] = q = *prealloc; in gred_change_vq() [all …]
|