Home
last modified time | relevance | path

Searched refs:smc_sock (Results 1 - 25 of 33) sorted by relevance

12

/kernel/linux/linux-5.10/net/smc/
H A Dsmc_close.h22 void smc_close_wake_tx_prepared(struct smc_sock *smc);
23 int smc_close_active(struct smc_sock *smc);
24 int smc_close_shutdown_write(struct smc_sock *smc);
25 void smc_close_init(struct smc_sock *smc);
26 void smc_clcsock_release(struct smc_sock *smc);
28 void smc_close_active_abort(struct smc_sock *smc);
H A Daf_smc.c67 struct smc_sock *smc = smc_sk(sk); in smc_set_keepalive()
113 .obj_size = sizeof(struct smc_sock),
125 .obj_size = sizeof(struct smc_sock),
131 static void smc_restore_fallback_changes(struct smc_sock *smc) in smc_restore_fallback_changes()
139 static int __smc_release(struct smc_sock *smc) in __smc_release()
182 struct smc_sock *smc; in smc_release()
238 struct smc_sock *smc; in smc_sock_alloc()
270 struct smc_sock *smc; in smc_bind()
343 static void smc_copy_sock_settings_to_clc(struct smc_sock *smc) in smc_copy_sock_settings_to_clc()
353 static void smc_copy_sock_settings_to_smc(struct smc_sock *sm
[all...]
H A Dsmc.h217 struct smc_sock { /* smc sock container */ struct
223 struct smc_sock *listen_smc; /* listen parent */
251 static inline struct smc_sock *smc_sk(const struct sock *sk) in smc_sk()
253 return (struct smc_sock *)sk; in smc_sk()
285 static inline bool using_ipsec(struct smc_sock *smc) in using_ipsec()
291 static inline bool using_ipsec(struct smc_sock *smc) in using_ipsec()
H A Dsmc_rx.h20 void smc_rx_init(struct smc_sock *smc);
22 int smc_rx_recvmsg(struct smc_sock *smc, struct msghdr *msg,
24 int smc_rx_wait(struct smc_sock *smc, long *timeo,
H A Dsmc_cdc.c32 struct smc_sock *smc; in smc_cdc_tx_handler()
36 smc = container_of(conn, struct smc_sock, conn); in smc_cdc_tx_handler()
227 struct smc_sock *smc = container_of(conn, struct smc_sock, conn); in smcd_cdc_msg_send()
268 static void smc_cdc_handle_urg_data_arrival(struct smc_sock *smc, in smc_cdc_handle_urg_data_arrival()
288 static void smc_cdc_msg_validate(struct smc_sock *smc, struct smc_cdc_msg *cdc, in smc_cdc_msg_validate()
310 static void smc_cdc_msg_recv_action(struct smc_sock *smc, in smc_cdc_msg_recv_action()
380 static void smc_cdc_msg_recv(struct smc_sock *smc, struct smc_cdc_msg *cdc) in smc_cdc_msg_recv()
400 struct smc_sock *smc; in smcd_cdc_rx_tsklet()
408 smc = container_of(conn, struct smc_sock, con in smcd_cdc_rx_tsklet()
[all...]
H A Dsmc_tx.h31 void smc_tx_init(struct smc_sock *smc);
32 int smc_tx_sendmsg(struct smc_sock *smc, struct msghdr *msg, size_t len);
34 void smc_tx_sndbuf_nonfull(struct smc_sock *smc);
H A Dsmc_close.c23 /* release the clcsock that is assigned to the smc_sock */
24 void smc_clcsock_release(struct smc_sock *smc) in smc_clcsock_release()
49 static void smc_close_stream_wait(struct smc_sock *smc, long timeout) in smc_close_stream_wait()
78 void smc_close_wake_tx_prepared(struct smc_sock *smc) in smc_close_wake_tx_prepared()
111 static void smc_close_cancel_work(struct smc_sock *smc) in smc_close_cancel_work()
125 void smc_close_active_abort(struct smc_sock *smc) in smc_close_active_abort()
190 int smc_close_active(struct smc_sock *smc) in smc_close_active()
306 static void smc_close_passive_abort_received(struct smc_sock *smc) in smc_close_passive_abort_received()
355 struct smc_sock *smc = container_of(conn, struct smc_sock, con in smc_close_passive_work()
[all...]
H A Dsmc_rx.c53 static int smc_rx_update_consumer(struct smc_sock *smc, in smc_rx_update_consumer()
94 static void smc_rx_update_cons(struct smc_sock *smc, size_t len) in smc_rx_update_cons()
104 struct smc_sock *smc;
112 struct smc_sock *smc = priv->smc; in smc_rx_pipe_buf_release()
144 struct smc_sock *smc) in smc_rx_splice()
191 int smc_rx_wait(struct smc_sock *smc, long *timeo, in smc_rx_wait()
217 static int smc_rx_recv_urg(struct smc_sock *smc, struct msghdr *msg, int len, in smc_rx_recv_urg()
260 static bool smc_rx_recvmsg_data_available(struct smc_sock *smc) in smc_rx_recvmsg_data_available()
279 int smc_rx_recvmsg(struct smc_sock *smc, struct msghdr *msg, in smc_rx_recvmsg()
439 void smc_rx_init(struct smc_sock *sm
[all...]
H A Dsmc_tx.c43 struct smc_sock *smc = smc_sk(sk); in smc_tx_write_space()
64 void smc_tx_sndbuf_nonfull(struct smc_sock *smc) in smc_tx_sndbuf_nonfull()
74 static int smc_tx_wait(struct smc_sock *smc, int flags) in smc_tx_wait()
124 static bool smc_tx_is_corked(struct smc_sock *smc) in smc_tx_is_corked()
134 int smc_tx_sendmsg(struct smc_sock *smc, struct msghdr *msg, size_t len) in smc_tx_sendmsg()
497 struct smc_sock *smc = in smcr_tx_sndbuf_nonempty()
498 container_of(conn, struct smc_sock, conn); in smcr_tx_sndbuf_nonempty()
573 struct smc_sock *smc = container_of(conn, struct smc_sock, in smc_tx_sndbuf_nonempty()
588 struct smc_sock *sm in smc_tx_work()
[all...]
H A Dsmc_clc.h323 int smc_clc_wait_msg(struct smc_sock *smc, void *buf, int buflen,
325 int smc_clc_send_decline(struct smc_sock *smc, u32 peer_diag_info, u8 version);
326 int smc_clc_send_proposal(struct smc_sock *smc, struct smc_init_info *ini);
327 int smc_clc_send_confirm(struct smc_sock *smc, bool clnt_first_contact,
329 int smc_clc_send_accept(struct smc_sock *smc, bool srv_first_contact,
H A Dsmc_core.c152 struct smc_sock *smc = container_of(conn, struct smc_sock, conn); in smc_lgr_register_conn()
179 struct smc_sock *smc = container_of(conn, struct smc_sock, conn); in __smc_lgr_unregister_conn()
367 static int smc_lgr_create(struct smc_sock *smc, struct smc_init_info *ini) in smc_lgr_create()
479 static int smc_switch_cursor(struct smc_sock *smc, struct smc_cdc_tx_pend *pend, in smc_switch_cursor()
536 struct smc_sock *smc; in smc_switch_conns()
563 smc = container_of(conn, struct smc_sock, conn); in smc_switch_conns()
855 static void smc_sk_wake_ups(struct smc_sock *smc) in smc_sk_wake_ups()
865 struct smc_sock *sm in smc_conn_kill()
[all...]
H A Dsmc_core.h373 struct smc_sock;
385 int smc_buf_create(struct smc_sock *smc, bool is_smcd);
402 int smc_conn_create(struct smc_sock *smc, struct smc_init_info *ini);
H A Dsmc_clc.c337 int smc_clc_wait_msg(struct smc_sock *smc, void *buf, int buflen, in smc_clc_wait_msg()
447 int smc_clc_send_decline(struct smc_sock *smc, u32 peer_diag_info, u8 version) in smc_clc_send_decline()
480 int smc_clc_send_proposal(struct smc_sock *smc, struct smc_init_info *ini) in smc_clc_send_proposal()
637 static int smc_clc_send_confirm_accept(struct smc_sock *smc, in smc_clc_send_confirm_accept()
735 int smc_clc_send_confirm(struct smc_sock *smc, bool clnt_first_contact, in smc_clc_send_confirm()
760 int smc_clc_send_accept(struct smc_sock *new_smc, bool srv_first_contact, in smc_clc_send_accept()
/kernel/linux/linux-6.6/net/smc/
H A Dsmc_close.h22 void smc_close_wake_tx_prepared(struct smc_sock *smc);
23 int smc_close_active(struct smc_sock *smc);
24 int smc_close_shutdown_write(struct smc_sock *smc);
25 void smc_close_init(struct smc_sock *smc);
26 void smc_clcsock_release(struct smc_sock *smc);
28 void smc_close_active_abort(struct smc_sock *smc);
H A Daf_smc.c112 struct smc_sock *smc = smc_sk(sk); in smc_set_keepalive()
124 struct smc_sock *smc; in smc_tcp_syn_recv_sock()
159 const struct smc_sock *smc; in smc_hs_congested()
213 struct smc_sock *smc = smc_sk(sk); in smc_release_cb()
228 .obj_size = sizeof(struct smc_sock),
241 .obj_size = sizeof(struct smc_sock),
247 static void smc_fback_restore_callbacks(struct smc_sock *smc) in smc_fback_restore_callbacks()
262 static void smc_restore_fallback_changes(struct smc_sock *smc) in smc_restore_fallback_changes()
271 static int __smc_release(struct smc_sock *smc) in __smc_release()
314 struct smc_sock *sm in smc_release()
[all...]
H A Dsmc_tx.c44 struct smc_sock *smc = smc_sk(sk); in smc_tx_write_space()
67 void smc_tx_sndbuf_nonfull(struct smc_sock *smc) in smc_tx_sndbuf_nonfull()
77 static int smc_tx_wait(struct smc_sock *smc, int flags) in smc_tx_wait()
127 static bool smc_tx_is_corked(struct smc_sock *smc) in smc_tx_is_corked()
145 static bool smc_should_autocork(struct smc_sock *smc) in smc_should_autocork()
159 static bool smc_tx_should_cork(struct smc_sock *smc, struct msghdr *msg) in smc_tx_should_cork()
181 int smc_tx_sendmsg(struct smc_sock *smc, struct msghdr *msg, size_t len) in smc_tx_sendmsg()
484 struct smc_sock *smc = container_of(conn, struct smc_sock, in smc_tx_rdma_writes()
562 struct smc_sock *sm in smcr_tx_sndbuf_nonempty()
[all...]
H A Dsmc.h244 struct smc_sock { /* smc sock container */ struct
256 struct smc_sock *listen_smc; /* listen parent */
289 #define smc_sk(ptr) container_of_const(ptr, struct smc_sock, sk)
291 static inline void smc_init_saved_callbacks(struct smc_sock *smc) in smc_init_saved_callbacks()
299 static inline struct smc_sock *smc_clcsock_user_data(const struct sock *clcsk) in smc_clcsock_user_data()
301 return (struct smc_sock *) in smc_clcsock_user_data()
355 static inline bool using_ipsec(struct smc_sock *smc) in using_ipsec()
361 static inline bool using_ipsec(struct smc_sock *smc) in using_ipsec()
H A Dsmc_rx.h20 void smc_rx_init(struct smc_sock *smc);
22 int smc_rx_recvmsg(struct smc_sock *smc, struct msghdr *msg,
24 int smc_rx_wait(struct smc_sock *smc, long *timeo,
H A Dsmc_cdc.c32 struct smc_sock *smc; in smc_cdc_tx_handler()
36 smc = container_of(conn, struct smc_sock, conn); in smc_cdc_tx_handler()
238 struct smc_sock *smc = container_of(conn, struct smc_sock, conn); in smcd_cdc_msg_send()
279 static void smc_cdc_handle_urg_data_arrival(struct smc_sock *smc, in smc_cdc_handle_urg_data_arrival()
299 static void smc_cdc_msg_validate(struct smc_sock *smc, struct smc_cdc_msg *cdc, in smc_cdc_msg_validate()
321 static void smc_cdc_msg_recv_action(struct smc_sock *smc, in smc_cdc_msg_recv_action()
395 static void smc_cdc_msg_recv(struct smc_sock *smc, struct smc_cdc_msg *cdc) in smc_cdc_msg_recv()
415 struct smc_sock *smc; in smcd_cdc_rx_tsklet()
423 smc = container_of(conn, struct smc_sock, con in smcd_cdc_rx_tsklet()
[all...]
H A Dsmc_tx.h32 void smc_tx_init(struct smc_sock *smc);
33 int smc_tx_sendmsg(struct smc_sock *smc, struct msghdr *msg, size_t len);
35 void smc_tx_sndbuf_nonfull(struct smc_sock *smc);
H A Dsmc_close.c23 /* release the clcsock that is assigned to the smc_sock */
24 void smc_clcsock_release(struct smc_sock *smc) in smc_clcsock_release()
49 static void smc_close_stream_wait(struct smc_sock *smc, long timeout) in smc_close_stream_wait()
81 void smc_close_wake_tx_prepared(struct smc_sock *smc) in smc_close_wake_tx_prepared()
114 static void smc_close_cancel_work(struct smc_sock *smc) in smc_close_cancel_work()
128 void smc_close_active_abort(struct smc_sock *smc) in smc_close_active_abort()
193 int smc_close_active(struct smc_sock *smc) in smc_close_active()
312 static void smc_close_passive_abort_received(struct smc_sock *smc) in smc_close_passive_abort_received()
361 struct smc_sock *smc = container_of(conn, struct smc_sock, con in smc_close_passive_work()
[all...]
H A Dsmc_rx.c59 static int smc_rx_update_consumer(struct smc_sock *smc, in smc_rx_update_consumer()
100 static void smc_rx_update_cons(struct smc_sock *smc, size_t len) in smc_rx_update_cons()
110 struct smc_sock *smc;
118 struct smc_sock *smc = priv->smc; in smc_rx_pipe_buf_release()
150 struct smc_sock *smc) in smc_rx_splice()
255 int smc_rx_wait(struct smc_sock *smc, long *timeo, in smc_rx_wait()
281 static int smc_rx_recv_urg(struct smc_sock *smc, struct msghdr *msg, int len, in smc_rx_recv_urg()
325 static bool smc_rx_recvmsg_data_available(struct smc_sock *smc) in smc_rx_recvmsg_data_available()
344 int smc_rx_recvmsg(struct smc_sock *smc, struct msghdr *msg, in smc_rx_recvmsg()
510 void smc_rx_init(struct smc_sock *sm
[all...]
H A Dsmc_tracepoint.h18 TP_PROTO(const struct smc_sock *smc, int fallback_rsn),
46 TP_PROTO(const struct smc_sock *smc, size_t len),
73 TP_PROTO(const struct smc_sock *smc, size_t len),
80 TP_PROTO(const struct smc_sock *smc, size_t len),
H A Dsmc_clc.h417 int smc_clc_wait_msg(struct smc_sock *smc, void *buf, int buflen,
419 int smc_clc_send_decline(struct smc_sock *smc, u32 peer_diag_info, u8 version);
420 int smc_clc_send_proposal(struct smc_sock *smc, struct smc_init_info *ini);
421 int smc_clc_send_confirm(struct smc_sock *smc, bool clnt_first_contact,
423 int smc_clc_send_accept(struct smc_sock *smc, bool srv_first_contact,
H A Dsmc_core.c169 struct smc_sock *smc = container_of(conn, struct smc_sock, conn); in smc_lgr_register_conn()
198 struct smc_sock *smc = container_of(conn, struct smc_sock, conn); in __smc_lgr_unregister_conn()
826 static int smc_lgr_create(struct smc_sock *smc, struct smc_init_info *ini) in smc_lgr_create()
967 static int smc_switch_cursor(struct smc_sock *smc, struct smc_cdc_tx_pend *pend, in smc_switch_cursor()
1036 struct smc_sock *smc; in smc_switch_conns()
1063 smc = container_of(conn, struct smc_sock, conn); in smc_switch_conns()
1417 static void smc_sk_wake_ups(struct smc_sock *smc) in smc_sk_wake_ups()
1427 struct smc_sock *sm in smc_conn_kill()
[all...]

Completed in 20 milliseconds

12