block/drbd/drbd_receiver.c

56 static int drbd_do_features(struct drbd_connection *connection);
57 static int drbd_do_auth(struct drbd_connection *connection);
59 static void conn_wait_active_ee_empty(struct drbd_connection *connection);
60 static enum finish_epoch drbd_may_finish_epoch(struct drbd_connection *, struct drbd_epoch *, enum epoch_event);
222 static void conn_reclaim_net_peer_reqs(struct drbd_connection *connection)
513 static int drbd_recv(struct drbd_connection *connection, void *buf, size_t size)
546 static int drbd_recv_all(struct drbd_connection *connection, void *buf, size_t size)
559 static int drbd_recv_all_warn(struct drbd_connection *connection, void *buf, size_t size)
588 static struct socket *drbd_try_connect(struct drbd_connection *connection)
677 	struct drbd_connection *connection;
695 static int prepare_listen_socket(struct drbd_connection *connection, struct accept_wait_data *ad)
766 static struct socket *drbd_wait_for_connect(struct drbd_connection *connection, struct accept_wait_data *ad)
803 static int decode_header(struct drbd_connection *, void *, struct packet_info *);
805 static int send_first_packet(struct drbd_connection *connection, struct drbd_socket *sock,
813 static int receive_first_packet(struct drbd_connection *connection, struct socket *sock)
864 static bool connection_established(struct drbd_connection *connection,
923 static int conn_connect(struct drbd_connection *connection)
1158 static int decode_header(struct drbd_connection *connection, void *header, struct packet_info *pi)
1194 static void drbd_unplug_all_devices(struct drbd_connection *connection)
1202 static int drbd_recv_header(struct drbd_connection *connection, struct packet_info *pi)
1217 static int drbd_recv_header_maybe_unplug(struct drbd_connection *connection, struct packet_info *pi)
1312 static void drbd_flush(struct drbd_connection *connection)
1359 static enum finish_epoch drbd_may_finish_epoch(struct drbd_connection *connection,
1740 static void conn_wait_active_ee_empty(struct drbd_connection *connection)
1758 static int receive_Barrier(struct drbd_connection *connection, struct packet_info *pi)
2116 static int receive_DataReply(struct drbd_connection *connection, struct packet_info *pi)
2148 static int receive_RSDataReply(struct drbd_connection *connection, struct packet_info *pi)
2270 	struct drbd_connection *connection = peer_req->peer_device->connection;
2411 static blk_opf_t wire_flags_to_bio(struct drbd_connection *connection, u32 dpf)
2448 	struct drbd_connection *connection = peer_req->peer_device->connection;
2554 static int receive_Data(struct drbd_connection *connection, struct packet_info *pi)
2802 static int receive_DataRequest(struct drbd_connection *connection, struct packet_info *pi)
3233 	struct drbd_connection *const connection = peer_device->connection;
3629 static int receive_protocol(struct drbd_connection *connection, struct packet_info *pi)
3800 static int ignore_remaining_packet(struct drbd_connection *connection, struct packet_info *pi)
3831 static int config_unknown_volume(struct drbd_connection *connection, struct packet_info *pi)
3838 static int receive_SyncParam(struct drbd_connection *connection, struct packet_info *pi)
4061 static int receive_sizes(struct drbd_connection *connection, struct packet_info *pi)
4232 static int receive_uuids(struct drbd_connection *connection, struct packet_info *pi)
4337 static int receive_req_state(struct drbd_connection *connection, struct packet_info *pi)
4370 static int receive_req_conn_state(struct drbd_connection *connection, struct packet_info *pi)
4394 static int receive_state(struct drbd_connection *connection, struct packet_info *pi)
4591 static int receive_sync_uuid(struct drbd_connection *connection, struct packet_info *pi)
4815 static int receive_bitmap(struct drbd_connection *connection, struct packet_info *pi)
4903 static int receive_skip(struct drbd_connection *connection, struct packet_info *pi)
4911 static int receive_UnplugRemote(struct drbd_connection *connection, struct packet_info *pi)
4919 static int receive_out_of_sync(struct drbd_connection *connection, struct packet_info *pi)
4945 static int receive_rs_deallocated(struct drbd_connection *connection, struct packet_info *pi)
5014 	int (*fn)(struct drbd_connection *, struct packet_info *);
5048 static void drbdd(struct drbd_connection *connection)
5105 static void conn_disconnect(struct drbd_connection *connection)
5257 static int drbd_send_features(struct drbd_connection *connection)
5280 static int drbd_do_features(struct drbd_connection *connection)
5347 static int drbd_do_auth(struct drbd_connection *connection)
5362 static int drbd_do_auth(struct drbd_connection *connection)
5541 	struct drbd_connection *connection = thi->connection;
5572 static int got_conn_RqSReply(struct drbd_connection *connection, struct packet_info *pi)
5589 static int got_RqSReply(struct drbd_connection *connection, struct packet_info *pi)
5618 static int got_Ping(struct drbd_connection *connection, struct packet_info *pi)
5624 static int got_PingAck(struct drbd_connection *connection, struct packet_info *pi)
5634 static int got_IsInSync(struct drbd_connection *connection, struct packet_info *pi)
5687 static int got_BlockAck(struct drbd_connection *connection, struct packet_info *pi)
5733 static int got_NegAck(struct drbd_connection *connection, struct packet_info *pi)
5769 static int got_NegDReply(struct drbd_connection *connection, struct packet_info *pi)
5791 static int got_NegRSDReply(struct drbd_connection *connection, struct packet_info *pi)
5828 static int got_BarrierAck(struct drbd_connection *connection, struct packet_info *pi)
5852 static int got_OVResult(struct drbd_connection *connection, struct packet_info *pi)
5904 static int got_skip(struct drbd_connection *connection, struct packet_info *pi)
5911 	int (*fn)(struct drbd_connection *connection, struct packet_info *);
5914 static void set_rcvtimeo(struct drbd_connection *connection, bool ping_timeout)
5931 static void set_ping_timeout(struct drbd_connection *connection)
5936 static void set_idle_timeout(struct drbd_connection *connection)
5963 	struct drbd_connection *connection = thi->connection;
6101 	struct drbd_connection *connection = peer_device->connection;