Lines Matching defs:connection
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;
560 /* flag bits per connection */
566 CONN_WD_ST_CHG_REQ, /* A cluster wide state change on the connection is active */
629 unsigned int connect_cnt; /* Inc each time a connection is established */
650 struct crypto_shash *integrity_tfm; /* checksums we compute, updates protected by connection->data->mutex */
705 static inline bool has_net_conf(struct drbd_connection *connection)
710 has_net_conf = rcu_dereference(connection->net_conf);
738 struct drbd_connection *connection;
761 unsigned int vnr; /* volume number within the connection */
884 struct mutex *state_mutex; /* either own_state_mutex or first_peer_device(device)->connection->cstate_mutex */
892 struct fifo_buffer *rs_plan_s; /* correction values of resync planer (RCU, connection->conn_update) */
937 struct drbd_connection *connection;
951 conn_peer_device(struct drbd_connection *connection, int volume_number)
953 return idr_find(&connection->peer_devices, volume_number);
965 #define for_each_connection(connection, resource) \
966 list_for_each_entry(connection, &resource->connections, connections)
968 #define for_each_connection_rcu(connection, resource) \
969 list_for_each_entry_rcu(connection, &resource->connections, connections)
971 #define for_each_connection_safe(connection, tmp, resource) \
972 list_for_each_entry_safe(connection, tmp, &resource->connections, connections)
1010 extern void drbd_free_sock(struct drbd_connection *connection);
1011 extern int drbd_send(struct drbd_connection *connection, struct socket *sock,
1016 extern int __drbd_send_protocol(struct drbd_connection *connection, enum drbd_packet cmd);
1017 extern int drbd_send_protocol(struct drbd_connection *connection);
1025 extern void drbd_send_b_ack(struct drbd_connection *connection, u32 barrier_nr,
1048 extern void conn_send_sr_reply(struct drbd_connection *connection, enum drbd_state_rv retcode);
1055 extern void conn_md_sync(struct drbd_connection *connection);
1370 extern int conn_lowest_minor(struct drbd_connection *connection);
1385 extern void conn_free_crypto(struct drbd_connection *connection);
1420 extern bool conn_try_outdate_peer(struct drbd_connection *connection);
1421 extern void conn_try_outdate_peer_async(struct drbd_connection *connection);
1422 extern enum drbd_peer_state conn_khelper(struct drbd_connection *connection, char *cmd);
1852 struct drbd_connection *connection =
1853 first_peer_device(device)->connection;
1854 struct drbd_work_queue *q = &connection->sender_work;
1855 if (!test_and_set_bit(DEVICE_WORK_PENDING, &connection->flags))
1866 static inline void wake_ack_receiver(struct drbd_connection *connection)
1868 struct task_struct *task = connection->ack_receiver.task;
1869 if (task && get_t_state(&connection->ack_receiver) == RUNNING)
1873 static inline void request_ping(struct drbd_connection *connection)
1875 set_bit(SEND_PING, &connection->flags);
1876 wake_ack_receiver(connection);
1888 extern int drbd_send_ping(struct drbd_connection *connection);
1889 extern int drbd_send_ping_ack(struct drbd_connection *connection);
2073 nc = rcu_dereference(first_peer_device(device)->connection->net_conf);
2088 /* new io only accepted when there is no connection, ... */
2091 /* ... or there is a well established connection. */
2116 if (first_peer_device(device)->connection->agreed_pro_version < 96)
2200 * until the bitmap is no longer on the fly during connection
2219 connection->sender_work,
2232 return first_peer_device(device)->connection->agreed_pro_version >= 97 &&
2233 first_peer_device(device)->connection->agreed_pro_version != 100;