| H A D | drbd_receiver.c | 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); 121 nc = rcu_dereference(peer_device->connection->net_conf); in drbd_alloc_pages() 325 static int drbd_recv(struct drbd_connection *connection, void *buf, size_t size) in drbd_recv() argument 329 rv = drbd_recv_short(connection->data.socket, buf, size, 0); in drbd_recv() 333 drbd_info(connection, "sock was reset by peer\n"); in drbd_recv() 335 drbd_err(connection, "sock_recvmsg returned %d\n", rv); in drbd_recv() 337 if (test_bit(DISCONNECT_SENT, &connection->flags)) { in drbd_recv() 340 t = rcu_dereference(connection in drbd_recv() 358 drbd_recv_all(struct drbd_connection * connection,void * buf,size_t size) drbd_recv_all() argument 371 drbd_recv_all_warn(struct drbd_connection * connection,void * buf,size_t size) drbd_recv_all_warn() argument 400 drbd_try_connect(struct drbd_connection * connection) drbd_try_connect() argument 489 struct drbd_connection *connection; global() member 507 prepare_listen_socket(struct drbd_connection * connection,struct accept_wait_data * ad) prepare_listen_socket() argument 578 drbd_wait_for_connect(struct drbd_connection * connection,struct accept_wait_data * ad) drbd_wait_for_connect() argument 617 send_first_packet(struct drbd_connection * connection,struct drbd_socket * sock,enum drbd_packet cmd) send_first_packet() argument 625 receive_first_packet(struct drbd_connection * connection,struct socket * sock) receive_first_packet() argument 676 connection_established(struct drbd_connection * connection,struct socket ** sock1,struct socket ** sock2) connection_established() argument 735 conn_connect(struct drbd_connection * connection) conn_connect() argument 970 decode_header(struct drbd_connection * connection,void * header,struct packet_info * pi) decode_header() argument 1006 drbd_unplug_all_devices(struct drbd_connection * connection) drbd_unplug_all_devices() argument 1014 drbd_recv_header(struct drbd_connection * connection,struct packet_info * pi) drbd_recv_header() argument 1029 drbd_recv_header_maybe_unplug(struct drbd_connection * connection,struct packet_info * pi) drbd_recv_header_maybe_unplug() argument 1124 drbd_flush(struct drbd_connection * connection) drbd_flush() argument 1171 drbd_may_finish_epoch(struct drbd_connection * connection,struct drbd_epoch * epoch,enum epoch_event ev) drbd_may_finish_epoch() argument 1552 conn_wait_active_ee_empty(struct drbd_connection * connection) conn_wait_active_ee_empty() argument 1570 receive_Barrier(struct drbd_connection * connection,struct packet_info * pi) receive_Barrier() argument 1928 receive_DataReply(struct drbd_connection * connection,struct packet_info * pi) receive_DataReply() argument 1960 receive_RSDataReply(struct drbd_connection * connection,struct packet_info * pi) receive_RSDataReply() argument 2082 struct drbd_connection *connection = peer_req->peer_device->connection; e_send_retry_write() local 2223 wire_flags_to_bio(struct drbd_connection * connection,u32 dpf) wire_flags_to_bio() argument 2260 struct drbd_connection *connection = peer_req->peer_device->connection; handle_write_conflicts() local 2370 receive_Data(struct drbd_connection * connection,struct packet_info * pi) receive_Data() argument 2618 receive_DataRequest(struct drbd_connection * connection,struct packet_info * pi) receive_DataRequest() argument 3049 struct drbd_connection *const connection = peer_device->connection; drbd_uuid_compare() local 3445 receive_protocol(struct drbd_connection * connection,struct packet_info * pi) receive_protocol() argument 3616 ignore_remaining_packet(struct drbd_connection * connection,struct packet_info * pi) ignore_remaining_packet() argument 3647 config_unknown_volume(struct drbd_connection * connection,struct packet_info * pi) config_unknown_volume() argument 3654 receive_SyncParam(struct drbd_connection * connection,struct packet_info * pi) receive_SyncParam() argument 3877 receive_sizes(struct drbd_connection * connection,struct packet_info * pi) receive_sizes() argument 4048 receive_uuids(struct drbd_connection * connection,struct packet_info * pi) receive_uuids() argument 4153 receive_req_state(struct drbd_connection * connection,struct packet_info * pi) receive_req_state() argument 4186 receive_req_conn_state(struct drbd_connection * connection,struct packet_info * pi) receive_req_conn_state() argument 4210 receive_state(struct drbd_connection * connection,struct packet_info * pi) receive_state() argument 4407 receive_sync_uuid(struct drbd_connection * connection,struct packet_info * pi) receive_sync_uuid() argument 4631 receive_bitmap(struct drbd_connection * connection,struct packet_info * pi) receive_bitmap() argument 4719 receive_skip(struct drbd_connection * connection,struct packet_info * pi) receive_skip() argument 4727 receive_UnplugRemote(struct drbd_connection * connection,struct packet_info * pi) receive_UnplugRemote() argument 4735 receive_out_of_sync(struct drbd_connection * connection,struct packet_info * pi) receive_out_of_sync() argument 4761 receive_rs_deallocated(struct drbd_connection * connection,struct packet_info * pi) receive_rs_deallocated() argument 4864 drbdd(struct drbd_connection * connection) drbdd() argument 4921 conn_disconnect(struct drbd_connection * connection) conn_disconnect() argument 5063 drbd_send_features(struct drbd_connection * connection) drbd_send_features() argument 5086 drbd_do_features(struct drbd_connection * connection) drbd_do_features() argument 5153 drbd_do_auth(struct drbd_connection * connection) drbd_do_auth() argument 5168 drbd_do_auth(struct drbd_connection * connection) drbd_do_auth() argument 5347 struct drbd_connection *connection = thi->connection; drbd_receiver() local 5378 got_conn_RqSReply(struct drbd_connection * connection,struct packet_info * pi) got_conn_RqSReply() argument 5395 got_RqSReply(struct drbd_connection * connection,struct packet_info * pi) got_RqSReply() argument 5424 got_Ping(struct drbd_connection * connection,struct packet_info * pi) got_Ping() argument 5430 got_PingAck(struct drbd_connection * connection,struct packet_info * pi) got_PingAck() argument 5440 got_IsInSync(struct drbd_connection * connection,struct packet_info * pi) got_IsInSync() argument 5493 got_BlockAck(struct drbd_connection * connection,struct packet_info * pi) got_BlockAck() argument 5539 got_NegAck(struct drbd_connection * connection,struct packet_info * pi) got_NegAck() argument 5575 got_NegDReply(struct drbd_connection * connection,struct packet_info * pi) got_NegDReply() argument 5597 got_NegRSDReply(struct drbd_connection * connection,struct packet_info * pi) got_NegRSDReply() argument 5634 got_BarrierAck(struct drbd_connection * connection,struct packet_info * pi) got_BarrierAck() argument 5658 got_OVResult(struct drbd_connection * connection,struct packet_info * pi) got_OVResult() argument 5710 got_skip(struct drbd_connection * connection,struct packet_info * pi) got_skip() argument 5720 set_rcvtimeo(struct drbd_connection * connection,bool ping_timeout) set_rcvtimeo() argument 5737 set_ping_timeout(struct drbd_connection * connection) set_ping_timeout() argument 5742 set_idle_timeout(struct drbd_connection * connection) set_idle_timeout() argument 5769 struct drbd_connection *connection = thi->connection; drbd_ack_receiver() local 5905 struct drbd_connection *connection = peer_device->connection; drbd_send_acks_wf() local [all...] |