net/rds/rds.h

1 /* SPDX-License-Identifier: GPL-2.0 */
56 /* Used to limit both RDMA and non-RDMA RDS message to 1MB */
96 #define	RDS_MPATH_HASH(rs, n) (jhash_1word((rs)->rs_bound_port, \
97 			       (rs)->rs_hash_initval) & ((n) - 1))
176 	return read_pnet(&conn->c_net);  in rds_conn_net()
182 	write_pnet(&conn->c_net, net);  in rds_conn_net_set()
190 /* RDS_FLAG_PROBE_PORT is the reserved sport used for sending a ping
194  * it would return a pong message without additional control information
221  * Reserved - indicates end of extensions
328  * conn->c_lock.  m_sock_item has additional meaning in that once it is empty
333  * back up into the rx path.  It embeds a wire header which is also used by
384 	spin_lock_init(&q->lock);  in rds_message_zcopy_queue_init()
385 	INIT_LIST_HEAD(&q->zcookie_head);  in rds_message_zcopy_queue_init()
411 	 *  rm->m_rs_lock
412 	 *   -> rs->rs_lock
509  * struct rds_transport -  transport specific behavioural hooks
521  *        available.  Returning -EAGAIN tells the caller to retry the send
522  *        immediately.  Returning -ENOMEM tells the caller to retry the send at
528  *                 non-zero success and will The caller serializes this with
649 	/* Socket options - in case there will be more */
667 	return &rs->rs_sk;  in rds_rs_to_sk()
677 	return rds_rs_to_sk(rs)->sk_sndbuf / 2;  in rds_sk_sndbuf()
681 	return rds_rs_to_sk(rs)->sk_rcvbuf / 2;  in rds_sk_rcvbuf()
797 	return atomic_cmpxchg(&cp->cp_state, old, new) == old;  in rds_conn_path_transition()
803 	WARN_ON(conn->c_trans->t_mp_capable);  in rds_conn_transition()
804 	return rds_conn_path_transition(&conn->c_path[0], old, new);  in rds_conn_transition()
810 	return atomic_read(&cp->cp_state);  in rds_conn_path_state()
816 	WARN_ON(conn->c_trans->t_mp_capable);  in rds_conn_state()
817 	return rds_conn_path_state(&conn->c_path[0]);  in rds_conn_state()
823 	return atomic_read(&cp->cp_state) == RDS_CONN_UP;  in rds_conn_path_up()
829 	return atomic_read(&cp->cp_state) == RDS_CONN_DOWN;  in rds_conn_path_down()
835 	WARN_ON(conn->c_trans->t_mp_capable);  in rds_conn_up()
836 	return rds_conn_path_up(&conn->c_path[0]);  in rds_conn_up()
842 	return atomic_read(&cp->cp_state) == RDS_CONN_CONNECTING;  in rds_conn_path_connecting()
848 	WARN_ON(conn->c_trans->t_mp_capable);  in rds_conn_connecting()
849 	return rds_conn_path_connecting(&conn->c_path[0]);  in rds_conn_connecting()
874 	hdr->h_csum = 0;  in rds_message_make_checksum()
875 	hdr->h_csum = ip_fast_csum((void *) hdr, sizeof(*hdr) >> 2);  in rds_message_make_checksum()
880 	return !hdr->h_csum || ip_fast_csum((void *) hdr, sizeof(*hdr) >> 2) == 0;  in rds_message_verify_checksum()
951 	       (conn->c_trans->t_unloading && conn->c_trans->t_unloading(conn));  in rds_destroy_pending()