Home
last modified time | relevance | path

Searched refs:con (Results 1 - 25 of 356) sorted by relevance

12345678910>>...15

/kernel/linux/linux-6.6/net/ceph/
H A Dmessenger_v1.c110 static void con_out_kvec_reset(struct ceph_connection *con) in con_out_kvec_reset() argument
112 BUG_ON(con->v1.out_skip); in con_out_kvec_reset()
114 con->v1.out_kvec_left = 0; in con_out_kvec_reset()
115 con->v1.out_kvec_bytes = 0; in con_out_kvec_reset()
116 con->v1.out_kvec_cur = &con->v1.out_kvec[0]; in con_out_kvec_reset()
119 static void con_out_kvec_add(struct ceph_connection *con, in con_out_kvec_add() argument
122 int index = con->v1.out_kvec_left; in con_out_kvec_add()
124 BUG_ON(con->v1.out_skip); in con_out_kvec_add()
125 BUG_ON(index >= ARRAY_SIZE(con in con_out_kvec_add()
138 con_out_kvec_skip(struct ceph_connection *con) con_out_kvec_skip() argument
153 sizeof_footer(struct ceph_connection *con) sizeof_footer() argument
172 prepare_write_message_footer(struct ceph_connection *con) prepare_write_message_footer() argument
195 prepare_write_message(struct ceph_connection *con) prepare_write_message() argument
267 prepare_write_ack(struct ceph_connection *con) prepare_write_ack() argument
288 prepare_write_seq(struct ceph_connection *con) prepare_write_seq() argument
306 prepare_write_keepalive(struct ceph_connection *con) prepare_write_keepalive() argument
328 get_connect_authorizer(struct ceph_connection *con) get_connect_authorizer() argument
354 prepare_write_banner(struct ceph_connection *con) prepare_write_banner() argument
364 __prepare_write_connect(struct ceph_connection *con) __prepare_write_connect() argument
376 prepare_write_connect(struct ceph_connection *con) prepare_write_connect() argument
421 write_partial_kvec(struct ceph_connection *con) write_partial_kvec() argument
465 write_partial_message_data(struct ceph_connection *con) write_partial_message_data() argument
527 write_partial_skip(struct ceph_connection *con) write_partial_skip() argument
549 prepare_read_banner(struct ceph_connection *con) prepare_read_banner() argument
555 prepare_read_connect(struct ceph_connection *con) prepare_read_connect() argument
561 prepare_read_ack(struct ceph_connection *con) prepare_read_ack() argument
567 prepare_read_seq(struct ceph_connection *con) prepare_read_seq() argument
574 prepare_read_tag(struct ceph_connection *con) prepare_read_tag() argument
581 prepare_read_keepalive_ack(struct ceph_connection *con) prepare_read_keepalive_ack() argument
590 prepare_read_message(struct ceph_connection *con) prepare_read_message() argument
599 read_partial(struct ceph_connection *con, int end, int size, void *object) read_partial() argument
616 read_partial_banner(struct ceph_connection *con) read_partial_banner() argument
649 read_partial_connect(struct ceph_connection *con) read_partial_connect() argument
690 verify_hello(struct ceph_connection *con) verify_hello() argument
701 process_banner(struct ceph_connection *con) process_banner() argument
744 process_connect(struct ceph_connection *con) process_connect() argument
941 read_partial_ack(struct ceph_connection *con) read_partial_ack() argument
952 process_ack(struct ceph_connection *con) process_ack() argument
964 read_partial_message_chunk(struct ceph_connection *con, struct kvec *section, unsigned int sec_len, u32 *crc) read_partial_message_chunk() argument
987 read_partial_message_section(struct ceph_connection *con, struct kvec *section, unsigned int sec_len, u32 *crc) read_partial_message_section() argument
995 read_partial_sparse_msg_extent(struct ceph_connection *con, u32 *crc) read_partial_sparse_msg_extent() argument
1030 read_partial_sparse_msg_data(struct ceph_connection *con) read_partial_sparse_msg_data() argument
1067 read_partial_msg_data(struct ceph_connection *con) read_partial_msg_data() argument
1104 read_partial_msg_data_bounce(struct ceph_connection *con) read_partial_msg_data_bounce() argument
1147 read_partial_message(struct ceph_connection *con) read_partial_message() argument
1311 read_keepalive_ack(struct ceph_connection *con) read_keepalive_ack() argument
1326 ceph_con_v1_try_read(struct ceph_connection *con) ceph_con_v1_try_read() argument
1473 ceph_con_v1_try_write(struct ceph_connection *con) ceph_con_v1_try_write() argument
1567 ceph_con_v1_revoke(struct ceph_connection *con) ceph_con_v1_revoke() argument
1590 ceph_con_v1_revoke_incoming(struct ceph_connection *con) ceph_con_v1_revoke_incoming() argument
1610 ceph_con_v1_opened(struct ceph_connection *con) ceph_con_v1_opened() argument
1615 ceph_con_v1_reset_session(struct ceph_connection *con) ceph_con_v1_reset_session() argument
1621 ceph_con_v1_reset_protocol(struct ceph_connection *con) ceph_con_v1_reset_protocol() argument
[all...]
H A Dmessenger_v2.c109 static int ceph_tcp_recv(struct ceph_connection *con) in ceph_tcp_recv() argument
113 dout("%s con %p %s %zu\n", __func__, con, in ceph_tcp_recv()
114 iov_iter_is_discard(&con->v2.in_iter) ? "discard" : "need", in ceph_tcp_recv()
115 iov_iter_count(&con->v2.in_iter)); in ceph_tcp_recv()
116 ret = do_recvmsg(con->sock, &con->v2.in_iter); in ceph_tcp_recv()
117 dout("%s con %p ret %d left %zu\n", __func__, con, ret, in ceph_tcp_recv()
118 iov_iter_count(&con in ceph_tcp_recv()
196 ceph_tcp_send(struct ceph_connection *con) ceph_tcp_send() argument
211 add_in_kvec(struct ceph_connection *con, void *buf, int len) add_in_kvec() argument
224 reset_in_kvecs(struct ceph_connection *con) reset_in_kvecs() argument
232 set_in_bvec(struct ceph_connection *con, const struct bio_vec *bv) set_in_bvec() argument
240 set_in_skip(struct ceph_connection *con, int len) set_in_skip() argument
248 add_out_kvec(struct ceph_connection *con, void *buf, int len) add_out_kvec() argument
262 reset_out_kvecs(struct ceph_connection *con) reset_out_kvecs() argument
273 set_out_bvec(struct ceph_connection *con, const struct bio_vec *bv, bool zerocopy) set_out_bvec() argument
285 set_out_bvec_zero(struct ceph_connection *con) set_out_bvec_zero() argument
297 out_zero_add(struct ceph_connection *con, int len) out_zero_add() argument
303 alloc_conn_buf(struct ceph_connection *con, int len) alloc_conn_buf() argument
320 free_conn_bufs(struct ceph_connection *con) free_conn_bufs() argument
326 add_in_sign_kvec(struct ceph_connection *con, void *buf, int len) add_in_sign_kvec() argument
335 clear_in_sign_kvecs(struct ceph_connection *con) clear_in_sign_kvecs() argument
340 add_out_sign_kvec(struct ceph_connection *con, void *buf, int len) add_out_sign_kvec() argument
349 clear_out_sign_kvecs(struct ceph_connection *con) clear_out_sign_kvecs() argument
354 con_secure(struct ceph_connection *con) con_secure() argument
565 encode_epilogue_plain(struct ceph_connection *con, bool aborted) encode_epilogue_plain() argument
574 encode_epilogue_secure(struct ceph_connection *con, bool aborted) encode_epilogue_secure() argument
639 verify_control_crc(struct ceph_connection *con) verify_control_crc() argument
658 verify_epilogue_crcs(struct ceph_connection *con, u32 front_crc, u32 middle_crc, u32 data_crc) verify_epilogue_crcs() argument
703 setup_crypto(struct ceph_connection *con, const u8 *session_key, int session_key_len, const u8 *con_secret, int con_secret_len) setup_crypto() argument
798 hmac_sha256(struct ceph_connection *con, const struct kvec *kvecs, int kvec_cnt, u8 *hmac) hmac_sha256() argument
842 gcm_crypt(struct ceph_connection *con, bool encrypt, struct scatterlist *src, struct scatterlist *dst, int src_len) gcm_crypt() argument
1064 decrypt_preamble(struct ceph_connection *con) decrypt_preamble() argument
1072 decrypt_control_remainder(struct ceph_connection *con) decrypt_control_remainder() argument
1091 process_v2_sparse_read(struct ceph_connection *con, struct page **pages, int spos) process_v2_sparse_read() argument
1130 decrypt_tail(struct ceph_connection *con) decrypt_tail() argument
1182 prepare_banner(struct ceph_connection *con) prepare_banner() argument
1221 prepare_head_plain(struct ceph_connection *con, void *base, int ctrl_len, void *extdata, int extdata_len, bool to_be_signed) prepare_head_plain() argument
1251 prepare_head_secure_small(struct ceph_connection *con, void *base, int ctrl_len) prepare_head_secure_small() argument
1292 prepare_head_secure_big(struct ceph_connection *con, void *base, int ctrl_len) prepare_head_secure_big() argument
1324 __prepare_control(struct ceph_connection *con, int tag, void *base, int ctrl_len, void *extdata, int extdata_len, bool to_be_signed) __prepare_control() argument
1363 prepare_control(struct ceph_connection *con, int tag, void *base, int ctrl_len) prepare_control() argument
1369 prepare_hello(struct ceph_connection *con) prepare_hello() argument
1391 prepare_auth_request(struct ceph_connection *con) prepare_auth_request() argument
1427 prepare_auth_request_more(struct ceph_connection *con, void *reply, int reply_len) prepare_auth_request_more() argument
1459 prepare_auth_signature(struct ceph_connection *con) prepare_auth_signature() argument
1478 prepare_client_ident(struct ceph_connection *con) prepare_client_ident() argument
1530 prepare_session_reconnect(struct ceph_connection *con) prepare_session_reconnect() argument
1565 prepare_keepalive2(struct ceph_connection *con) prepare_keepalive2() argument
1581 prepare_ack(struct ceph_connection *con) prepare_ack() argument
1596 prepare_epilogue_plain(struct ceph_connection *con, bool aborted) prepare_epilogue_plain() argument
1610 prepare_message_plain(struct ceph_connection *con) prepare_message_plain() argument
1666 prepare_message_secure(struct ceph_connection *con) prepare_message_secure() argument
1730 prepare_message(struct ceph_connection *con) prepare_message() argument
1768 prepare_read_banner_prefix(struct ceph_connection *con) prepare_read_banner_prefix() argument
1783 prepare_read_banner_payload(struct ceph_connection *con, int payload_len) prepare_read_banner_payload() argument
1799 prepare_read_preamble(struct ceph_connection *con) prepare_read_preamble() argument
1808 prepare_read_control(struct ceph_connection *con) prepare_read_control() argument
1844 prepare_read_control_remainder(struct ceph_connection *con) prepare_read_control_remainder() argument
1864 prepare_read_data(struct ceph_connection *con) prepare_read_data() argument
1890 prepare_read_data_cont(struct ceph_connection *con) prepare_read_data_cont() argument
1930 prepare_sparse_read_cont(struct ceph_connection *con) prepare_sparse_read_cont() argument
2029 prepare_sparse_read_data(struct ceph_connection *con) prepare_sparse_read_data() argument
2047 prepare_read_tail_plain(struct ceph_connection *con) prepare_read_tail_plain() argument
2078 prepare_read_enc_page(struct ceph_connection *con) prepare_read_enc_page() argument
2106 prepare_read_tail_secure(struct ceph_connection *con) prepare_read_tail_secure() argument
2130 __finish_skip(struct ceph_connection *con) __finish_skip() argument
2136 prepare_skip_message(struct ceph_connection *con) prepare_skip_message() argument
2154 process_banner_prefix(struct ceph_connection *con) process_banner_prefix() argument
2177 process_banner_payload(struct ceph_connection *con) process_banner_payload() argument
2222 process_hello(struct ceph_connection *con, void *p, void *end) process_hello() argument
2289 process_auth_bad_method(struct ceph_connection *con, void *p, void *end) process_auth_bad_method() argument
2351 process_auth_reply_more(struct ceph_connection *con, void *p, void *end) process_auth_reply_more() argument
2388 process_auth_done(struct ceph_connection *con, void *p, void *end) process_auth_done() argument
2453 process_auth_signature(struct ceph_connection *con, void *p, void *end) process_auth_signature() argument
2503 process_server_ident(struct ceph_connection *con, void *p, void *end) process_server_ident() argument
2587 process_ident_missing_features(struct ceph_connection *con, void *p, void *end) process_ident_missing_features() argument
2609 process_session_reconnect_ok(struct ceph_connection *con, void *p, void *end) process_session_reconnect_ok() argument
2638 process_session_retry(struct ceph_connection *con, void *p, void *end) process_session_retry() argument
2671 process_session_retry_global(struct ceph_connection *con, void *p, void *end) process_session_retry_global() argument
2704 process_session_reset(struct ceph_connection *con, void *p, void *end) process_session_reset() argument
2752 process_keepalive2_ack(struct ceph_connection *con, void *p, void *end) process_keepalive2_ack() argument
2773 process_ack(struct ceph_connection *con, void *p, void *end) process_ack() argument
2793 process_control(struct ceph_connection *con, void *p, void *end) process_control() argument
2860 process_message_header(struct ceph_connection *con, void *p, void *end) process_message_header() argument
2902 process_message(struct ceph_connection *con) process_message() argument
2920 __handle_control(struct ceph_connection *con, void *p) __handle_control() argument
2960 handle_preamble(struct ceph_connection *con) handle_preamble() argument
2996 handle_control(struct ceph_connection *con) handle_control() argument
3022 handle_control_remainder(struct ceph_connection *con) handle_control_remainder() argument
3039 handle_epilogue(struct ceph_connection *con) handle_epilogue() argument
3077 finish_skip(struct ceph_connection *con) finish_skip() argument
3087 populate_in_iter(struct ceph_connection *con) populate_in_iter() argument
3156 ceph_con_v2_try_read(struct ceph_connection *con) ceph_con_v2_try_read() argument
3188 queue_data(struct ceph_connection *con) queue_data() argument
3201 queue_data_cont(struct ceph_connection *con) queue_data_cont() argument
3226 queue_enc_page(struct ceph_connection *con) queue_enc_page() argument
3254 queue_zeros(struct ceph_connection *con) queue_zeros() argument
3275 finish_message(struct ceph_connection *con) finish_message() argument
3296 populate_out_iter(struct ceph_connection *con) populate_out_iter() argument
3374 ceph_con_v2_try_write(struct ceph_connection *con) ceph_con_v2_try_write() argument
3457 prepare_zero_front(struct ceph_connection *con, int resid) prepare_zero_front() argument
3478 prepare_zero_middle(struct ceph_connection *con, int resid) prepare_zero_middle() argument
3499 prepare_zero_data(struct ceph_connection *con) prepare_zero_data() argument
3506 revoke_at_queue_data(struct ceph_connection *con) revoke_at_queue_data() argument
3549 revoke_at_queue_data_cont(struct ceph_connection *con) revoke_at_queue_data_cont() argument
3575 revoke_at_finish_message(struct ceph_connection *con) revoke_at_finish_message() argument
3633 ceph_con_v2_revoke(struct ceph_connection *con) ceph_con_v2_revoke() argument
3660 revoke_at_prepare_read_data(struct ceph_connection *con) revoke_at_prepare_read_data() argument
3679 revoke_at_prepare_read_data_cont(struct ceph_connection *con) revoke_at_prepare_read_data_cont() argument
3704 revoke_at_prepare_read_enc_page(struct ceph_connection *con) revoke_at_prepare_read_enc_page() argument
3720 revoke_at_prepare_sparse_data(struct ceph_connection *con) revoke_at_prepare_sparse_data() argument
3737 revoke_at_handle_epilogue(struct ceph_connection *con) revoke_at_handle_epilogue() argument
3750 ceph_con_v2_revoke_incoming(struct ceph_connection *con) ceph_con_v2_revoke_incoming() argument
3775 ceph_con_v2_opened(struct ceph_connection *con) ceph_con_v2_opened() argument
3780 ceph_con_v2_reset_session(struct ceph_connection *con) ceph_con_v2_reset_session() argument
3789 ceph_con_v2_reset_protocol(struct ceph_connection *con) ceph_con_v2_reset_protocol() argument
[all...]
H A Dmessenger.c100 void ceph_con_flag_clear(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_clear() argument
104 clear_bit(con_flag, &con->flags); in ceph_con_flag_clear()
107 void ceph_con_flag_set(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_set() argument
111 set_bit(con_flag, &con->flags); in ceph_con_flag_set()
114 bool ceph_con_flag_test(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_test() argument
118 return test_bit(con_flag, &con->flags); in ceph_con_flag_test()
121 bool ceph_con_flag_test_and_clear(struct ceph_connection *con, in ceph_con_flag_test_and_clear() argument
126 return test_and_clear_bit(con_flag, &con->flags); in ceph_con_flag_test_and_clear()
129 bool ceph_con_flag_test_and_set(struct ceph_connection *con, in ceph_con_flag_test_and_set() argument
134 return test_and_set_bit(con_flag, &con in ceph_con_flag_test_and_set()
280 con_sock_state_init(struct ceph_connection *con) con_sock_state_init() argument
291 con_sock_state_connecting(struct ceph_connection *con) con_sock_state_connecting() argument
302 con_sock_state_connected(struct ceph_connection *con) con_sock_state_connected() argument
313 con_sock_state_closing(struct ceph_connection *con) con_sock_state_closing() argument
326 con_sock_state_closed(struct ceph_connection *con) con_sock_state_closed() argument
347 struct ceph_connection *con = sk->sk_user_data; ceph_sock_data_ready() local
365 struct ceph_connection *con = sk->sk_user_data; ceph_sock_write_space() local
388 struct ceph_connection *con = sk->sk_user_data; ceph_sock_state_change() local
416 set_sock_callbacks(struct socket *sock, struct ceph_connection *con) set_sock_callbacks() argument
434 ceph_tcp_connect(struct ceph_connection *con) ceph_tcp_connect() argument
485 ceph_con_close_socket(struct ceph_connection *con) ceph_con_close_socket() argument
508 ceph_con_reset_protocol(struct ceph_connection *con) ceph_con_reset_protocol() argument
554 ceph_con_reset_session(struct ceph_connection *con) ceph_con_reset_session() argument
575 ceph_con_close(struct ceph_connection *con) ceph_con_close() argument
597 ceph_con_open(struct ceph_connection *con, __u8 entity_type, __u64 entity_num, struct ceph_entity_addr *addr) ceph_con_open() argument
620 ceph_con_opened(struct ceph_connection *con) ceph_con_opened() argument
631 ceph_con_init(struct ceph_connection *con, void *private, const struct ceph_connection_operations *ops, struct ceph_messenger *msgr) ceph_con_init() argument
671 ceph_con_discard_sent(struct ceph_connection *con, u64 ack_seq) ceph_con_discard_sent() argument
696 ceph_con_discard_requeued(struct ceph_connection *con, u64 reconnect_seq) ceph_con_discard_requeued() argument
1401 ceph_con_process_message(struct ceph_connection *con) ceph_con_process_message() argument
1434 queue_con_delay(struct ceph_connection *con, unsigned long delay) queue_con_delay() argument
1454 queue_con(struct ceph_connection *con) queue_con() argument
1459 cancel_con(struct ceph_connection *con) cancel_con() argument
1467 con_sock_closed(struct ceph_connection *con) con_sock_closed() argument
1499 con_backoff(struct ceph_connection *con) con_backoff() argument
1519 con_fault_finish(struct ceph_connection *con) con_fault_finish() argument
1543 struct ceph_connection *con = container_of(work, struct ceph_connection, ceph_con_workfn() local
1614 con_fault(struct ceph_connection *con) con_fault() argument
1704 msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) msg_con_set() argument
1713 clear_standby(struct ceph_connection *con) clear_standby() argument
1730 ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) ceph_con_send() argument
1772 struct ceph_connection *con = msg->con; ceph_msg_revoke() local
1812 struct ceph_connection *con = msg->con; ceph_msg_revoke_incoming() local
1839 ceph_con_keepalive(struct ceph_connection *con) ceph_con_keepalive() argument
1852 ceph_con_keepalive_expired(struct ceph_connection *con, unsigned long interval) ceph_con_keepalive_expired() argument
2034 ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) ceph_alloc_middle() argument
2065 ceph_con_in_msg_alloc(struct ceph_connection *con, struct ceph_msg_header *hdr, int *skip) ceph_con_in_msg_alloc() argument
2112 ceph_con_get_out_msg(struct ceph_connection *con) ceph_con_get_out_msg() argument
[all...]
/kernel/linux/linux-5.10/net/ceph/
H A Dmessenger.c119 static void con_flag_clear(struct ceph_connection *con, unsigned long con_flag) in con_flag_clear() argument
123 clear_bit(con_flag, &con->flags); in con_flag_clear()
126 static void con_flag_set(struct ceph_connection *con, unsigned long con_flag) in con_flag_set() argument
130 set_bit(con_flag, &con->flags); in con_flag_set()
133 static bool con_flag_test(struct ceph_connection *con, unsigned long con_flag) in con_flag_test() argument
137 return test_bit(con_flag, &con->flags); in con_flag_test()
140 static bool con_flag_test_and_clear(struct ceph_connection *con, in con_flag_test_and_clear() argument
145 return test_and_clear_bit(con_flag, &con->flags); in con_flag_test_and_clear()
148 static bool con_flag_test_and_set(struct ceph_connection *con, in con_flag_test_and_set() argument
153 return test_and_set_bit(con_flag, &con in con_flag_test_and_set()
302 con_sock_state_init(struct ceph_connection *con) con_sock_state_init() argument
313 con_sock_state_connecting(struct ceph_connection *con) con_sock_state_connecting() argument
324 con_sock_state_connected(struct ceph_connection *con) con_sock_state_connected() argument
335 con_sock_state_closing(struct ceph_connection *con) con_sock_state_closing() argument
348 con_sock_state_closed(struct ceph_connection *con) con_sock_state_closed() argument
369 struct ceph_connection *con = sk->sk_user_data; ceph_sock_data_ready() local
384 struct ceph_connection *con = sk->sk_user_data; ceph_sock_write_space() local
407 struct ceph_connection *con = sk->sk_user_data; ceph_sock_state_change() local
435 set_sock_callbacks(struct socket *sock, struct ceph_connection *con) set_sock_callbacks() argument
453 ceph_tcp_connect(struct ceph_connection *con) ceph_tcp_connect() argument
593 con_close_socket(struct ceph_connection *con) con_close_socket() argument
635 reset_connection(struct ceph_connection *con) reset_connection() argument
665 ceph_con_close(struct ceph_connection *con) ceph_con_close() argument
687 ceph_con_open(struct ceph_connection *con, __u8 entity_type, __u64 entity_num, struct ceph_entity_addr *addr) ceph_con_open() argument
710 ceph_con_opened(struct ceph_connection *con) ceph_con_opened() argument
718 ceph_con_init(struct ceph_connection *con, void *private, const struct ceph_connection_operations *ops, struct ceph_messenger *msgr) ceph_con_init() argument
756 con_out_kvec_reset(struct ceph_connection *con) con_out_kvec_reset() argument
765 con_out_kvec_add(struct ceph_connection *con, size_t size, void *data) con_out_kvec_add() argument
784 con_out_kvec_skip(struct ceph_connection *con) con_out_kvec_skip() argument
1213 sizeof_footer(struct ceph_connection *con) sizeof_footer() argument
1231 prepare_write_message_footer(struct ceph_connection *con) prepare_write_message_footer() argument
1254 prepare_write_message(struct ceph_connection *con) prepare_write_message() argument
1344 prepare_write_ack(struct ceph_connection *con) prepare_write_ack() argument
1365 prepare_write_seq(struct ceph_connection *con) prepare_write_seq() argument
1383 prepare_write_keepalive(struct ceph_connection *con) prepare_write_keepalive() argument
1405 get_connect_authorizer(struct ceph_connection *con) get_connect_authorizer() argument
1430 prepare_write_banner(struct ceph_connection *con) prepare_write_banner() argument
1440 __prepare_write_connect(struct ceph_connection *con) __prepare_write_connect() argument
1451 prepare_write_connect(struct ceph_connection *con) prepare_write_connect() argument
1496 write_partial_kvec(struct ceph_connection *con) write_partial_kvec() argument
1552 write_partial_message_data(struct ceph_connection *con) write_partial_message_data() argument
1617 write_partial_skip(struct ceph_connection *con) write_partial_skip() argument
1641 prepare_read_banner(struct ceph_connection *con) prepare_read_banner() argument
1647 prepare_read_connect(struct ceph_connection *con) prepare_read_connect() argument
1653 prepare_read_ack(struct ceph_connection *con) prepare_read_ack() argument
1659 prepare_read_seq(struct ceph_connection *con) prepare_read_seq() argument
1666 prepare_read_tag(struct ceph_connection *con) prepare_read_tag() argument
1673 prepare_read_keepalive_ack(struct ceph_connection *con) prepare_read_keepalive_ack() argument
1682 prepare_read_message(struct ceph_connection *con) prepare_read_message() argument
1692 read_partial(struct ceph_connection *con, int end, int size, void *object) read_partial() argument
1710 read_partial_banner(struct ceph_connection *con) read_partial_banner() argument
1743 read_partial_connect(struct ceph_connection *con) read_partial_connect() argument
1784 verify_hello(struct ceph_connection *con) verify_hello() argument
2003 process_banner(struct ceph_connection *con) process_banner() argument
2046 process_connect(struct ceph_connection *con) process_connect() argument
2246 read_partial_ack(struct ceph_connection *con) read_partial_ack() argument
2257 process_ack(struct ceph_connection *con) process_ack() argument
2287 read_partial_message_section(struct ceph_connection *con, struct kvec *section, unsigned int sec_len, u32 *crc) read_partial_message_section() argument
2310 read_partial_msg_data(struct ceph_connection *con) read_partial_msg_data() argument
2356 read_partial_message(struct ceph_connection *con) read_partial_message() argument
2517 process_message(struct ceph_connection *con) process_message() argument
2544 read_keepalive_ack(struct ceph_connection *con) read_keepalive_ack() argument
2560 try_write(struct ceph_connection *con) try_write() argument
2656 try_read(struct ceph_connection *con) try_read() argument
2807 queue_con_delay(struct ceph_connection *con, unsigned long delay) queue_con_delay() argument
2824 queue_con(struct ceph_connection *con) queue_con() argument
2829 cancel_con(struct ceph_connection *con) cancel_con() argument
2837 con_sock_closed(struct ceph_connection *con) con_sock_closed() argument
2866 con_backoff(struct ceph_connection *con) con_backoff() argument
2886 con_fault_finish(struct ceph_connection *con) con_fault_finish() argument
2910 struct ceph_connection *con = container_of(work, struct ceph_connection, ceph_con_workfn() local
2975 con_fault(struct ceph_connection *con) con_fault() argument
3066 msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) msg_con_set() argument
3075 clear_standby(struct ceph_connection *con) clear_standby() argument
3090 ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) ceph_con_send() argument
3132 struct ceph_connection *con = msg->con; ceph_msg_revoke() local
3178 struct ceph_connection *con = msg->con; ceph_msg_revoke_incoming() local
3213 ceph_con_keepalive(struct ceph_connection *con) ceph_con_keepalive() argument
3226 ceph_con_keepalive_expired(struct ceph_connection *con, unsigned long interval) ceph_con_keepalive_expired() argument
3396 ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) ceph_alloc_middle() argument
3427 ceph_con_in_msg_alloc(struct ceph_connection *con, int *skip) ceph_con_in_msg_alloc() argument
[all...]
/kernel/linux/linux-5.10/fs/dlm/
H A Dlowcomms.c85 void (*shutdown_action)(struct connection *con); /* What to do to shutdown */
108 struct connection *con; member
156 struct connection *con; in __find_con() local
161 hlist_for_each_entry_rcu(con, &connection_hash[r], list) { in __find_con()
162 if (con->nodeid == nodeid) { in __find_con()
164 return con; in __find_con()
178 struct connection *con, *tmp; in nodeid2con() local
181 con = __find_con(nodeid); in nodeid2con()
182 if (con || !alloc) in nodeid2con()
183 return con; in nodeid2con()
240 struct connection *con; foreach_conn() local
404 struct connection *con; lowcomms_data_ready() local
415 struct connection *con; lowcomms_write_space() local
434 lowcomms_connect_sock(struct connection *con) lowcomms_connect_sock() argument
459 struct connection *con; dlm_lowcomms_connect_node() local
473 struct connection *con; lowcomms_error_report() local
542 add_sock(struct socket *sock, struct connection *con) add_sock() argument
579 close_connection(struct connection *con, bool and_other, bool tx, bool rx) close_connection() argument
610 shutdown_connection(struct connection *con) shutdown_connection() argument
648 dlm_tcp_shutdown(struct connection *con) dlm_tcp_shutdown() argument
655 con_realloc_receive_buf(struct connection *con, int newlen) con_realloc_receive_buf() argument
676 receive_from_sock(struct connection *con) receive_from_sock() argument
766 accept_from_sock(struct connection *con) accept_from_sock() argument
929 sctp_bind_addrs(struct connection *con, uint16_t port) sctp_bind_addrs() argument
958 sctp_connect_to_sock(struct connection *con) sctp_connect_to_sock() argument
1056 tcp_connect_to_sock(struct connection *con) tcp_connect_to_sock() argument
1152 tcp_create_listen_sock(struct connection *con, struct sockaddr_storage *saddr) tcp_create_listen_sock() argument
1241 struct connection *con = nodeid2con(0, GFP_NOFS); sctp_listen_for_all() local
1292 struct connection *con = nodeid2con(0, GFP_NOFS); tcp_listen_for_all() local
1321 new_writequeue_entry(struct connection *con, gfp_t allocation) new_writequeue_entry() argument
1347 struct connection *con; dlm_lowcomms_get_buffer() local
1389 struct connection *con = e->con; dlm_lowcomms_commit_buffer() local
1408 send_to_sock(struct connection *con) send_to_sock() argument
1480 clean_one_writequeue(struct connection *con) clean_one_writequeue() argument
1496 struct connection *con; dlm_lowcomms_close() local
1523 struct connection *con = container_of(work, struct connection, rwork); process_recv_sockets() local
1535 struct connection *con = container_of(work, struct connection, swork); process_send_sockets() local
1572 _stop_conn(struct connection *con, bool and_other) _stop_conn() argument
1588 stop_conn(struct connection *con) stop_conn() argument
1593 shutdown_conn(struct connection *con) shutdown_conn() argument
1601 struct connection *con = container_of(rcu, struct connection, rcu); connection_release() local
1607 free_conn(struct connection *con) free_conn() argument
1625 struct connection *con; work_flush() local
1674 struct connection *con; dlm_lowcomms_start() local
[all...]
/kernel/linux/linux-5.10/net/tipc/
H A Dtopsrv.c116 static void tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s);
118 static bool connected(struct tipc_conn *con) in connected() argument
120 return con && test_bit(CF_CONNECTED, &con->flags); in connected()
125 struct tipc_conn *con = container_of(kref, struct tipc_conn, kref); in tipc_conn_kref_release() local
126 struct tipc_topsrv *s = con->server; in tipc_conn_kref_release()
130 idr_remove(&s->conn_idr, con->conid); in tipc_conn_kref_release()
133 if (con->sock) in tipc_conn_kref_release()
134 sock_release(con->sock); in tipc_conn_kref_release()
136 spin_lock_bh(&con in tipc_conn_kref_release()
145 conn_put(struct tipc_conn *con) conn_put() argument
150 conn_get(struct tipc_conn *con) conn_get() argument
155 tipc_conn_close(struct tipc_conn *con) tipc_conn_close() argument
181 struct tipc_conn *con; tipc_conn_alloc() local
217 struct tipc_conn *con; tipc_conn_lookup() local
230 tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s) tipc_conn_delete_sub() argument
248 tipc_conn_send_to_sock(struct tipc_conn *con) tipc_conn_send_to_sock() argument
302 struct tipc_conn *con = container_of(work, struct tipc_conn, swork); tipc_conn_send_work() local
318 struct tipc_conn *con; tipc_topsrv_queue_evt() local
348 struct tipc_conn *con; tipc_conn_write_space() local
360 tipc_conn_rcv_sub(struct tipc_topsrv *srv, struct tipc_conn *con, struct tipc_subscr *s) tipc_conn_rcv_sub() argument
387 tipc_conn_rcv_from_sock(struct tipc_conn *con) tipc_conn_rcv_from_sock() argument
419 struct tipc_conn *con = container_of(work, struct tipc_conn, rwork); tipc_conn_recv_work() local
440 struct tipc_conn *con; tipc_conn_data_ready() local
456 struct tipc_conn *con; tipc_topsrv_accept() local
572 struct tipc_conn *con; tipc_topsrv_kern_subscr() local
597 struct tipc_conn *con; tipc_topsrv_kern_unsubscr() local
695 struct tipc_conn *con; tipc_topsrv_stop() local
[all...]
/kernel/linux/linux-6.6/net/tipc/
H A Dtopsrv.c117 static void tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s);
119 static bool connected(struct tipc_conn *con) in connected() argument
121 return con && test_bit(CF_CONNECTED, &con->flags); in connected()
126 struct tipc_conn *con = container_of(kref, struct tipc_conn, kref); in tipc_conn_kref_release() local
127 struct tipc_topsrv *s = con->server; in tipc_conn_kref_release()
131 idr_remove(&s->conn_idr, con->conid); in tipc_conn_kref_release()
134 if (con->sock) in tipc_conn_kref_release()
135 sock_release(con->sock); in tipc_conn_kref_release()
137 spin_lock_bh(&con in tipc_conn_kref_release()
146 conn_put(struct tipc_conn *con) conn_put() argument
151 conn_get(struct tipc_conn *con) conn_get() argument
156 tipc_conn_close(struct tipc_conn *con) tipc_conn_close() argument
182 struct tipc_conn *con; tipc_conn_alloc() local
218 struct tipc_conn *con; tipc_conn_lookup() local
231 tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s) tipc_conn_delete_sub() argument
249 tipc_conn_send_to_sock(struct tipc_conn *con) tipc_conn_send_to_sock() argument
303 struct tipc_conn *con = container_of(work, struct tipc_conn, swork); tipc_conn_send_work() local
319 struct tipc_conn *con; tipc_topsrv_queue_evt() local
349 struct tipc_conn *con; tipc_conn_write_space() local
361 tipc_conn_rcv_sub(struct tipc_topsrv *srv, struct tipc_conn *con, struct tipc_subscr *s) tipc_conn_rcv_sub() argument
388 tipc_conn_rcv_from_sock(struct tipc_conn *con) tipc_conn_rcv_from_sock() argument
420 struct tipc_conn *con = container_of(work, struct tipc_conn, rwork); tipc_conn_recv_work() local
441 struct tipc_conn *con; tipc_conn_data_ready() local
459 struct tipc_conn *con; tipc_topsrv_accept() local
577 struct tipc_conn *con; tipc_topsrv_kern_subscr() local
602 struct tipc_conn *con; tipc_topsrv_kern_unsubscr() local
700 struct tipc_conn *con; tipc_topsrv_stop() local
[all...]
/kernel/linux/linux-6.6/drivers/usb/typec/ucsi/
H A Dpsy.c33 static int ucsi_psy_get_scope(struct ucsi_connector *con, in ucsi_psy_get_scope() argument
37 struct device *dev = con->ucsi->dev; in ucsi_psy_get_scope()
44 if (con->ucsi->cap.attributes & mask) in ucsi_psy_get_scope()
53 static int ucsi_psy_get_online(struct ucsi_connector *con, in ucsi_psy_get_online() argument
57 if (con->status.flags & UCSI_CONSTAT_CONNECTED && in ucsi_psy_get_online()
58 (con->status.flags & UCSI_CONSTAT_PWR_DIR) == TYPEC_SINK) in ucsi_psy_get_online()
63 static int ucsi_psy_get_voltage_min(struct ucsi_connector *con, in ucsi_psy_get_voltage_min() argument
68 switch (UCSI_CONSTAT_PWR_OPMODE(con->status.flags)) { in ucsi_psy_get_voltage_min()
70 pdo = con->src_pdos[0]; in ucsi_psy_get_voltage_min()
86 static int ucsi_psy_get_voltage_max(struct ucsi_connector *con, in ucsi_psy_get_voltage_max() argument
113 ucsi_psy_get_voltage_now(struct ucsi_connector *con, union power_supply_propval *val) ucsi_psy_get_voltage_now() argument
142 ucsi_psy_get_current_max(struct ucsi_connector *con, union power_supply_propval *val) ucsi_psy_get_current_max() argument
172 ucsi_psy_get_current_now(struct ucsi_connector *con, union power_supply_propval *val) ucsi_psy_get_current_now() argument
184 ucsi_psy_get_usb_type(struct ucsi_connector *con, union power_supply_propval *val) ucsi_psy_get_usb_type() argument
201 struct ucsi_connector *con = power_supply_get_drvdata(psy); ucsi_psy_get_prop() local
231 ucsi_register_port_psy(struct ucsi_connector *con) ucsi_register_port_psy() argument
258 ucsi_unregister_port_psy(struct ucsi_connector *con) ucsi_unregister_port_psy() argument
267 ucsi_port_psy_changed(struct ucsi_connector *con) ucsi_port_psy_changed() argument
[all...]
H A Ducsi.c196 struct ucsi_connector *con; member
203 struct ucsi_connector *con = uwork->con; in ucsi_poll_worker() local
206 mutex_lock(&con->lock); in ucsi_poll_worker()
208 if (!con->partner) { in ucsi_poll_worker()
210 mutex_unlock(&con->lock); in ucsi_poll_worker()
215 ret = uwork->cb(con); in ucsi_poll_worker()
218 queue_delayed_work(con->wq, &uwork->work, uwork->delay); in ucsi_poll_worker()
224 mutex_unlock(&con->lock); in ucsi_poll_worker()
227 static int ucsi_partner_task(struct ucsi_connector *con, in ucsi_partner_task() argument
254 ucsi_altmode_update_active(struct ucsi_connector *con) ucsi_altmode_update_active() argument
319 ucsi_register_altmode(struct ucsi_connector *con, struct typec_altmode_desc *desc, u8 recipient) ucsi_register_altmode() argument
405 ucsi_register_altmodes_nvidia(struct ucsi_connector *con, u8 recipient) ucsi_register_altmodes_nvidia() argument
480 ucsi_register_altmodes(struct ucsi_connector *con, u8 recipient) ucsi_register_altmodes() argument
543 ucsi_unregister_altmodes(struct ucsi_connector *con, u8 recipient) ucsi_unregister_altmodes() argument
573 ucsi_read_pdos(struct ucsi_connector *con, enum typec_role role, int is_partner, u32 *pdos, int offset, int num_pdos) ucsi_read_pdos() argument
594 ucsi_get_pdos(struct ucsi_connector *con, enum typec_role role, int is_partner, u32 *pdos) ucsi_get_pdos() argument
618 ucsi_get_src_pdos(struct ucsi_connector *con) ucsi_get_src_pdos() argument
633 ucsi_check_altmodes(struct ucsi_connector *con) ucsi_check_altmodes() argument
655 ucsi_register_partner_pdos(struct ucsi_connector *con) ucsi_register_partner_pdos() argument
711 ucsi_unregister_partner_pdos(struct ucsi_connector *con) ucsi_unregister_partner_pdos() argument
721 ucsi_pwr_opmode_change(struct ucsi_connector *con) ucsi_pwr_opmode_change() argument
746 ucsi_register_partner(struct ucsi_connector *con) ucsi_register_partner() argument
783 ucsi_unregister_partner(struct ucsi_connector *con) ucsi_unregister_partner() argument
797 ucsi_partner_change(struct ucsi_connector *con) ucsi_partner_change() argument
843 ucsi_check_connection(struct ucsi_connector *con) ucsi_check_connection() argument
874 struct ucsi_connector *con = container_of(work, struct ucsi_connector, ucsi_handle_connector_change() local
955 struct ucsi_connector *con = &ucsi->connector[num - 1]; ucsi_connector_change() local
969 ucsi_reset_connector(struct ucsi_connector *con, bool hard) ucsi_reset_connector() argument
1022 ucsi_role_cmd(struct ucsi_connector *con, u64 command) ucsi_role_cmd() argument
1044 struct ucsi_connector *con = typec_get_drvdata(port); ucsi_dr_swap() local
1088 struct ucsi_connector *con = typec_get_drvdata(port); ucsi_pr_swap() local
1141 ucsi_find_fwnode(struct ucsi_connector *con) ucsi_find_fwnode() argument
1152 ucsi_register_port(struct ucsi *ucsi, struct ucsi_connector *con) ucsi_register_port() argument
1353 struct ucsi_connector *con, *connector; ucsi_init() local
1437 struct ucsi_connector *con; ucsi_resume_work() local
[all...]
/kernel/linux/linux-5.10/drivers/usb/typec/ucsi/
H A Ducsi.c196 void ucsi_altmode_update_active(struct ucsi_connector *con) in ucsi_altmode_update_active() argument
204 command = UCSI_GET_CURRENT_CAM | UCSI_CONNECTOR_NUMBER(con->num); in ucsi_altmode_update_active()
205 ret = ucsi_send_command(con->ucsi, command, &cur, sizeof(cur)); in ucsi_altmode_update_active()
207 if (con->ucsi->version > 0x0100) { in ucsi_altmode_update_active()
208 dev_err(con->ucsi->dev, in ucsi_altmode_update_active()
216 altmode = typec_altmode_get_partner(con->port_altmode[cur]); in ucsi_altmode_update_active()
218 for (i = 0; con->partner_altmode[i]; i++) in ucsi_altmode_update_active()
219 typec_altmode_update_active(con->partner_altmode[i], in ucsi_altmode_update_active()
220 con->partner_altmode[i] == altmode); in ucsi_altmode_update_active()
250 static int ucsi_register_altmode(struct ucsi_connector *con, in ucsi_register_altmode() argument
336 ucsi_register_altmodes_nvidia(struct ucsi_connector *con, u8 recipient) ucsi_register_altmodes_nvidia() argument
411 ucsi_register_altmodes(struct ucsi_connector *con, u8 recipient) ucsi_register_altmodes() argument
472 ucsi_unregister_altmodes(struct ucsi_connector *con, u8 recipient) ucsi_unregister_altmodes() argument
502 ucsi_get_pdos(struct ucsi_connector *con, int is_partner, u32 *pdos, int offset, int num_pdos) ucsi_get_pdos() argument
522 ucsi_get_src_pdos(struct ucsi_connector *con, int is_partner) ucsi_get_src_pdos() argument
544 ucsi_pwr_opmode_change(struct ucsi_connector *con) ucsi_pwr_opmode_change() argument
567 ucsi_register_partner(struct ucsi_connector *con) ucsi_register_partner() argument
604 ucsi_unregister_partner(struct ucsi_connector *con) ucsi_unregister_partner() argument
614 ucsi_partner_change(struct ucsi_connector *con) ucsi_partner_change() argument
650 struct ucsi_connector *con = container_of(work, struct ucsi_connector, ucsi_handle_connector_change() local
823 struct ucsi_connector *con = &ucsi->connector[num - 1]; ucsi_connector_change() local
839 ucsi_reset_connector(struct ucsi_connector *con, bool hard) ucsi_reset_connector() argument
892 ucsi_role_cmd(struct ucsi_connector *con, u64 command) ucsi_role_cmd() argument
914 struct ucsi_connector *con = typec_get_drvdata(port); ucsi_dr_swap() local
958 struct ucsi_connector *con = typec_get_drvdata(port); ucsi_pr_swap() local
1011 ucsi_find_fwnode(struct ucsi_connector *con) ucsi_find_fwnode() argument
1024 struct ucsi_connector *con = &ucsi->connector[index]; ucsi_register_port() local
1154 struct ucsi_connector *con; ucsi_init() local
[all...]
H A Dpsy.c32 static int ucsi_psy_get_online(struct ucsi_connector *con, in ucsi_psy_get_online() argument
36 if (con->status.flags & UCSI_CONSTAT_CONNECTED && in ucsi_psy_get_online()
37 (con->status.flags & UCSI_CONSTAT_PWR_DIR) == TYPEC_SINK) in ucsi_psy_get_online()
42 static int ucsi_psy_get_voltage_min(struct ucsi_connector *con, in ucsi_psy_get_voltage_min() argument
47 switch (UCSI_CONSTAT_PWR_OPMODE(con->status.flags)) { in ucsi_psy_get_voltage_min()
49 pdo = con->src_pdos[0]; in ucsi_psy_get_voltage_min()
65 static int ucsi_psy_get_voltage_max(struct ucsi_connector *con, in ucsi_psy_get_voltage_max() argument
70 switch (UCSI_CONSTAT_PWR_OPMODE(con->status.flags)) { in ucsi_psy_get_voltage_max()
72 if (con->num_pdos > 0) { in ucsi_psy_get_voltage_max()
73 pdo = con in ucsi_psy_get_voltage_max()
92 ucsi_psy_get_voltage_now(struct ucsi_connector *con, union power_supply_propval *val) ucsi_psy_get_voltage_now() argument
121 ucsi_psy_get_current_max(struct ucsi_connector *con, union power_supply_propval *val) ucsi_psy_get_current_max() argument
151 ucsi_psy_get_current_now(struct ucsi_connector *con, union power_supply_propval *val) ucsi_psy_get_current_now() argument
163 ucsi_psy_get_usb_type(struct ucsi_connector *con, union power_supply_propval *val) ucsi_psy_get_usb_type() argument
180 struct ucsi_connector *con = power_supply_get_drvdata(psy); ucsi_psy_get_prop() local
208 ucsi_register_port_psy(struct ucsi_connector *con) ucsi_register_port_psy() argument
235 ucsi_unregister_port_psy(struct ucsi_connector *con) ucsi_unregister_port_psy() argument
244 ucsi_port_psy_changed(struct ucsi_connector *con) ucsi_port_psy_changed() argument
[all...]
/kernel/linux/linux-6.6/fs/dlm/
H A Dlowcomms.c133 struct connection *con; member
163 int (*connect)(struct connection *con, struct socket *sock,
212 static void lowcomms_queue_swork(struct connection *con) in lowcomms_queue_swork() argument
214 assert_spin_locked(&con->writequeue_lock); in lowcomms_queue_swork()
216 if (!test_bit(CF_IO_STOP, &con->flags) && in lowcomms_queue_swork()
217 !test_bit(CF_APP_LIMITED, &con->flags) && in lowcomms_queue_swork()
218 !test_and_set_bit(CF_SEND_PENDING, &con->flags)) in lowcomms_queue_swork()
219 queue_work(io_workqueue, &con->swork); in lowcomms_queue_swork()
222 static void lowcomms_queue_rwork(struct connection *con) in lowcomms_queue_rwork() argument
225 WARN_ON_ONCE(!lockdep_sock_is_held(con in lowcomms_queue_rwork()
252 con_next_wq(struct connection *con) con_next_wq() argument
269 struct connection *con; __find_con() local
279 dlm_con_init(struct connection *con, int nodeid) dlm_con_init() argument
297 struct connection *con, *tmp; nodeid2con() local
364 struct connection *con; nodeid_to_addr() local
421 struct connection *con; addr_to_nodeid() local
447 dlm_lowcomms_con_has_addr(const struct connection *con, const struct sockaddr_storage *addr) dlm_lowcomms_con_has_addr() argument
462 struct connection *con; dlm_lowcomms_addr() local
504 struct connection *con = sock2con(sk); lowcomms_data_ready() local
514 struct connection *con = sock2con(sk); lowcomms_write_space() local
546 struct connection *con; dlm_lowcomms_connect_node() local
571 struct connection *con; dlm_lowcomms_nodes_set_mark() local
590 struct connection *con = sock2con(sk); lowcomms_error_report() local
641 add_sock(struct socket *sock, struct connection *con) add_sock() argument
723 allow_connection_io(struct connection *con) allow_connection_io() argument
730 stop_connection_io(struct connection *con) stop_connection_io() argument
752 close_connection(struct connection *con, bool and_other) close_connection() argument
795 shutdown_connection(struct connection *con, bool and_other) shutdown_connection() argument
899 receive_from_sock(struct connection *con, int buflen) receive_from_sock() argument
1159 new_writequeue_entry(struct connection *con) new_writequeue_entry() argument
1183 new_wq_entry(struct connection *con, int len, char **ppc, void (*cb)(void *data), void *data) new_wq_entry() argument
1222 dlm_lowcomms_new_msg_con(struct connection *con, int len, gfp_t allocation, char **ppc, void (*cb)(void *data), void *data) dlm_lowcomms_new_msg_con() argument
1259 struct connection *con; dlm_lowcomms_new_msg() local
1295 struct connection *con = e->con; _dlm_lowcomms_commit_msg() local
1359 send_to_sock(struct connection *con) send_to_sock() argument
1418 clean_one_writequeue(struct connection *con) clean_one_writequeue() argument
1431 struct connection *con = container_of(rcu, struct connection, rcu); connection_release() local
1442 struct connection *con; dlm_lowcomms_close() local
1482 struct connection *con = container_of(work, struct connection, rwork); process_recv_sockets() local
1548 dlm_connect(struct connection *con) dlm_connect() argument
1603 struct connection *con = container_of(work, struct connection, swork); process_send_sockets() local
1711 struct connection *con; dlm_lowcomms_shutdown() local
1818 dlm_tcp_connect(struct connection *con, struct socket *sock, struct sockaddr *addr, int addr_len) dlm_tcp_connect() argument
1873 dlm_sctp_connect(struct connection *con, struct socket *sock, struct sockaddr *addr, int addr_len) dlm_sctp_connect() argument
1980 struct connection *con; dlm_lowcomms_exit() local
[all...]
/kernel/linux/linux-5.10/fs/hmdfs/
H A Dhmdfs_server.h23 static inline void hmdfs_send_err_response(struct hmdfs_peer *con, in hmdfs_send_err_response() argument
26 if (hmdfs_sendmessage_response(con, cmd, 0, NULL, (__u32)err)) in hmdfs_send_err_response()
30 void hmdfs_server_open(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
32 void hmdfs_server_atomic_open(struct hmdfs_peer *con,
34 void hmdfs_server_fsync(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
36 void hmdfs_server_release(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
38 void hmdfs_server_readpage(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
40 void hmdfs_server_writepage(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
43 void hmdfs_server_readdir(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
46 void hmdfs_server_mkdir(struct hmdfs_peer *con, struc
[all...]
H A Dhmdfs_client.h34 int hmdfs_client_start_readdir(struct hmdfs_peer *con, struct file *filp,
37 int hmdfs_client_start_mkdir(struct hmdfs_peer *con,
40 int hmdfs_client_start_create(struct hmdfs_peer *con,
44 int hmdfs_client_start_rmdir(struct hmdfs_peer *con, const char *path,
46 int hmdfs_client_start_unlink(struct hmdfs_peer *con, const char *path,
48 int hmdfs_client_start_rename(struct hmdfs_peer *con, const char *old_path,
83 int hmdfs_client_writepage(struct hmdfs_peer *con,
85 int hmdfs_remote_do_writepage(struct hmdfs_peer *con,
92 int hmdfs_send_open(struct hmdfs_peer *con, const char *send_buf,
94 void hmdfs_send_close(struct hmdfs_peer *con, cons
[all...]
/kernel/linux/linux-6.6/fs/hmdfs/
H A Dhmdfs_server.h23 static inline void hmdfs_send_err_response(struct hmdfs_peer *con, in hmdfs_send_err_response() argument
26 if (hmdfs_sendmessage_response(con, cmd, 0, NULL, (__u32)err)) in hmdfs_send_err_response()
30 void hmdfs_server_open(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
32 void hmdfs_server_atomic_open(struct hmdfs_peer *con,
34 void hmdfs_server_fsync(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
36 void hmdfs_server_release(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
38 void hmdfs_server_readpage(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
40 void hmdfs_server_writepage(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
43 void hmdfs_server_readdir(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd,
46 void hmdfs_server_mkdir(struct hmdfs_peer *con, struc
[all...]
H A Dhmdfs_client.h34 int hmdfs_client_start_readdir(struct hmdfs_peer *con, struct file *filp,
37 int hmdfs_client_start_mkdir(struct hmdfs_peer *con,
40 int hmdfs_client_start_create(struct hmdfs_peer *con,
44 int hmdfs_client_start_rmdir(struct hmdfs_peer *con, const char *path,
46 int hmdfs_client_start_unlink(struct hmdfs_peer *con, const char *path,
48 int hmdfs_client_start_rename(struct hmdfs_peer *con, const char *old_path,
83 int hmdfs_client_writepage(struct hmdfs_peer *con,
85 int hmdfs_remote_do_writepage(struct hmdfs_peer *con,
92 int hmdfs_send_open(struct hmdfs_peer *con, const char *send_buf,
94 void hmdfs_send_close(struct hmdfs_peer *con, cons
[all...]
/kernel/linux/linux-6.6/tools/perf/util/
H A Dbpf_lock_contention.c20 int lock_contention_prepare(struct lock_contention *con) in lock_contention_prepare() argument
24 struct evlist *evlist = con->evlist; in lock_contention_prepare()
25 struct target *target = con->target; in lock_contention_prepare()
33 bpf_map__set_value_size(skel->maps.stacks, con->max_stack * sizeof(u64)); in lock_contention_prepare()
34 bpf_map__set_max_entries(skel->maps.lock_stat, con->map_nr_entries); in lock_contention_prepare()
35 bpf_map__set_max_entries(skel->maps.tstamp, con->map_nr_entries); in lock_contention_prepare()
37 if (con->aggr_mode == LOCK_AGGR_TASK) in lock_contention_prepare()
38 bpf_map__set_max_entries(skel->maps.task_data, con->map_nr_entries); in lock_contention_prepare()
42 if (con->save_callstack) in lock_contention_prepare()
43 bpf_map__set_max_entries(skel->maps.stacks, con in lock_contention_prepare()
172 lock_contention_get_name(struct lock_contention *con, struct contention_key *key, u64 *stack_trace, u32 flags) lock_contention_get_name() argument
249 lock_contention_read(struct lock_contention *con) lock_contention_read() argument
[all...]
/kernel/linux/linux-6.6/include/linux/ceph/
H A Dmessenger.h30 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
34 struct ceph_connection *con,
36 int (*add_authorizer_challenge)(struct ceph_connection *con,
39 int (*verify_authorizer_reply) (struct ceph_connection *con);
40 int (*invalidate_authorizer)(struct ceph_connection *con);
43 void (*fault) (struct ceph_connection *con);
47 void (*peer_reset) (struct ceph_connection *con);
49 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
59 int (*get_auth_request)(struct ceph_connection *con,
62 int (*handle_auth_reply_more)(struct ceph_connection *con,
280 struct ceph_connection *con; global() member
[all...]
/kernel/linux/linux-6.6/drivers/infiniband/ulp/rtrs/
H A Drtrs-clt.c188 return to_clt_con(clt_path->s.con[id]); in rtrs_permit_to_clt_con()
307 static void rtrs_rdma_error_recovery(struct rtrs_clt_con *con) in rtrs_rdma_error_recovery() argument
309 struct rtrs_clt_path *clt_path = to_clt_path(con->c.path); in rtrs_rdma_error_recovery()
331 struct rtrs_clt_con *con = to_clt_con(wc->qp->qp_context); in rtrs_clt_fast_reg_done() local
334 rtrs_err(con->c.path, "Failed IB_WR_REG_MR: %s\n", in rtrs_clt_fast_reg_done()
336 rtrs_rdma_error_recovery(con); in rtrs_clt_fast_reg_done()
351 struct rtrs_clt_con *con = to_clt_con(wc->qp->qp_context); in rtrs_clt_inv_rkey_done() local
354 rtrs_err(con->c.path, "Failed IB_WR_LOCAL_INV: %s\n", in rtrs_clt_inv_rkey_done()
356 rtrs_rdma_error_recovery(con); in rtrs_clt_inv_rkey_done()
368 struct rtrs_clt_con *con in rtrs_inv_rkey() local
383 struct rtrs_clt_con *con = req->con; complete_rdma_req() local
458 rtrs_post_send_rdma(struct rtrs_clt_con *con, struct rtrs_clt_io_req *req, struct rtrs_rbuf *rbuf, u32 off, u32 imm, struct ib_send_wr *wr) rtrs_post_send_rdma() argument
508 rtrs_clt_recv_done(struct rtrs_clt_con *con, struct ib_wc *wc) rtrs_clt_recv_done() argument
524 rtrs_clt_rkey_rsp_done(struct rtrs_clt_con *con, struct ib_wc *wc) rtrs_clt_rkey_rsp_done() argument
586 rtrs_post_recv_empty_x2(struct rtrs_con *con, struct ib_cqe *cqe) rtrs_post_recv_empty_x2() argument
605 struct rtrs_clt_con *con = to_clt_con(wc->qp->qp_context); rtrs_clt_rdma_done() local
696 post_recv_io(struct rtrs_clt_con *con, size_t q_size) post_recv_io() argument
1012 rtrs_post_rdma_write_sg(struct rtrs_clt_con *con, struct rtrs_clt_io_req *req, struct rtrs_rbuf *rbuf, bool fr_en, u32 count, u32 size, u32 imm, struct ib_send_wr *wr, struct ib_send_wr *tail) rtrs_post_rdma_write_sg() argument
1078 struct rtrs_clt_con *con = req->con; rtrs_clt_write_req() local
1172 struct rtrs_clt_con *con = req->con; rtrs_clt_read_req() local
1491 struct rtrs_clt_con *con = container_of(c, typeof(*con), c); rtrs_clt_hb_err_handler() local
1614 struct rtrs_clt_con *con; create_con() local
1633 destroy_con(struct rtrs_clt_con *con) destroy_con() argument
1642 create_con_cq_qp(struct rtrs_clt_con *con) create_con_cq_qp() argument
1731 destroy_con_cq_qp(struct rtrs_clt_con *con) destroy_con_cq_qp() argument
1753 stop_cm(struct rtrs_clt_con *con) stop_cm() argument
1760 destroy_cm(struct rtrs_clt_con *con) destroy_cm() argument
1766 rtrs_rdma_addr_resolved(struct rtrs_clt_con *con) rtrs_rdma_addr_resolved() argument
1785 rtrs_rdma_route_resolved(struct rtrs_clt_con *con) rtrs_rdma_route_resolved() argument
1819 rtrs_rdma_conn_established(struct rtrs_clt_con *con, struct rdma_cm_event *ev) rtrs_rdma_conn_established() argument
1909 flag_success_on_conn(struct rtrs_clt_con *con) flag_success_on_conn() argument
1917 rtrs_rdma_conn_rejected(struct rtrs_clt_con *con, struct rdma_cm_event *ev) rtrs_rdma_conn_rejected() argument
1958 flag_error_on_conn(struct rtrs_clt_con *con, int cm_err) flag_error_on_conn() argument
1974 struct rtrs_clt_con *con = cm_id->context; rtrs_clt_rdma_cm_handler() local
2045 create_cm(struct rtrs_clt_con *con) create_cm() argument
2148 struct rtrs_clt_con *con; rtrs_clt_stop_and_destroy_conns() local
2353 struct rtrs_clt_con *con; init_conns() local
2380 struct rtrs_clt_con *con = to_clt_con(wc->qp->qp_context); rtrs_clt_info_req_done() local
2464 struct rtrs_clt_con *con = to_clt_con(wc->qp->qp_context); rtrs_clt_info_rsp_done() local
3044 struct rtrs_con *con; rtrs_clt_rdma_cq_direct() local
[all...]
H A Drtrs.c72 int rtrs_iu_post_recv(struct rtrs_con *con, struct rtrs_iu *iu) in rtrs_iu_post_recv() argument
74 struct rtrs_path *path = con->path; in rtrs_iu_post_recv()
83 rtrs_wrn(con->path, in rtrs_iu_post_recv()
93 return ib_post_recv(con->qp, &wr, NULL); in rtrs_iu_post_recv()
97 int rtrs_post_recv_empty(struct rtrs_con *con, struct ib_cqe *cqe) in rtrs_post_recv_empty() argument
105 return ib_post_recv(con->qp, &wr, NULL); in rtrs_post_recv_empty()
128 int rtrs_iu_post_send(struct rtrs_con *con, struct rtrs_iu *iu, size_t size, in rtrs_iu_post_send() argument
131 struct rtrs_path *path = con->path; in rtrs_iu_post_send()
150 return rtrs_post_send(con->qp, head, &wr, NULL); in rtrs_iu_post_send()
154 int rtrs_iu_post_rdma_write_imm(struct rtrs_con *con, struc argument
187 rtrs_post_rdma_write_imm_empty(struct rtrs_con *con, struct ib_cqe *cqe, u32 imm_data, struct ib_send_wr *head) rtrs_post_rdma_write_imm_empty() argument
212 struct rtrs_con *con = ctx; qp_event_handler() local
227 is_pollqueue(struct rtrs_con *con) is_pollqueue() argument
232 create_cq(struct rtrs_con *con, int cq_vector, int nr_cqe, enum ib_poll_context poll_ctx) create_cq() argument
255 create_qp(struct rtrs_con *con, struct ib_pd *pd, u32 max_send_wr, u32 max_recv_wr, u32 max_sge) create_qp() argument
284 destroy_cq(struct rtrs_con *con) destroy_cq() argument
295 rtrs_cq_qp_create(struct rtrs_path *path, struct rtrs_con *con, u32 max_send_sge, int cq_vector, int nr_cqe, u32 max_send_wr, u32 max_recv_wr, enum ib_poll_context poll_ctx) rtrs_cq_qp_create() argument
318 rtrs_cq_qp_destroy(struct rtrs_con *con) rtrs_cq_qp_destroy() argument
386 rtrs_init_hb(struct rtrs_path *path, struct ib_cqe *cqe, unsigned int interval_ms, unsigned int missed_max, void (*err_handler)(struct rtrs_con *con), struct workqueue_struct *wq) rtrs_init_hb() argument
[all...]
/kernel/linux/linux-5.10/drivers/gpu/drm/amd/amdgpu/
H A Damdgpu_ras.c461 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); in amdgpu_ras_create_obj() local
464 if (!con) in amdgpu_ras_create_obj()
470 obj = &con->objs[head->block]; in amdgpu_ras_create_obj()
477 list_add(&obj->node, &con->head); in amdgpu_ras_create_obj()
487 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); in amdgpu_ras_find_obj() local
491 if (!con) in amdgpu_ras_find_obj()
498 obj = &con->objs[head->block]; in amdgpu_ras_find_obj()
506 obj = &con->objs[i]; in amdgpu_ras_find_obj()
545 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); in amdgpu_ras_is_feature_allowed() local
547 return con in amdgpu_ras_is_feature_allowed()
553 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_is_feature_enabled() local
565 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); __amdgpu_ras_feature_enable() local
603 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_feature_enable() local
662 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_feature_enable_on_boot() local
705 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_disable_all_features() local
727 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_enable_all_features() local
917 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_query_error_count() local
993 struct amdgpu_ras *con = amdgpu_ras_sysfs_badpages_read() local
1024 struct amdgpu_ras *con = amdgpu_ras_sysfs_features_read() local
1032 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_sysfs_remove_bad_page_node() local
1042 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_sysfs_remove_feature_node() local
1113 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_sysfs_remove_all() local
1150 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_debugfs_create_ctrl_node() local
1181 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_debugfs_create() local
1200 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_debugfs_create_all() local
1238 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_debugfs_remove_all() local
1256 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_fs_init() local
1438 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_interrupt_remove_all() local
1455 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_log_on_err_counter() local
1503 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_query_err_status() local
1526 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_badpages_read() local
1639 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_add_bad_pages() local
1673 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_save_bad_pages() local
1741 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_check_bad_page() local
1769 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_validate_threshold() local
1810 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_reserve_bad_pages() local
1855 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_release_bad_pages() local
1883 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_recovery_init() local
1951 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_recovery_fini() local
2036 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_init() local
2165 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_resume() local
2208 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_suspend() local
2222 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_pre_fini() local
2235 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_fini() local
2283 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); amdgpu_ras_check_err_threshold() local
[all...]
/kernel/linux/linux-5.10/fs/proc/
H A Dconsoles.c29 struct console *con = v; in show_console_dev() local
33 if (con->device) { in show_console_dev()
36 driver = con->device(con, &index); in show_console_dev()
44 flags[a] = (con->flags & con_flags[a].flag) ? in show_console_dev()
49 seq_printf(m, "%s%d", con->name, con->index); in show_console_dev()
51 seq_printf(m, "%c%c%c (%s)", con->read ? 'R' : '-', in show_console_dev()
52 con->write ? 'W' : '-', con in show_console_dev()
63 struct console *con; c_start() local
76 struct console *con = v; c_next() local
[all...]
/kernel/linux/linux-6.6/fs/proc/
H A Dconsoles.c29 struct console *con = v; in show_console_dev() local
33 if (con->device) { in show_console_dev()
43 driver = con->device(con, &index); in show_console_dev()
53 flags[a] = (con->flags & con_flags[a].flag) ? in show_console_dev()
58 seq_printf(m, "%s%d", con->name, con->index); in show_console_dev()
60 seq_printf(m, "%c%c%c (%s)", con->read ? 'R' : '-', in show_console_dev()
61 con->write ? 'W' : '-', con in show_console_dev()
72 struct console *con; c_start() local
90 struct console *con = v; c_next() local
[all...]
/kernel/linux/linux-5.10/drivers/infiniband/ulp/rtrs/
H A Drtrs-clt.c185 return to_clt_con(sess->s.con[id]); in rtrs_permit_to_clt_con()
303 static void rtrs_rdma_error_recovery(struct rtrs_clt_con *con) in rtrs_rdma_error_recovery() argument
305 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_rdma_error_recovery()
334 struct rtrs_clt_con *con = cq->cq_context; in rtrs_clt_fast_reg_done() local
337 rtrs_err(con->c.sess, "Failed IB_WR_REG_MR: %s\n", in rtrs_clt_fast_reg_done()
339 rtrs_rdma_error_recovery(con); in rtrs_clt_fast_reg_done()
354 struct rtrs_clt_con *con = cq->cq_context; in rtrs_clt_inv_rkey_done() local
357 rtrs_err(con->c.sess, "Failed IB_WR_LOCAL_INV: %s\n", in rtrs_clt_inv_rkey_done()
359 rtrs_rdma_error_recovery(con); in rtrs_clt_inv_rkey_done()
371 struct rtrs_clt_con *con in rtrs_inv_rkey() local
386 struct rtrs_clt_con *con = req->con; complete_rdma_req() local
450 rtrs_post_send_rdma(struct rtrs_clt_con *con, struct rtrs_clt_io_req *req, struct rtrs_rbuf *rbuf, u32 off, u32 imm, struct ib_send_wr *wr) rtrs_post_send_rdma() argument
499 rtrs_clt_recv_done(struct rtrs_clt_con *con, struct ib_wc *wc) rtrs_clt_recv_done() argument
515 rtrs_clt_rkey_rsp_done(struct rtrs_clt_con *con, struct ib_wc *wc) rtrs_clt_rkey_rsp_done() argument
576 rtrs_post_recv_empty_x2(struct rtrs_con *con, struct ib_cqe *cqe) rtrs_post_recv_empty_x2() argument
595 struct rtrs_clt_con *con = cq->cq_context; rtrs_clt_rdma_done() local
684 post_recv_io(struct rtrs_clt_con *con, size_t q_size) post_recv_io() argument
946 rtrs_post_rdma_write_sg(struct rtrs_clt_con *con, struct rtrs_clt_io_req *req, struct rtrs_rbuf *rbuf, u32 size, u32 imm) rtrs_post_rdma_write_sg() argument
986 struct rtrs_clt_con *con = req->con; rtrs_clt_write_req() local
1060 struct rtrs_clt_con *con = req->con; rtrs_clt_read_req() local
1389 struct rtrs_clt_con *con = container_of(c, typeof(*con), c); rtrs_clt_hb_err_handler() local
1500 struct rtrs_clt_con *con; create_con() local
1517 destroy_con(struct rtrs_clt_con *con) destroy_con() argument
1525 create_con_cq_qp(struct rtrs_clt_con *con) create_con_cq_qp() argument
1611 destroy_con_cq_qp(struct rtrs_clt_con *con) destroy_con_cq_qp() argument
1632 stop_cm(struct rtrs_clt_con *con) stop_cm() argument
1639 destroy_cm(struct rtrs_clt_con *con) destroy_cm() argument
1645 rtrs_rdma_addr_resolved(struct rtrs_clt_con *con) rtrs_rdma_addr_resolved() argument
1662 rtrs_rdma_route_resolved(struct rtrs_clt_con *con) rtrs_rdma_route_resolved() argument
1696 rtrs_rdma_conn_established(struct rtrs_clt_con *con, struct rdma_cm_event *ev) rtrs_rdma_conn_established() argument
1784 flag_success_on_conn(struct rtrs_clt_con *con) flag_success_on_conn() argument
1792 rtrs_rdma_conn_rejected(struct rtrs_clt_con *con, struct rdma_cm_event *ev) rtrs_rdma_conn_rejected() argument
1831 flag_error_on_conn(struct rtrs_clt_con *con, int cm_err) flag_error_on_conn() argument
1847 struct rtrs_clt_con *con = cm_id->context; rtrs_clt_rdma_cm_handler() local
1912 create_cm(struct rtrs_clt_con *con) create_cm() argument
2028 struct rtrs_clt_con *con; rtrs_clt_stop_and_destroy_conns() local
2244 struct rtrs_clt_con *con = to_clt_con(sess->s.con[cid]); init_conns() local
2263 struct rtrs_clt_con *con = cq->cq_context; rtrs_clt_info_req_done() local
2346 struct rtrs_clt_con *con = cq->cq_context; rtrs_clt_info_rsp_done() local
[all...]
/kernel/linux/linux-6.6/arch/arm/mach-s3c/
H A Dgpio-samsung.c73 u32 con; in samsung_gpio_setcfg_2bit() local
83 con = __raw_readl(reg); in samsung_gpio_setcfg_2bit()
84 con &= ~(0x3 << shift); in samsung_gpio_setcfg_2bit()
85 con |= cfg; in samsung_gpio_setcfg_2bit()
86 __raw_writel(con, reg); in samsung_gpio_setcfg_2bit()
104 u32 con; in samsung_gpio_getcfg_2bit() local
106 con = __raw_readl(chip->base); in samsung_gpio_getcfg_2bit()
107 con >>= off * 2; in samsung_gpio_getcfg_2bit()
108 con &= 3; in samsung_gpio_getcfg_2bit()
111 return S3C_GPIO_SPECIAL(con); in samsung_gpio_getcfg_2bit()
136 u32 con; samsung_gpio_setcfg_4bit() local
171 u32 con; samsung_gpio_getcfg_4bit() local
250 unsigned long con; samsung_gpiolib_2bit_input() local
270 unsigned long con; samsung_gpiolib_2bit_output() local
312 unsigned long con; samsung_gpiolib_4bit_input() local
331 unsigned long con; samsung_gpiolib_4bit_output() local
382 unsigned long con; samsung_gpiolib_4bit2_input() local
404 unsigned long con; samsung_gpiolib_4bit2_output() local
[all...]

Completed in 36 milliseconds

12345678910>>...15