Home
last modified time | relevance | path

Searched refs:con (Results 1 – 8 of 8) sorted by relevance

/net/ceph/
A Dmessenger_v1.c206 con->in_seq_acked = con->in_seq; in prepare_write_message()
225 con_out_kvec_add(con, sizeof(con->v1.out_hdr), &con->v1.out_hdr); in prepare_write_message()
235 memcpy(&con->v1.out_hdr, &con->out_msg->hdr, sizeof(con->v1.out_hdr)); in prepare_write_message()
271 con->in_seq_acked = con->in_seq; in prepare_write_ack()
292 con->in_seq_acked = con->in_seq; in prepare_write_seq()
340 auth = con->ops->get_authorizer(con, &auth_proto, con->v1.auth_retry); in get_connect_authorizer()
595 con->in_front_crc = con->in_middle_crc = con->in_data_crc = 0; in prepare_read_message()
680 con, con->v1.in_reply.tag, in read_partial_connect()
843 con->ops->peer_reset(con); in process_connect()
1225 BUG_ON(con->in_msg->con != con); in read_partial_message()
[all …]
A Dmessenger_v2.c682 con->in_front_crc, con->in_middle_crc, con->in_data_crc); in verify_epilogue_crcs()
712 WARN_ON(con->v2.hmac_tfm || con->v2.gcm_tfm || con->v2.gcm_req); in setup_crypto()
1539 con->v2.client_cookie, con->v2.server_cookie, con->v2.global_seq, in prepare_session_reconnect()
1582 con->in_seq_acked, con->in_seq); in prepare_ack()
1583 con->in_seq_acked = con->in_seq; in prepare_ack()
1740 if (con->in_seq > con->in_seq_acked) { in prepare_message()
1743 con->in_seq_acked = con->in_seq; in prepare_message()
1798 add_in_kvec(con, con->v2.in_buf, in prepare_read_preamble()
1854 add_in_kvec(con, con->v2.in_buf, in prepare_read_control_remainder()
2726 con->ops->peer_reset(con); in process_session_reset()
[all …]
A Dmessenger.c357 con, con->state); in ceph_sock_data_ready()
514 WARN_ON(con->in_msg->con != con); in ceph_con_reset_protocol()
519 WARN_ON(con->out_msg->con != con); in ceph_con_reset_protocol()
1405 BUG_ON(con->in_msg->con != con); in ceph_con_process_message()
1447 con->ops->put(con); in queue_con_delay()
1463 con->ops->put(con); in cancel_con()
1509 con, con->delay); in con_backoff()
1535 con->ops->fault(con); in con_fault_finish()
1607 con->ops->put(con); in ceph_con_workfn()
1709 msg->con = con ? con->ops->get(con) : NULL; in msg_con_set()
[all …]
A Dmon_client.c182 ceph_con_send(&monc->con, monc->m_auth); in __send_prepared_auth_request()
195 ceph_con_close(&monc->con); in __close_session()
265 ceph_con_keepalive(&monc->con); in __open_session()
379 ceph_con_send(&monc->con, ceph_msg_get(msg)); in __send_subscribe()
1101 if (ceph_con_keepalive_expired(&monc->con, in delayed_work()
1109 ceph_con_keepalive(&monc->con); in delayed_work()
1309 ceph_pr_addr(&monc->con.peer_addr)); in finish_auth()
1511 return get_generic_reply(con, hdr, skip); in mon_alloc_msg()
1541 (unsigned int)con->peer_name.type, in mon_alloc_msg()
1542 le64_to_cpu(con->peer_name.num)); in mon_alloc_msg()
[all …]
A Dosd_client.c5510 return get_reply(con, hdr, skip); in osd_alloc_msg()
5526 return con; in osd_get_con()
5547 struct ceph_osd *o = con->private; in osd_get_authorizer()
5564 struct ceph_osd *o = con->private; in osd_add_authorizer_challenge()
5574 struct ceph_osd *o = con->private; in osd_verify_authorizer_reply()
5586 struct ceph_osd *o = con->private; in osd_invalidate_authorizer()
5598 struct ceph_osd *o = con->private; in osd_get_auth_request()
5618 struct ceph_osd *o = con->private; in osd_handle_auth_reply_more()
5638 struct ceph_osd *o = con->private; in osd_handle_auth_done()
5652 struct ceph_osd *o = con->private; in osd_handle_auth_bad_method()
[all …]
A Dauth_x.c968 if (!CEPH_HAVE_FEATURE(msg->con->peer_features, CEPHX_V2)) { in calc_signature()
1033 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) in ceph_x_sign_message()
1052 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) in ceph_x_check_message_signature()
/net/tipc/
A Dtopsrv.c121 return con && test_bit(CF_CONNECTED, &con->flags); in connected()
143 kfree(con); in tipc_conn_kref_release()
185 con = kzalloc(sizeof(*con), GFP_ATOMIC); in tipc_conn_alloc()
186 if (!con) in tipc_conn_alloc()
200 kfree(con); in tipc_conn_alloc()
213 return con; in tipc_conn_alloc()
225 return con; in tipc_conn_lookup()
322 if (!con) in tipc_topsrv_queue_evt()
355 if (!queue_work(con->server->send_wq, &con->swork)) in tipc_conn_write_space()
449 if (!queue_work(con->server->rcv_wq, &con->rwork)) in tipc_conn_data_ready()
[all …]
A Dnetlink_compat.c1059 struct nlattr *con[TIPC_NLA_CON_MAX + 1]; in tipc_nl_compat_sk_dump() local
1061 err = nla_parse_nested_deprecated(con, TIPC_NLA_CON_MAX, in tipc_nl_compat_sk_dump()
1068 node = nla_get_u32(con[TIPC_NLA_CON_NODE]); in tipc_nl_compat_sk_dump()
1073 nla_get_u32(con[TIPC_NLA_CON_SOCK])); in tipc_nl_compat_sk_dump()
1075 if (con[TIPC_NLA_CON_FLAG]) in tipc_nl_compat_sk_dump()
1077 nla_get_u32(con[TIPC_NLA_CON_TYPE]), in tipc_nl_compat_sk_dump()
1078 nla_get_u32(con[TIPC_NLA_CON_INST])); in tipc_nl_compat_sk_dump()

Completed in 665 milliseconds