495 	int rv;  in drbd_recv()  local
497 	rv = drbd_recv_short(connection->data.socket, buf, size, 0);  in drbd_recv()
499 	if (rv < 0) {  in drbd_recv()
500 		if (rv == -ECONNRESET)  in drbd_recv()
502 		else if (rv != -ERESTARTSYS)  in drbd_recv()
503 			drbd_err(connection, "sock_recvmsg returned %d\n", rv);  in drbd_recv()
504 	} else if (rv == 0) {  in drbd_recv()
519 	if (rv != size)  in drbd_recv()
523 	return rv;  in drbd_recv()
910 	enum drbd_state_rv rv;  in conn_connect()  local
1096 	rv = conn_request_state(connection, NS(conn, C_WF_REPORT_PARAMS), CS_VERBOSE);  in conn_connect()
1097 	if (rv < SS_SUCCESS || connection->cstate != C_WF_REPORT_PARAMS) {  in conn_connect()
1177 	int rv;  in drbd_flush()  local
1198 			rv = blkdev_issue_flush(device->ldev->backing_bdev,  in drbd_flush()
1201 			if (rv) {  in drbd_flush()
1202 				drbd_info(device, "local disk flush failed with status %d\n", rv);  in drbd_flush()
1212 			if (rv)  in drbd_flush()
1231 	enum finish_epoch rv = FE_STILL_LIVE;  in drbd_may_finish_epoch()  local
1273 				if (rv == FE_STILL_LIVE)  in drbd_may_finish_epoch()
1274 					rv = FE_DESTROYED;  in drbd_may_finish_epoch()
1279 				if (rv == FE_STILL_LIVE)  in drbd_may_finish_epoch()
1280 					rv = FE_RECYCLED;  in drbd_may_finish_epoch()
1292 	return rv;  in drbd_may_finish_epoch()
1519 	int rv;  in receive_Barrier()  local
1528 	rv = drbd_may_finish_epoch(connection, connection->current_epoch, EV_GOT_BARRIER_NR);  in receive_Barrier()
1537 		if (rv == FE_RECYCLED)  in receive_Barrier()
2042 	bool rv = 0;  in overlapping_resync_write()  local
2048 			rv = 1;  in overlapping_resync_write()
2054 	return rv;  in overlapping_resync_write()
2723 	int self, peer, rv = -100;  in drbd_asb_recover_0p()  local
2747 			rv = -1;  in drbd_asb_recover_0p()
2751 			rv =  1;  in drbd_asb_recover_0p()
2757 			rv = 1;  in drbd_asb_recover_0p()
2761 			rv = -1;  in drbd_asb_recover_0p()
2769 			rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)  in drbd_asb_recover_0p()
2773 			if (ch_peer == 0) { rv =  1; break; }  in drbd_asb_recover_0p()
2774 			if (ch_self == 0) { rv = -1; break; }  in drbd_asb_recover_0p()
2780 			rv = -1;  in drbd_asb_recover_0p()
2782 			rv =  1;  in drbd_asb_recover_0p()
2785 			rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)  in drbd_asb_recover_0p()
2789 		rv = -1;  in drbd_asb_recover_0p()
2792 		rv =  1;  in drbd_asb_recover_0p()
2795 	return rv;  in drbd_asb_recover_0p()
2804 	int hg, rv = -100;  in drbd_asb_recover_1p()  local
2824 			rv = hg;  in drbd_asb_recover_1p()
2826 			rv = hg;  in drbd_asb_recover_1p()
2829 		rv = drbd_asb_recover_0p(peer_device);  in drbd_asb_recover_1p()
2846 				rv = hg;  in drbd_asb_recover_1p()
2849 			rv = hg;  in drbd_asb_recover_1p()
2852 	return rv;  in drbd_asb_recover_1p()
2861 	int hg, rv = -100;  in drbd_asb_recover_2p()  local
2879 		rv = drbd_asb_recover_0p(peer_device);  in drbd_asb_recover_2p()
2896 				rv = hg;  in drbd_asb_recover_2p()
2899 			rv = hg;  in drbd_asb_recover_2p()
2902 	return rv;  in drbd_asb_recover_2p()
3126 	enum drbd_conns rv = C_MASK;  in drbd_sync_handshake()  local
3263 		rv = C_WF_BITMAP_S;  in drbd_sync_handshake()
3265 		rv = C_WF_BITMAP_T;  in drbd_sync_handshake()
3267 		rv = C_CONNECTED;  in drbd_sync_handshake()
3274 	return rv;  in drbd_sync_handshake()
3980 	enum drbd_state_rv rv;  in receive_req_state()  local
3999 	rv = drbd_change_state(device, CS_VERBOSE, mask, val);  in receive_req_state()
4000 	drbd_send_sr_reply(peer_device, rv);  in receive_req_state()
4011 	enum drbd_state_rv rv;  in receive_req_conn_state()  local
4025 	rv = conn_request_state(connection, mask, val, CS_VERBOSE | CS_LOCAL_ONLY | CS_IGN_OUTD_FAIL);  in receive_req_conn_state()
4026 	conn_send_sr_reply(connection, rv);  in receive_req_conn_state()
4039 	int rv;  in receive_state()  local
4182 	rv = _drbd_set_state(device, ns, cs_flags, NULL);  in receive_state()
4186 	if (rv < SS_SUCCESS) {  in receive_state()
4498 		enum drbd_state_rv rv;  in receive_bitmap()  local
4504 		rv = _drbd_request_state(device, NS(conn, C_WF_SYNC_UUID), CS_VERBOSE);  in receive_bitmap()
4505 		D_ASSERT(device, rv == SS_SUCCESS);  in receive_bitmap()
4908 	int err, rv;  in drbd_do_auth()  local
4921 	rv = crypto_hash_setkey(connection->cram_hmac_tfm, (u8 *)secret, key_len);  in drbd_do_auth()
4922 	if (rv) {  in drbd_do_auth()
4923 		drbd_err(connection, "crypto_hash_setkey() failed with %d\n", rv);  in drbd_do_auth()
4924 		rv = -1;  in drbd_do_auth()
4932 		rv = 0;  in drbd_do_auth()
4935 	rv = !conn_send_command(connection, sock, P_AUTH_CHALLENGE, 0,  in drbd_do_auth()
4937 	if (!rv)  in drbd_do_auth()
4942 		rv = 0;  in drbd_do_auth()
4949 		rv = 0;  in drbd_do_auth()
4955 		rv = -1;  in drbd_do_auth()
4961 		rv = -1;  in drbd_do_auth()
4968 		rv = -1;  in drbd_do_auth()
4974 		rv = 0;  in drbd_do_auth()
4980 		rv = -1;  in drbd_do_auth()
4988 		rv = -1;  in drbd_do_auth()
4995 	rv = crypto_hash_digest(&desc, &sg, sg.length, response);  in drbd_do_auth()
4996 	if (rv) {  in drbd_do_auth()
4997 		drbd_err(connection, "crypto_hash_digest() failed with %d\n", rv);  in drbd_do_auth()
4998 		rv = -1;  in drbd_do_auth()
5003 		rv = 0;  in drbd_do_auth()
5006 	rv = !conn_send_command(connection, sock, P_AUTH_RESPONSE, 0,  in drbd_do_auth()
5008 	if (!rv)  in drbd_do_auth()
5013 		rv = 0;  in drbd_do_auth()
5020 		rv = 0;  in drbd_do_auth()
5026 		rv = 0;  in drbd_do_auth()
5032 		rv = 0;  in drbd_do_auth()
5039 		rv = -1;  in drbd_do_auth()
5045 	rv = crypto_hash_digest(&desc, &sg, sg.length, right_response);  in drbd_do_auth()
5046 	if (rv) {  in drbd_do_auth()
5047 		drbd_err(connection, "crypto_hash_digest() failed with %d\n", rv);  in drbd_do_auth()
5048 		rv = -1;  in drbd_do_auth()
5052 	rv = !memcmp(response, right_response, resp_size);  in drbd_do_auth()
5054 	if (rv)  in drbd_do_auth()
5058 		rv = -1;  in drbd_do_auth()
5065 	return rv;  in drbd_do_auth()
5501 	int rv;  in drbd_asender()  local
5511 	rv = sched_setscheduler(current, SCHED_RR, &param);  in drbd_asender()
5512 	if (rv < 0)  in drbd_asender()
5513 		drbd_err(connection, "drbd_asender: ERROR set priority, ret=%d\n", rv);  in drbd_asender()
5550 		rv = drbd_recv_short(connection->meta.socket, buf, expect-received, 0);  in drbd_asender()
5566 		if (likely(rv > 0)) {  in drbd_asender()
5567 			received += rv;  in drbd_asender()
5568 			buf	 += rv;  in drbd_asender()
5569 		} else if (rv == 0) {  in drbd_asender()
5584 		} else if (rv == -EAGAIN) {  in drbd_asender()
5596 		} else if (rv == -EINTR) {  in drbd_asender()
5599 			drbd_err(connection, "sock_recvmsg returned %d\n", rv);  in drbd_asender()
5643 		rv = drbd_recv_short(connection->meta.socket, buf, expect-received, MSG_DONTWAIT);  in drbd_asender()
5644 		if (rv > 0)  in drbd_asender()