494 	int rv;  in drbd_recv()  local
496 	rv = drbd_recv_short(connection->data.socket, buf, size, 0);  in drbd_recv()
498 	if (rv < 0) {  in drbd_recv()
499 		if (rv == -ECONNRESET)  in drbd_recv()
501 		else if (rv != -ERESTARTSYS)  in drbd_recv()
502 			drbd_err(connection, "sock_recvmsg returned %d\n", rv);  in drbd_recv()
503 	} else if (rv == 0) {  in drbd_recv()
518 	if (rv != size)  in drbd_recv()
522 	return rv;  in drbd_recv()
909 	enum drbd_state_rv rv;  in conn_connect()  local
1095 	rv = conn_request_state(connection, NS(conn, C_WF_REPORT_PARAMS), CS_VERBOSE);  in conn_connect()
1096 	if (rv < SS_SUCCESS || connection->cstate != C_WF_REPORT_PARAMS) {  in conn_connect()
1176 	int rv;  in drbd_flush()  local
1197 			rv = blkdev_issue_flush(device->ldev->backing_bdev,  in drbd_flush()
1200 			if (rv) {  in drbd_flush()
1201 				drbd_info(device, "local disk flush failed with status %d\n", rv);  in drbd_flush()
1211 			if (rv)  in drbd_flush()
1230 	enum finish_epoch rv = FE_STILL_LIVE;  in drbd_may_finish_epoch()  local
1272 				if (rv == FE_STILL_LIVE)  in drbd_may_finish_epoch()
1273 					rv = FE_DESTROYED;  in drbd_may_finish_epoch()
1278 				if (rv == FE_STILL_LIVE)  in drbd_may_finish_epoch()
1279 					rv = FE_RECYCLED;  in drbd_may_finish_epoch()
1291 	return rv;  in drbd_may_finish_epoch()
1518 	int rv;  in receive_Barrier()  local
1527 	rv = drbd_may_finish_epoch(connection, connection->current_epoch, EV_GOT_BARRIER_NR);  in receive_Barrier()
1536 		if (rv == FE_RECYCLED)  in receive_Barrier()
2041 	bool rv = 0;  in overlapping_resync_write()  local
2047 			rv = 1;  in overlapping_resync_write()
2053 	return rv;  in overlapping_resync_write()
2722 	int self, peer, rv = -100;  in drbd_asb_recover_0p()  local
2746 			rv = -1;  in drbd_asb_recover_0p()
2750 			rv =  1;  in drbd_asb_recover_0p()
2756 			rv = 1;  in drbd_asb_recover_0p()
2760 			rv = -1;  in drbd_asb_recover_0p()
2768 			rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)  in drbd_asb_recover_0p()
2772 			if (ch_peer == 0) { rv =  1; break; }  in drbd_asb_recover_0p()
2773 			if (ch_self == 0) { rv = -1; break; }  in drbd_asb_recover_0p()
2779 			rv = -1;  in drbd_asb_recover_0p()
2781 			rv =  1;  in drbd_asb_recover_0p()
2784 			rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)  in drbd_asb_recover_0p()
2788 		rv = -1;  in drbd_asb_recover_0p()
2791 		rv =  1;  in drbd_asb_recover_0p()
2794 	return rv;  in drbd_asb_recover_0p()
2803 	int hg, rv = -100;  in drbd_asb_recover_1p()  local
2823 			rv = hg;  in drbd_asb_recover_1p()
2825 			rv = hg;  in drbd_asb_recover_1p()
2828 		rv = drbd_asb_recover_0p(peer_device);  in drbd_asb_recover_1p()
2845 				rv = hg;  in drbd_asb_recover_1p()
2848 			rv = hg;  in drbd_asb_recover_1p()
2851 	return rv;  in drbd_asb_recover_1p()
2860 	int hg, rv = -100;  in drbd_asb_recover_2p()  local
2878 		rv = drbd_asb_recover_0p(peer_device);  in drbd_asb_recover_2p()
2895 				rv = hg;  in drbd_asb_recover_2p()
2898 			rv = hg;  in drbd_asb_recover_2p()
2901 	return rv;  in drbd_asb_recover_2p()
3125 	enum drbd_conns rv = C_MASK;  in drbd_sync_handshake()  local
3262 		rv = C_WF_BITMAP_S;  in drbd_sync_handshake()
3264 		rv = C_WF_BITMAP_T;  in drbd_sync_handshake()
3266 		rv = C_CONNECTED;  in drbd_sync_handshake()
3273 	return rv;  in drbd_sync_handshake()
3979 	enum drbd_state_rv rv;  in receive_req_state()  local
3998 	rv = drbd_change_state(device, CS_VERBOSE, mask, val);  in receive_req_state()
3999 	drbd_send_sr_reply(peer_device, rv);  in receive_req_state()
4010 	enum drbd_state_rv rv;  in receive_req_conn_state()  local
4024 	rv = conn_request_state(connection, mask, val, CS_VERBOSE | CS_LOCAL_ONLY | CS_IGN_OUTD_FAIL);  in receive_req_conn_state()
4025 	conn_send_sr_reply(connection, rv);  in receive_req_conn_state()
4038 	int rv;  in receive_state()  local
4181 	rv = _drbd_set_state(device, ns, cs_flags, NULL);  in receive_state()
4185 	if (rv < SS_SUCCESS) {  in receive_state()
4497 		enum drbd_state_rv rv;  in receive_bitmap()  local
4503 		rv = _drbd_request_state(device, NS(conn, C_WF_SYNC_UUID), CS_VERBOSE);  in receive_bitmap()
4504 		D_ASSERT(device, rv == SS_SUCCESS);  in receive_bitmap()
4907 	int err, rv;  in drbd_do_auth()  local
4920 	rv = crypto_hash_setkey(connection->cram_hmac_tfm, (u8 *)secret, key_len);  in drbd_do_auth()
4921 	if (rv) {  in drbd_do_auth()
4922 		drbd_err(connection, "crypto_hash_setkey() failed with %d\n", rv);  in drbd_do_auth()
4923 		rv = -1;  in drbd_do_auth()
4931 		rv = 0;  in drbd_do_auth()
4934 	rv = !conn_send_command(connection, sock, P_AUTH_CHALLENGE, 0,  in drbd_do_auth()
4936 	if (!rv)  in drbd_do_auth()
4941 		rv = 0;  in drbd_do_auth()
4948 		rv = 0;  in drbd_do_auth()
4954 		rv = -1;  in drbd_do_auth()
4960 		rv = -1;  in drbd_do_auth()
4967 		rv = -1;  in drbd_do_auth()
4973 		rv = 0;  in drbd_do_auth()
4979 		rv = -1;  in drbd_do_auth()
4987 		rv = -1;  in drbd_do_auth()
4994 	rv = crypto_hash_digest(&desc, &sg, sg.length, response);  in drbd_do_auth()
4995 	if (rv) {  in drbd_do_auth()
4996 		drbd_err(connection, "crypto_hash_digest() failed with %d\n", rv);  in drbd_do_auth()
4997 		rv = -1;  in drbd_do_auth()
5002 		rv = 0;  in drbd_do_auth()
5005 	rv = !conn_send_command(connection, sock, P_AUTH_RESPONSE, 0,  in drbd_do_auth()
5007 	if (!rv)  in drbd_do_auth()
5012 		rv = 0;  in drbd_do_auth()
5019 		rv = 0;  in drbd_do_auth()
5025 		rv = 0;  in drbd_do_auth()
5031 		rv = 0;  in drbd_do_auth()
5038 		rv = -1;  in drbd_do_auth()
5044 	rv = crypto_hash_digest(&desc, &sg, sg.length, right_response);  in drbd_do_auth()
5045 	if (rv) {  in drbd_do_auth()
5046 		drbd_err(connection, "crypto_hash_digest() failed with %d\n", rv);  in drbd_do_auth()
5047 		rv = -1;  in drbd_do_auth()
5051 	rv = !memcmp(response, right_response, resp_size);  in drbd_do_auth()
5053 	if (rv)  in drbd_do_auth()
5057 		rv = -1;  in drbd_do_auth()
5064 	return rv;  in drbd_do_auth()
5500 	int rv;  in drbd_asender()  local
5510 	rv = sched_setscheduler(current, SCHED_RR, &param);  in drbd_asender()
5511 	if (rv < 0)  in drbd_asender()
5512 		drbd_err(connection, "drbd_asender: ERROR set priority, ret=%d\n", rv);  in drbd_asender()
5549 		rv = drbd_recv_short(connection->meta.socket, buf, expect-received, 0);  in drbd_asender()
5565 		if (likely(rv > 0)) {  in drbd_asender()
5566 			received += rv;  in drbd_asender()
5567 			buf	 += rv;  in drbd_asender()
5568 		} else if (rv == 0) {  in drbd_asender()
5583 		} else if (rv == -EAGAIN) {  in drbd_asender()
5595 		} else if (rv == -EINTR) {  in drbd_asender()
5598 			drbd_err(connection, "sock_recvmsg returned %d\n", rv);  in drbd_asender()
5642 		rv = drbd_recv_short(connection->meta.socket, buf, expect-received, MSG_DONTWAIT);  in drbd_asender()
5643 		if (rv > 0)  in drbd_asender()