37     .id  = {.name = "vbus"},
47     .id  = {.name = "vbus"},
129     rt_uint8_t id;  member
237         rt_wm_que_dec(&_chn_wm_que[dpkg.id]);  in _bus_out_entry()
240         if (!_chn_connected(dpkg.id))  in _bus_out_entry()
246                    "(data: %p, len: %d, prio: %d, id: %d)\n",  in _bus_out_entry()
247                    dpkg.data, dpkg.len, dpkg.prio, dpkg.id);  in _bus_out_entry()
272         RT_VBUS_OUT_RING->blks[RT_VBUS_OUT_RING->put_idx].id  = dpkg.id;  in _bus_out_entry()
310             _vbus_indicate(RT_VBUS_EVENT_ID_TX, dpkg.id);  in _bus_out_entry()
322 rt_err_t rt_vbus_post(rt_uint8_t id,  in rt_vbus_post()  argument
341     if (id >= RT_VBUS_CHANNEL_NR)  in rt_vbus_post()
350     while (_chn_status[id] == RT_VBUS_CHN_ST_SUSPEND)  in rt_vbus_post()
366         rt_list_insert_after(&_chn_suspended_threads[id], &thread->tlist);  in rt_vbus_post()
382     if (_chn_status[id] != RT_VBUS_CHN_ST_ESTABLISHED)  in rt_vbus_post()
386     pkg.id   = id;  in rt_vbus_post()
407         err = rt_wm_que_inc(&_chn_wm_que[id], timeout);  in rt_vbus_post()
502 void rt_vbus_data_push(unsigned int id, struct rt_vbus_data *act)  in rt_vbus_data_push()  argument
506     RT_ASSERT(0 < id && id < RT_VBUS_CHANNEL_NR);  in rt_vbus_data_push()
510     if (_bus_in_action[id][_IN_ACT_HEAD] == RT_NULL)  in rt_vbus_data_push()
512         _bus_in_action[id][_IN_ACT_HEAD] = act;  in rt_vbus_data_push()
513         _bus_in_action[id][_IN_ACT_TAIL] = act;  in rt_vbus_data_push()
517         _bus_in_action[id][_IN_ACT_TAIL]->next = act;  in rt_vbus_data_push()
518         _bus_in_action[id][_IN_ACT_TAIL] = act;  in rt_vbus_data_push()
522     _bus_in_action_nr[id]++;  in rt_vbus_data_push()
528     _chn_recv_wm[id].level++;  in rt_vbus_data_push()
529     if (_chn_recv_wm[id].level == 0)  in rt_vbus_data_push()
530         _chn_recv_wm[id].level = ~0;  in rt_vbus_data_push()
531     if (_chn_recv_wm[id].level > _chn_recv_wm[id].high_mark &&  in rt_vbus_data_push()
532         _chn_recv_wm[id].level > _chn_recv_wm[id].last_warn)  in rt_vbus_data_push()
537         buf[1] = id;  in rt_vbus_data_push()
541         _chn_recv_wm[id].last_warn = _chn_recv_wm[id].level + 100;  in rt_vbus_data_push()
546 struct rt_vbus_data* rt_vbus_data_pop(unsigned int id)  in rt_vbus_data_pop()  argument
551     RT_ASSERT(0 < id && id < RT_VBUS_CHANNEL_NR);  in rt_vbus_data_pop()
555     act = _bus_in_action[id][_IN_ACT_HEAD];  in rt_vbus_data_pop()
558         _bus_in_action[id][_IN_ACT_HEAD] = act->next;  in rt_vbus_data_pop()
564     if (_chn_recv_wm[id].level != 0)  in rt_vbus_data_pop()
566         _chn_recv_wm[id].level--;  in rt_vbus_data_pop()
567         if (_chn_recv_wm[id].level <= _chn_recv_wm[id].low_mark &&  in rt_vbus_data_pop()
568             _chn_recv_wm[id].last_warn > _chn_recv_wm[id].low_mark)  in rt_vbus_data_pop()
573             buf[1] = id;  in rt_vbus_data_pop()
576             _chn_recv_wm[id].last_warn = 0;  in rt_vbus_data_pop()
1060             unsigned int id, nxtidx;  in _bus_in_entry()  local
1066             id = RT_VBUS_IN_RING->blks[RT_VBUS_IN_RING->get_idx].id;  in _bus_in_entry()
1068             vbus_debug("vmm bus in: chnr %d, size %d\n", id, size);  in _bus_in_entry()
1071             if (id > RT_VBUS_CHANNEL_NR || !_chn_connected(id))  in _bus_in_entry()
1073                 vbus_error("drop on invalid chn %d\n", id);  in _bus_in_entry()
1079             if (id == 0)  in _bus_in_entry()
1096                 //vbus_error("drop on OOM (%d, %d)\n", id, size);  in _bus_in_entry()
1134             rt_vbus_data_push(id, act);  in _bus_in_entry()
1135             _vbus_indicate(RT_VBUS_EVENT_ID_RX, id);  in _bus_in_entry()
1136             event_set |= 1 << id;  in _bus_in_entry()