Lines Matching refs:channel
24 * dump pending message TID's for given channel
26 static void pending_msg_dump(struct bulk_channel *channel)
28 assert(channel);
29 thread_mutex_lock_nested(&CHANNEL_DATA(channel)->mutex);
31 struct bulk_sm_pending_msg *node = CHANNEL_DATA(channel)->root;
32 debug_printf("Dumping pending message TID's for channel %p.\n", channel);
38 thread_mutex_unlock(&CHANNEL_DATA(channel)->mutex);
43 * add the data to the list of pending messages in channel
46 * @param channel: Channel this message belongs to
50 errval_t pending_msg_add(struct bulk_channel* channel,
54 assert(channel);
68 // pending_msg_dump(channel);
70 thread_mutex_lock(&CHANNEL_DATA(channel)->mutex);
71 struct bulk_sm_pending_msg *node = CHANNEL_DATA(channel)->root;
74 CHANNEL_DATA(channel)->root = p;
76 thread_mutex_unlock(&CHANNEL_DATA(channel)->mutex);
78 // pending_msg_dump(channel);
89 thread_mutex_unlock(&CHANNEL_DATA(channel)->mutex);
91 // pending_msg_dump(channel);
104 CHANNEL_DATA(channel)->root = p;
108 thread_mutex_unlock(&CHANNEL_DATA(channel)->mutex);
110 // pending_msg_dump(channel);
116 // node = CHANNEL_DATA(channel)->root; // XXX WRONG. root could be NULL -- jb
117 thread_mutex_unlock(&CHANNEL_DATA(channel)->mutex);
119 pending_msg_add(channel, tid, data); // XXX does copy of data recursively :-(
129 * @param channel: Channel this message belongs to
134 errval_t pending_msg_get(struct bulk_channel *channel,
139 assert(channel);
141 thread_mutex_lock(&CHANNEL_DATA(channel)->mutex);
142 struct bulk_sm_pending_msg *p = CHANNEL_DATA(channel)->root;
145 if (0) pending_msg_dump(channel); // defined but not used :-(
164 CHANNEL_DATA(channel)->root = p->next;
170 thread_mutex_unlock(&CHANNEL_DATA(channel)->mutex);
174 thread_mutex_unlock(&CHANNEL_DATA(channel)->mutex);