/net/openvswitch/ |
D | datapath.c | 136 static int queue_gso_packets(struct datapath *dp, struct sk_buff *, 138 static int queue_userspace_packet(struct datapath *dp, struct sk_buff *, 144 struct datapath *dp = NULL; in get_dp() local 152 dp = vport->dp; in get_dp() 156 return dp; in get_dp() 160 const char *ovs_dp_name(const struct datapath *dp) in ovs_dp_name() argument 162 struct vport *vport = ovs_vport_ovsl_rcu(dp, OVSP_LOCAL); in ovs_dp_name() 166 static int get_dpifindex(struct datapath *dp) in get_dpifindex() argument 173 local = ovs_vport_rcu(dp, OVSP_LOCAL); in get_dpifindex() 186 struct datapath *dp = container_of(rcu, struct datapath, rcu); in destroy_dp_rcu() local [all …]
|
D | datapath.h | 154 static inline struct net *ovs_dp_get_net(struct datapath *dp) in ovs_dp_get_net() argument 156 return read_pnet(&dp->net); in ovs_dp_get_net() 159 static inline void ovs_dp_set_net(struct datapath *dp, struct net *net) in ovs_dp_set_net() argument 161 write_pnet(&dp->net, net); in ovs_dp_set_net() 164 struct vport *ovs_lookup_vport(const struct datapath *dp, u16 port_no); 166 static inline struct vport *ovs_vport_rcu(const struct datapath *dp, int port_no) in ovs_vport_rcu() argument 169 return ovs_lookup_vport(dp, port_no); in ovs_vport_rcu() 172 static inline struct vport *ovs_vport_ovsl_rcu(const struct datapath *dp, int port_no) in ovs_vport_ovsl_rcu() argument 175 return ovs_lookup_vport(dp, port_no); in ovs_vport_ovsl_rcu() 178 static inline struct vport *ovs_vport_ovsl(const struct datapath *dp, int port_no) in ovs_vport_ovsl() argument [all …]
|
D | dp_notify.c | 30 struct datapath *dp; in dp_detach_port_notify() local 32 dp = vport->dp; in dp_detach_port_notify() 37 genl_set_err(&dp_vport_genl_family, ovs_dp_get_net(dp), 0, in dp_detach_port_notify() 43 ovs_dp_get_net(dp), notify, 0, in dp_detach_port_notify() 50 struct datapath *dp; in ovs_dp_notify_wq() local 53 list_for_each_entry(dp, &ovs_net->dps, list_node) { in ovs_dp_notify_wq() 60 hlist_for_each_entry_safe(vport, n, &dp->ports[i], dp_hash_node) { in ovs_dp_notify_wq()
|
D | actions.c | 41 static int do_execute_actions(struct datapath *dp, struct sk_buff *skb, 468 static int do_output(struct datapath *dp, struct sk_buff *skb, int out_port) in do_output() argument 475 vport = ovs_vport_rcu(dp, out_port); in do_output() 485 static int output_userspace(struct datapath *dp, struct sk_buff *skb, in output_userspace() argument 510 return ovs_dp_upcall(dp, skb, &upcall); in output_userspace() 518 static int sample(struct datapath *dp, struct sk_buff *skb, in sample() argument 553 return output_userspace(dp, skb, key, a); in sample() 563 ovs_dp_name(dp)); in sample() 631 static int execute_recirc(struct datapath *dp, struct sk_buff *skb, in execute_recirc() argument 663 ovs_dp_name(dp)); in execute_recirc() [all …]
|
D | vport-netdev.c | 78 static struct net_device *get_dpdev(struct datapath *dp) in get_dpdev() argument 82 local = ovs_vport_ovsl(dp, OVSP_LOCAL); in get_dpdev() 102 netdev_vport->dev = dev_get_by_name(ovs_dp_get_net(vport->dp), parms->name); in netdev_create() 117 get_dpdev(vport->dp)); in netdev_create() 133 netdev_upper_dev_unlink(netdev_vport->dev, get_dpdev(vport->dp)); in netdev_create()
|
D | vport.c | 105 net_eq(ovs_dp_get_net(vport->dp), net)) in ovs_vport_locate() 138 vport->dp = parms->dp; in ovs_vport_alloc() 201 bucket = hash_bucket(ovs_dp_get_net(vport->dp), in ovs_vport_add() 393 if (vport->dp->user_features & OVS_DP_F_VPORT_PIDS) in ovs_vport_get_upcall_portids()
|
D | vport.h | 100 struct datapath *dp; member 130 struct datapath *dp; member
|
D | vport-gre.c | 133 struct net *net = ovs_dp_get_net(vport->dp); in gre_tnl_send() 240 struct net *net = ovs_dp_get_net(parms->dp); in gre_create() 270 struct net *net = ovs_dp_get_net(vport->dp); in gre_tnl_destroy()
|
/net/dccp/ |
D | input.c | 176 const struct dccp_sock *dp = dccp_sk(sk); in dccp_deliver_input_to_ccids() local 180 ccid_hc_rx_packet_recv(dp->dccps_hc_rx_ccid, sk, skb); in dccp_deliver_input_to_ccids() 186 ccid_hc_tx_packet_recv(dp->dccps_hc_tx_ccid, sk, skb); in dccp_deliver_input_to_ccids() 192 struct dccp_sock *dp = dccp_sk(sk); in dccp_check_seqno() local 210 if (between48(ackno, dp->dccps_awl, dp->dccps_awh) && in dccp_check_seqno() 211 dccp_delta_seqno(dp->dccps_swl, seqno) >= 0) in dccp_check_seqno() 228 lswl = dp->dccps_swl; in dccp_check_seqno() 229 lawl = dp->dccps_awl; in dccp_check_seqno() 234 lswl = ADD48(dp->dccps_gsr, 1); in dccp_check_seqno() 235 lawl = dp->dccps_gar; in dccp_check_seqno() [all …]
|
D | output.c | 50 struct dccp_sock *dp = dccp_sk(sk); in dccp_transmit_skb() local 58 u64 ackno = dp->dccps_gsr; in dccp_transmit_skb() 63 dcb->dccpd_seq = ADD48(dp->dccps_gss, 1); in dccp_transmit_skb() 77 dcb->dccpd_seq = dp->dccps_iss; in dccp_transmit_skb() 109 dh->dccph_cscov = dp->dccps_pcslen; in dccp_transmit_skb() 114 dccp_hdr_set_seq(dh, dp->dccps_gss); in dccp_transmit_skb() 121 dp->dccps_service; in dccp_transmit_skb() 126 dp->dccps_awl = dp->dccps_iss; in dccp_transmit_skb() 153 static u32 dccp_determine_ccmps(const struct dccp_sock *dp) in dccp_determine_ccmps() argument 155 const struct ccid *tx_ccid = dp->dccps_hc_tx_ccid; in dccp_determine_ccmps() [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 | dccp.h | 268 int dccp_reqsk_init(struct request_sock *rq, struct dccp_sock const *dp, 333 const struct dccp_sock *dp = dccp_sk(sk); in dccp_bad_service_code() local 335 if (dp->dccps_service == service) in dccp_bad_service_code() 337 return !dccp_list_has_service(dp->dccps_service_list, service); in dccp_bad_service_code() 422 struct dccp_sock *dp = dccp_sk(sk); in dccp_update_gsr() local 424 if (after48(seq, dp->dccps_gsr)) in dccp_update_gsr() 425 dp->dccps_gsr = seq; in dccp_update_gsr() 427 dp->dccps_swl = SUB48(ADD48(dp->dccps_gsr, 1), dp->dccps_r_seq_win / 4); in dccp_update_gsr() 443 if (before48(dp->dccps_swl, dp->dccps_isr)) in dccp_update_gsr() 444 dp->dccps_swl = dp->dccps_isr; in dccp_update_gsr() [all …]
|
D | options.c | 54 struct dccp_sock *dp = dccp_sk(sk); in dccp_parse_options() local 61 struct dccp_options_received *opt_recv = &dp->dccps_options_received; in dccp_parse_options() 152 dp->dccps_timestamp_echo = ntohl(opt_val); in dccp_parse_options() 153 dp->dccps_timestamp_time = dccp_timestamp(); in dccp_parse_options() 218 if (ccid_hc_rx_parse_options(dp->dccps_hc_rx_ccid, sk, in dccp_parse_options() 233 if (ccid_hc_tx_parse_options(dp->dccps_hc_tx_ccid, sk, in dccp_parse_options() 314 struct dccp_sock *dp = dccp_sk(sk); in dccp_insert_option_ndp() local 315 u64 ndp = dp->dccps_ndp_count; in dccp_insert_option_ndp() 318 ++dp->dccps_ndp_count; in dccp_insert_option_ndp() 320 dp->dccps_ndp_count = 0; in dccp_insert_option_ndp() [all …]
|
D | feat.c | 43 struct dccp_sock *dp = dccp_sk(sk); in dccp_hdlr_ccid() local 50 ccid_hc_rx_delete(dp->dccps_hc_rx_ccid, sk); in dccp_hdlr_ccid() 51 dp->dccps_hc_rx_ccid = new_ccid; in dccp_hdlr_ccid() 53 ccid_hc_tx_delete(dp->dccps_hc_tx_ccid, sk); in dccp_hdlr_ccid() 54 dp->dccps_hc_tx_ccid = new_ccid; in dccp_hdlr_ccid() 61 struct dccp_sock *dp = dccp_sk(sk); in dccp_hdlr_seq_win() local 64 dp->dccps_r_seq_win = seq_win; in dccp_hdlr_seq_win() 66 dccp_update_gsr(sk, dp->dccps_gsr); in dccp_hdlr_seq_win() 68 dp->dccps_l_seq_win = seq_win; in dccp_hdlr_seq_win() 70 dccp_update_gss(sk, dp->dccps_gss); in dccp_hdlr_seq_win() [all …]
|
D | diag.c | 21 struct dccp_sock *dp = dccp_sk(sk); in dccp_get_info() local 32 if (dp->dccps_hc_rx_ackvec != NULL) in dccp_get_info() 35 if (dp->dccps_hc_rx_ccid != NULL) in dccp_get_info() 36 ccid_hc_rx_get_info(dp->dccps_hc_rx_ccid, sk, info); in dccp_get_info() 38 if (dp->dccps_hc_tx_ccid != NULL) in dccp_get_info() 39 ccid_hc_tx_get_info(dp->dccps_hc_tx_ccid, sk, info); in dccp_get_info()
|
D | ccid.h | 116 static inline int ccid_get_current_rx_ccid(struct dccp_sock *dp) in ccid_get_current_rx_ccid() argument 118 struct ccid *ccid = dp->dccps_hc_rx_ccid; in ccid_get_current_rx_ccid() 125 static inline int ccid_get_current_tx_ccid(struct dccp_sock *dp) in ccid_get_current_tx_ccid() argument 127 struct ccid *ccid = dp->dccps_hc_tx_ccid; in ccid_get_current_tx_ccid()
|
D | ipv4.c | 46 struct dccp_sock *dp = dccp_sk(sk); in dccp_v4_connect() local 54 dp->dccps_role = DCCP_ROLE_CLIENT; in dccp_v4_connect() 121 dp->dccps_iss = secure_dccp_sequence_number(inet->inet_saddr, in dccp_v4_connect() 125 inet->inet_id = dp->dccps_iss ^ jiffies; in dccp_v4_connect() 155 const struct dccp_sock *dp = dccp_sk(sk); in dccp_do_pmtu_discovery() local 188 dccp_send_sync(sk, dp->dccps_gsr, DCCP_PKT_SYNC); in dccp_do_pmtu_discovery() 217 struct dccp_sock *dp; in dccp_v4_err() local 255 dp = dccp_sk(sk); in dccp_v4_err() 258 !between48(seq, dp->dccps_awl, dp->dccps_awh)) { in dccp_v4_err()
|
D | timer.c | 265 struct dccp_sock *dp = dccp_sk(sk); in dccp_init_xmit_timers() local 267 tasklet_init(&dp->dccps_xmitlet, dccp_write_xmitlet, (unsigned long)sk); in dccp_init_xmit_timers() 268 setup_timer(&dp->dccps_xmit_timer, dccp_write_xmit_timer, in dccp_init_xmit_timers()
|
/net/rds/ |
D | iw_cm.c | 72 const struct rds_iw_connect_private *dp = NULL; in rds_iw_cm_connect_complete() local 78 dp = event->param.conn.private_data; in rds_iw_cm_connect_complete() 81 RDS_PROTOCOL(dp->dp_protocol_major, in rds_iw_cm_connect_complete() 82 dp->dp_protocol_minor)); in rds_iw_cm_connect_complete() 83 rds_iw_set_flow_control(conn, be32_to_cpu(dp->dp_credit)); in rds_iw_cm_connect_complete() 95 if (dp && dp->dp_ack_seq) in rds_iw_cm_connect_complete() 96 rds_send_drop_acked(conn, be64_to_cpu(dp->dp_ack_seq), NULL); in rds_iw_cm_connect_complete() 109 struct rds_iw_connect_private *dp, in rds_iw_cm_fill_conn_param() argument 119 if (dp) { in rds_iw_cm_fill_conn_param() 120 memset(dp, 0, sizeof(*dp)); in rds_iw_cm_fill_conn_param() [all …]
|
D | ib_cm.c | 127 const struct rds_ib_connect_private *dp = NULL; in rds_ib_cm_connect_complete() local 132 if (event->param.conn.private_data_len >= sizeof(*dp)) { in rds_ib_cm_connect_complete() 133 dp = event->param.conn.private_data; in rds_ib_cm_connect_complete() 136 if (dp->dp_protocol_major) { in rds_ib_cm_connect_complete() 138 RDS_PROTOCOL(dp->dp_protocol_major, in rds_ib_cm_connect_complete() 139 dp->dp_protocol_minor)); in rds_ib_cm_connect_complete() 140 rds_ib_set_flow_control(conn, be32_to_cpu(dp->dp_credit)); in rds_ib_cm_connect_complete() 186 if (dp && dp->dp_ack_seq) in rds_ib_cm_connect_complete() 187 rds_send_drop_acked(conn, be64_to_cpu(dp->dp_ack_seq), NULL); in rds_ib_cm_connect_complete() 194 struct rds_ib_connect_private *dp, in rds_ib_cm_fill_conn_param() argument [all …]
|
/net/ax25/ |
D | ax25_in.c | 193 ax25_digi dp, reverse_dp; in ax25_rcv() local 210 if (ax25_addr_parse(skb->data, skb->len, &src, &dest, &dp, &type, &dama) == NULL) in ax25_rcv() 216 if (dp.lastrepeat + 1 < dp.ndigi) /* Not yet digipeated completely */ in ax25_rcv() 217 next_digi = &dp.calls[dp.lastrepeat + 1]; in ax25_rcv() 222 skb_pull(skb, ax25_addr_size(&dp)); in ax25_rcv() 225 if (ax25cmp(&dest, dev_addr) == 0 && dp.lastrepeat + 1 == dp.ndigi) in ax25_rcv() 229 if (!mine && ax25_listen_mine(&dest, dev) && dp.lastrepeat + 1 == dp.ndigi) in ax25_rcv() 233 if ((*skb->data & ~0x10) == AX25_UI && dp.lastrepeat + 1 == dp.ndigi) { in ax25_rcv() 305 ax25_digi_invert(&dp, &reverse_dp); in ax25_rcv() 332 ax25_return_dm(dev, &src, &dest, &dp); in ax25_rcv() [all …]
|
D | ax25_addr.c | 276 int ax25_addr_size(const ax25_digi *dp) in ax25_addr_size() argument 278 if (dp == NULL) in ax25_addr_size() 281 return AX25_ADDR_LEN * (2 + dp->ndigi); in ax25_addr_size()
|
/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 …]
|
D | ccid3.c | 282 struct dccp_sock *dp = dccp_sk(sk); in ccid3_hc_tx_send_packet() local 311 if (dp->dccps_syn_rtt) { in ccid3_hc_tx_send_packet() 312 ccid3_pr_debug("SYN RTT = %uus\n", dp->dccps_syn_rtt); in ccid3_hc_tx_send_packet() 313 hc->tx_rtt = dp->dccps_syn_rtt; in ccid3_hc_tx_send_packet() 349 dp->dccps_hc_tx_insert_options = 1; in ccid3_hc_tx_send_packet() 601 struct dccp_sock *dp = dccp_sk(sk); in ccid3_hc_rx_send_feedback() local 642 dp->dccps_hc_rx_insert_options = 1; in ccid3_hc_rx_send_feedback()
|
/net/sched/ |
D | sch_gred.c | 157 u16 dp = tc_index_to_dp(skb); in gred_enqueue() local 159 if (dp >= t->DPs || (q = t->tab[dp]) == NULL) { in gred_enqueue() 160 dp = t->def; in gred_enqueue() 162 q = t->tab[dp]; in gred_enqueue() 176 skb->tc_index = (skb->tc_index & ~GRED_VQ_MASK) | dp; in gred_enqueue() 255 u16 dp = tc_index_to_dp(skb); in gred_dequeue() local 257 if (dp >= t->DPs || (q = t->tab[dp]) == NULL) { in gred_dequeue() 287 u16 dp = tc_index_to_dp(skb); in gred_drop() local 289 if (dp >= t->DPs || (q = t->tab[dp]) == NULL) { in gred_drop() 383 static inline int gred_change_vq(struct Qdisc *sch, int dp, in gred_change_vq() argument [all …]
|