Lines Matching +full:num +full:- +full:rings
47 #define XEN_9PFS_RING_SIZE(ring) XEN_FLEX_RING_SIZE(ring->intf->ring_order)
81 struct xen_9pfs_dataring *rings; member
98 return -EINVAL; in p9_xen_create()
102 if (!strcmp(priv->tag, addr)) { in p9_xen_create()
103 priv->client = client; in p9_xen_create()
109 return -EINVAL; in p9_xen_create()
118 if (priv->client == client) { in p9_xen_close()
119 priv->client = NULL; in p9_xen_close()
131 cons = ring->intf->out_cons; in p9_xen_write_todo()
132 prod = ring->intf->out_prod; in p9_xen_write_todo()
135 return XEN_9PFS_RING_SIZE(ring) - in p9_xen_write_todo()
144 u32 size = p9_req->tc.size; in p9_xen_request()
146 int num; in p9_xen_request() local
150 if (priv->client == client) in p9_xen_request()
155 return -EINVAL; in p9_xen_request()
157 num = p9_req->tc.tag % priv->num_rings; in p9_xen_request()
158 ring = &priv->rings[num]; in p9_xen_request()
161 while (wait_event_killable(ring->wq, in p9_xen_request()
165 spin_lock_irqsave(&ring->lock, flags); in p9_xen_request()
166 cons = ring->intf->out_cons; in p9_xen_request()
167 prod = ring->intf->out_prod; in p9_xen_request()
170 if (XEN_9PFS_RING_SIZE(ring) - in p9_xen_request()
172 spin_unlock_irqrestore(&ring->lock, flags); in p9_xen_request()
179 xen_9pfs_write_packet(ring->data.out, p9_req->tc.sdata, size, in p9_xen_request()
183 p9_req->status = REQ_STATUS_SENT; in p9_xen_request()
186 ring->intf->out_prod = prod; in p9_xen_request()
187 spin_unlock_irqrestore(&ring->lock, flags); in p9_xen_request()
188 notify_remote_via_irq(ring->irq); in p9_xen_request()
204 priv = ring->priv; in p9_xen_response()
207 cons = ring->intf->in_cons; in p9_xen_response()
208 prod = ring->intf->in_prod; in p9_xen_response()
213 notify_remote_via_irq(ring->irq); in p9_xen_response()
221 xen_9pfs_read_packet(&h, ring->data.in, sizeof(h), in p9_xen_response()
225 req = p9_tag_lookup(priv->client, h.tag); in p9_xen_response()
226 if (!req || req->status != REQ_STATUS_SENT) { in p9_xen_response()
227 dev_warn(&priv->dev->dev, "Wrong req tag=%x\n", h.tag); in p9_xen_response()
230 ring->intf->in_cons = cons; in p9_xen_response()
234 if (h.size > req->rc.capacity) { in p9_xen_response()
235 dev_warn(&priv->dev->dev, in p9_xen_response()
237 h.size, h.tag, req->rc.capacity); in p9_xen_response()
238 req->status = REQ_STATUS_ERROR; in p9_xen_response()
242 memcpy(&req->rc, &h, sizeof(h)); in p9_xen_response()
243 req->rc.offset = 0; in p9_xen_response()
247 xen_9pfs_read_packet(req->rc.sdata, ring->data.in, h.size, in p9_xen_response()
254 ring->intf->in_cons = cons; in p9_xen_response()
256 status = (req->status != REQ_STATUS_ERROR) ? in p9_xen_response()
259 p9_client_cb(priv->client, req, status); in p9_xen_response()
267 if (!ring || !ring->priv->client) { in xen_9pfs_front_event_handler()
272 wake_up_interruptible(&ring->wq); in xen_9pfs_front_event_handler()
273 schedule_work(&ring->work); in xen_9pfs_front_event_handler()
280 .maxsize = 1 << (XEN_9PFS_RING_ORDER + XEN_PAGE_SHIFT - 2),
299 list_del(&priv->list); in xen_9pfs_front_free()
302 for (i = 0; i < priv->num_rings; i++) { in xen_9pfs_front_free()
303 struct xen_9pfs_dataring *ring = &priv->rings[i]; in xen_9pfs_front_free()
305 cancel_work_sync(&ring->work); in xen_9pfs_front_free()
307 if (!priv->rings[i].intf) in xen_9pfs_front_free()
309 if (priv->rings[i].irq > 0) in xen_9pfs_front_free()
310 unbind_from_irqhandler(priv->rings[i].irq, priv->dev); in xen_9pfs_front_free()
311 if (priv->rings[i].data.in) { in xen_9pfs_front_free()
313 j < (1 << priv->rings[i].intf->ring_order); in xen_9pfs_front_free()
317 ref = priv->rings[i].intf->ref[j]; in xen_9pfs_front_free()
320 free_pages_exact(priv->rings[i].data.in, in xen_9pfs_front_free()
321 1UL << (priv->rings[i].intf->ring_order + in xen_9pfs_front_free()
324 gnttab_end_foreign_access(priv->rings[i].ref, 0, 0); in xen_9pfs_front_free()
325 free_page((unsigned long)priv->rings[i].intf); in xen_9pfs_front_free()
327 kfree(priv->rings); in xen_9pfs_front_free()
328 kfree(priv->tag); in xen_9pfs_front_free()
334 struct xen_9pfs_front_priv *priv = dev_get_drvdata(&dev->dev); in xen_9pfs_front_remove()
336 dev_set_drvdata(&dev->dev, NULL); in xen_9pfs_front_remove()
346 int ret = -ENOMEM; in xen_9pfs_front_alloc_dataring()
349 init_waitqueue_head(&ring->wq); in xen_9pfs_front_alloc_dataring()
350 spin_lock_init(&ring->lock); in xen_9pfs_front_alloc_dataring()
351 INIT_WORK(&ring->work, p9_xen_response); in xen_9pfs_front_alloc_dataring()
353 ring->intf = (struct xen_9pfs_data_intf *)get_zeroed_page(GFP_KERNEL); in xen_9pfs_front_alloc_dataring()
354 if (!ring->intf) in xen_9pfs_front_alloc_dataring()
356 ret = gnttab_grant_foreign_access(dev->otherend_id, in xen_9pfs_front_alloc_dataring()
357 virt_to_gfn(ring->intf), 0); in xen_9pfs_front_alloc_dataring()
360 ring->ref = ret; in xen_9pfs_front_alloc_dataring()
364 ret = -ENOMEM; in xen_9pfs_front_alloc_dataring()
369 dev->otherend_id, virt_to_gfn(bytes) + i, 0); in xen_9pfs_front_alloc_dataring()
372 ring->intf->ref[i] = ret; in xen_9pfs_front_alloc_dataring()
374 ring->intf->ring_order = order; in xen_9pfs_front_alloc_dataring()
375 ring->data.in = bytes; in xen_9pfs_front_alloc_dataring()
376 ring->data.out = bytes + XEN_FLEX_RING_SIZE(order); in xen_9pfs_front_alloc_dataring()
378 ret = xenbus_alloc_evtchn(dev, &ring->evtchn); in xen_9pfs_front_alloc_dataring()
381 ring->irq = bind_evtchn_to_irqhandler(ring->evtchn, in xen_9pfs_front_alloc_dataring()
383 0, "xen_9pfs-frontend", ring); in xen_9pfs_front_alloc_dataring()
384 if (ring->irq >= 0) in xen_9pfs_front_alloc_dataring()
387 xenbus_free_evtchn(dev, ring->evtchn); in xen_9pfs_front_alloc_dataring()
388 ret = ring->irq; in xen_9pfs_front_alloc_dataring()
391 for (i--; i >= 0; i--) in xen_9pfs_front_alloc_dataring()
392 gnttab_end_foreign_access(ring->intf->ref[i], 0, 0); in xen_9pfs_front_alloc_dataring()
395 gnttab_end_foreign_access(ring->ref, 0, 0); in xen_9pfs_front_alloc_dataring()
396 free_page((unsigned long)ring->intf); in xen_9pfs_front_alloc_dataring()
404 struct xen_9pfs_front_priv *priv = dev_get_drvdata(&dev->dev); in xen_9pfs_front_init()
408 versions = xenbus_read(XBT_NIL, dev->otherend, "versions", &len); in xen_9pfs_front_init()
419 return -EINVAL; in xen_9pfs_front_init()
422 max_rings = xenbus_read_unsigned(dev->otherend, "max-rings", 0); in xen_9pfs_front_init()
424 return -EINVAL; in xen_9pfs_front_init()
425 max_ring_order = xenbus_read_unsigned(dev->otherend, in xen_9pfs_front_init()
426 "max-ring-page-order", 0); in xen_9pfs_front_init()
432 priv->num_rings = XEN_9PFS_NUM_RINGS; in xen_9pfs_front_init()
433 priv->rings = kcalloc(priv->num_rings, sizeof(*priv->rings), in xen_9pfs_front_init()
435 if (!priv->rings) { in xen_9pfs_front_init()
437 return -ENOMEM; in xen_9pfs_front_init()
440 for (i = 0; i < priv->num_rings; i++) { in xen_9pfs_front_init()
441 priv->rings[i].priv = priv; in xen_9pfs_front_init()
442 ret = xen_9pfs_front_alloc_dataring(dev, &priv->rings[i], in xen_9pfs_front_init()
454 ret = xenbus_printf(xbt, dev->nodename, "version", "%u", 1); in xen_9pfs_front_init()
457 ret = xenbus_printf(xbt, dev->nodename, "num-rings", "%u", in xen_9pfs_front_init()
458 priv->num_rings); in xen_9pfs_front_init()
461 for (i = 0; i < priv->num_rings; i++) { in xen_9pfs_front_init()
465 sprintf(str, "ring-ref%d", i); in xen_9pfs_front_init()
466 ret = xenbus_printf(xbt, dev->nodename, str, "%d", in xen_9pfs_front_init()
467 priv->rings[i].ref); in xen_9pfs_front_init()
471 sprintf(str, "event-channel-%d", i); in xen_9pfs_front_init()
472 ret = xenbus_printf(xbt, dev->nodename, str, "%u", in xen_9pfs_front_init()
473 priv->rings[i].evtchn); in xen_9pfs_front_init()
477 priv->tag = xenbus_read(xbt, dev->nodename, "tag", NULL); in xen_9pfs_front_init()
478 if (IS_ERR(priv->tag)) { in xen_9pfs_front_init()
479 ret = PTR_ERR(priv->tag); in xen_9pfs_front_init()
484 if (ret == -EAGAIN) in xen_9pfs_front_init()
507 return -ENOMEM; in xen_9pfs_front_probe()
509 priv->dev = dev; in xen_9pfs_front_probe()
510 dev_set_drvdata(&dev->dev, priv); in xen_9pfs_front_probe()
513 list_add_tail(&priv->list, &xen_9pfs_devs); in xen_9pfs_front_probe()
521 dev_warn(&dev->dev, "suspend/resume unsupported\n"); in xen_9pfs_front_resume()
546 if (dev->state == XenbusStateClosed) in xen_9pfs_front_changed()
568 return -ENODEV; in p9_trans_xen_init()