xref: /openbmc/linux/drivers/i2c/busses/i2c-virtio.c (revision cc432b07)
1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /*
3  * Virtio I2C Bus Driver
4  *
5  * The Virtio I2C Specification:
6  * https://raw.githubusercontent.com/oasis-tcs/virtio-spec/master/virtio-i2c.tex
7  *
8  * Copyright (c) 2021 Intel Corporation. All rights reserved.
9  */
10 
11 #include <linux/acpi.h>
12 #include <linux/completion.h>
13 #include <linux/err.h>
14 #include <linux/i2c.h>
15 #include <linux/kernel.h>
16 #include <linux/module.h>
17 #include <linux/virtio.h>
18 #include <linux/virtio_ids.h>
19 #include <linux/virtio_config.h>
20 #include <linux/virtio_i2c.h>
21 
22 /**
23  * struct virtio_i2c - virtio I2C data
24  * @vdev: virtio device for this controller
25  * @completion: completion of virtio I2C message
26  * @adap: I2C adapter for this controller
27  * @vq: the virtio virtqueue for communication
28  */
29 struct virtio_i2c {
30 	struct virtio_device *vdev;
31 	struct completion completion;
32 	struct i2c_adapter adap;
33 	struct virtqueue *vq;
34 };
35 
36 /**
37  * struct virtio_i2c_req - the virtio I2C request structure
38  * @out_hdr: the OUT header of the virtio I2C message
39  * @buf: the buffer into which data is read, or from which it's written
40  * @in_hdr: the IN header of the virtio I2C message
41  */
42 struct virtio_i2c_req {
43 	struct virtio_i2c_out_hdr out_hdr	____cacheline_aligned;
44 	uint8_t *buf				____cacheline_aligned;
45 	struct virtio_i2c_in_hdr in_hdr		____cacheline_aligned;
46 };
47 
48 static void virtio_i2c_msg_done(struct virtqueue *vq)
49 {
50 	struct virtio_i2c *vi = vq->vdev->priv;
51 
52 	complete(&vi->completion);
53 }
54 
55 static int virtio_i2c_prepare_reqs(struct virtqueue *vq,
56 				   struct virtio_i2c_req *reqs,
57 				   struct i2c_msg *msgs, int num)
58 {
59 	struct scatterlist *sgs[3], out_hdr, msg_buf, in_hdr;
60 	int i;
61 
62 	for (i = 0; i < num; i++) {
63 		int outcnt = 0, incnt = 0;
64 
65 		/*
66 		 * We don't support 0 length messages and so filter out
67 		 * 0 length transfers by using i2c_adapter_quirks.
68 		 */
69 		if (!msgs[i].len)
70 			break;
71 
72 		/*
73 		 * Only 7-bit mode supported for this moment. For the address
74 		 * format, Please check the Virtio I2C Specification.
75 		 */
76 		reqs[i].out_hdr.addr = cpu_to_le16(msgs[i].addr << 1);
77 
78 		if (i != num - 1)
79 			reqs[i].out_hdr.flags = cpu_to_le32(VIRTIO_I2C_FLAGS_FAIL_NEXT);
80 
81 		sg_init_one(&out_hdr, &reqs[i].out_hdr, sizeof(reqs[i].out_hdr));
82 		sgs[outcnt++] = &out_hdr;
83 
84 		reqs[i].buf = i2c_get_dma_safe_msg_buf(&msgs[i], 1);
85 		if (!reqs[i].buf)
86 			break;
87 
88 		sg_init_one(&msg_buf, reqs[i].buf, msgs[i].len);
89 
90 		if (msgs[i].flags & I2C_M_RD)
91 			sgs[outcnt + incnt++] = &msg_buf;
92 		else
93 			sgs[outcnt++] = &msg_buf;
94 
95 		sg_init_one(&in_hdr, &reqs[i].in_hdr, sizeof(reqs[i].in_hdr));
96 		sgs[outcnt + incnt++] = &in_hdr;
97 
98 		if (virtqueue_add_sgs(vq, sgs, outcnt, incnt, &reqs[i], GFP_KERNEL)) {
99 			i2c_put_dma_safe_msg_buf(reqs[i].buf, &msgs[i], false);
100 			break;
101 		}
102 	}
103 
104 	return i;
105 }
106 
107 static int virtio_i2c_complete_reqs(struct virtqueue *vq,
108 				    struct virtio_i2c_req *reqs,
109 				    struct i2c_msg *msgs, int num)
110 {
111 	struct virtio_i2c_req *req;
112 	bool failed = false;
113 	unsigned int len;
114 	int i, j = 0;
115 
116 	for (i = 0; i < num; i++) {
117 		/* Detach the ith request from the vq */
118 		req = virtqueue_get_buf(vq, &len);
119 
120 		/*
121 		 * Condition req == &reqs[i] should always meet since we have
122 		 * total num requests in the vq. reqs[i] can never be NULL here.
123 		 */
124 		if (!failed && (WARN_ON(req != &reqs[i]) ||
125 				req->in_hdr.status != VIRTIO_I2C_MSG_OK))
126 			failed = true;
127 
128 		i2c_put_dma_safe_msg_buf(reqs[i].buf, &msgs[i], !failed);
129 
130 		if (!failed)
131 			j++;
132 	}
133 
134 	return j;
135 }
136 
137 static int virtio_i2c_xfer(struct i2c_adapter *adap, struct i2c_msg *msgs,
138 			   int num)
139 {
140 	struct virtio_i2c *vi = i2c_get_adapdata(adap);
141 	struct virtqueue *vq = vi->vq;
142 	struct virtio_i2c_req *reqs;
143 	int count;
144 
145 	reqs = kcalloc(num, sizeof(*reqs), GFP_KERNEL);
146 	if (!reqs)
147 		return -ENOMEM;
148 
149 	count = virtio_i2c_prepare_reqs(vq, reqs, msgs, num);
150 	if (!count)
151 		goto err_free;
152 
153 	/*
154 	 * For the case where count < num, i.e. we weren't able to queue all the
155 	 * msgs, ideally we should abort right away and return early, but some
156 	 * of the messages are already sent to the remote I2C controller and the
157 	 * virtqueue will be left in undefined state in that case. We kick the
158 	 * remote here to clear the virtqueue, so we can try another set of
159 	 * messages later on.
160 	 */
161 
162 	reinit_completion(&vi->completion);
163 	virtqueue_kick(vq);
164 
165 	wait_for_completion(&vi->completion);
166 
167 	count = virtio_i2c_complete_reqs(vq, reqs, msgs, count);
168 
169 err_free:
170 	kfree(reqs);
171 	return count;
172 }
173 
174 static void virtio_i2c_del_vqs(struct virtio_device *vdev)
175 {
176 	vdev->config->reset(vdev);
177 	vdev->config->del_vqs(vdev);
178 }
179 
180 static int virtio_i2c_setup_vqs(struct virtio_i2c *vi)
181 {
182 	struct virtio_device *vdev = vi->vdev;
183 
184 	vi->vq = virtio_find_single_vq(vdev, virtio_i2c_msg_done, "msg");
185 	return PTR_ERR_OR_ZERO(vi->vq);
186 }
187 
188 static u32 virtio_i2c_func(struct i2c_adapter *adap)
189 {
190 	return I2C_FUNC_I2C | (I2C_FUNC_SMBUS_EMUL & ~I2C_FUNC_SMBUS_QUICK);
191 }
192 
193 static struct i2c_algorithm virtio_algorithm = {
194 	.master_xfer = virtio_i2c_xfer,
195 	.functionality = virtio_i2c_func,
196 };
197 
198 static const struct i2c_adapter_quirks virtio_i2c_quirks = {
199 	.flags = I2C_AQ_NO_ZERO_LEN,
200 };
201 
202 static int virtio_i2c_probe(struct virtio_device *vdev)
203 {
204 	struct virtio_i2c *vi;
205 	int ret;
206 
207 	vi = devm_kzalloc(&vdev->dev, sizeof(*vi), GFP_KERNEL);
208 	if (!vi)
209 		return -ENOMEM;
210 
211 	vdev->priv = vi;
212 	vi->vdev = vdev;
213 
214 	init_completion(&vi->completion);
215 
216 	ret = virtio_i2c_setup_vqs(vi);
217 	if (ret)
218 		return ret;
219 
220 	vi->adap.owner = THIS_MODULE;
221 	snprintf(vi->adap.name, sizeof(vi->adap.name),
222 		 "i2c_virtio at virtio bus %d", vdev->index);
223 	vi->adap.algo = &virtio_algorithm;
224 	vi->adap.quirks = &virtio_i2c_quirks;
225 	vi->adap.dev.parent = &vdev->dev;
226 	vi->adap.dev.of_node = vdev->dev.of_node;
227 	i2c_set_adapdata(&vi->adap, vi);
228 
229 	/*
230 	 * Setup ACPI node for controlled devices which will be probed through
231 	 * ACPI.
232 	 */
233 	ACPI_COMPANION_SET(&vi->adap.dev, ACPI_COMPANION(vdev->dev.parent));
234 
235 	ret = i2c_add_adapter(&vi->adap);
236 	if (ret)
237 		virtio_i2c_del_vqs(vdev);
238 
239 	return ret;
240 }
241 
242 static void virtio_i2c_remove(struct virtio_device *vdev)
243 {
244 	struct virtio_i2c *vi = vdev->priv;
245 
246 	i2c_del_adapter(&vi->adap);
247 	virtio_i2c_del_vqs(vdev);
248 }
249 
250 static struct virtio_device_id id_table[] = {
251 	{ VIRTIO_ID_I2C_ADAPTER, VIRTIO_DEV_ANY_ID },
252 	{}
253 };
254 MODULE_DEVICE_TABLE(virtio, id_table);
255 
256 #ifdef CONFIG_PM_SLEEP
257 static int virtio_i2c_freeze(struct virtio_device *vdev)
258 {
259 	virtio_i2c_del_vqs(vdev);
260 	return 0;
261 }
262 
263 static int virtio_i2c_restore(struct virtio_device *vdev)
264 {
265 	return virtio_i2c_setup_vqs(vdev->priv);
266 }
267 #endif
268 
269 static struct virtio_driver virtio_i2c_driver = {
270 	.id_table	= id_table,
271 	.probe		= virtio_i2c_probe,
272 	.remove		= virtio_i2c_remove,
273 	.driver	= {
274 		.name	= "i2c_virtio",
275 	},
276 #ifdef CONFIG_PM_SLEEP
277 	.freeze = virtio_i2c_freeze,
278 	.restore = virtio_i2c_restore,
279 #endif
280 };
281 module_virtio_driver(virtio_i2c_driver);
282 
283 MODULE_AUTHOR("Jie Deng <jie.deng@intel.com>");
284 MODULE_AUTHOR("Conghui Chen <conghui.chen@intel.com>");
285 MODULE_DESCRIPTION("Virtio i2c bus driver");
286 MODULE_LICENSE("GPL");
287