Lines Matching defs:msg
43 volatile struct ump_message *msg;
47 msg = ump_chan_get_next(chan, &ctrl);
51 msg->data[0] = 123;
52 msg->header.control = ctrl;
64 msg = ump_chan_get_next(chan, &ctrl);
65 msg->header.control = ctrl;
85 volatile struct ump_message *msg;
97 err = ump_chan_recv(chan, &msg);
113 msg = ump_chan_get_next(chan, &ctrl);
114 msg->header.control = ctrl;
116 err = ump_chan_recv(chan, &msg);
124 msg = ump_chan_get_next(chan, &ctrl);
125 msg->data[0] = XPHI_BENCH_STOP_FLAG;
126 msg->header.control = ctrl;
144 volatile struct ump_message *msg;
159 err = ump_chan_recv(uc, &msg);
178 msg = ump_chan_get_next(uc, &ctrl);
184 msg->data[0] = b_idx;
185 msg->header.control = ctrl;
189 err = ump_chan_recv(uc, &msg);
193 buf_idx = msg->data[0];
205 msg = ump_chan_get_next(uc, &ctrl);
206 assert(msg);
207 msg->data[0] = b_idx;
208 msg->header.control = ctrl;
212 err = ump_chan_recv(uc, &msg);
214 buf_idx = msg->data[0];
227 msg = ump_chan_get_next(uc, &ctrl);
228 msg->data[0] = XPHI_BENCH_STOP_FLAG;
229 msg->header.control = ctrl;
254 volatile struct ump_message *msg;
277 err = ump_chan_recv(uc, &msg);
300 msg = ump_chan_get_next(uc, &ctrl);
301 if (!msg) {
306 XPHI_BENCH_DBG("sending message [%lu] %p\n", b_idx, msg);
307 msg->data[0] = b_idx;
308 msg->header.control = ctrl;
314 err = ump_chan_recv(uc, &msg);
316 buf_idx = msg->data[0];
327 err = ump_chan_recv(uc, &msg);
329 buf_idx = msg->data[0];
353 msg = ump_chan_get_next(uc, &ctrl);
354 msg->data[0] = XPHI_BENCH_STOP_FLAG;
355 msg->header.control = ctrl;