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 memcpy(&req->rc, &h, sizeof(h)); in p9_xen_response()
235 req->rc.offset = 0; in p9_xen_response()
239 xen_9pfs_read_packet(req->rc.sdata, ring->data.in, h.size, in p9_xen_response()
245 ring->intf->in_cons = cons; in p9_xen_response()
247 status = (req->status != REQ_STATUS_ERROR) ? in p9_xen_response()
250 p9_client_cb(priv->client, req, status); in p9_xen_response()
258 if (!ring || !ring->priv->client) { in xen_9pfs_front_event_handler()
263 wake_up_interruptible(&ring->wq); in xen_9pfs_front_event_handler()
264 schedule_work(&ring->work); in xen_9pfs_front_event_handler()
271 .maxsize = 1 << (XEN_9PFS_RING_ORDER + XEN_PAGE_SHIFT - 2),
290 list_del(&priv->list); in xen_9pfs_front_free()
293 for (i = 0; i < priv->num_rings; i++) { in xen_9pfs_front_free()
294 if (!priv->rings[i].intf) in xen_9pfs_front_free()
296 if (priv->rings[i].irq > 0) in xen_9pfs_front_free()
297 unbind_from_irqhandler(priv->rings[i].irq, priv->dev); in xen_9pfs_front_free()
298 if (priv->rings[i].data.in) { in xen_9pfs_front_free()
300 j < (1 << priv->rings[i].intf->ring_order); in xen_9pfs_front_free()
304 ref = priv->rings[i].intf->ref[j]; in xen_9pfs_front_free()
307 free_pages((unsigned long)priv->rings[i].data.in, in xen_9pfs_front_free()
308 priv->rings[i].intf->ring_order - in xen_9pfs_front_free()
309 (PAGE_SHIFT - XEN_PAGE_SHIFT)); in xen_9pfs_front_free()
311 gnttab_end_foreign_access(priv->rings[i].ref, 0, 0); in xen_9pfs_front_free()
312 free_page((unsigned long)priv->rings[i].intf); in xen_9pfs_front_free()
314 kfree(priv->rings); in xen_9pfs_front_free()
315 kfree(priv->tag); in xen_9pfs_front_free()
321 struct xen_9pfs_front_priv *priv = dev_get_drvdata(&dev->dev); in xen_9pfs_front_remove()
323 dev_set_drvdata(&dev->dev, NULL); in xen_9pfs_front_remove()
333 int ret = -ENOMEM; in xen_9pfs_front_alloc_dataring()
336 init_waitqueue_head(&ring->wq); in xen_9pfs_front_alloc_dataring()
337 spin_lock_init(&ring->lock); in xen_9pfs_front_alloc_dataring()
338 INIT_WORK(&ring->work, p9_xen_response); in xen_9pfs_front_alloc_dataring()
340 ring->intf = (struct xen_9pfs_data_intf *)get_zeroed_page(GFP_KERNEL); in xen_9pfs_front_alloc_dataring()
341 if (!ring->intf) in xen_9pfs_front_alloc_dataring()
343 ret = gnttab_grant_foreign_access(dev->otherend_id, in xen_9pfs_front_alloc_dataring()
344 virt_to_gfn(ring->intf), 0); in xen_9pfs_front_alloc_dataring()
347 ring->ref = ret; in xen_9pfs_front_alloc_dataring()
349 order - (PAGE_SHIFT - XEN_PAGE_SHIFT)); in xen_9pfs_front_alloc_dataring()
351 ret = -ENOMEM; in xen_9pfs_front_alloc_dataring()
356 dev->otherend_id, virt_to_gfn(bytes) + i, 0); in xen_9pfs_front_alloc_dataring()
359 ring->intf->ref[i] = ret; in xen_9pfs_front_alloc_dataring()
361 ring->intf->ring_order = order; in xen_9pfs_front_alloc_dataring()
362 ring->data.in = bytes; in xen_9pfs_front_alloc_dataring()
363 ring->data.out = bytes + XEN_FLEX_RING_SIZE(order); in xen_9pfs_front_alloc_dataring()
365 ret = xenbus_alloc_evtchn(dev, &ring->evtchn); in xen_9pfs_front_alloc_dataring()
368 ring->irq = bind_evtchn_to_irqhandler(ring->evtchn, in xen_9pfs_front_alloc_dataring()
370 0, "xen_9pfs-frontend", ring); in xen_9pfs_front_alloc_dataring()
371 if (ring->irq >= 0) in xen_9pfs_front_alloc_dataring()
374 xenbus_free_evtchn(dev, ring->evtchn); in xen_9pfs_front_alloc_dataring()
375 ret = ring->irq; in xen_9pfs_front_alloc_dataring()
378 for (i--; i >= 0; i--) in xen_9pfs_front_alloc_dataring()
379 gnttab_end_foreign_access(ring->intf->ref[i], 0, 0); in xen_9pfs_front_alloc_dataring()
381 ring->intf->ring_order - in xen_9pfs_front_alloc_dataring()
382 (PAGE_SHIFT - XEN_PAGE_SHIFT)); in xen_9pfs_front_alloc_dataring()
384 gnttab_end_foreign_access(ring->ref, 0, 0); in xen_9pfs_front_alloc_dataring()
385 free_page((unsigned long)ring->intf); in xen_9pfs_front_alloc_dataring()
398 versions = xenbus_read(XBT_NIL, dev->otherend, "versions", &len); in xen_9pfs_front_probe()
403 return -EINVAL; in xen_9pfs_front_probe()
406 max_rings = xenbus_read_unsigned(dev->otherend, "max-rings", 0); in xen_9pfs_front_probe()
408 return -EINVAL; in xen_9pfs_front_probe()
409 max_ring_order = xenbus_read_unsigned(dev->otherend, in xen_9pfs_front_probe()
410 "max-ring-page-order", 0); in xen_9pfs_front_probe()
418 return -ENOMEM; in xen_9pfs_front_probe()
420 priv->dev = dev; in xen_9pfs_front_probe()
421 priv->num_rings = XEN_9PFS_NUM_RINGS; in xen_9pfs_front_probe()
422 priv->rings = kcalloc(priv->num_rings, sizeof(*priv->rings), in xen_9pfs_front_probe()
424 if (!priv->rings) { in xen_9pfs_front_probe()
426 return -ENOMEM; in xen_9pfs_front_probe()
429 for (i = 0; i < priv->num_rings; i++) { in xen_9pfs_front_probe()
430 priv->rings[i].priv = priv; in xen_9pfs_front_probe()
431 ret = xen_9pfs_front_alloc_dataring(dev, &priv->rings[i], in xen_9pfs_front_probe()
443 ret = xenbus_printf(xbt, dev->nodename, "version", "%u", 1); in xen_9pfs_front_probe()
446 ret = xenbus_printf(xbt, dev->nodename, "num-rings", "%u", in xen_9pfs_front_probe()
447 priv->num_rings); in xen_9pfs_front_probe()
450 for (i = 0; i < priv->num_rings; i++) { in xen_9pfs_front_probe()
454 sprintf(str, "ring-ref%d", i); in xen_9pfs_front_probe()
455 ret = xenbus_printf(xbt, dev->nodename, str, "%d", in xen_9pfs_front_probe()
456 priv->rings[i].ref); in xen_9pfs_front_probe()
460 sprintf(str, "event-channel-%d", i); in xen_9pfs_front_probe()
461 ret = xenbus_printf(xbt, dev->nodename, str, "%u", in xen_9pfs_front_probe()
462 priv->rings[i].evtchn); in xen_9pfs_front_probe()
466 priv->tag = xenbus_read(xbt, dev->nodename, "tag", NULL); in xen_9pfs_front_probe()
467 if (IS_ERR(priv->tag)) { in xen_9pfs_front_probe()
468 ret = PTR_ERR(priv->tag); in xen_9pfs_front_probe()
473 if (ret == -EAGAIN) in xen_9pfs_front_probe()
480 list_add_tail(&priv->list, &xen_9pfs_devs); in xen_9pfs_front_probe()
482 dev_set_drvdata(&dev->dev, priv); in xen_9pfs_front_probe()
491 dev_set_drvdata(&dev->dev, NULL); in xen_9pfs_front_probe()
498 dev_warn(&dev->dev, "suspend/resume unsupported\n"); in xen_9pfs_front_resume()
521 if (dev->state == XenbusStateClosed) in xen_9pfs_front_changed()
543 return -ENODEV; in p9_trans_xen_init()