Home
last modified time | relevance | path

Searched refs:cp (Results 1 – 25 of 55) sorted by relevance

123

/net/netfilter/ipvs/
A Dip_vs_conn.c147 ip_vs_conn_fill_param(cp->ipvs, cp->af, cp->protocol, in ip_vs_conn_hashkey_conn()
618 IP_VS_DBG_ADDR(cp->af, &cp->caddr), ntohs(cp->cport), in ip_vs_bind_dest()
619 IP_VS_DBG_ADDR(cp->af, &cp->vaddr), ntohs(cp->vport), in ip_vs_bind_dest()
620 IP_VS_DBG_ADDR(cp->daf, &cp->daddr), ntohs(cp->dport), in ip_vs_bind_dest()
621 ip_vs_fwd_tag(cp), cp->state, in ip_vs_bind_dest()
662 dest = ip_vs_find_dest(cp->ipvs, cp->af, cp->af, &cp->daddr, in ip_vs_try_bind_dest()
663 cp->dport, &cp->vaddr, cp->vport, in ip_vs_try_bind_dest()
664 cp->protocol, cp->fwmark, cp->flags); in ip_vs_try_bind_dest()
715 IP_VS_DBG_ADDR(cp->af, &cp->caddr), ntohs(cp->cport), in ip_vs_unbind_dest()
716 IP_VS_DBG_ADDR(cp->af, &cp->vaddr), ntohs(cp->vport), in ip_vs_unbind_dest()
[all …]
A Dip_vs_proto_tcp.c187 tcp_partial_csum_update(cp->af, tcph, &cp->daddr, &cp->vaddr, in tcp_snat_handler()
192 tcp_fast_csum_update(cp->af, tcph, &cp->daddr, &cp->vaddr, in tcp_snat_handler()
193 cp->dport, cp->vport); in tcp_snat_handler()
270 tcp_partial_csum_update(cp->af, tcph, &cp->vaddr, &cp->daddr, in tcp_dnat_handler()
275 tcp_fast_csum_update(cp->af, tcph, &cp->vaddr, &cp->daddr, in tcp_dnat_handler()
276 cp->vport, cp->dport); in tcp_dnat_handler()
551 IP_VS_DBG_ADDR(cp->af, &cp->caddr), in set_tcp_state()
553 IP_VS_DBG_ADDR(cp->af, &cp->vaddr), in set_tcp_state()
555 IP_VS_DBG_ADDR(cp->daf, &cp->daddr), in set_tcp_state()
673 IP_VS_DBG_ADDR(cp->af, &cp->caddr), in tcp_app_conn_bind()
[all …]
A Dip_vs_proto_udp.c180 udp_partial_csum_update(cp->af, udph, &cp->daddr, &cp->vaddr, in udp_snat_handler()
185 udp_fast_csum_update(cp->af, udph, &cp->daddr, &cp->vaddr, in udp_snat_handler()
186 cp->dport, cp->vport); in udp_snat_handler()
203 cp->caddr.ip, in udp_snat_handler()
205 cp->protocol, in udp_snat_handler()
264 udp_partial_csum_update(cp->af, udph, &cp->vaddr, &cp->daddr, in udp_dnat_handler()
269 udp_fast_csum_update(cp->af, udph, &cp->vaddr, &cp->daddr, in udp_dnat_handler()
270 cp->vport, cp->dport); in udp_dnat_handler()
417 IP_VS_DBG_ADDR(cp->af, &cp->caddr), in udp_app_conn_bind()
419 IP_VS_DBG_ADDR(cp->af, &cp->vaddr), in udp_app_conn_bind()
[all …]
A Dip_vs_ftp.c300 from = cp->daddr; in ip_vs_ftp_out()
311 IP_VS_DBG_ADDR(cp->af, &cp->caddr), 0); in ip_vs_ftp_out()
320 ip_vs_conn_fill_param(cp->ipvs, cp->af, in ip_vs_ftp_out()
329 cp->af, ipvsh->protocol, &cp->caddr, in ip_vs_ftp_out()
445 if (cp->af == AF_INET && in ip_vs_ftp_in()
491 if (cp->af == AF_INET && in ip_vs_ftp_in()
496 &to, &port, cp->af, in ip_vs_ftp_in()
505 ntohs(cp->vport)-1); in ip_vs_ftp_in()
520 IP_VS_DBG_ADDR(cp->af, &cp->vaddr), in ip_vs_ftp_in()
531 ip_vs_conn_fill_param(cp->ipvs, cp->af, in ip_vs_ftp_in()
[all …]
A Dip_vs_nfct.c144 struct ip_vs_conn *cp; in ip_vs_nfct_expect_callback() local
162 if (cp) { in ip_vs_nfct_expect_callback()
178 if (cp) { in ip_vs_nfct_expect_callback()
201 ip_vs_conn_put(cp); in ip_vs_nfct_expect_callback()
225 from_rs ? &cp->daddr : &cp->caddr, in ip_vs_nfct_expect_related()
226 from_rs ? &cp->caddr : &cp->vaddr, in ip_vs_nfct_expect_related()
228 from_rs ? &cp->cport : &cp->vport); in ip_vs_nfct_expect_related()
248 if (!cp->cport) in ip_vs_conn_drop_conntrack()
253 tuple.src.u3 = cp->caddr; in ip_vs_conn_drop_conntrack()
255 tuple.src.l3num = cp->af; in ip_vs_conn_drop_conntrack()
[all …]
A Dip_vs_xmit.c637 if (!local || cp->vport != cp->dport || in ip_vs_nat_send_or_cont()
638 !ip_vs_addr_equal(cp->af, &cp->vaddr, &cp->daddr)) in ip_vs_nat_send_or_cont()
764 local = __ip_vs_get_out_rt(cp->ipvs, cp->af, skb, cp->dest, cp->daddr.ip, in ip_vs_nat_xmit()
846 local = __ip_vs_get_out_rt_v6(cp->ipvs, cp->af, skb, cp->dest, in ip_vs_nat_xmit_v6()
1125 local = __ip_vs_get_out_rt(ipvs, cp->af, skb, cp->dest, cp->daddr.ip, in ip_vs_tunnel_xmit()
1403 local = __ip_vs_get_out_rt(cp->ipvs, cp->af, skb, cp->dest, cp->daddr.ip, in ip_vs_dr_xmit()
1433 local = __ip_vs_get_out_rt_v6(cp->ipvs, cp->af, skb, cp->dest, in ip_vs_dr_xmit_v6()
1477 rc = cp->packet_xmit(skb, cp, pp, iph); in ip_vs_icmp_xmit()
1494 local = __ip_vs_get_out_rt(cp->ipvs, cp->af, skb, cp->dest, cp->daddr.ip, rt_mode, in ip_vs_icmp_xmit()
1562 rc = cp->packet_xmit(skb, cp, pp, ipvsh); in ip_vs_icmp_xmit_v6()
[all …]
A Dip_vs_core.c561 IP_VS_DBG_ADDR(cp->af, &cp->caddr), ntohs(cp->cport), in ip_vs_schedule()
562 IP_VS_DBG_ADDR(cp->af, &cp->vaddr), ntohs(cp->vport), in ip_vs_schedule()
563 IP_VS_DBG_ADDR(cp->daf, &cp->daddr), ntohs(cp->dport), in ip_vs_schedule()
564 cp->flags, refcount_read(&cp->refcnt)); in ip_vs_schedule()
631 ret = cp->packet_xmit(skb, cp, pd->pp, iph); in ip_vs_leave()
827 ntohs(inout ? cp->vport : cp->dport)); in ip_vs_nat_icmp_v6()
1206 IP_VS_DBG_ADDR(cp->af, &cp->caddr), ntohs(cp->cport), in ip_vs_new_conn_out()
1207 IP_VS_DBG_ADDR(cp->af, &cp->vaddr), ntohs(cp->vport), in ip_vs_new_conn_out()
1208 IP_VS_DBG_ADDR(cp->af, &cp->daddr), ntohs(cp->dport), in ip_vs_new_conn_out()
2032 if (cp && cp->dest && !(cp->dest->flags & IP_VS_DEST_F_AVAILABLE)) { in ip_vs_in_hook()
[all …]
A Dip_vs_sync.c444 for (cp = cp->control; cp; cp = cp->control) { in in_persistence()
483 force = cp->state != cp->old_state; in ip_vs_sync_conn_needed()
494 force = cp->state != cp->old_state; in ip_vs_sync_conn_needed()
531 cp->old_state = cp->state; in ip_vs_sync_conn_needed()
615 cp = cp->control; in ip_vs_sync_conn_v0()
655 if (!cp->pe_data || !cp->dest) { in ip_vs_sync_conn()
757 if (cp->pe_data_len && cp->pe_data) { in ip_vs_sync_conn()
760 memcpy(p, cp->pe_data, cp->pe_data_len); in ip_vs_sync_conn()
775 cp = cp->control; in ip_vs_sync_conn()
854 if (cp && ((cp->dport != dport) || in ip_vs_proc_conn()
[all …]
A Dip_vs_proto_sctp.c446 IP_VS_DBG_ADDR(cp->daf, &cp->daddr), in set_sctp_state()
447 ntohs(cp->dport), in set_sctp_state()
448 IP_VS_DBG_ADDR(cp->af, &cp->caddr), in set_sctp_state()
449 ntohs(cp->cport), in set_sctp_state()
470 cp->timeout = pd->timeout_table[cp->state = next_state]; in set_sctp_state()
472 cp->timeout = sctp_timeouts[cp->state = next_state]; in set_sctp_state()
542 IP_VS_DBG_ADDR(cp->af, &cp->caddr), in sctp_app_conn_bind()
543 ntohs(cp->cport), in sctp_app_conn_bind()
544 IP_VS_DBG_ADDR(cp->af, &cp->vaddr), in sctp_app_conn_bind()
545 ntohs(cp->vport), in sctp_app_conn_bind()
[all …]
A Dip_vs_app.c262 return pp->app_conn_bind(cp); in ip_vs_bind_app()
277 inc->unbind_conn(inc, cp); in ip_vs_unbind_app()
279 inc->done_conn(inc, cp); in ip_vs_unbind_app()
281 cp->app = NULL; in ip_vs_unbind_app()
350 spin_lock_bh(&cp->lock); in vs_seq_update()
355 cp->flags |= flag; in vs_seq_update()
357 spin_unlock_bh(&cp->lock); in vs_seq_update()
400 vs_seq_update(cp, &cp->out_seq, in app_tcp_pkt_out()
420 if ((app = cp->app) == NULL) in ip_vs_app_pkt_out()
477 vs_seq_update(cp, &cp->in_seq, in app_tcp_pkt_in()
[all …]
/net/rds/
A Dthreads.c86 cp->cp_conn, &cp->cp_conn->c_laddr, &cp->cp_conn->c_faddr); in rds_connect_path_complete()
88 cp->cp_reconnect_jiffies = 0; in rds_connect_path_complete()
131 cp->cp_reconnect_jiffies); in rds_queue_reconnect()
150 rand % cp->cp_reconnect_jiffies, cp->cp_reconnect_jiffies, in rds_queue_reconnect()
158 cp->cp_reconnect_jiffies = min(cp->cp_reconnect_jiffies * 2, in rds_queue_reconnect()
170 if (cp->cp_index > 0 && in rds_connect_worker()
171 rds_addr_cmp(&cp->cp_conn->c_laddr, &cp->cp_conn->c_faddr) >= 0) in rds_connect_worker()
184 rds_queue_reconnect(cp); in rds_connect_worker()
200 ret = rds_send_xmit(cp); in rds_send_worker()
226 ret = cp->cp_conn->c_trans->recv_path(cp); in rds_recv_worker()
[all …]
A Dconnection.c121 rds_send_path_reset(cp); in rds_conn_path_reset()
122 cp->cp_flags = 0; in rds_conn_path_reset()
134 cp->cp_next_tx_seq = 1; in __rds_conn_path_init()
139 cp->cp_conn = conn; in __rds_conn_path_init()
141 cp->cp_send_gen = 0; in __rds_conn_path_init()
149 cp->cp_flags = 0; in __rds_conn_path_init()
457 &cp->cp_send_queue, in rds_conn_path_destroy()
463 if (cp->cp_xmit_rm) in rds_conn_path_destroy()
471 cp->cp_conn->c_trans->conn_free(cp->cp_transport_data); in rds_conn_path_destroy()
500 cp = &conn->c_path[i]; in rds_conn_destroy()
[all …]
A Dsend.c70 if (cp->cp_xmit_rm) { in rds_send_path_reset()
71 rm = cp->cp_xmit_rm; in rds_send_path_reset()
72 cp->cp_xmit_rm = NULL; in rds_send_path_reset()
81 cp->cp_xmit_sg = 0; in rds_send_path_reset()
99 list_splice_init(&cp->cp_retrans, &cp->cp_send_queue); in rds_send_path_reset()
166 release_in_xmit(cp); in rds_send_xmit()
187 release_in_xmit(cp); in rds_send_xmit()
201 rm = cp->cp_xmit_rm; in rds_send_xmit()
390 cp->cp_xmit_sg++; in rds_send_xmit()
408 cp->cp_xmit_sg = 0; in rds_send_xmit()
[all …]
A Dtcp_connect.c43 struct rds_conn_path *cp; in rds_tcp_state_change() local
47 cp = sk->sk_user_data; in rds_tcp_state_change()
48 if (!cp) { in rds_tcp_state_change()
52 tc = cp->cp_transport_data; in rds_tcp_state_change()
70 &cp->cp_conn->c_faddr) >= 0 && in rds_tcp_state_change()
73 rds_conn_path_drop(cp, false); in rds_tcp_state_change()
80 rds_conn_path_drop(cp, false); in rds_tcp_state_change()
105 if (cp->cp_index > 0 && cp->cp_conn->c_npaths < 2) in rds_tcp_conn_path_connect()
110 if (rds_conn_path_up(cp)) { in rds_tcp_conn_path_connect()
175 rds_tcp_set_callbacks(sock, cp); in rds_tcp_conn_path_connect()
[all …]
A Dtcp_send.c43 struct rds_tcp_connection *tc = cp->cp_transport_data; in rds_tcp_xmit_path_prepare()
73 struct rds_conn_path *cp = rm->m_inc.i_conn_path; in rds_tcp_xmit() local
151 if (rds_conn_path_up(cp)) { in rds_tcp_xmit()
155 &conn->c_faddr, cp->cp_index, ret); in rds_tcp_xmit()
156 rds_conn_path_drop(cp, false); in rds_tcp_xmit()
182 struct rds_conn_path *cp; in rds_tcp_write_space() local
186 cp = sk->sk_user_data; in rds_tcp_write_space()
187 if (!cp) { in rds_tcp_write_space()
192 tc = cp->cp_transport_data; in rds_tcp_write_space()
203 !rds_destroy_pending(cp->cp_conn)) in rds_tcp_write_space()
[all …]
A Dtcp_recv.c159 struct rds_conn_path *cp = arg->conn_path; in rds_tcp_data_recv() local
182 rds_inc_path_init(&tinc->ti_inc, cp, in rds_tcp_data_recv()
183 &cp->cp_conn->c_faddr); in rds_tcp_data_recv()
271 arg.conn_path = cp; in rds_tcp_read_sock()
298 cp->cp_index, tc, sock); in rds_tcp_recv_path()
301 ret = rds_tcp_read_sock(cp, GFP_KERNEL); in rds_tcp_recv_path()
310 struct rds_conn_path *cp; in rds_tcp_data_ready() local
317 cp = sk->sk_user_data; in rds_tcp_data_ready()
318 if (!cp) { /* check for teardown race */ in rds_tcp_data_ready()
323 tc = cp->cp_transport_data; in rds_tcp_data_ready()
[all …]
A Dtcp_listen.c86 struct rds_conn_path *cp = &conn->c_path[i]; in rds_tcp_accept_one_path() local
88 if (rds_conn_path_transition(cp, RDS_CONN_DOWN, in rds_tcp_accept_one_path()
90 rds_conn_path_transition(cp, RDS_CONN_ERROR, in rds_tcp_accept_one_path()
92 return cp->cp_transport_data; in rds_tcp_accept_one_path()
106 struct rds_conn_path *cp; in rds_tcp_accept_one() local
181 cp = rs_tcp->t_cpath; in rds_tcp_accept_one()
182 conn_state = rds_conn_path_state(cp); in rds_tcp_accept_one()
188 rds_tcp_reset_callbacks(new_sock, cp); in rds_tcp_accept_one()
190 rds_connect_path_complete(cp, RDS_CONN_RESETTING); in rds_tcp_accept_one()
192 rds_tcp_set_callbacks(new_sock, cp); in rds_tcp_accept_one()
[all …]
/net/bluetooth/
A Dhci_sync.c917 memset(&cp, 0, sizeof(cp)); in hci_update_eir_sync()
1199 memset(&cp, 0, sizeof(cp)); in hci_set_adv_set_random_addr_sync()
1295 memset(&cp, 0, sizeof(cp)); in hci_set_adv_data_sync()
1375 memset(&cp, 0, sizeof(cp)); in hci_setup_ext_adv_instance_sync()
1506 memset(&cp, 0, sizeof(cp)); in __hci_set_scan_rsp_data_sync()
1555 memset(cp, 0, sizeof(*cp)); in hci_enable_ext_advertising_sync()
3493 sizeof(cp), &cp, in hci_update_name_sync()
3812 sizeof(cp.flt_type) : sizeof(cp), &cp, in hci_set_event_filter_sync()
5518 sizeof(cp), &cp, in hci_disconnect_sync()
6892 sizeof(cp), &cp, in hci_acl_create_conn_sync()
[all …]
A Dmgmt.c1568 if (cp->val != 0x00 && cp->val != 0x01 && cp->val != 0x02) in set_discoverable()
2555 cp->event, cp->timeout ? in send_hci_cmd_sync()
3884 cp, sizeof(*cp)); in set_name_complete()
6108 &cp->addr, sizeof(cp->addr)); in confirm_name()
6144 &cp->addr, sizeof(cp->addr)); in block_device()
6180 &cp->addr, sizeof(cp->addr)); in unblock_device()
6329 if (cp->val != 0x00 && cp->val != 0x01 && cp->val != 0x02) in set_advertising()
6793 if (cp->val != 0x00 && cp->val != 0x01 && cp->val != 0x02) in set_secure_conn()
6862 if (cp->val != 0x00 && cp->val != 0x01 && cp->val != 0x02) in set_debug_keys()
8159 cp, sizeof(*cp)); in read_local_ssp_oob_req()
[all …]
A Dhci_conn.c217 hci_send_cmd(hdev, HCI_OP_ADD_SCO, sizeof(cp), &cp); in hci_add_sco()
305 memset(&cp, 0x00, sizeof(cp)); in hci_enhanced_setup_sync()
503 memset(&cp, 0, sizeof(cp)); in hci_le_conn_update()
512 hci_send_cmd(hdev, HCI_OP_LE_CONN_UPDATE, sizeof(cp), &cp); in hci_le_conn_update()
528 memset(&cp, 0, sizeof(cp)); in hci_le_start_enc()
535 hci_send_cmd(hdev, HCI_OP_LE_START_ENC, sizeof(cp), &cp); in hci_le_start_enc()
604 hci_send_cmd(hdev, HCI_OP_SNIFF_SUBRATE, sizeof(cp), &cp); in hci_conn_idle()
614 hci_send_cmd(hdev, HCI_OP_SNIFF_MODE, sizeof(cp), &cp); in hci_conn_idle()
636 &cp); in le_disable_advertising()
1746 memset(&cp, 0, sizeof(cp)); in hci_le_create_big()
[all …]
A Dmsft.c150 skb = __hci_cmd_sync(hdev, hdev->msft_opcode, sizeof(cp), &cp, in read_supported_features()
350 skb = __hci_cmd_sync(hdev, hdev->msft_opcode, sizeof(cp), &cp, in msft_remove_addr_filters_sync()
439 skb = __hci_cmd_sync(hdev, hdev->msft_opcode, sizeof(cp), &cp, in msft_remove_monitor_sync()
528 if (!cp) in msft_add_monitor_sync()
577 kfree(cp); in msft_add_monitor_sync()
734 skb = __hci_cmd_sync(hdev, hdev->msft_opcode, sizeof(cp), &cp, in msft_cancel_address_filter_sync()
868 size = sizeof(*cp) + in msft_add_address_filter_sync()
872 if (!cp) { in msft_add_address_filter_sync()
890 kfree(cp); in msft_add_address_filter_sync()
1189 cp.enable = enable; in msft_set_filter_enable()
[all …]
A Dhci_event.c1419 if (!cp || !cp->handle) in hci_cc_le_set_adv_set_random_addr()
2393 memset(&cp, 0, sizeof(cp)); in hci_resolve_name()
3179 sizeof(cp), &cp); in hci_conn_complete_evt()
3636 sizeof(cp), &cp)) in hci_encrypt_change_evt()
3696 sizeof(cp), &cp); in hci_remote_features_evt()
5254 sizeof(cp), &cp); in hci_io_capa_request_evt()
5262 sizeof(cp), &cp); in hci_io_capa_request_evt()
5515 sizeof(cp), &cp); in hci_remote_oob_data_request_evt()
5534 sizeof(cp), &cp); in hci_remote_oob_data_request_evt()
5543 sizeof(cp), &cp); in hci_remote_oob_data_request_evt()
[all …]
A Daosp.c150 struct aosp_bqr_cp cp; in enable_quality_report() local
152 cp.report_action = REPORT_ACTION_ADD; in enable_quality_report()
153 cp.event_mask = DEFAULT_BQR_EVENT_MASK; in enable_quality_report()
154 cp.min_report_interval = DEFALUT_REPORT_INTERVAL_MS; in enable_quality_report()
156 skb = __hci_cmd_sync(hdev, BQR_OPCODE, sizeof(cp), &cp, in enable_quality_report()
174 struct aosp_bqr_cp cp = { 0 }; in disable_quality_report() local
176 cp.report_action = REPORT_ACTION_CLEAR; in disable_quality_report()
178 skb = __hci_cmd_sync(hdev, BQR_OPCODE, sizeof(cp), &cp, in disable_quality_report()
/net/sched/
A Dact_ctinfo.c36 newdscp = (((READ_ONCE(ct->mark) & cp->dscpmask) >> cp->dscpmaskshift) << 2) & in tcf_ctinfo_dscp_set()
88 struct tcf_ctinfo_params *cp; in tcf_ctinfo_act() local
122 zone.id = cp->zone; in tcf_ctinfo_act()
133 if (!cp->dscpstatemask || (READ_ONCE(ct->mark) & cp->dscpstatemask)) in tcf_ctinfo_act()
142 return cp->action; in tcf_ctinfo_act()
302 opt.action = cp->action; in tcf_ctinfo_dump()
311 cp->dscpmask)) in tcf_ctinfo_dump()
314 cp->dscpstatemask)) in tcf_ctinfo_dump()
320 cp->cpmarkmask)) in tcf_ctinfo_dump()
354 if (cp) in tcf_ctinfo_cleanup()
[all …]
/net/can/
A Daf_can.c98 const struct can_proto *cp; in can_get_proto() local
102 if (cp && !try_module_get(cp->prot->owner)) in can_get_proto()
103 cp = NULL; in can_get_proto()
106 return cp; in can_get_proto()
118 const struct can_proto *cp; in can_create() local
129 if (!cp) { in can_create()
148 if (!cp) in can_create()
156 sock->ops = cp->ops; in can_create()
180 can_put_proto(cp); in can_create()
738 int proto = cp->protocol; in can_proto_register()
[all …]

Completed in 887 milliseconds

123