Lines Matching full:channel
63 * @in_use: To mark if intent is already in use for the channel
82 * @mbox_chan: mailbox channel
91 * @lcids: idr of all channels with a known local channel id
92 * @rcids: idr of all channels with a known remote channel id
131 * struct glink_channel - internal representation of a channel
133 * @ept: rpmsg endpoint this channel is associated with
135 * @refcount: refcount for the channel object
137 * @name: unique channel name/identifier
138 * @lcid: channel id, in local space
139 * @rcid: channel id, in remote space
212 struct glink_channel *channel; in qcom_glink_alloc_channel() local
214 channel = kzalloc(sizeof(*channel), GFP_KERNEL); in qcom_glink_alloc_channel()
215 if (!channel) in qcom_glink_alloc_channel()
219 spin_lock_init(&channel->recv_lock); in qcom_glink_alloc_channel()
220 spin_lock_init(&channel->intent_lock); in qcom_glink_alloc_channel()
221 mutex_init(&channel->intent_req_lock); in qcom_glink_alloc_channel()
223 channel->glink = glink; in qcom_glink_alloc_channel()
224 channel->name = kstrdup(name, GFP_KERNEL); in qcom_glink_alloc_channel()
226 init_completion(&channel->open_req); in qcom_glink_alloc_channel()
227 init_completion(&channel->open_ack); in qcom_glink_alloc_channel()
228 init_completion(&channel->intent_req_comp); in qcom_glink_alloc_channel()
230 INIT_LIST_HEAD(&channel->done_intents); in qcom_glink_alloc_channel()
231 INIT_WORK(&channel->intent_work, qcom_glink_rx_done_work); in qcom_glink_alloc_channel()
233 idr_init(&channel->liids); in qcom_glink_alloc_channel()
234 idr_init(&channel->riids); in qcom_glink_alloc_channel()
235 kref_init(&channel->refcount); in qcom_glink_alloc_channel()
237 return channel; in qcom_glink_alloc_channel()
242 struct glink_channel *channel = container_of(ref, struct glink_channel, in qcom_glink_channel_release() local
246 spin_lock_irqsave(&channel->intent_lock, flags); in qcom_glink_channel_release()
247 idr_destroy(&channel->liids); in qcom_glink_channel_release()
248 idr_destroy(&channel->riids); in qcom_glink_channel_release()
249 spin_unlock_irqrestore(&channel->intent_lock, flags); in qcom_glink_channel_release()
251 kfree(channel->name); in qcom_glink_channel_release()
252 kfree(channel); in qcom_glink_channel_release()
345 struct glink_channel *channel) in qcom_glink_send_open_ack() argument
350 msg.param1 = cpu_to_le16(channel->rcid); in qcom_glink_send_open_ack()
359 struct glink_channel *channel; in qcom_glink_handle_intent_req_ack() local
363 channel = idr_find(&glink->rcids, cid); in qcom_glink_handle_intent_req_ack()
365 if (!channel) { in qcom_glink_handle_intent_req_ack()
366 dev_err(glink->dev, "unable to find channel\n"); in qcom_glink_handle_intent_req_ack()
370 channel->intent_req_result = granted; in qcom_glink_handle_intent_req_ack()
371 complete(&channel->intent_req_comp); in qcom_glink_handle_intent_req_ack()
377 * @channel: Ptr to the channel that the open req is sent
379 * Allocates a local channel id and sends a RPM_CMD_OPEN message to the remote.
385 struct glink_channel *channel) in qcom_glink_send_open_req() argument
391 int name_len = strlen(channel->name) + 1; in qcom_glink_send_open_req()
396 kref_get(&channel->refcount); in qcom_glink_send_open_req()
399 ret = idr_alloc_cyclic(&glink->lcids, channel, in qcom_glink_send_open_req()
406 channel->lcid = ret; in qcom_glink_send_open_req()
409 req.msg.param1 = cpu_to_le16(channel->lcid); in qcom_glink_send_open_req()
411 strcpy(req.name, channel->name); in qcom_glink_send_open_req()
421 idr_remove(&glink->lcids, channel->lcid); in qcom_glink_send_open_req()
422 channel->lcid = 0; in qcom_glink_send_open_req()
429 struct glink_channel *channel) in qcom_glink_send_close_req() argument
434 req.param1 = cpu_to_le16(channel->lcid); in qcom_glink_send_close_req()
454 struct glink_channel *channel = container_of(work, struct glink_channel, in qcom_glink_rx_done_work() local
456 struct qcom_glink *glink = channel->glink; in qcom_glink_rx_done_work()
464 unsigned int cid = channel->lcid; in qcom_glink_rx_done_work()
469 spin_lock_irqsave(&channel->intent_lock, flags); in qcom_glink_rx_done_work()
470 list_for_each_entry_safe(intent, tmp, &channel->done_intents, node) { in qcom_glink_rx_done_work()
472 spin_unlock_irqrestore(&channel->intent_lock, flags); in qcom_glink_rx_done_work()
485 spin_lock_irqsave(&channel->intent_lock, flags); in qcom_glink_rx_done_work()
487 spin_unlock_irqrestore(&channel->intent_lock, flags); in qcom_glink_rx_done_work()
491 struct glink_channel *channel, in qcom_glink_rx_done() argument
503 spin_lock(&channel->intent_lock); in qcom_glink_rx_done()
504 idr_remove(&channel->liids, intent->id); in qcom_glink_rx_done()
505 spin_unlock(&channel->intent_lock); in qcom_glink_rx_done()
509 spin_lock(&channel->intent_lock); in qcom_glink_rx_done()
510 list_add_tail(&intent->node, &channel->done_intents); in qcom_glink_rx_done()
511 spin_unlock(&channel->intent_lock); in qcom_glink_rx_done()
513 schedule_work(&channel->intent_work); in qcom_glink_rx_done()
577 * @channel: The glink channel
583 struct glink_channel *channel, in qcom_glink_send_intent_req_ack() argument
589 msg.param1 = cpu_to_le16(channel->lcid); in qcom_glink_send_intent_req_ack()
601 * @channel: The local channel
607 struct glink_channel *channel, in qcom_glink_advertise_intent() argument
620 cmd.lcid = cpu_to_le16(channel->lcid); in qcom_glink_advertise_intent()
632 struct glink_channel *channel, in qcom_glink_alloc_intent() argument
648 spin_lock_irqsave(&channel->intent_lock, flags); in qcom_glink_alloc_intent()
649 ret = idr_alloc_cyclic(&channel->liids, intent, 1, -1, GFP_ATOMIC); in qcom_glink_alloc_intent()
651 spin_unlock_irqrestore(&channel->intent_lock, flags); in qcom_glink_alloc_intent()
654 spin_unlock_irqrestore(&channel->intent_lock, flags); in qcom_glink_alloc_intent()
674 struct glink_channel *channel; in qcom_glink_handle_rx_done() local
678 channel = idr_find(&glink->rcids, cid); in qcom_glink_handle_rx_done()
680 if (!channel) { in qcom_glink_handle_rx_done()
681 dev_err(glink->dev, "invalid channel id received\n"); in qcom_glink_handle_rx_done()
685 spin_lock_irqsave(&channel->intent_lock, flags); in qcom_glink_handle_rx_done()
686 intent = idr_find(&channel->riids, iid); in qcom_glink_handle_rx_done()
689 spin_unlock_irqrestore(&channel->intent_lock, flags); in qcom_glink_handle_rx_done()
697 idr_remove(&channel->riids, intent->id); in qcom_glink_handle_rx_done()
700 spin_unlock_irqrestore(&channel->intent_lock, flags); in qcom_glink_handle_rx_done()
707 * @cid: Remote channel ID
710 * The function searches for the local channel to which the request for
717 struct glink_channel *channel; in qcom_glink_handle_intent_req() local
721 channel = idr_find(&glink->rcids, cid); in qcom_glink_handle_intent_req()
724 if (!channel) { in qcom_glink_handle_intent_req()
725 pr_err("%s channel not found for cid %d\n", __func__, cid); in qcom_glink_handle_intent_req()
729 intent = qcom_glink_alloc_intent(glink, channel, size, false); in qcom_glink_handle_intent_req()
731 qcom_glink_advertise_intent(glink, channel, intent); in qcom_glink_handle_intent_req()
733 qcom_glink_send_intent_req_ack(glink, channel, !!intent); in qcom_glink_handle_intent_req()
768 struct glink_channel *channel; in qcom_glink_rx_data() local
797 channel = idr_find(&glink->rcids, rcid); in qcom_glink_rx_data()
799 if (!channel) { in qcom_glink_rx_data()
800 dev_dbg(glink->dev, "Data on non-existing channel\n"); in qcom_glink_rx_data()
808 if (!channel->buf) { in qcom_glink_rx_data()
824 channel->buf = intent; in qcom_glink_rx_data()
826 intent = channel->buf; in qcom_glink_rx_data()
831 spin_lock_irqsave(&channel->intent_lock, flags); in qcom_glink_rx_data()
832 intent = idr_find(&channel->liids, liid); in qcom_glink_rx_data()
833 spin_unlock_irqrestore(&channel->intent_lock, flags); in qcom_glink_rx_data()
837 "no intent found for channel %s intent %d", in qcom_glink_rx_data()
838 channel->name, liid); in qcom_glink_rx_data()
856 spin_lock(&channel->recv_lock); in qcom_glink_rx_data()
857 if (channel->ept.cb) { in qcom_glink_rx_data()
858 channel->ept.cb(channel->ept.rpdev, in qcom_glink_rx_data()
861 channel->ept.priv, in qcom_glink_rx_data()
864 spin_unlock(&channel->recv_lock); in qcom_glink_rx_data()
867 channel->buf = NULL; in qcom_glink_rx_data()
869 qcom_glink_rx_done(glink, channel, intent); in qcom_glink_rx_data()
884 struct glink_channel *channel; in qcom_glink_handle_intent() local
906 channel = idr_find(&glink->rcids, cid); in qcom_glink_handle_intent()
908 if (!channel) { in qcom_glink_handle_intent()
909 dev_err(glink->dev, "intents for non-existing channel\n"); in qcom_glink_handle_intent()
927 spin_lock_irqsave(&channel->intent_lock, flags); in qcom_glink_handle_intent()
928 ret = idr_alloc(&channel->riids, intent, in qcom_glink_handle_intent()
930 spin_unlock_irqrestore(&channel->intent_lock, flags); in qcom_glink_handle_intent()
942 struct glink_channel *channel; in qcom_glink_rx_open_ack() local
945 channel = idr_find(&glink->lcids, lcid); in qcom_glink_rx_open_ack()
947 if (!channel) { in qcom_glink_rx_open_ack()
952 complete(&channel->open_ack); in qcom_glink_rx_open_ack()
1035 struct glink_channel *channel; in qcom_glink_create_local() local
1039 channel = qcom_glink_alloc_channel(glink, name); in qcom_glink_create_local()
1040 if (IS_ERR(channel)) in qcom_glink_create_local()
1041 return ERR_CAST(channel); in qcom_glink_create_local()
1043 ret = qcom_glink_send_open_req(glink, channel); in qcom_glink_create_local()
1047 ret = wait_for_completion_timeout(&channel->open_ack, 5 * HZ); in qcom_glink_create_local()
1051 ret = wait_for_completion_timeout(&channel->open_req, 5 * HZ); in qcom_glink_create_local()
1055 qcom_glink_send_open_ack(glink, channel); in qcom_glink_create_local()
1057 return channel; in qcom_glink_create_local()
1060 /* qcom_glink_send_open_req() did register the channel in lcids*/ in qcom_glink_create_local()
1062 idr_remove(&glink->lcids, channel->lcid); in qcom_glink_create_local()
1067 kref_put(&channel->refcount, qcom_glink_channel_release); in qcom_glink_create_local()
1069 kref_put(&channel->refcount, qcom_glink_channel_release); in qcom_glink_create_local()
1076 struct glink_channel *channel) in qcom_glink_create_remote() argument
1080 qcom_glink_send_open_ack(glink, channel); in qcom_glink_create_remote()
1082 ret = qcom_glink_send_open_req(glink, channel); in qcom_glink_create_remote()
1086 ret = wait_for_completion_timeout(&channel->open_ack, 5 * HZ); in qcom_glink_create_remote()
1099 qcom_glink_send_close_req(glink, channel); in qcom_glink_create_remote()
1102 kref_put(&channel->refcount, qcom_glink_channel_release); in qcom_glink_create_remote()
1114 struct glink_channel *channel; in qcom_glink_create_ept() local
1123 idr_for_each_entry(&glink->rcids, channel, cid) { in qcom_glink_create_ept()
1124 if (!strcmp(channel->name, name)) in qcom_glink_create_ept()
1129 if (!channel) { in qcom_glink_create_ept()
1130 channel = qcom_glink_create_local(glink, name); in qcom_glink_create_ept()
1131 if (IS_ERR(channel)) in qcom_glink_create_ept()
1134 ret = qcom_glink_create_remote(glink, channel); in qcom_glink_create_ept()
1139 ept = &channel->ept; in qcom_glink_create_ept()
1150 struct glink_channel *channel = to_glink_channel(rpdev->ept); in qcom_glink_announce_create() local
1152 struct qcom_glink *glink = channel->glink; in qcom_glink_announce_create()
1170 /* Channel is now open, advertise base set of intents */ in qcom_glink_announce_create()
1175 intent = qcom_glink_alloc_intent(glink, channel, size, in qcom_glink_announce_create()
1180 qcom_glink_advertise_intent(glink, channel, intent); in qcom_glink_announce_create()
1188 struct glink_channel *channel = to_glink_channel(ept); in qcom_glink_destroy_ept() local
1189 struct qcom_glink *glink = channel->glink; in qcom_glink_destroy_ept()
1192 spin_lock_irqsave(&channel->recv_lock, flags); in qcom_glink_destroy_ept()
1193 channel->ept.cb = NULL; in qcom_glink_destroy_ept()
1194 spin_unlock_irqrestore(&channel->recv_lock, flags); in qcom_glink_destroy_ept()
1196 /* Decouple the potential rpdev from the channel */ in qcom_glink_destroy_ept()
1197 channel->rpdev = NULL; in qcom_glink_destroy_ept()
1199 qcom_glink_send_close_req(glink, channel); in qcom_glink_destroy_ept()
1203 struct glink_channel *channel, in qcom_glink_request_intent() argument
1214 mutex_lock(&channel->intent_req_lock); in qcom_glink_request_intent()
1216 reinit_completion(&channel->intent_req_comp); in qcom_glink_request_intent()
1219 cmd.cid = channel->lcid; in qcom_glink_request_intent()
1226 ret = wait_for_completion_timeout(&channel->intent_req_comp, 10 * HZ); in qcom_glink_request_intent()
1231 ret = channel->intent_req_result ? 0 : -ECANCELED; in qcom_glink_request_intent()
1235 mutex_unlock(&channel->intent_req_lock); in qcom_glink_request_intent()
1239 static int __qcom_glink_send(struct glink_channel *channel, in __qcom_glink_send() argument
1242 struct qcom_glink *glink = channel->glink; in __qcom_glink_send()
1256 spin_lock_irqsave(&channel->intent_lock, flags); in __qcom_glink_send()
1257 idr_for_each_entry(&channel->riids, tmp, iid) { in __qcom_glink_send()
1269 spin_unlock_irqrestore(&channel->intent_lock, flags); in __qcom_glink_send()
1278 ret = qcom_glink_request_intent(glink, channel, len); in __qcom_glink_send()
1287 req.msg.param1 = cpu_to_le16(channel->lcid); in __qcom_glink_send()
1303 struct glink_channel *channel = to_glink_channel(ept); in qcom_glink_send() local
1305 return __qcom_glink_send(channel, data, len, true); in qcom_glink_send()
1310 struct glink_channel *channel = to_glink_channel(ept); in qcom_glink_trysend() local
1312 return __qcom_glink_send(channel, data, len, false); in qcom_glink_trysend()
1316 * Finds the device_node for the glink child interested in this channel.
1319 const char *channel) in qcom_glink_match_channel() argument
1332 if (strcmp(name, channel) == 0) in qcom_glink_match_channel()
1353 struct glink_channel *channel = to_glink_channel(rpdev->ept); in qcom_glink_rpdev_release() local
1355 channel->rpdev = NULL; in qcom_glink_rpdev_release()
1362 struct glink_channel *channel; in qcom_glink_rx_open() local
1371 idr_for_each_entry(&glink->lcids, channel, lcid) { in qcom_glink_rx_open()
1372 if (!strcmp(channel->name, name)) in qcom_glink_rx_open()
1377 if (!channel) { in qcom_glink_rx_open()
1378 channel = qcom_glink_alloc_channel(glink, name); in qcom_glink_rx_open()
1379 if (IS_ERR(channel)) in qcom_glink_rx_open()
1380 return PTR_ERR(channel); in qcom_glink_rx_open()
1387 ret = idr_alloc(&glink->rcids, channel, rcid, rcid + 1, GFP_ATOMIC); in qcom_glink_rx_open()
1389 dev_err(glink->dev, "Unable to insert channel into rcid list\n"); in qcom_glink_rx_open()
1393 channel->rcid = ret; in qcom_glink_rx_open()
1396 complete(&channel->open_req); in qcom_glink_rx_open()
1405 rpdev->ept = &channel->ept; in qcom_glink_rx_open()
1420 channel->rpdev = rpdev; in qcom_glink_rx_open()
1429 idr_remove(&glink->rcids, channel->rcid); in qcom_glink_rx_open()
1430 channel->rcid = 0; in qcom_glink_rx_open()
1435 kref_put(&channel->refcount, qcom_glink_channel_release); in qcom_glink_rx_open()
1443 struct glink_channel *channel; in qcom_glink_rx_close() local
1447 channel = idr_find(&glink->rcids, rcid); in qcom_glink_rx_close()
1449 if (WARN(!channel, "close request on unknown channel\n")) in qcom_glink_rx_close()
1453 cancel_work_sync(&channel->intent_work); in qcom_glink_rx_close()
1455 if (channel->rpdev) { in qcom_glink_rx_close()
1456 strncpy(chinfo.name, channel->name, sizeof(chinfo.name)); in qcom_glink_rx_close()
1463 qcom_glink_send_close_ack(glink, channel->rcid); in qcom_glink_rx_close()
1466 idr_remove(&glink->rcids, channel->rcid); in qcom_glink_rx_close()
1467 channel->rcid = 0; in qcom_glink_rx_close()
1470 kref_put(&channel->refcount, qcom_glink_channel_release); in qcom_glink_rx_close()
1475 struct glink_channel *channel; in qcom_glink_rx_close_ack() local
1479 channel = idr_find(&glink->lcids, lcid); in qcom_glink_rx_close_ack()
1480 if (WARN(!channel, "close ack on unknown channel\n")) { in qcom_glink_rx_close_ack()
1485 idr_remove(&glink->lcids, channel->lcid); in qcom_glink_rx_close_ack()
1486 channel->lcid = 0; in qcom_glink_rx_close_ack()
1489 kref_put(&channel->refcount, qcom_glink_channel_release); in qcom_glink_rx_close_ack()
1586 dev_err(dev, "failed to acquire IPC channel\n"); in qcom_glink_native_probe()
1619 struct glink_channel *channel; in qcom_glink_native_remove() local
1633 idr_for_each_entry(&glink->lcids, channel, cid) in qcom_glink_native_remove()
1634 kref_put(&channel->refcount, qcom_glink_channel_release); in qcom_glink_native_remove()