Lines Matching +full:num +full:- +full:rings
1 // SPDX-License-Identifier: GPL-2.0-only
24 #define XEN_9PFS_RING_SIZE(ring) XEN_FLEX_RING_SIZE(ring->intf->ring_order)
58 struct xen_9pfs_dataring *rings; member
75 return -EINVAL; in p9_xen_create()
79 if (!strcmp(priv->tag, addr)) { in p9_xen_create()
80 priv->client = client; in p9_xen_create()
86 return -EINVAL; in p9_xen_create()
95 if (priv->client == client) { in p9_xen_close()
96 priv->client = NULL; in p9_xen_close()
108 cons = ring->intf->out_cons; in p9_xen_write_todo()
109 prod = ring->intf->out_prod; in p9_xen_write_todo()
112 return XEN_9PFS_RING_SIZE(ring) - in p9_xen_write_todo()
121 u32 size = p9_req->tc.size; in p9_xen_request()
123 int num; in p9_xen_request() local
127 if (priv->client == client) in p9_xen_request()
132 return -EINVAL; in p9_xen_request()
134 num = p9_req->tc.tag % priv->num_rings; in p9_xen_request()
135 ring = &priv->rings[num]; in p9_xen_request()
138 while (wait_event_killable(ring->wq, in p9_xen_request()
142 spin_lock_irqsave(&ring->lock, flags); in p9_xen_request()
143 cons = ring->intf->out_cons; in p9_xen_request()
144 prod = ring->intf->out_prod; in p9_xen_request()
147 if (XEN_9PFS_RING_SIZE(ring) - in p9_xen_request()
149 spin_unlock_irqrestore(&ring->lock, flags); in p9_xen_request()
156 xen_9pfs_write_packet(ring->data.out, p9_req->tc.sdata, size, in p9_xen_request()
160 WRITE_ONCE(p9_req->status, REQ_STATUS_SENT); in p9_xen_request()
163 ring->intf->out_prod = prod; in p9_xen_request()
164 spin_unlock_irqrestore(&ring->lock, flags); in p9_xen_request()
165 notify_remote_via_irq(ring->irq); in p9_xen_request()
181 priv = ring->priv; in p9_xen_response()
184 cons = ring->intf->in_cons; in p9_xen_response()
185 prod = ring->intf->in_prod; in p9_xen_response()
190 notify_remote_via_irq(ring->irq); in p9_xen_response()
198 xen_9pfs_read_packet(&h, ring->data.in, sizeof(h), in p9_xen_response()
202 req = p9_tag_lookup(priv->client, h.tag); in p9_xen_response()
203 if (!req || req->status != REQ_STATUS_SENT) { in p9_xen_response()
204 dev_warn(&priv->dev->dev, "Wrong req tag=%x\n", h.tag); in p9_xen_response()
207 ring->intf->in_cons = cons; in p9_xen_response()
211 if (h.size > req->rc.capacity) { in p9_xen_response()
212 dev_warn(&priv->dev->dev, in p9_xen_response()
214 h.size, h.tag, req->rc.capacity); in p9_xen_response()
215 WRITE_ONCE(req->status, REQ_STATUS_ERROR); in p9_xen_response()
219 req->rc.size = h.size; in p9_xen_response()
220 req->rc.id = h.id; in p9_xen_response()
221 req->rc.tag = h.tag; in p9_xen_response()
222 req->rc.offset = 0; in p9_xen_response()
226 xen_9pfs_read_packet(req->rc.sdata, ring->data.in, h.size, in p9_xen_response()
233 ring->intf->in_cons = cons; in p9_xen_response()
235 status = (req->status != REQ_STATUS_ERROR) ? in p9_xen_response()
238 p9_client_cb(priv->client, req, status); in p9_xen_response()
246 if (!ring || !ring->priv->client) { in xen_9pfs_front_event_handler()
251 wake_up_interruptible(&ring->wq); in xen_9pfs_front_event_handler()
252 schedule_work(&ring->work); in xen_9pfs_front_event_handler()
259 .maxsize = 1 << (XEN_9PFS_RING_ORDER + XEN_PAGE_SHIFT - 2),
279 list_del(&priv->list); in xen_9pfs_front_free()
282 for (i = 0; i < priv->num_rings; i++) { in xen_9pfs_front_free()
283 struct xen_9pfs_dataring *ring = &priv->rings[i]; in xen_9pfs_front_free()
285 cancel_work_sync(&ring->work); in xen_9pfs_front_free()
287 if (!priv->rings[i].intf) in xen_9pfs_front_free()
289 if (priv->rings[i].irq > 0) in xen_9pfs_front_free()
290 unbind_from_irqhandler(priv->rings[i].irq, ring); in xen_9pfs_front_free()
291 if (priv->rings[i].data.in) { in xen_9pfs_front_free()
293 j < (1 << priv->rings[i].intf->ring_order); in xen_9pfs_front_free()
297 ref = priv->rings[i].intf->ref[j]; in xen_9pfs_front_free()
300 free_pages_exact(priv->rings[i].data.in, in xen_9pfs_front_free()
301 1UL << (priv->rings[i].intf->ring_order + in xen_9pfs_front_free()
304 gnttab_end_foreign_access(priv->rings[i].ref, NULL); in xen_9pfs_front_free()
305 free_page((unsigned long)priv->rings[i].intf); in xen_9pfs_front_free()
307 kfree(priv->rings); in xen_9pfs_front_free()
308 kfree(priv->tag); in xen_9pfs_front_free()
314 struct xen_9pfs_front_priv *priv = dev_get_drvdata(&dev->dev); in xen_9pfs_front_remove()
316 dev_set_drvdata(&dev->dev, NULL); in xen_9pfs_front_remove()
325 int ret = -ENOMEM; in xen_9pfs_front_alloc_dataring()
328 init_waitqueue_head(&ring->wq); in xen_9pfs_front_alloc_dataring()
329 spin_lock_init(&ring->lock); in xen_9pfs_front_alloc_dataring()
330 INIT_WORK(&ring->work, p9_xen_response); in xen_9pfs_front_alloc_dataring()
332 ring->intf = (struct xen_9pfs_data_intf *)get_zeroed_page(GFP_KERNEL); in xen_9pfs_front_alloc_dataring()
333 if (!ring->intf) in xen_9pfs_front_alloc_dataring()
335 ret = gnttab_grant_foreign_access(dev->otherend_id, in xen_9pfs_front_alloc_dataring()
336 virt_to_gfn(ring->intf), 0); in xen_9pfs_front_alloc_dataring()
339 ring->ref = ret; in xen_9pfs_front_alloc_dataring()
343 ret = -ENOMEM; in xen_9pfs_front_alloc_dataring()
348 dev->otherend_id, virt_to_gfn(bytes) + i, 0); in xen_9pfs_front_alloc_dataring()
351 ring->intf->ref[i] = ret; in xen_9pfs_front_alloc_dataring()
353 ring->intf->ring_order = order; in xen_9pfs_front_alloc_dataring()
354 ring->data.in = bytes; in xen_9pfs_front_alloc_dataring()
355 ring->data.out = bytes + XEN_FLEX_RING_SIZE(order); in xen_9pfs_front_alloc_dataring()
357 ret = xenbus_alloc_evtchn(dev, &ring->evtchn); in xen_9pfs_front_alloc_dataring()
360 ring->irq = bind_evtchn_to_irqhandler(ring->evtchn, in xen_9pfs_front_alloc_dataring()
362 0, "xen_9pfs-frontend", ring); in xen_9pfs_front_alloc_dataring()
363 if (ring->irq >= 0) in xen_9pfs_front_alloc_dataring()
366 xenbus_free_evtchn(dev, ring->evtchn); in xen_9pfs_front_alloc_dataring()
367 ret = ring->irq; in xen_9pfs_front_alloc_dataring()
370 for (i--; i >= 0; i--) in xen_9pfs_front_alloc_dataring()
371 gnttab_end_foreign_access(ring->intf->ref[i], NULL); in xen_9pfs_front_alloc_dataring()
374 gnttab_end_foreign_access(ring->ref, NULL); in xen_9pfs_front_alloc_dataring()
375 free_page((unsigned long)ring->intf); in xen_9pfs_front_alloc_dataring()
383 struct xen_9pfs_front_priv *priv = dev_get_drvdata(&dev->dev); in xen_9pfs_front_init()
387 versions = xenbus_read(XBT_NIL, dev->otherend, "versions", &len); in xen_9pfs_front_init()
398 return -EINVAL; in xen_9pfs_front_init()
401 max_rings = xenbus_read_unsigned(dev->otherend, "max-rings", 0); in xen_9pfs_front_init()
403 return -EINVAL; in xen_9pfs_front_init()
404 max_ring_order = xenbus_read_unsigned(dev->otherend, in xen_9pfs_front_init()
405 "max-ring-page-order", 0); in xen_9pfs_front_init()
411 priv->num_rings = XEN_9PFS_NUM_RINGS; in xen_9pfs_front_init()
412 priv->rings = kcalloc(priv->num_rings, sizeof(*priv->rings), in xen_9pfs_front_init()
414 if (!priv->rings) { in xen_9pfs_front_init()
416 return -ENOMEM; in xen_9pfs_front_init()
419 for (i = 0; i < priv->num_rings; i++) { in xen_9pfs_front_init()
420 priv->rings[i].priv = priv; in xen_9pfs_front_init()
421 ret = xen_9pfs_front_alloc_dataring(dev, &priv->rings[i], in xen_9pfs_front_init()
433 ret = xenbus_printf(xbt, dev->nodename, "version", "%u", 1); in xen_9pfs_front_init()
436 ret = xenbus_printf(xbt, dev->nodename, "num-rings", "%u", in xen_9pfs_front_init()
437 priv->num_rings); in xen_9pfs_front_init()
440 for (i = 0; i < priv->num_rings; i++) { in xen_9pfs_front_init()
444 sprintf(str, "ring-ref%d", i); in xen_9pfs_front_init()
445 ret = xenbus_printf(xbt, dev->nodename, str, "%d", in xen_9pfs_front_init()
446 priv->rings[i].ref); in xen_9pfs_front_init()
450 sprintf(str, "event-channel-%d", i); in xen_9pfs_front_init()
451 ret = xenbus_printf(xbt, dev->nodename, str, "%u", in xen_9pfs_front_init()
452 priv->rings[i].evtchn); in xen_9pfs_front_init()
456 priv->tag = xenbus_read(xbt, dev->nodename, "tag", NULL); in xen_9pfs_front_init()
457 if (IS_ERR(priv->tag)) { in xen_9pfs_front_init()
458 ret = PTR_ERR(priv->tag); in xen_9pfs_front_init()
463 if (ret == -EAGAIN) in xen_9pfs_front_init()
487 return -ENOMEM; in xen_9pfs_front_probe()
489 priv->dev = dev; in xen_9pfs_front_probe()
490 dev_set_drvdata(&dev->dev, priv); in xen_9pfs_front_probe()
493 list_add_tail(&priv->list, &xen_9pfs_devs); in xen_9pfs_front_probe()
501 dev_warn(&dev->dev, "suspend/resume unsupported\n"); in xen_9pfs_front_resume()
517 if (dev->state != XenbusStateInitialising) in xen_9pfs_front_changed()
528 if (dev->state == XenbusStateClosed) in xen_9pfs_front_changed()
550 return -ENODEV; in p9_trans_xen_init()