block/drbd/drbd_int.h

152 extern unsigned int drbd_header_size(struct drbd_connection *connection);
169 	struct drbd_connection *connection;
246 	/* per connection */
271 	 *      or decide, e.g. on connection loss, that we do no longer expect
292 	struct drbd_connection *connection;
562 /* flag bits per connection */
568 	CONN_WD_ST_CHG_REQ,	/* A cluster wide state change on the connection is active */
631 	unsigned int connect_cnt;	/* Inc each time a connection is established */
652 	struct crypto_shash *integrity_tfm;  /* checksums we compute, updates protected by connection->data->mutex */
707 static inline bool has_net_conf(struct drbd_connection *connection)
712 	has_net_conf = rcu_dereference(connection->net_conf);
740 	struct drbd_connection *connection;
763 	unsigned int vnr;	/* volume number within the connection */
886 	struct mutex *state_mutex; /* either own_state_mutex or first_peer_device(device)->connection->cstate_mutex */
894 	struct fifo_buffer *rs_plan_s; /* correction values of resync planer (RCU, connection->conn_update) */
939 	struct drbd_connection *connection;
953 conn_peer_device(struct drbd_connection *connection, int volume_number)
955 	return idr_find(&connection->peer_devices, volume_number);
967 #define for_each_connection(connection, resource) \
968 	list_for_each_entry(connection, &resource->connections, connections)
970 #define for_each_connection_rcu(connection, resource) \
971 	list_for_each_entry_rcu(connection, &resource->connections, connections)
973 #define for_each_connection_safe(connection, tmp, resource) \
974 	list_for_each_entry_safe(connection, tmp, &resource->connections, connections)
1012 extern void drbd_free_sock(struct drbd_connection *connection);
1013 extern int drbd_send(struct drbd_connection *connection, struct socket *sock,
1018 extern int __drbd_send_protocol(struct drbd_connection *connection, enum drbd_packet cmd);
1019 extern int drbd_send_protocol(struct drbd_connection *connection);
1027 extern void drbd_send_b_ack(struct drbd_connection *connection, u32 barrier_nr,
1050 extern void conn_send_sr_reply(struct drbd_connection *connection, enum drbd_state_rv retcode);
1057 extern void conn_md_sync(struct drbd_connection *connection);
1372 extern int conn_lowest_minor(struct drbd_connection *connection);
1387 extern void conn_free_crypto(struct drbd_connection *connection);
1422 extern bool conn_try_outdate_peer(struct drbd_connection *connection);
1423 extern void conn_try_outdate_peer_async(struct drbd_connection *connection);
1424 extern enum drbd_peer_state conn_khelper(struct drbd_connection *connection, char *cmd);
1854 		struct drbd_connection *connection =
1855 			first_peer_device(device)->connection;
1856 		struct drbd_work_queue *q = &connection->sender_work;
1857 		if (!test_and_set_bit(DEVICE_WORK_PENDING, &connection->flags))
1868 static inline void wake_ack_receiver(struct drbd_connection *connection)
1870 	struct task_struct *task = connection->ack_receiver.task;
1871 	if (task && get_t_state(&connection->ack_receiver) == RUNNING)
1875 static inline void request_ping(struct drbd_connection *connection)
1877 	set_bit(SEND_PING, &connection->flags);
1878 	wake_ack_receiver(connection);
1890 extern int drbd_send_ping(struct drbd_connection *connection);
1891 extern int drbd_send_ping_ack(struct drbd_connection *connection);
2075 	nc = rcu_dereference(first_peer_device(device)->connection->net_conf);
2090 	/* new io only accepted when there is no connection, ... */
2093 	/* ... or there is a well established connection. */
2118 		if (first_peer_device(device)->connection->agreed_pro_version < 96)
2202 	 *    until the bitmap is no longer on the fly during connection
2221 				connection->sender_work,
2234 	return first_peer_device(device)->connection->agreed_pro_version >= 97 &&
2235 		first_peer_device(device)->connection->agreed_pro_version != 100;