68 static int drbd_do_features(struct drbd_connection *connection);
69 static int drbd_do_auth(struct drbd_connection *connection);
71 static void conn_wait_active_ee_empty(struct drbd_connection *connection);
232 static void conn_reclaim_net_peer_reqs(struct drbd_connection *connection)  in conn_reclaim_net_peer_reqs()  argument
238 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in conn_reclaim_net_peer_reqs()
282 	nc = rcu_dereference(peer_device->connection->net_conf);  in drbd_alloc_pages()
523 static int drbd_recv(struct drbd_connection *connection, void *buf, size_t size)  in drbd_recv()  argument
527 	rv = drbd_recv_short(connection->data.socket, buf, size, 0);  in drbd_recv()
531 			drbd_info(connection, "sock was reset by peer\n");  in drbd_recv()
533 			drbd_err(connection, "sock_recvmsg returned %d\n", rv);  in drbd_recv()
535 		if (test_bit(DISCONNECT_SENT, &connection->flags)) {  in drbd_recv()
538 			t = rcu_dereference(connection->net_conf)->ping_timeo * HZ/10;  in drbd_recv()
541 			t = wait_event_timeout(connection->ping_wait, connection->cstate < C_WF_REPORT_PARAMS, t);  in drbd_recv()
546 		drbd_info(connection, "sock was shut down by peer\n");  in drbd_recv()
550 		conn_request_state(connection, NS(conn, C_BROKEN_PIPE), CS_HARD);  in drbd_recv()
556 static int drbd_recv_all(struct drbd_connection *connection, void *buf, size_t size)  in drbd_recv_all()  argument
560 	err = drbd_recv(connection, buf, size);  in drbd_recv_all()
569 static int drbd_recv_all_warn(struct drbd_connection *connection, void *buf, size_t size)  in drbd_recv_all_warn()  argument
573 	err = drbd_recv_all(connection, buf, size);  in drbd_recv_all_warn()
575 		drbd_warn(connection, "short read (expected size %d)\n", (int)size);  in drbd_recv_all_warn()
598 static struct socket *drbd_try_connect(struct drbd_connection *connection)  in drbd_try_connect()  argument
610 	nc = rcu_dereference(connection->net_conf);  in drbd_try_connect()
620 	my_addr_len = min_t(int, connection->my_addr_len, sizeof(src_in6));  in drbd_try_connect()
621 	memcpy(&src_in6, &connection->my_addr, my_addr_len);  in drbd_try_connect()
623 	if (((struct sockaddr *)&connection->my_addr)->sa_family == AF_INET6)  in drbd_try_connect()
628 	peer_addr_len = min_t(int, connection->peer_addr_len, sizeof(src_in6));  in drbd_try_connect()
629 	memcpy(&peer_in6, &connection->peer_addr, peer_addr_len);  in drbd_try_connect()
677 			drbd_err(connection, "%s failed, err = %d\n", what, err);  in drbd_try_connect()
680 			conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD);  in drbd_try_connect()
687 	struct drbd_connection *connection;  member
705 static int prepare_listen_socket(struct drbd_connection *connection, struct accept_wait_data *ad)  in prepare_listen_socket()  argument
714 	nc = rcu_dereference(connection->net_conf);  in prepare_listen_socket()
723 	my_addr_len = min_t(int, connection->my_addr_len, sizeof(struct sockaddr_in6));  in prepare_listen_socket()
724 	memcpy(&my_addr, &connection->my_addr, my_addr_len);  in prepare_listen_socket()
760 			drbd_err(connection, "%s failed, err = %d\n", what, err);  in prepare_listen_socket()
761 			conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD);  in prepare_listen_socket()
776 static struct socket *drbd_wait_for_connect(struct drbd_connection *connection, struct accept_wait_…  in drbd_wait_for_connect()  argument
783 	nc = rcu_dereference(connection->net_conf);  in drbd_wait_for_connect()
802 			drbd_err(connection, "accept failed, err = %d\n", err);  in drbd_wait_for_connect()
803 			conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD);  in drbd_wait_for_connect()
815 static int send_first_packet(struct drbd_connection *connection, struct drbd_socket *sock,  in send_first_packet()  argument
818 	if (!conn_prepare_command(connection, sock))  in send_first_packet()
820 	return conn_send_command(connection, sock, cmd, 0, NULL, 0);  in send_first_packet()
823 static int receive_first_packet(struct drbd_connection *connection, struct socket *sock)  in receive_first_packet()  argument
825 	unsigned int header_size = drbd_header_size(connection);  in receive_first_packet()
831 	nc = rcu_dereference(connection->net_conf);  in receive_first_packet()
839 	err = drbd_recv_short(sock, connection->data.rbuf, header_size, 0);  in receive_first_packet()
845 	err = decode_header(connection, connection->data.rbuf, &pi);  in receive_first_packet()
874 static bool connection_established(struct drbd_connection *connection,  in connection_established()  argument
886 	nc = rcu_dereference(connection->net_conf);  in connection_established()
907 	device->state_mutex = peer_device->connection->agreed_pro_version < 100 ?  in drbd_connected()
908 		&peer_device->connection->cstate_mutex :  in drbd_connected()
933 static int conn_connect(struct drbd_connection *connection)  in conn_connect()  argument
942 		.connection = connection,  in conn_connect()
946 	clear_bit(DISCONNECT_SENT, &connection->flags);  in conn_connect()
947 	if (conn_request_state(connection, NS(conn, C_WF_CONNECTION), CS_VERBOSE) < SS_SUCCESS)  in conn_connect()
951 	sock.sbuf = connection->data.sbuf;  in conn_connect()
952 	sock.rbuf = connection->data.rbuf;  in conn_connect()
955 	msock.sbuf = connection->meta.sbuf;  in conn_connect()
956 	msock.rbuf = connection->meta.rbuf;  in conn_connect()
960 	connection->agreed_pro_version = 80;  in conn_connect()
962 	if (prepare_listen_socket(connection, &ad))  in conn_connect()
968 		s = drbd_try_connect(connection);  in conn_connect()
972 				send_first_packet(connection, &sock, P_INITIAL_DATA);  in conn_connect()
974 				clear_bit(RESOLVE_CONFLICTS, &connection->flags);  in conn_connect()
976 				send_first_packet(connection, &msock, P_INITIAL_META);  in conn_connect()
978 				drbd_err(connection, "Logic error in conn_connect()\n");  in conn_connect()
983 		if (connection_established(connection, &sock.socket, &msock.socket))  in conn_connect()
987 		s = drbd_wait_for_connect(connection, &ad);  in conn_connect()
989 			int fp = receive_first_packet(connection, s);  in conn_connect()
995 					drbd_warn(connection, "initial packet S crossed\n");  in conn_connect()
1003 				set_bit(RESOLVE_CONFLICTS, &connection->flags);  in conn_connect()
1005 					drbd_warn(connection, "initial packet M crossed\n");  in conn_connect()
1013 				drbd_warn(connection, "Error receiving initial packet\n");  in conn_connect()
1021 		if (connection->cstate <= C_DISCONNECTING)  in conn_connect()
1026 			if (get_t_state(&connection->receiver) == EXITING)  in conn_connect()
1030 		ok = connection_established(connection, &sock.socket, &msock.socket);  in conn_connect()
1051 	nc = rcu_dereference(connection->net_conf);  in conn_connect()
1068 	connection->data.socket = sock.socket;  in conn_connect()
1069 	connection->meta.socket = msock.socket;  in conn_connect()
1070 	connection->last_received = jiffies;  in conn_connect()
1072 	h = drbd_do_features(connection);  in conn_connect()
1076 	if (connection->cram_hmac_tfm) {  in conn_connect()
1078 		switch (drbd_do_auth(connection)) {  in conn_connect()
1080 			drbd_err(connection, "Authentication of peer failed\n");  in conn_connect()
1083 			drbd_err(connection, "Authentication of peer failed, trying again.\n");  in conn_connect()
1088 	connection->data.socket->sk->sk_sndtimeo = timeout;  in conn_connect()
1089 	connection->data.socket->sk->sk_rcvtimeo = MAX_SCHEDULE_TIMEOUT;  in conn_connect()
1091 	if (drbd_send_protocol(connection) == -EOPNOTSUPP)  in conn_connect()
1101 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr)  in conn_connect()
1105 	spin_lock_irq(&connection->resource->req_lock);  in conn_connect()
1106 	set_bit(STATE_SENT, &connection->flags);  in conn_connect()
1107 	spin_unlock_irq(&connection->resource->req_lock);  in conn_connect()
1109 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr)  in conn_connect()
1113 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in conn_connect()
1129 	rv = conn_request_state(connection, NS(conn, C_WF_REPORT_PARAMS), CS_VERBOSE);  in conn_connect()
1130 	if (rv < SS_SUCCESS || connection->cstate != C_WF_REPORT_PARAMS) {  in conn_connect()
1131 		clear_bit(STATE_SENT, &connection->flags);  in conn_connect()
1135 	drbd_thread_start(&connection->ack_receiver);  in conn_connect()
1138 	connection->ack_sender =  in conn_connect()
1139 		alloc_ordered_workqueue("drbd_as_%s", WQ_MEM_RECLAIM, connection->resource->name);  in conn_connect()
1140 	if (!connection->ack_sender) {  in conn_connect()
1141 		drbd_err(connection, "Failed to create workqueue ack_sender\n");  in conn_connect()
1145 	mutex_lock(&connection->resource->conf_update);  in conn_connect()
1150 	connection->net_conf->discard_my_data = 0;  in conn_connect()
1151 	mutex_unlock(&connection->resource->conf_update);  in conn_connect()
1165 static int decode_header(struct drbd_connection *connection, void *header, struct packet_info *pi)  in decode_header()  argument
1167 	unsigned int header_size = drbd_header_size(connection);  in decode_header()
1173 			drbd_err(connection, "Header padding is not zero\n");  in decode_header()
1192 		drbd_err(connection, "Wrong magic value 0x%08x in protocol version %d\n",  in decode_header()
1194 			 connection->agreed_pro_version);  in decode_header()
1201 static void drbd_unplug_all_devices(struct drbd_connection *connection)  in drbd_unplug_all_devices()  argument
1203 	if (current->plug == &connection->receiver_plug) {  in drbd_unplug_all_devices()
1204 		blk_finish_plug(&connection->receiver_plug);  in drbd_unplug_all_devices()
1205 		blk_start_plug(&connection->receiver_plug);  in drbd_unplug_all_devices()
1209 static int drbd_recv_header(struct drbd_connection *connection, struct packet_info *pi)  in drbd_recv_header()  argument
1211 	void *buffer = connection->data.rbuf;  in drbd_recv_header()
1214 	err = drbd_recv_all_warn(connection, buffer, drbd_header_size(connection));  in drbd_recv_header()
1218 	err = decode_header(connection, buffer, pi);  in drbd_recv_header()
1219 	connection->last_received = jiffies;  in drbd_recv_header()
1224 static int drbd_recv_header_maybe_unplug(struct drbd_connection *connection, struct packet_info *pi)  in drbd_recv_header_maybe_unplug()  argument
1226 	void *buffer = connection->data.rbuf;  in drbd_recv_header_maybe_unplug()
1227 	unsigned int size = drbd_header_size(connection);  in drbd_recv_header_maybe_unplug()
1230 	err = drbd_recv_short(connection->data.socket, buffer, size, MSG_NOSIGNAL|MSG_DONTWAIT);  in drbd_recv_header_maybe_unplug()
1237 			drbd_tcp_quickack(connection->data.socket);  in drbd_recv_header_maybe_unplug()
1238 			drbd_unplug_all_devices(connection);  in drbd_recv_header_maybe_unplug()
1244 		err = drbd_recv_all_warn(connection, buffer, size);  in drbd_recv_header_maybe_unplug()
1249 	err = decode_header(connection, connection->data.rbuf, pi);  in drbd_recv_header_maybe_unplug()
1250 	connection->last_received = jiffies;  in drbd_recv_header_maybe_unplug()
1321 static void drbd_flush(struct drbd_connection *connection)  in drbd_flush()  argument
1323 	if (connection->resource->write_ordering >= WO_BDEV_FLUSH) {  in drbd_flush()
1333 		idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in drbd_flush()
1357 			drbd_bump_write_ordering(connection->resource, NULL, WO_DRAIN_IO);  in drbd_flush()
1368 static enum finish_epoch drbd_may_finish_epoch(struct drbd_connection *connection,  in drbd_may_finish_epoch()  argument
1376 	spin_lock(&connection->epoch_lock);  in drbd_may_finish_epoch()
1398 				spin_unlock(&connection->epoch_lock);  in drbd_may_finish_epoch()
1399 				drbd_send_b_ack(epoch->connection, epoch->barrier_nr, epoch_size);  in drbd_may_finish_epoch()
1400 				spin_lock(&connection->epoch_lock);  in drbd_may_finish_epoch()
1406 				dec_unacked(epoch->connection);  in drbd_may_finish_epoch()
1409 			if (connection->current_epoch != epoch) {  in drbd_may_finish_epoch()
1413 				connection->epochs--;  in drbd_may_finish_epoch()
1433 	spin_unlock(&connection->epoch_lock);  in drbd_may_finish_epoch()
1556 		conn_wait_active_ee_empty(peer_req->peer_device->connection);  in drbd_submit_peer_request()
1648 static void conn_wait_active_ee_empty(struct drbd_connection *connection)  in conn_wait_active_ee_empty()  argument
1654 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in conn_wait_active_ee_empty()
1666 static int receive_Barrier(struct drbd_connection *connection, struct packet_info *pi)  in receive_Barrier()  argument
1675 	connection->current_epoch->barrier_nr = p->barrier;  in receive_Barrier()
1676 	connection->current_epoch->connection = connection;  in receive_Barrier()
1677 	rv = drbd_may_finish_epoch(connection, connection->current_epoch, EV_GOT_BARRIER_NR);  in receive_Barrier()
1684 	switch (connection->resource->write_ordering) {  in receive_Barrier()
1695 			drbd_warn(connection, "Allocation of an epoch failed, slowing down\n");  in receive_Barrier()
1700 		conn_wait_active_ee_empty(connection);  in receive_Barrier()
1701 		drbd_flush(connection);  in receive_Barrier()
1703 		if (atomic_read(&connection->current_epoch->epoch_size)) {  in receive_Barrier()
1711 		drbd_err(connection, "Strangeness in connection->write_ordering %d\n",  in receive_Barrier()
1712 			 connection->resource->write_ordering);  in receive_Barrier()
1720 	spin_lock(&connection->epoch_lock);  in receive_Barrier()
1721 	if (atomic_read(&connection->current_epoch->epoch_size)) {  in receive_Barrier()
1722 		list_add(&epoch->list, &connection->current_epoch->list);  in receive_Barrier()
1723 		connection->current_epoch = epoch;  in receive_Barrier()
1724 		connection->epochs++;  in receive_Barrier()
1729 	spin_unlock(&connection->epoch_lock);  in receive_Barrier()
1764 	void *dig_in = peer_device->connection->int_dig_in;  in read_in_block()
1765 	void *dig_vv = peer_device->connection->int_dig_vv;  in read_in_block()
1771 	if (!trim && peer_device->connection->peer_integrity_tfm) {  in read_in_block()
1772 		digest_size = crypto_ahash_digestsize(peer_device->connection->peer_integrity_tfm);  in read_in_block()
1777 		err = drbd_recv_all_warn(peer_device->connection, dig_in, digest_size);  in read_in_block()
1842 		err = drbd_recv_all_warn(peer_device->connection, data, len);  in read_in_block()
1856 		drbd_csum_ee_size(peer_device->connection->peer_integrity_tfm, peer_req, dig_vv, data_size);  in read_in_block()
1886 		err = drbd_recv_all_warn(peer_device->connection, data, len);  in drbd_drain_block()
1903 	void *dig_in = peer_device->connection->int_dig_in;  in recv_dless_read()
1904 	void *dig_vv = peer_device->connection->int_dig_vv;  in recv_dless_read()
1907 	if (peer_device->connection->peer_integrity_tfm) {  in recv_dless_read()
1908 		digest_size = crypto_ahash_digestsize(peer_device->connection->peer_integrity_tfm);  in recv_dless_read()
1909 		err = drbd_recv_all_warn(peer_device->connection, dig_in, digest_size);  in recv_dless_read()
1925 		err = drbd_recv_all_warn(peer_device->connection, mapped, expect);  in recv_dless_read()
1933 		drbd_csum_bio(peer_device->connection->peer_integrity_tfm, bio, dig_vv);  in recv_dless_read()
2030 static int receive_DataReply(struct drbd_connection *connection, struct packet_info *pi)  in receive_DataReply()  argument
2039 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_DataReply()
2065 static int receive_RSDataReply(struct drbd_connection *connection, struct packet_info *pi)  in receive_RSDataReply()  argument
2073 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_RSDataReply()
2160 …drbd_may_finish_epoch(peer_device->connection, peer_req->epoch, EV_PUT + (cancel ? EV_CLEANUP : 0)…  in e_end_block()
2187 	struct drbd_connection *connection = peer_req->peer_device->connection;  in e_send_retry_write()  local
2189 	return e_send_ack(w, connection->agreed_pro_version >= 100 ?  in e_send_retry_write()
2213 	if (test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)) {  in update_peer_seq()
2276 	if (!test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags))  in wait_for_and_update_peer_seq()
2292 		tp = rcu_dereference(peer_device->connection->net_conf)->two_primaries;  in wait_for_and_update_peer_seq()
2302 		timeout = rcu_dereference(peer_device->connection->net_conf)->ping_timeo*HZ/10;  in wait_for_and_update_peer_seq()
2363 	struct drbd_connection *connection = peer_req->peer_device->connection;  in handle_write_conflicts()  local
2364 	bool resolve_conflicts = test_bit(RESOLVE_CONFLICTS, &connection->flags);  in handle_write_conflicts()
2418 			queue_work(connection->ack_sender, &peer_req->peer_device->send_acks_work);  in handle_write_conflicts()
2447 					_conn_request_state(connection, NS(conn, C_TIMEOUT), CS_HARD);  in handle_write_conflicts()
2469 static int receive_Data(struct drbd_connection *connection, struct packet_info *pi)  in receive_Data()  argument
2482 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_Data()
2492 		atomic_inc(&connection->current_epoch->epoch_size);  in receive_Data()
2531 	spin_lock(&connection->epoch_lock);  in receive_Data()
2532 	peer_req->epoch = connection->current_epoch;  in receive_Data()
2535 	spin_unlock(&connection->epoch_lock);  in receive_Data()
2538 	nc = rcu_dereference(peer_device->connection->net_conf);  in receive_Data()
2540 	if (peer_device->connection->agreed_pro_version < 100) {  in receive_Data()
2622 	drbd_may_finish_epoch(connection, peer_req->epoch, EV_PUT | EV_CLEANUP);  in receive_Data()
2708 static int receive_DataRequest(struct drbd_connection *connection, struct packet_info *pi)  in receive_DataRequest()  argument
2720 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_DataRequest()
2813 		if (drbd_recv_all(peer_device->connection, di->digest, pi->size))  in receive_DataRequest()
2817 			D_ASSERT(device, peer_device->connection->agreed_pro_version >= 89);  in receive_DataRequest()
2836 		    peer_device->connection->agreed_pro_version >= 90) {  in receive_DataRequest()
2889 	update_receiver_timing_details(connection, drbd_rs_should_slow_down);  in receive_DataRequest()
2893 	update_receiver_timing_details(connection, drbd_rs_begin_io);  in receive_DataRequest()
2901 	update_receiver_timing_details(connection, drbd_submit_peer_request);  in receive_DataRequest()
2938 	after_sb_0p = rcu_dereference(peer_device->connection->net_conf)->after_sb_0p;  in drbd_asb_recover_0p()
2974 			rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)  in drbd_asb_recover_0p()
2991 			rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)  in drbd_asb_recover_0p()
3014 	after_sb_1p = rcu_dereference(peer_device->connection->net_conf)->after_sb_1p;  in drbd_asb_recover_1p()
3071 	after_sb_2p = rcu_dereference(peer_device->connection->net_conf)->after_sb_2p;  in drbd_asb_recover_2p()
3144 	struct drbd_connection *const connection = peer_device ? peer_device->connection : NULL;  in drbd_uuid_compare()  local
3170 			if (connection->agreed_pro_version < 91)  in drbd_uuid_compare()
3193 			if (connection->agreed_pro_version < 91)  in drbd_uuid_compare()
3233 			if (!(connection->agreed_features & DRBD_FF_WSAME)) {  in drbd_uuid_compare()
3257 			dc = test_bit(RESOLVE_CONFLICTS, &connection->flags);  in drbd_uuid_compare()
3270 		if (connection->agreed_pro_version < 96 ?  in drbd_uuid_compare()
3277 			if (connection->agreed_pro_version < 91)  in drbd_uuid_compare()
3307 		if (connection->agreed_pro_version < 96 ?  in drbd_uuid_compare()
3314 			if (connection->agreed_pro_version < 91)  in drbd_uuid_compare()
3417 	nc = rcu_dereference(peer_device->connection->net_conf);  in drbd_sync_handshake()
3492 	if (tentative || test_bit(CONN_DRY_RUN, &peer_device->connection->flags)) {  in drbd_sync_handshake()
3538 static int receive_protocol(struct drbd_connection *connection, struct packet_info *pi)  in receive_protocol()  argument
3556 	if (connection->agreed_pro_version >= 87) {  in receive_protocol()
3561 		err = drbd_recv_all(connection, integrity_alg, pi->size);  in receive_protocol()
3568 		clear_bit(CONN_DRY_RUN, &connection->flags);  in receive_protocol()
3571 			set_bit(CONN_DRY_RUN, &connection->flags);  in receive_protocol()
3574 		nc = rcu_dereference(connection->net_conf);  in receive_protocol()
3577 			drbd_err(connection, "incompatible %s settings\n", "protocol");  in receive_protocol()
3582 			drbd_err(connection, "incompatible %s settings\n", "after-sb-0pri");  in receive_protocol()
3587 			drbd_err(connection, "incompatible %s settings\n", "after-sb-1pri");  in receive_protocol()
3592 			drbd_err(connection, "incompatible %s settings\n", "after-sb-2pri");  in receive_protocol()
3597 			drbd_err(connection, "incompatible %s settings\n", "discard-my-data");  in receive_protocol()
3602 			drbd_err(connection, "incompatible %s settings\n", "allow-two-primaries");  in receive_protocol()
3607 			drbd_err(connection, "incompatible %s settings\n", "data-integrity-alg");  in receive_protocol()
3629 			drbd_err(connection, "peer data-integrity-alg %s not supported\n",  in receive_protocol()
3638 			drbd_err(connection, "Allocation of buffers for data integrity checking failed\n");  in receive_protocol()
3645 		drbd_err(connection, "Allocation of new net_conf failed\n");  in receive_protocol()
3649 	mutex_lock(&connection->data.mutex);  in receive_protocol()
3650 	mutex_lock(&connection->resource->conf_update);  in receive_protocol()
3651 	old_net_conf = connection->net_conf;  in receive_protocol()
3660 	rcu_assign_pointer(connection->net_conf, new_net_conf);  in receive_protocol()
3661 	mutex_unlock(&connection->resource->conf_update);  in receive_protocol()
3662 	mutex_unlock(&connection->data.mutex);  in receive_protocol()
3664 	crypto_free_ahash(connection->peer_integrity_tfm);  in receive_protocol()
3665 	kfree(connection->int_dig_in);  in receive_protocol()
3666 	kfree(connection->int_dig_vv);  in receive_protocol()
3667 	connection->peer_integrity_tfm = peer_integrity_tfm;  in receive_protocol()
3668 	connection->int_dig_in = int_dig_in;  in receive_protocol()
3669 	connection->int_dig_vv = int_dig_vv;  in receive_protocol()
3672 		drbd_info(connection, "peer data-integrity-alg: %s\n",  in receive_protocol()
3685 	conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_protocol()
3711 static int ignore_remaining_packet(struct drbd_connection *connection, struct packet_info *pi)  in ignore_remaining_packet()  argument
3713 	void *buffer = connection->data.rbuf;  in ignore_remaining_packet()
3718 		s = drbd_recv(connection, buffer, s);  in ignore_remaining_packet()
3742 static int config_unknown_volume(struct drbd_connection *connection, struct packet_info *pi)  in config_unknown_volume()  argument
3744 	drbd_warn(connection, "%s packet received for volume %u, which is not configured locally\n",  in config_unknown_volume()
3746 	return ignore_remaining_packet(connection, pi);  in config_unknown_volume()
3749 static int receive_SyncParam(struct drbd_connection *connection, struct packet_info *pi)  in receive_SyncParam()  argument
3759 	const int apv = connection->agreed_pro_version;  in receive_SyncParam()
3764 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_SyncParam()
3766 		return config_unknown_volume(connection, pi);  in receive_SyncParam()
3798 	err = drbd_recv_all(peer_device->connection, p, header_size);  in receive_SyncParam()
3802 	mutex_lock(&connection->resource->conf_update);  in receive_SyncParam()
3803 	old_net_conf = peer_device->connection->net_conf;  in receive_SyncParam()
3808 			mutex_unlock(&connection->resource->conf_update);  in receive_SyncParam()
3829 			err = drbd_recv_all(peer_device->connection, p->verify_alg, data_size);  in receive_SyncParam()
3903 				crypto_free_ahash(peer_device->connection->verify_tfm);  in receive_SyncParam()
3904 				peer_device->connection->verify_tfm = verify_tfm;  in receive_SyncParam()
3910 				crypto_free_ahash(peer_device->connection->csums_tfm);  in receive_SyncParam()
3911 				peer_device->connection->csums_tfm = csums_tfm;  in receive_SyncParam()
3914 			rcu_assign_pointer(connection->net_conf, new_net_conf);  in receive_SyncParam()
3928 	mutex_unlock(&connection->resource->conf_update);  in receive_SyncParam()
3942 	mutex_unlock(&connection->resource->conf_update);  in receive_SyncParam()
3951 	mutex_unlock(&connection->resource->conf_update);  in receive_SyncParam()
3957 	conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_SyncParam()
3974 static int receive_sizes(struct drbd_connection *connection, struct packet_info *pi)  in receive_sizes()  argument
3979 	struct o_qlim *o = (connection->agreed_features & DRBD_FF_WSAME) ? p->qlim : NULL;  in receive_sizes()
3985 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_sizes()
3987 		return config_unknown_volume(connection, pi);  in receive_sizes()
4023 			conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_sizes()
4038 			mutex_lock(&connection->resource->conf_update);  in receive_sizes()
4044 			mutex_unlock(&connection->resource->conf_update);  in receive_sizes()
4119 static int receive_uuids(struct drbd_connection *connection, struct packet_info *pi)  in receive_uuids()  argument
4127 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_uuids()
4129 		return config_unknown_volume(connection, pi);  in receive_uuids()
4150 		conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_uuids()
4157 			peer_device->connection->agreed_pro_version >= 90 &&  in receive_uuids()
4226 static int receive_req_state(struct drbd_connection *connection, struct packet_info *pi)  in receive_req_state()  argument
4234 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_req_state()
4242 	if (test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags) &&  in receive_req_state()
4259 static int receive_req_conn_state(struct drbd_connection *connection, struct packet_info *pi)  in receive_req_conn_state()  argument
4268 	if (test_bit(RESOLVE_CONFLICTS, &connection->flags) &&  in receive_req_conn_state()
4269 	    mutex_is_locked(&connection->cstate_mutex)) {  in receive_req_conn_state()
4270 		conn_send_sr_reply(connection, SS_CONCURRENT_ST_CHG);  in receive_req_conn_state()
4277 	rv = conn_request_state(connection, mask, val, CS_VERBOSE | CS_LOCAL_ONLY | CS_IGN_OUTD_FAIL);  in receive_req_conn_state()
4278 	conn_send_sr_reply(connection, rv);  in receive_req_conn_state()
4283 static int receive_state(struct drbd_connection *connection, struct packet_info *pi)  in receive_state()  argument
4293 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_state()
4295 		return config_unknown_volume(connection, pi);  in receive_state()
4403 				if (test_and_clear_bit(CONN_DRY_RUN, &peer_device->connection->flags))  in receive_state()
4406 				conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_state()
4428 		tl_clear(peer_device->connection);  in receive_state()
4431 		conn_request_state(peer_device->connection, NS2(conn, C_PROTOCOL_ERROR, susp, 0), CS_HARD);  in receive_state()
4439 		conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_state()
4461 static int receive_sync_uuid(struct drbd_connection *connection, struct packet_info *pi)  in receive_sync_uuid()  argument
4467 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_sync_uuid()
4507 				 drbd_header_size(peer_device->connection);  in receive_bitmap_plain()
4519 	err = drbd_recv_all(peer_device->connection, p, want);  in receive_bitmap_plain()
4637 	conn_request_state(peer_device->connection, NS(conn, C_PROTOCOL_ERROR), CS_HARD);  in decode_bitmap_c()
4645 	unsigned int header_size = drbd_header_size(first_peer_device(device)->connection);  in INFO_bm_xfer_stats()
4685 static int receive_bitmap(struct drbd_connection *connection, struct packet_info *pi)  in receive_bitmap()  argument
4692 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_bitmap()
4714 			if (pi->size > DRBD_SOCKET_BUFFER_SIZE - drbd_header_size(connection)) {  in receive_bitmap()
4724 			err = drbd_recv_all(peer_device->connection, p, pi->size);  in receive_bitmap()
4735 		c.bytes[pi->cmd == P_BITMAP] += drbd_header_size(connection) + pi->size;  in receive_bitmap()
4742 		err = drbd_recv_header(peer_device->connection, pi);  in receive_bitmap()
4773 static int receive_skip(struct drbd_connection *connection, struct packet_info *pi)  in receive_skip()  argument
4775 	drbd_warn(connection, "skipping unknown optional packet type %d, l: %d!\n",  in receive_skip()
4778 	return ignore_remaining_packet(connection, pi);  in receive_skip()
4781 static int receive_UnplugRemote(struct drbd_connection *connection, struct packet_info *pi)  in receive_UnplugRemote()  argument
4785 	drbd_tcp_quickack(connection->data.socket);  in receive_UnplugRemote()
4790 static int receive_out_of_sync(struct drbd_connection *connection, struct packet_info *pi)  in receive_out_of_sync()  argument
4796 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_out_of_sync()
4816 static int receive_rs_deallocated(struct drbd_connection *connection, struct packet_info *pi)  in receive_rs_deallocated()  argument
4824 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_rs_deallocated()
4919 static void drbdd(struct drbd_connection *connection)  in drbdd()  argument
4925 	while (get_t_state(&connection->receiver) == RUNNING) {  in drbdd()
4928 		drbd_thread_current_set_cpu(&connection->receiver);  in drbdd()
4929 		update_receiver_timing_details(connection, drbd_recv_header_maybe_unplug);  in drbdd()
4930 		if (drbd_recv_header_maybe_unplug(connection, &pi))  in drbdd()
4935 			drbd_err(connection, "Unexpected data packet %s (0x%04x)",  in drbdd()
4941 		if (pi.cmd == P_SIZES && connection->agreed_features & DRBD_FF_WSAME)  in drbdd()
4944 			drbd_err(connection, "No payload expected %s l:%d\n",  in drbdd()
4949 			drbd_err(connection, "%s: unexpected packet size, expected:%d received:%d\n",  in drbdd()
4955 			update_receiver_timing_details(connection, drbd_recv_all_warn);  in drbdd()
4956 			err = drbd_recv_all_warn(connection, pi.data, shs);  in drbdd()
4962 		update_receiver_timing_details(connection, cmd->fn);  in drbdd()
4963 		err = cmd->fn(connection, &pi);  in drbdd()
4965 			drbd_err(connection, "error receiving %s, e: %d l: %d!\n",  in drbdd()
4973 	conn_request_state(connection, NS(conn, C_PROTOCOL_ERROR), CS_HARD);  in drbdd()
4976 static void conn_disconnect(struct drbd_connection *connection)  in conn_disconnect()  argument
4982 	if (connection->cstate == C_STANDALONE)  in conn_disconnect()
4990 	conn_request_state(connection, NS(conn, C_NETWORK_FAILURE), CS_HARD);  in conn_disconnect()
4993 	drbd_thread_stop(&connection->ack_receiver);  in conn_disconnect()
4994 	if (connection->ack_sender) {  in conn_disconnect()
4995 		destroy_workqueue(connection->ack_sender);  in conn_disconnect()
4996 		connection->ack_sender = NULL;  in conn_disconnect()
4998 	drbd_free_sock(connection);  in conn_disconnect()
5001 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in conn_disconnect()
5011 	if (!list_empty(&connection->current_epoch->list))  in conn_disconnect()
5012 		drbd_err(connection, "ASSERTION FAILED: connection->current_epoch->list not empty\n");  in conn_disconnect()
5014 	atomic_set(&connection->current_epoch->epoch_size, 0);  in conn_disconnect()
5015 	connection->send.seen_any_write_yet = false;  in conn_disconnect()
5017 	drbd_info(connection, "Connection closed\n");  in conn_disconnect()
5019 	if (conn_highest_role(connection) == R_PRIMARY && conn_highest_pdsk(connection) >= D_UNKNOWN)  in conn_disconnect()
5020 		conn_try_outdate_peer_async(connection);  in conn_disconnect()
5022 	spin_lock_irq(&connection->resource->req_lock);  in conn_disconnect()
5023 	oc = connection->cstate;  in conn_disconnect()
5025 		_conn_request_state(connection, NS(conn, C_UNCONNECTED), CS_VERBOSE);  in conn_disconnect()
5027 	spin_unlock_irq(&connection->resource->req_lock);  in conn_disconnect()
5030 		conn_request_state(connection, NS(conn, C_STANDALONE), CS_VERBOSE | CS_HARD);  in conn_disconnect()
5067 	drbd_flush_workqueue(&peer_device->connection->sender_work);  in drbd_disconnected()
5074 	drbd_flush_workqueue(&peer_device->connection->sender_work);  in drbd_disconnected()
5084 		tl_clear(peer_device->connection);  in drbd_disconnected()
5128 static int drbd_send_features(struct drbd_connection *connection)  in drbd_send_features()  argument
5133 	sock = &connection->data;  in drbd_send_features()
5134 	p = conn_prepare_command(connection, sock);  in drbd_send_features()
5141 	return conn_send_command(connection, sock, P_CONNECTION_FEATURES, sizeof(*p), NULL, 0);  in drbd_send_features()
5151 static int drbd_do_features(struct drbd_connection *connection)  in drbd_do_features()  argument
5159 	err = drbd_send_features(connection);  in drbd_do_features()
5163 	err = drbd_recv_header(connection, &pi);  in drbd_do_features()
5168 		drbd_err(connection, "expected ConnectionFeatures packet, received: %s (0x%04x)\n",  in drbd_do_features()
5174 		drbd_err(connection, "expected ConnectionFeatures length: %u, received: %u\n",  in drbd_do_features()
5180 	err = drbd_recv_all_warn(connection, p, expect);  in drbd_do_features()
5193 	connection->agreed_pro_version = min_t(int, PRO_VERSION_MAX, p->protocol_max);  in drbd_do_features()
5194 	connection->agreed_features = PRO_FEATURES & be32_to_cpu(p->feature_flags);  in drbd_do_features()
5196 	drbd_info(connection, "Handshake successful: "  in drbd_do_features()
5197 	     "Agreed network protocol version %d\n", connection->agreed_pro_version);  in drbd_do_features()
5199 	drbd_info(connection, "Feature flags enabled on protocol level: 0x%x%s%s%s.\n",  in drbd_do_features()
5200 		  connection->agreed_features,  in drbd_do_features()
5201 		  connection->agreed_features & DRBD_FF_TRIM ? " TRIM" : "",  in drbd_do_features()
5202 		  connection->agreed_features & DRBD_FF_THIN_RESYNC ? " THIN_RESYNC" : "",  in drbd_do_features()
5203 		  connection->agreed_features & DRBD_FF_WSAME ? " WRITE_SAME" :  in drbd_do_features()
5204 		  connection->agreed_features ? "" : " none");  in drbd_do_features()
5209 	drbd_err(connection, "incompatible DRBD dialects: "  in drbd_do_features()
5217 static int drbd_do_auth(struct drbd_connection *connection)  in drbd_do_auth()  argument
5219 	drbd_err(connection, "This kernel was build without CONFIG_CRYPTO_HMAC.\n");  in drbd_do_auth()
5220 	drbd_err(connection, "You need to disable 'cram-hmac-alg' in drbd.conf.\n");  in drbd_do_auth()
5232 static int drbd_do_auth(struct drbd_connection *connection)  in drbd_do_auth()  argument
5242 	SHASH_DESC_ON_STACK(desc, connection->cram_hmac_tfm);  in drbd_do_auth()
5250 	nc = rcu_dereference(connection->net_conf);  in drbd_do_auth()
5255 	desc->tfm = connection->cram_hmac_tfm;  in drbd_do_auth()
5258 	rv = crypto_shash_setkey(connection->cram_hmac_tfm, (u8 *)secret, key_len);  in drbd_do_auth()
5260 		drbd_err(connection, "crypto_shash_setkey() failed with %d\n", rv);  in drbd_do_auth()
5267 	sock = &connection->data;  in drbd_do_auth()
5268 	if (!conn_prepare_command(connection, sock)) {  in drbd_do_auth()
5272 	rv = !conn_send_command(connection, sock, P_AUTH_CHALLENGE, 0,  in drbd_do_auth()
5277 	err = drbd_recv_header(connection, &pi);  in drbd_do_auth()
5284 		drbd_err(connection, "expected AuthChallenge packet, received: %s (0x%04x)\n",  in drbd_do_auth()
5291 		drbd_err(connection, "expected AuthChallenge payload too big.\n");  in drbd_do_auth()
5297 		drbd_err(connection, "AuthChallenge payload too small.\n");  in drbd_do_auth()
5304 		drbd_err(connection, "kmalloc of peers_ch failed\n");  in drbd_do_auth()
5309 	err = drbd_recv_all_warn(connection, peers_ch, pi.size);  in drbd_do_auth()
5316 		drbd_err(connection, "Peer presented the same challenge!\n");  in drbd_do_auth()
5321 	resp_size = crypto_shash_digestsize(connection->cram_hmac_tfm);  in drbd_do_auth()
5324 		drbd_err(connection, "kmalloc of response failed\n");  in drbd_do_auth()
5331 		drbd_err(connection, "crypto_hash_digest() failed with %d\n", rv);  in drbd_do_auth()
5336 	if (!conn_prepare_command(connection, sock)) {  in drbd_do_auth()
5340 	rv = !conn_send_command(connection, sock, P_AUTH_RESPONSE, 0,  in drbd_do_auth()
5345 	err = drbd_recv_header(connection, &pi);  in drbd_do_auth()
5352 		drbd_err(connection, "expected AuthResponse packet, received: %s (0x%04x)\n",  in drbd_do_auth()
5359 		drbd_err(connection, "expected AuthResponse payload of wrong size\n");  in drbd_do_auth()
5364 	err = drbd_recv_all_warn(connection, response , resp_size);  in drbd_do_auth()
5372 		drbd_err(connection, "kmalloc of right_response failed\n");  in drbd_do_auth()
5380 		drbd_err(connection, "crypto_hash_digest() failed with %d\n", rv);  in drbd_do_auth()
5388 		drbd_info(connection, "Peer authenticated using %d bytes HMAC\n",  in drbd_do_auth()
5405 	struct drbd_connection *connection = thi->connection;  in drbd_receiver()  local
5408 	drbd_info(connection, "receiver (re)started\n");  in drbd_receiver()
5411 		h = conn_connect(connection);  in drbd_receiver()
5413 			conn_disconnect(connection);  in drbd_receiver()
5417 			drbd_warn(connection, "Discarding network configuration.\n");  in drbd_receiver()
5418 			conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD);  in drbd_receiver()
5423 		blk_start_plug(&connection->receiver_plug);  in drbd_receiver()
5424 		drbdd(connection);  in drbd_receiver()
5425 		blk_finish_plug(&connection->receiver_plug);  in drbd_receiver()
5428 	conn_disconnect(connection);  in drbd_receiver()
5430 	drbd_info(connection, "receiver terminated\n");  in drbd_receiver()
5436 static int got_conn_RqSReply(struct drbd_connection *connection, struct packet_info *pi)  in got_conn_RqSReply()  argument
5442 		set_bit(CONN_WD_ST_CHG_OKAY, &connection->flags);  in got_conn_RqSReply()
5444 		set_bit(CONN_WD_ST_CHG_FAIL, &connection->flags);  in got_conn_RqSReply()
5445 		drbd_err(connection, "Requested state change failed by peer: %s (%d)\n",  in got_conn_RqSReply()
5448 	wake_up(&connection->ping_wait);  in got_conn_RqSReply()
5453 static int got_RqSReply(struct drbd_connection *connection, struct packet_info *pi)  in got_RqSReply()  argument
5460 	peer_device = conn_peer_device(connection, pi->vnr);  in got_RqSReply()
5465 	if (test_bit(CONN_WD_ST_CHG_REQ, &connection->flags)) {  in got_RqSReply()
5466 		D_ASSERT(device, connection->agreed_pro_version < 100);  in got_RqSReply()
5467 		return got_conn_RqSReply(connection, pi);  in got_RqSReply()
5482 static int got_Ping(struct drbd_connection *connection, struct packet_info *pi)  in got_Ping()  argument
5484 	return drbd_send_ping_ack(connection);  in got_Ping()
5488 static int got_PingAck(struct drbd_connection *connection, struct packet_info *pi)  in got_PingAck()  argument
5491 	connection->meta.socket->sk->sk_rcvtimeo = connection->net_conf->ping_int*HZ;  in got_PingAck()
5492 	if (!test_and_set_bit(GOT_PING_ACK, &connection->flags))  in got_PingAck()
5493 		wake_up(&connection->ping_wait);  in got_PingAck()
5498 static int got_IsInSync(struct drbd_connection *connection, struct packet_info *pi)  in got_IsInSync()  argument
5506 	peer_device = conn_peer_device(connection, pi->vnr);  in got_IsInSync()
5511 	D_ASSERT(device, peer_device->connection->agreed_pro_version >= 89);  in got_IsInSync()
5550 static int got_BlockAck(struct drbd_connection *connection, struct packet_info *pi)  in got_BlockAck()  argument
5559 	peer_device = conn_peer_device(connection, pi->vnr);  in got_BlockAck()
5596 static int got_NegAck(struct drbd_connection *connection, struct packet_info *pi)  in got_NegAck()  argument
5605 	peer_device = conn_peer_device(connection, pi->vnr);  in got_NegAck()
5632 static int got_NegDReply(struct drbd_connection *connection, struct packet_info *pi)  in got_NegDReply()  argument
5639 	peer_device = conn_peer_device(connection, pi->vnr);  in got_NegDReply()
5654 static int got_NegRSDReply(struct drbd_connection *connection, struct packet_info *pi)  in got_NegRSDReply()  argument
5662 	peer_device = conn_peer_device(connection, pi->vnr);  in got_NegRSDReply()
5690 static int got_BarrierAck(struct drbd_connection *connection, struct packet_info *pi)  in got_BarrierAck()  argument
5696 	tl_release(connection, p->barrier, be32_to_cpu(p->set_size));  in got_BarrierAck()
5699 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in got_BarrierAck()
5714 static int got_OVResult(struct drbd_connection *connection, struct packet_info *pi)  in got_OVResult()  argument
5723 	peer_device = conn_peer_device(connection, pi->vnr);  in got_OVResult()
5755 			drbd_queue_work(&peer_device->connection->sender_work, &dw->w);  in got_OVResult()
5766 static int got_skip(struct drbd_connection *connection, struct packet_info *pi)  in got_skip()  argument
5773 	int (*fn)(struct drbd_connection *connection, struct packet_info *);
5776 static void set_rcvtimeo(struct drbd_connection *connection, bool ping_timeout)  in set_rcvtimeo()  argument
5782 	nc = rcu_dereference(connection->net_conf);  in set_rcvtimeo()
5790 	connection->meta.socket->sk->sk_rcvtimeo = t;  in set_rcvtimeo()
5793 static void set_ping_timeout(struct drbd_connection *connection)  in set_ping_timeout()  argument
5795 	set_rcvtimeo(connection, 1);  in set_ping_timeout()
5798 static void set_idle_timeout(struct drbd_connection *connection)  in set_idle_timeout()  argument
5800 	set_rcvtimeo(connection, 0);  in set_idle_timeout()
5825 	struct drbd_connection *connection = thi->connection;  in drbd_ack_receiver()  local
5830 	void *buf    = connection->meta.rbuf;  in drbd_ack_receiver()
5832 	unsigned int header_size = drbd_header_size(connection);  in drbd_ack_receiver()
5839 		drbd_err(connection, "drbd_ack_receiver: ERROR set priority, ret=%d\n", rv);  in drbd_ack_receiver()
5844 		conn_reclaim_net_peer_reqs(connection);  in drbd_ack_receiver()
5846 		if (test_and_clear_bit(SEND_PING, &connection->flags)) {  in drbd_ack_receiver()
5847 			if (drbd_send_ping(connection)) {  in drbd_ack_receiver()
5848 				drbd_err(connection, "drbd_send_ping has failed\n");  in drbd_ack_receiver()
5851 			set_ping_timeout(connection);  in drbd_ack_receiver()
5856 		rv = drbd_recv_short(connection->meta.socket, buf, expect-received, 0);  in drbd_ack_receiver()
5872 			if (test_bit(DISCONNECT_SENT, &connection->flags)) {  in drbd_ack_receiver()
5875 				t = rcu_dereference(connection->net_conf)->ping_timeo * HZ/10;  in drbd_ack_receiver()
5878 				t = wait_event_timeout(connection->ping_wait,  in drbd_ack_receiver()
5879 						       connection->cstate < C_WF_REPORT_PARAMS,  in drbd_ack_receiver()
5884 			drbd_err(connection, "meta connection shut down by peer.\n");  in drbd_ack_receiver()
5889 			if (time_after(connection->last_received, pre_recv_jif))  in drbd_ack_receiver()
5892 				drbd_err(connection, "PingAck did not arrive in time.\n");  in drbd_ack_receiver()
5895 			set_bit(SEND_PING, &connection->flags);  in drbd_ack_receiver()
5904 			drbd_err(connection, "sock_recvmsg returned %d\n", rv);  in drbd_ack_receiver()
5909 			if (decode_header(connection, connection->meta.rbuf, &pi))  in drbd_ack_receiver()
5913 				drbd_err(connection, "Unexpected meta packet %s (0x%04x)\n",  in drbd_ack_receiver()
5919 				drbd_err(connection, "Wrong packet size on meta (c: %d, l: %d)\n",  in drbd_ack_receiver()
5927 			err = cmd->fn(connection, &pi);  in drbd_ack_receiver()
5929 				drbd_err(connection, "%pf failed\n", cmd->fn);  in drbd_ack_receiver()
5933 			connection->last_received = jiffies;  in drbd_ack_receiver()
5936 				set_idle_timeout(connection);  in drbd_ack_receiver()
5940 			buf	 = connection->meta.rbuf;  in drbd_ack_receiver()
5949 		conn_request_state(connection, NS(conn, C_NETWORK_FAILURE), CS_HARD);  in drbd_ack_receiver()
5950 		conn_md_sync(connection);  in drbd_ack_receiver()
5954 		conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD);  in drbd_ack_receiver()
5957 	drbd_info(connection, "ack_receiver terminated\n");  in drbd_ack_receiver()
5966 	struct drbd_connection *connection = peer_device->connection;  in drbd_send_acks_wf()  local
5972 	nc = rcu_dereference(connection->net_conf);  in drbd_send_acks_wf()
5977 		drbd_tcp_cork(connection->meta.socket);  in drbd_send_acks_wf()
5985 		conn_request_state(connection, NS(conn, C_NETWORK_FAILURE), CS_HARD);  in drbd_send_acks_wf()
5990 		drbd_tcp_uncork(connection->meta.socket);  in drbd_send_acks_wf()