Lines Matching refs:drbd_connection
57 static int drbd_do_features(struct drbd_connection *connection);
58 static int drbd_do_auth(struct drbd_connection *connection);
60 static void conn_wait_active_ee_empty(struct drbd_connection *connection);
61 static enum finish_epoch drbd_may_finish_epoch(struct drbd_connection *, struct drbd_epoch *, enum …
325 static int drbd_recv(struct drbd_connection *connection, void *buf, size_t size) in drbd_recv()
358 static int drbd_recv_all(struct drbd_connection *connection, void *buf, size_t size) in drbd_recv_all()
371 static int drbd_recv_all_warn(struct drbd_connection *connection, void *buf, size_t size) in drbd_recv_all_warn()
400 static struct socket *drbd_try_connect(struct drbd_connection *connection) in drbd_try_connect()
489 struct drbd_connection *connection;
507 static int prepare_listen_socket(struct drbd_connection *connection, struct accept_wait_data *ad) in prepare_listen_socket()
578 static struct socket *drbd_wait_for_connect(struct drbd_connection *connection, struct accept_wait_… in drbd_wait_for_connect()
615 static int decode_header(struct drbd_connection *, void *, struct packet_info *);
617 static int send_first_packet(struct drbd_connection *connection, struct drbd_socket *sock, in send_first_packet()
625 static int receive_first_packet(struct drbd_connection *connection, struct socket *sock) in receive_first_packet()
676 static bool connection_established(struct drbd_connection *connection, in connection_established()
735 static int conn_connect(struct drbd_connection *connection) in conn_connect()
970 static int decode_header(struct drbd_connection *connection, void *header, struct packet_info *pi) in decode_header()
1006 static void drbd_unplug_all_devices(struct drbd_connection *connection) in drbd_unplug_all_devices()
1014 static int drbd_recv_header(struct drbd_connection *connection, struct packet_info *pi) in drbd_recv_header()
1029 static int drbd_recv_header_maybe_unplug(struct drbd_connection *connection, struct packet_info *pi) in drbd_recv_header_maybe_unplug()
1124 static void drbd_flush(struct drbd_connection *connection) in drbd_flush()
1171 static enum finish_epoch drbd_may_finish_epoch(struct drbd_connection *connection, in drbd_may_finish_epoch()
1552 static void conn_wait_active_ee_empty(struct drbd_connection *connection) in conn_wait_active_ee_empty()
1570 static int receive_Barrier(struct drbd_connection *connection, struct packet_info *pi) in receive_Barrier()
1928 static int receive_DataReply(struct drbd_connection *connection, struct packet_info *pi) in receive_DataReply()
1960 static int receive_RSDataReply(struct drbd_connection *connection, struct packet_info *pi) in receive_RSDataReply()
2082 struct drbd_connection *connection = peer_req->peer_device->connection; in e_send_retry_write()
2223 static blk_opf_t wire_flags_to_bio(struct drbd_connection *connection, u32 dpf) in wire_flags_to_bio()
2260 struct drbd_connection *connection = peer_req->peer_device->connection; in handle_write_conflicts()
2370 static int receive_Data(struct drbd_connection *connection, struct packet_info *pi) in receive_Data()
2618 static int receive_DataRequest(struct drbd_connection *connection, struct packet_info *pi) in receive_DataRequest()
3049 struct drbd_connection *const connection = peer_device->connection; in drbd_uuid_compare()
3445 static int receive_protocol(struct drbd_connection *connection, struct packet_info *pi) in receive_protocol()
3616 static int ignore_remaining_packet(struct drbd_connection *connection, struct packet_info *pi) in ignore_remaining_packet()
3647 static int config_unknown_volume(struct drbd_connection *connection, struct packet_info *pi) in config_unknown_volume()
3654 static int receive_SyncParam(struct drbd_connection *connection, struct packet_info *pi) in receive_SyncParam()
3877 static int receive_sizes(struct drbd_connection *connection, struct packet_info *pi) in receive_sizes()
4048 static int receive_uuids(struct drbd_connection *connection, struct packet_info *pi) in receive_uuids()
4153 static int receive_req_state(struct drbd_connection *connection, struct packet_info *pi) in receive_req_state()
4186 static int receive_req_conn_state(struct drbd_connection *connection, struct packet_info *pi) in receive_req_conn_state()
4210 static int receive_state(struct drbd_connection *connection, struct packet_info *pi) in receive_state()
4407 static int receive_sync_uuid(struct drbd_connection *connection, struct packet_info *pi) in receive_sync_uuid()
4631 static int receive_bitmap(struct drbd_connection *connection, struct packet_info *pi) in receive_bitmap()
4719 static int receive_skip(struct drbd_connection *connection, struct packet_info *pi) in receive_skip()
4727 static int receive_UnplugRemote(struct drbd_connection *connection, struct packet_info *pi) in receive_UnplugRemote()
4735 static int receive_out_of_sync(struct drbd_connection *connection, struct packet_info *pi) in receive_out_of_sync()
4761 static int receive_rs_deallocated(struct drbd_connection *connection, struct packet_info *pi) in receive_rs_deallocated()
4830 int (*fn)(struct drbd_connection *, struct packet_info *);
4864 static void drbdd(struct drbd_connection *connection) in drbdd()
4921 static void conn_disconnect(struct drbd_connection *connection) in conn_disconnect()
5063 static int drbd_send_features(struct drbd_connection *connection) in drbd_send_features()
5086 static int drbd_do_features(struct drbd_connection *connection) in drbd_do_features()
5153 static int drbd_do_auth(struct drbd_connection *connection) in drbd_do_auth()
5168 static int drbd_do_auth(struct drbd_connection *connection) in drbd_do_auth()
5347 struct drbd_connection *connection = thi->connection; in drbd_receiver()
5378 static int got_conn_RqSReply(struct drbd_connection *connection, struct packet_info *pi) in got_conn_RqSReply()
5395 static int got_RqSReply(struct drbd_connection *connection, struct packet_info *pi) in got_RqSReply()
5424 static int got_Ping(struct drbd_connection *connection, struct packet_info *pi) in got_Ping()
5430 static int got_PingAck(struct drbd_connection *connection, struct packet_info *pi) in got_PingAck()
5440 static int got_IsInSync(struct drbd_connection *connection, struct packet_info *pi) in got_IsInSync()
5493 static int got_BlockAck(struct drbd_connection *connection, struct packet_info *pi) in got_BlockAck()
5539 static int got_NegAck(struct drbd_connection *connection, struct packet_info *pi) in got_NegAck()
5575 static int got_NegDReply(struct drbd_connection *connection, struct packet_info *pi) in got_NegDReply()
5597 static int got_NegRSDReply(struct drbd_connection *connection, struct packet_info *pi) in got_NegRSDReply()
5634 static int got_BarrierAck(struct drbd_connection *connection, struct packet_info *pi) in got_BarrierAck()
5658 static int got_OVResult(struct drbd_connection *connection, struct packet_info *pi) in got_OVResult()
5710 static int got_skip(struct drbd_connection *connection, struct packet_info *pi) in got_skip()
5717 int (*fn)(struct drbd_connection *connection, struct packet_info *);
5720 static void set_rcvtimeo(struct drbd_connection *connection, bool ping_timeout) in set_rcvtimeo()
5737 static void set_ping_timeout(struct drbd_connection *connection) in set_ping_timeout()
5742 static void set_idle_timeout(struct drbd_connection *connection) in set_idle_timeout()
5769 struct drbd_connection *connection = thi->connection; in drbd_ack_receiver()
5905 struct drbd_connection *connection = peer_device->connection; in drbd_send_acks_wf()