Function list_channel

components/lwp/lwp_ipc.c:1267–1328

}

static int list_channel(void)
{
    rt_channel_t *channels;
    rt_ubase_t index, count;
    struct rt_object *object;
    struct rt_list_node *node;
    struct rt_object_information *information;

    RT_DEBUG_NOT_IN_INTERRUPT;

    const char *stat_strs[] = {"idle", "wait", "active"};

    information = rt_object_get_information(RT_Object_Class_Channel);
    RT_ASSERT(information != RT_NULL);

    count = 0;
    rt_mutex_take(&_chn_obj_lock, RT_WAITING_FOREVER);
    /* get the count of IPC channels */
    for (node = information->object_list.next;
         node != &(information->object_list);
         node = node->next)
    {
        count++;
    }
    rt_mutex_release(&_chn_obj_lock);

    if (count == 0)
        return 0;

    channels = (rt_channel_t *)rt_calloc(count, sizeof(rt_channel_t));
    if (channels == RT_NULL)
        return 0; /* out of memory */

    rt_mutex_take(&_chn_obj_lock, RT_WAITING_FOREVER);
    /* retrieve pointer of IPC channels */
    for (index = 0, node = information->object_list.next;
         index < count && node != &(information->object_list);
         node = node->next)
    {
        object = rt_list_entry(node, struct rt_object, list);

        channels[index] = (rt_channel_t)object;
        index++;
    }
    rt_mutex_release(&_chn_obj_lock);

    rt_kprintf(" channel state\n");
    rt_kprintf("-------- -------\n");
    for (index = 0; index < count; index++)
    {
        if (channels[index] != RT_NULL)
        {
            rt_kprintf("%-*.s", RT_NAME_MAX, channels[index]->parent.parent.name);
            if (channels[index]->stat < 3)
                rt_kprintf(" %s\n", stat_strs[channels[index]->stat]);
        }
    }