| /linux/include/net/ |
| H A D | sock.h | 441 void (*sk_data_ready)(struct sock *sk); 501 struct sk_buff* (*sk_validate_xmit_skb)(struct sock *sk, 564 void (*sk_state_change)(struct sock *sk); 565 void (*sk_write_space)(struct sock *sk); 566 void (*sk_error_report)(struct sock *sk); 567 int (*sk_backlog_rcv)(struct sock *sk, 569 void (*sk_destruct)(struct sock *sk); 620 static inline bool sk_user_data_is_nocopy(const struct sock *sk) in sk_user_data_is_nocopy() argument 622 return ((uintptr_t)sk->sk_user_data & SK_USER_DATA_NOCOPY); in sk_user_data_is_nocopy() 625 #define __sk_user_data(sk) ((*((void __rcu **)&(sk)->sk_user_data))) argument [all …]
|
| H A D | llc_c_ev.h | 128 typedef int (*llc_conn_ev_t)(struct sock *sk, struct sk_buff *skb); 129 typedef int (*llc_conn_ev_qfyr_t)(struct sock *sk, struct sk_buff *skb); 131 int llc_conn_ev_conn_req(struct sock *sk, struct sk_buff *skb); 132 int llc_conn_ev_data_req(struct sock *sk, struct sk_buff *skb); 133 int llc_conn_ev_disc_req(struct sock *sk, struct sk_buff *skb); 134 int llc_conn_ev_rst_req(struct sock *sk, struct sk_buff *skb); 135 int llc_conn_ev_local_busy_detected(struct sock *sk, struct sk_buff *skb); 136 int llc_conn_ev_local_busy_cleared(struct sock *sk, struct sk_buff *skb); 137 int llc_conn_ev_rx_bad_pdu(struct sock *sk, struct sk_buff *skb); 138 int llc_conn_ev_rx_disc_cmd_pbit_set_x(struct sock *sk, struct sk_buff *skb); [all …]
|
| H A D | llc_c_ac.h | 97 typedef int (*llc_conn_action_t)(struct sock *sk, struct sk_buff *skb); 99 int llc_conn_ac_clear_remote_busy(struct sock *sk, struct sk_buff *skb); 100 int llc_conn_ac_conn_ind(struct sock *sk, struct sk_buff *skb); 101 int llc_conn_ac_conn_confirm(struct sock *sk, struct sk_buff *skb); 102 int llc_conn_ac_data_ind(struct sock *sk, struct sk_buff *skb); 103 int llc_conn_ac_disc_ind(struct sock *sk, struct sk_buff *skb); 104 int llc_conn_ac_rst_ind(struct sock *sk, struct sk_buff *skb); 105 int llc_conn_ac_rst_confirm(struct sock *sk, struct sk_buff *skb); 106 int llc_conn_ac_clear_remote_busy_if_f_eq_1(struct sock *sk, 108 int llc_conn_ac_stop_rej_tmr_if_data_flag_eq_2(struct sock *sk, [all …]
|
| H A D | tcp.h | 69 void tcp_time_wait(struct sock *sk, int state, int timeo); 300 static inline bool tcp_under_memory_pressure(const struct sock *sk) in tcp_under_memory_pressure() argument 302 if (mem_cgroup_sk_enabled(sk) && in tcp_under_memory_pressure() 303 mem_cgroup_sk_under_memory_pressure(sk)) in tcp_under_memory_pressure() 325 static inline void tcp_wmem_free_skb(struct sock *sk, struct sk_buff *skb) in tcp_wmem_free_skb() argument 327 sk_wmem_queued_add(sk, -skb->truesize); in tcp_wmem_free_skb() 329 sk_mem_uncharge(sk, skb->truesize); in tcp_wmem_free_skb() 331 sk_mem_uncharge(sk, SKB_TRUESIZE(skb_end_offset(skb))); in tcp_wmem_free_skb() 335 void sk_forced_mem_schedule(struct sock *sk, int size); 337 bool tcp_check_oom(const struct sock *sk, int shift); [all …]
|
| /linux/net/bluetooth/rfcomm/ |
| H A D | sock.c | 43 static void rfcomm_sock_close(struct sock *sk); 44 static void rfcomm_sock_kill(struct sock *sk); 52 struct sock *sk = d->owner; in rfcomm_sk_data_ready() local 53 if (!sk) in rfcomm_sk_data_ready() 56 atomic_add(skb->len, &sk->sk_rmem_alloc); in rfcomm_sk_data_ready() 57 skb_queue_tail(&sk->sk_receive_queue, skb); in rfcomm_sk_data_ready() 58 sk->sk_data_ready(sk); in rfcomm_sk_data_ready() 60 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf) in rfcomm_sk_data_ready() 66 struct sock *sk = d->owner, *parent; in rfcomm_sk_state_change() local 68 if (!sk) in rfcomm_sk_state_change() [all …]
|
| /linux/net/netrom/ |
| H A D | nr_timer.c | 35 void nr_init_timers(struct sock *sk) in nr_init_timers() argument 37 struct nr_sock *nr = nr_sk(sk); in nr_init_timers() 45 sk->sk_timer.function = nr_heartbeat_expiry; in nr_init_timers() 48 void nr_start_t1timer(struct sock *sk) in nr_start_t1timer() argument 50 struct nr_sock *nr = nr_sk(sk); in nr_start_t1timer() 52 sk_reset_timer(sk, &nr->t1timer, jiffies + nr->t1); in nr_start_t1timer() 55 void nr_start_t2timer(struct sock *sk) in nr_start_t2timer() argument 57 struct nr_sock *nr = nr_sk(sk); in nr_start_t2timer() 59 sk_reset_timer(sk, &nr->t2timer, jiffies + nr->t2); in nr_start_t2timer() 62 void nr_start_t4timer(struct sock *sk) in nr_start_t4timer() argument [all …]
|
| /linux/net/bluetooth/ |
| H A D | iso.c | 31 struct sock *sk; member 44 static void iso_sock_close(struct sock *sk); 45 static void iso_sock_kill(struct sock *sk); 48 #define iso_pi(sk) ((struct iso_pinfo *)sk) argument 82 static bool iso_match_sid(struct sock *sk, void *data); 83 static bool iso_match_sync_handle(struct sock *sk, void *data); 84 static bool iso_match_sync_handle_pa_report(struct sock *sk, void *data); 85 static void iso_sock_disconn(struct sock *sk); 87 typedef bool (*iso_sock_match_t)(struct sock *sk, void *data); 103 if (conn->sk) in iso_conn_free() [all …]
|
| H A D | sco.c | 49 struct sock *sk; member 60 static void sco_sock_close(struct sock *sk); 61 static void sco_sock_kill(struct sock *sk); 64 #define sco_pi(sk) ((struct sco_pinfo *) sk) argument 86 if (conn->sk) in sco_conn_free() 87 sco_pi(conn->sk)->conn = NULL; in sco_conn_free() 133 if (!conn || !bt_sock_linked(&sco_sk_list, conn->sk)) in sco_sock_hold() 136 sock_hold(conn->sk); in sco_sock_hold() 138 return conn->sk; in sco_sock_hold() 145 struct sock *sk; in sco_sock_timeout() local [all …]
|
| H A D | af_bluetooth.c | 74 void bt_sock_reclassify_lock(struct sock *sk, int proto) in bt_sock_reclassify_lock() argument 76 BUG_ON(!sk); in bt_sock_reclassify_lock() 77 BUG_ON(!sock_allow_reclassification(sk)); in bt_sock_reclassify_lock() 79 sock_lock_init_class_and_name(sk, in bt_sock_reclassify_lock() 137 bt_sock_reclassify_lock(sock->sk, proto); in bt_sock_create() 149 struct sock *sk; in bt_sock_alloc() local 151 sk = sk_alloc(net, PF_BLUETOOTH, prio, prot, kern); in bt_sock_alloc() 152 if (!sk) in bt_sock_alloc() 155 sock_init_data(sock, sk); in bt_sock_alloc() 156 INIT_LIST_HEAD(&bt_sk(sk)->accept_q); in bt_sock_alloc() [all …]
|
| /linux/net/core/ |
| H A D | sock.c | 158 static void sock_def_write_space_wfree(struct sock *sk); 159 static void sock_def_write_space(struct sock *sk); 171 bool sk_ns_capable(const struct sock *sk, in sk_ns_capable() argument 174 return file_ns_capable(sk->sk_socket->file, user_ns, cap) && in sk_ns_capable() 188 bool sk_capable(const struct sock *sk, int cap) in sk_capable() argument 190 return sk_ns_capable(sk, &init_user_ns, cap); in sk_capable() 203 bool sk_net_capable(const struct sock *sk, int cap) in sk_net_capable() argument 205 return sk_ns_capable(sk, sock_net(sk)->user_ns, cap); in sk_net_capable() 302 void sk_set_memalloc(struct sock *sk) in sk_set_memalloc() argument 304 sock_set_flag(sk, SOCK_MEMALLOC); in sk_set_memalloc() [all …]
|
| /linux/net/smc/ |
| H A D | smc_close.c | 41 struct sock *sk; in smc_close_cleanup_listen() local 44 while ((sk = smc_accept_dequeue(parent, NULL))) in smc_close_cleanup_listen() 45 smc_close_non_accepted(sk); in smc_close_cleanup_listen() 52 struct sock *sk = &smc->sk; in smc_close_stream_wait() local 64 add_wait_queue(sk_sleep(sk), &wait); in smc_close_stream_wait() 68 rc = sk_wait_event(sk, &timeout, in smc_close_stream_wait() 70 READ_ONCE(sk->sk_err) == ECONNABORTED || in smc_close_stream_wait() 71 READ_ONCE(sk->sk_err) == ECONNRESET || in smc_close_stream_wait() 77 remove_wait_queue(sk_sleep(sk), &wait); in smc_close_stream_wait() 85 smc->sk.sk_state_change(&smc->sk); in smc_close_wake_tx_prepared() [all …]
|
| /linux/net/rose/ |
| H A D | rose_timer.c | 32 void rose_start_heartbeat(struct sock *sk) in rose_start_heartbeat() argument 34 sk_stop_timer(sk, &sk->sk_timer); in rose_start_heartbeat() 36 sk->sk_timer.function = rose_heartbeat_expiry; in rose_start_heartbeat() 37 sk->sk_timer.expires = jiffies + 5 * HZ; in rose_start_heartbeat() 39 sk_reset_timer(sk, &sk->sk_timer, sk->sk_timer.expires); in rose_start_heartbeat() 42 void rose_start_t1timer(struct sock *sk) in rose_start_t1timer() argument 44 struct rose_sock *rose = rose_sk(sk); in rose_start_t1timer() 46 sk_stop_timer(sk, &rose->timer); in rose_start_t1timer() 51 sk_reset_timer(sk, &rose->timer, rose->timer.expires); in rose_start_t1timer() 54 void rose_start_t2timer(struct sock *sk) in rose_start_t2timer() argument [all …]
|
| H A D | rose_in.c | 37 static int rose_state1_machine(struct sock *sk, struct sk_buff *skb, int frametype) in rose_state1_machine() argument 39 struct rose_sock *rose = rose_sk(sk); in rose_state1_machine() 43 rose_stop_timer(sk); in rose_state1_machine() 44 rose_start_idletimer(sk); in rose_state1_machine() 51 sk->sk_state = TCP_ESTABLISHED; in rose_state1_machine() 52 if (!sock_flag(sk, SOCK_DEAD)) in rose_state1_machine() 53 sk->sk_state_change(sk); in rose_state1_machine() 57 rose_write_internal(sk, ROSE_CLEAR_CONFIRMATION); in rose_state1_machine() 58 rose_disconnect(sk, ECONNREFUSED, skb->data[3], skb->data[4]); in rose_state1_machine() 74 static int rose_state2_machine(struct sock *sk, struct sk_buff *skb, int frametype) in rose_state2_machine() argument [all …]
|
| /linux/net/ipv4/ |
| H A D | tcp_timer.c | 27 static u32 tcp_clamp_rto_to_user_timeout(const struct sock *sk) in tcp_clamp_rto_to_user_timeout() argument 29 const struct inet_connection_sock *icsk = inet_csk(sk); in tcp_clamp_rto_to_user_timeout() 30 const struct tcp_sock *tp = tcp_sk(sk); in tcp_clamp_rto_to_user_timeout() 49 u32 tcp_clamp_probe0_to_user_timeout(const struct sock *sk, u32 when) in tcp_clamp_probe0_to_user_timeout() argument 51 const struct inet_connection_sock *icsk = inet_csk(sk); in tcp_clamp_probe0_to_user_timeout() 75 static void tcp_write_err(struct sock *sk) in tcp_write_err() argument 77 tcp_done_with_error(sk, READ_ONCE(sk->sk_err_soft) ? : ETIMEDOUT); in tcp_write_err() 78 __NET_INC_STATS(sock_net(sk), LINUX_MIB_TCPABORTONTIMEOUT); in tcp_write_err() 105 static int tcp_out_of_resources(struct sock *sk, bool do_reset) in tcp_out_of_resources() argument 107 struct tcp_sock *tp = tcp_sk(sk); in tcp_out_of_resources() [all …]
|
| H A D | inet_hashtables.c | 47 static u32 sk_ehashfn(const struct sock *sk) in sk_ehashfn() argument 50 if (sk->sk_family == AF_INET6 && in sk_ehashfn() 51 !ipv6_addr_v4mapped(&sk->sk_v6_daddr)) in sk_ehashfn() 52 return inet6_ehashfn(sock_net(sk), in sk_ehashfn() 53 &sk->sk_v6_rcv_saddr, sk->sk_num, in sk_ehashfn() 54 &sk->sk_v6_daddr, sk->sk_dport); in sk_ehashfn() 56 return inet_ehashfn(sock_net(sk), in sk_ehashfn() 57 sk->sk_rcv_saddr, sk->sk_num, in sk_ehashfn() 58 sk->sk_daddr, sk->sk_dport); in sk_ehashfn() 61 static bool sk_is_connect_bind(const struct sock *sk) in sk_is_connect_bind() argument [all …]
|
| /linux/tools/testing/selftests/net/tcp_ao/ |
| H A D | setsockopt-closed.c | 12 static void make_listen(int sk) in make_listen() argument 17 if (bind(sk, (struct sockaddr *)&addr, sizeof(addr)) < 0) in make_listen() 19 if (listen(sk, 1)) in make_listen() 23 static void test_vefify_ao_info(int sk, struct tcp_ao_info_opt *info, in test_vefify_ao_info() argument 29 if (getsockopt(sk, IPPROTO_TCP, TCP_AO_INFO, &tmp, &len)) in test_vefify_ao_info() 58 static void __setsockopt_checked(int sk, int optname, bool get, in __setsockopt_checked() argument 71 ret = getsockopt(sk, IPPROTO_TCP, optname, optval, len); in __setsockopt_checked() 73 ret = setsockopt(sk, IPPROTO_TCP, optname, optval, *len); in __setsockopt_checked() 80 close(sk); in __setsockopt_checked() 90 test_verify_socket_key(sk, optval); in __setsockopt_checked() [all …]
|
| /linux/net/caif/ |
| H A D | caif_socket.c | 49 struct sock sk; /* must be first member */ member 88 static void caif_read_lock(struct sock *sk) in caif_read_lock() argument 91 cf_sk = container_of(sk, struct caifsock, sk); in caif_read_lock() 95 static void caif_read_unlock(struct sock *sk) in caif_read_unlock() argument 98 cf_sk = container_of(sk, struct caifsock, sk); in caif_read_unlock() 105 return cf_sk->sk.sk_rcvbuf / 4; in sk_rcvbuf_lowwater() 108 static void caif_flow_ctrl(struct sock *sk, int mode) in caif_flow_ctrl() argument 111 cf_sk = container_of(sk, struct caifsock, sk); in caif_flow_ctrl() 120 static void caif_queue_rcv_skb(struct sock *sk, struct sk_buff *skb) in caif_queue_rcv_skb() argument 124 struct sk_buff_head *list = &sk->sk_receive_queue; in caif_queue_rcv_skb() [all …]
|
| /linux/net/iucv/ |
| H A D | af_iucv.c | 57 #define __iucv_sock_wait(sk, condition, timeo, ret) \ argument 62 prepare_to_wait(sk_sleep(sk), &__wait, TASK_INTERRUPTIBLE); \ 72 release_sock(sk); \ 74 lock_sock(sk); \ 75 ret = sock_error(sk); \ 79 finish_wait(sk_sleep(sk), &__wait); \ 82 #define iucv_sock_wait(sk, condition, timeo) \ argument 86 __iucv_sock_wait(sk, condition, timeo, __ret); \ 92 static void iucv_sock_kill(struct sock *sk); 93 static void iucv_sock_close(struct sock *sk); [all …]
|
| /linux/net/x25/ |
| H A D | x25_timer.c | 27 void x25_init_timers(struct sock *sk) in x25_init_timers() argument 29 struct x25_sock *x25 = x25_sk(sk); in x25_init_timers() 34 sk->sk_timer.function = x25_heartbeat_expiry; in x25_init_timers() 37 void x25_start_heartbeat(struct sock *sk) in x25_start_heartbeat() argument 39 mod_timer(&sk->sk_timer, jiffies + 5 * HZ); in x25_start_heartbeat() 42 void x25_stop_heartbeat(struct sock *sk) in x25_stop_heartbeat() argument 44 timer_delete(&sk->sk_timer); in x25_stop_heartbeat() 47 void x25_start_t2timer(struct sock *sk) in x25_start_t2timer() argument 49 struct x25_sock *x25 = x25_sk(sk); in x25_start_t2timer() 54 void x25_start_t21timer(struct sock *sk) in x25_start_t21timer() argument [all …]
|
| H A D | x25_in.c | 32 static int x25_queue_rx_frame(struct sock *sk, struct sk_buff *skb, int more) in x25_queue_rx_frame() argument 35 struct x25_sock *x25 = x25_sk(sk); in x25_queue_rx_frame() 40 skb_set_owner_r(skb, sk); in x25_queue_rx_frame() 74 skb_set_owner_r(skbn, sk); in x25_queue_rx_frame() 75 skb_queue_tail(&sk->sk_receive_queue, skbn); in x25_queue_rx_frame() 76 if (!sock_flag(sk, SOCK_DEAD)) in x25_queue_rx_frame() 77 sk->sk_data_ready(sk); in x25_queue_rx_frame() 87 static int x25_state1_machine(struct sock *sk, struct sk_buff *skb, int frametype) in x25_state1_machine() argument 91 struct x25_sock *x25 = x25_sk(sk); in x25_state1_machine() 96 x25_stop_timer(sk); in x25_state1_machine() [all …]
|
| /linux/net/phonet/ |
| H A D | socket.c | 30 struct sock *sk = sock->sk; in pn_socket_release() local 32 if (sk) { in pn_socket_release() 33 sock->sk = NULL; in pn_socket_release() 34 sk->sk_prot->close(sk, 0); in pn_socket_release() 132 int pn_sock_hash(struct sock *sk) in pn_sock_hash() argument 134 struct hlist_head *hlist = pn_hash_list(pn_sk(sk)->sobject); in pn_sock_hash() 137 sk_add_node_rcu(sk, hlist); in pn_sock_hash() 144 void pn_sock_unhash(struct sock *sk) in pn_sock_unhash() argument 147 sk_del_node_init_rcu(sk); in pn_sock_unhash() 149 pn_sock_unbind_all_res(sk); in pn_sock_unhash() [all …]
|
| H A D | pep.c | 69 static struct sk_buff *pep_alloc_skb(struct sock *sk, const void *payload, in pep_alloc_skb() argument 75 skb_set_owner_w(skb, sk); in pep_alloc_skb() 85 static int pep_reply(struct sock *sk, struct sk_buff *oskb, u8 code, in pep_reply() argument 93 skb = pep_alloc_skb(sk, data, len, priority); in pep_reply() 104 return pn_skb_send(sk, skb, &peer); in pep_reply() 107 static int pep_indicate(struct sock *sk, u8 id, u8 code, in pep_indicate() argument 110 struct pep_sock *pn = pep_sk(sk); in pep_indicate() 114 skb = pep_alloc_skb(sk, data, len, priority); in pep_indicate() 123 return pn_skb_send(sk, skb, NULL); in pep_indicate() 128 static int pipe_handler_request(struct sock *sk, u8 id, u8 code, in pipe_handler_request() argument [all …]
|
| /linux/net/nfc/ |
| H A D | rawsock.c | 23 static void nfc_sock_link(struct nfc_sock_list *l, struct sock *sk) in nfc_sock_link() argument 26 sk_add_node(sk, &l->head); in nfc_sock_link() 30 static void nfc_sock_unlink(struct nfc_sock_list *l, struct sock *sk) in nfc_sock_unlink() argument 33 sk_del_node_init(sk); in nfc_sock_unlink() 37 static void rawsock_write_queue_purge(struct sock *sk) in rawsock_write_queue_purge() argument 39 pr_debug("sk=%p\n", sk); in rawsock_write_queue_purge() 41 spin_lock_bh(&sk->sk_write_queue.lock); in rawsock_write_queue_purge() 42 __skb_queue_purge(&sk->sk_write_queue); in rawsock_write_queue_purge() 43 nfc_rawsock(sk)->tx_work_scheduled = false; in rawsock_write_queue_purge() 44 spin_unlock_bh(&sk->sk_write_queue.lock); in rawsock_write_queue_purge() [all …]
|
| H A D | llcp_sock.c | 17 static int sock_wait_state(struct sock *sk, int state, unsigned long timeo) in sock_wait_state() argument 22 pr_debug("sk %p", sk); in sock_wait_state() 24 add_wait_queue(sk_sleep(sk), &wait); in sock_wait_state() 27 while (sk->sk_state != state) { in sock_wait_state() 38 release_sock(sk); in sock_wait_state() 40 lock_sock(sk); in sock_wait_state() 43 err = sock_error(sk); in sock_wait_state() 49 remove_wait_queue(sk_sleep(sk), &wait); in sock_wait_state() 61 struct sock *sk = sock->sk; in llcp_sock_bind() local 62 struct nfc_llcp_sock *llcp_sock = nfc_llcp_sock(sk); in llcp_sock_bind() [all …]
|
| /linux/tools/testing/selftests/bpf/progs/ |
| H A D | tcp_ca_kfunc.c | 7 extern void bbr_init(struct sock *sk) __ksym; 8 extern void bbr_main(struct sock *sk, u32 ack, int flag, const struct rate_sample *rs) __ksym; 9 extern u32 bbr_sndbuf_expand(struct sock *sk) __ksym; 10 extern u32 bbr_undo_cwnd(struct sock *sk) __ksym; 11 extern void bbr_cwnd_event(struct sock *sk, enum tcp_ca_event event) __ksym; 12 extern u32 bbr_ssthresh(struct sock *sk) __ksym; 13 extern u32 bbr_min_tso_segs(struct sock *sk) __ksym; 14 extern void bbr_set_state(struct sock *sk, u8 new_state) __ksym; 16 extern void dctcp_init(struct sock *sk) __ksym; 17 extern void dctcp_update_alpha(struct sock *sk, u32 flags) __ksym; [all …]
|