Searched refs:msg_st (Results 1 - 15 of 15) sorted by relevance

/barrelfish-2018-10-04/usr/drivers/xeon_phi/
H A Dxphi_service.c121 static errval_t chan_open_call_tx(struct txq_msg_st* msg_st) argument
123 struct xphi_svc_msg_st *xphi_st = (struct xphi_svc_msg_st *) msg_st;
125 return xeon_phi_chan_open_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
132 static errval_t chan_open_request_response_tx(struct txq_msg_st* msg_st) argument
134 return xeon_phi_chan_open_request_response__tx(msg_st->queue->binding,
135 TXQCONT(msg_st), msg_st->err);
138 static errval_t kill_response_tx(struct txq_msg_st* msg_st) argument
140 return xeon_phi_kill_response__tx(msg_st
144 spawn_with_cap_response_tx(struct txq_msg_st* msg_st) argument
154 spawn_response_tx(struct txq_msg_st* msg_st) argument
162 domain_init_response_tx(struct txq_msg_st* msg_st) argument
168 domain_register_response_tx(struct txq_msg_st* msg_st) argument
174 domain_lookup_response_tx(struct txq_msg_st* msg_st) argument
182 domain_wait_response_tx(struct txq_msg_st* msg_st) argument
205 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue); local
229 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue); local
251 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue); local
286 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue); local
338 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue); local
363 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue); local
394 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue); local
426 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue); local
587 struct txq_msg_st *msg_st = txq_msg_st_alloc(&st->queue); local
620 struct txq_msg_st *msg_st = txq_msg_st_alloc(&st->queue); local
[all...]
H A Dinterphi.c194 struct txq_msg_st *msg_st = txq_msg_st_alloc(&mi->queue); local
195 if (msg_st == NULL) {
199 msg_st->cleanup = NULL;
201 return msg_st;
239 static errval_t domain_wait_call_tx(struct txq_msg_st *msg_st) argument
241 struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
245 return interphi_domain_wait_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
252 static errval_t domain_wait_response_tx(struct txq_msg_st *msg_st) argument
254 struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
266 domain_lookup_call_tx(struct txq_msg_st *msg_st) argument
279 domain_lookup_response_tx(struct txq_msg_st *msg_st) argument
292 domain_register_call_tx(struct txq_msg_st *msg_st) argument
306 domain_register_response_tx(struct txq_msg_st *msg_st) argument
314 spawn_response_tx(struct txq_msg_st *msg_st) argument
322 spawn_call_tx(struct txq_msg_st *msg_st) argument
333 spawn_with_cap_response_tx(struct txq_msg_st *msg_st) argument
343 spawn_with_cap_call_tx(struct txq_msg_st *msg_st) argument
357 kill_response_tx(struct txq_msg_st *msg_st) argument
363 kill_call_tx(struct txq_msg_st *msg_st) argument
371 bootstrap_response_tx(struct txq_msg_st *msg_st) argument
377 bootstrap_call_tx(struct txq_msg_st *msg_st) argument
389 chan_open_call_tx(struct txq_msg_st *msg_st) argument
400 chan_open_response_tx(struct txq_msg_st *msg_st) argument
581 struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue); local
648 struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue); local
714 struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue); local
758 struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue); local
814 struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue); local
1250 struct txq_msg_st *msg_st = rpc_preamble(mi); local
1294 struct txq_msg_st *msg_st = rpc_preamble(mi); local
1353 struct txq_msg_st *msg_st = rpc_preamble(mi); local
1399 struct txq_msg_st *msg_st = rpc_preamble(mi); local
1448 struct txq_msg_st *msg_st = rpc_preamble(mi); local
1500 struct txq_msg_st *msg_st = rpc_preamble(mi); local
1542 struct txq_msg_st *msg_st = rpc_preamble(mi); local
1589 struct txq_msg_st *msg_st = txq_msg_st_alloc(&mi->queue); local
1634 struct txq_msg_st *msg_st = txq_msg_st_alloc(&mi->queue); local
[all...]
/barrelfish-2018-10-04/lib/dma/
H A Ddma_service.c83 static errval_t dma_register_response_tx(struct txq_msg_st *msg_st) argument
85 struct dma_binding *b = msg_st->queue->binding;
87 return dma_register__response__tx(b, TXQCONT(msg_st), msg_st->err);
95 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_handle->queue); local
96 if (msg_st == NULL) {
100 msg_st->send = dma_register_response_tx;
105 msg_st->err = DMA_ERR_SVC_REJECT;
108 txq_send(msg_st);
117 static errval_t dma_deregister_response_tx(struct txq_msg_st *msg_st) argument
129 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_handle->queue); local
151 dma_memcpy_response_tx(struct txq_msg_st *msg_st) argument
171 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_handle->queue); local
202 dma_done_tx(struct txq_msg_st *msg_st) argument
397 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_handle->queue); local
[all...]
/barrelfish-2018-10-04/usr/device_managers/dma/
H A Ddma_mgr_svc.c67 static errval_t svc_register_response_tx(struct txq_msg_st *msg_st) argument
70 return dma_mgr_register_driver_response__tx(msg_st->queue->binding,
71 TXQCONT(msg_st), msg_st->err);
88 struct txq_msg_st *msg_st = txq_msg_st_alloc(txq); local
89 if (msg_st == NULL) {
93 msg_st->send = svc_register_response_tx;
95 msg_st->err = driver_store_insert(mem_low, mem_high, numa_node, type, iref);
97 if (err_is_ok(msg_st->err)) {
107 txq_send(msg_st);
116 svc_lookup_response_tx(struct txq_msg_st *msg_st) argument
134 svc_lookup_by_iref_response_tx(struct txq_msg_st *msg_st) argument
163 struct txq_msg_st *msg_st = txq_msg_st_alloc(txq); local
184 struct txq_msg_st *msg_st = txq_msg_st_alloc(txq); local
[all...]
/barrelfish-2018-10-04/lib/bomp/backends/
H A Dxomp_gateway.c162 static errval_t get_memory_response_tx(struct txq_msg_st *msg_st) argument
164 struct xh_msg_st *st = (struct xh_msg_st *) msg_st;
166 return xomp_gateway_get_memory_response__tx(msg_st->queue->binding,
167 TXQCONT(msg_st), msg_st->err,
184 struct txq_msg_st *msg_st = txq_msg_st_alloc(txq); local
185 assert(msg_st != NULL);
187 msg_st->cleanup = NULL;
188 msg_st->send = get_memory_response_tx;
193 msg_st
[all...]
H A Dxomp_gateway_client.c77 static errval_t get_memory_call_tx(struct txq_msg_st *msg_st) argument
80 struct xgw_msg_st *st = (struct xgw_msg_st *) msg_st;
82 return xomp_gateway_get_memory_call__tx(msg_st->queue->binding,
83 TXQCONT(msg_st), st->addr, st->token);
187 struct txq_msg_st *msg_st = txq_msg_st_alloc(&txq); local
188 if (msg_st == NULL) {
192 msg_st->cleanup = NULL;
193 msg_st->send = get_memory_call_tx;
195 struct xgw_msg_st *st = (struct xgw_msg_st *) msg_st;
200 txq_send(msg_st);
[all...]
H A Dxomp_worker.c307 static errval_t gw_req_memory_response_tx(struct txq_msg_st *msg_st) argument
309 return xomp_gw_req_memory_response__tx(msg_st->queue->binding, TXQCONT(msg_st),
310 msg_st->err);
313 static errval_t add_memory_response_tx(struct txq_msg_st *msg_st) argument
315 return xomp_add_memory_response__tx(msg_st->queue->binding, TXQCONT(msg_st),
316 msg_st->err);
319 static errval_t done_notify_tx(struct txq_msg_st *msg_st) argument
321 struct xomp_msg_st *st = (struct xomp_msg_st *) msg_st;
327 done_with_arg_tx(struct txq_msg_st *msg_st) argument
354 struct txq_msg_st *msg_st = txq_msg_st_alloc(&txq); local
424 struct txq_msg_st *msg_st = txq_msg_st_alloc(&txq); local
494 struct txq_msg_st *msg_st = txq_msg_st_alloc(&txq); local
[all...]
H A Dxomp_master.c247 static errval_t do_work_tx(struct txq_msg_st *msg_st) argument
250 struct xomp_msg_st *st = (struct xomp_msg_st *) msg_st;
252 return xomp_do_work__tx(msg_st->queue->binding, TXQCONT(msg_st),
257 static errval_t gw_req_memory_call_tx(struct txq_msg_st *msg_st) argument
260 struct xomp_msg_st *st = (struct xomp_msg_st *) msg_st;
262 return xomp_gw_req_memory_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
267 static errval_t add_memory_call_tx(struct txq_msg_st *msg_st) argument
270 struct xomp_msg_st *st = (struct xomp_msg_st *) msg_st;
953 struct txq_msg_st *msg_st = txq_msg_st_alloc(&worker->txq); local
981 struct txq_msg_st *msg_st = txq_msg_st_alloc(&worker->txq); local
1218 struct txq_msg_st *msg_st = txq_msg_st_alloc(&worker->txq); local
[all...]
/barrelfish-2018-10-04/lib/xeon_phi/
H A Dxeon_phi_client.c197 static errval_t domain_init_call_tx(struct txq_msg_st *msg_st) argument
199 struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
201 return xeon_phi_domain_init_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
207 static errval_t domain_register_call_tx(struct txq_msg_st *msg_st) argument
209 struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
211 return xeon_phi_domain_register_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
215 static errval_t domain_lookup_call_tx(struct txq_msg_st *msg_st) argument
217 struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
223 domain_wait_call_tx(struct txq_msg_st *msg_st) argument
232 spawn_call_tx(struct txq_msg_st *msg_st) argument
241 spawn_with_cap_call_tx(struct txq_msg_st *msg_st) argument
252 kill_call_tx(struct txq_msg_st *msg_st) argument
259 chan_open_request_call_tx(struct txq_msg_st *msg_st) argument
270 chan_open_response_tx(struct txq_msg_st *msg_st) argument
412 struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq); local
456 struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq); local
683 struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq); local
785 struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq); local
863 struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq); local
[all...]
/barrelfish-2018-10-04/lib/bomp_new/
H A Dbomp_thread.c76 struct bomp_msg_st *msg_st = (struct bomp_msg_st *)st; local
77 *(msg_st->message_sent) = 1;
80 static errval_t execute__tx(struct txq_msg_st *msg_st) argument
82 struct bomp_msg_st *st = (struct bomp_msg_st *)msg_st;
84 return bomp_execute__tx(msg_st->queue->binding, TXQCONT(msg_st),
218 struct txq_msg_st *msg_st = txq_msg_st_alloc(&thread->txq); local
219 if (msg_st == NULL) {
225 msg_st->send = execute__tx;
226 msg_st
258 done__tx(struct txq_msg_st *msg_st) argument
298 struct txq_msg_st *msg_st = txq_msg_st_alloc(&t->txq); local
[all...]
/barrelfish-2018-10-04/usr/monitor/capops/
H A Dmove.c47 struct move_request_msg_st *msg_st = (struct move_request_msg_st*)e; local
48 err = intermon_capops_move_request__tx(b, NOP_CONT, msg_st->caprep,
49 msg_st->relations, (lvaddr_t)msg_st->st);
63 struct cap_move_rpc_st *rpc_st = (struct cap_move_rpc_st*)msg_st->st;
69 free(msg_st);
86 struct move_request_msg_st *msg_st = malloc(sizeof(struct move_request_msg_st)); local
87 if (!msg_st) {
91 msg_st->queue_elem.cont = move_request_send_cont;
92 capability_to_caprep(cap, &msg_st
120 struct move_result_msg_st *msg_st = (struct move_result_msg_st*)e; local
145 struct move_result_msg_st *msg_st = calloc(1, sizeof(struct move_result_msg_st)); local
[all...]
H A Dcopy.c79 struct recv_copy_result_msg_st *msg_st = (struct recv_copy_result_msg_st*)e; local
80 err = intermon_capops_recv_copy_result__tx(b, NOP_CONT, msg_st->status,
81 msg_st->capaddr, msg_st->level,
82 msg_st->slot, msg_st->st);
96 free(msg_st);
110 struct recv_copy_result_msg_st *msg_st = calloc(1, sizeof(struct recv_copy_result_msg_st)); local
111 if (!msg_st) {
114 msg_st
153 struct owner_copy_msg_st *msg_st = (struct owner_copy_msg_st*)e; local
275 struct owner_copy_msg_st *msg_st; local
320 struct request_copy_msg_st *msg_st = (struct request_copy_msg_st*)e; local
375 struct request_copy_msg_st *msg_st; local
[all...]
H A Dcapsend.c77 struct capsend_mc_msg_st *msg_st = (struct capsend_mc_msg_st*)e; local
78 struct capsend_mc_st *mc_st = msg_st->mc_st;
88 err = capsend_target(msg_st->dest, (struct msg_queue_elem*)msg_st);
112 // get next msg_st
113 struct capsend_mc_msg_st *msg_st = &mc_st->msg_st_arr[mc_st->num_queued]; local
114 msg_st->queue_elem.cont = capsend_mc_send_cont;
115 msg_st->mc_st = mc_st;
116 msg_st->dest = dest;
118 err = capsend_target(dest, (struct msg_queue_elem*)msg_st);
306 struct find_cap_result_msg_st *msg_st = (struct find_cap_result_msg_st*)e; local
332 struct find_cap_result_msg_st *msg_st = calloc(1, sizeof(struct find_cap_result_msg_st)); local
477 struct find_descendants_result_msg_st *msg_st; local
514 struct find_descendants_result_msg_st *msg_st; local
630 struct check_retypeable_result_msg_st *msg_st; local
669 struct check_retypeable_result_msg_st *msg_st; local
769 struct owner_updated_msg_st *msg_st = (struct owner_updated_msg_st*)e; local
794 struct owner_updated_msg_st *msg_st = calloc(1, sizeof(struct owner_updated_msg_st)); local
[all...]
H A Ddelete.c185 struct delete_remote_result_msg_st *msg_st = (struct delete_remote_result_msg_st*)e; local
186 err = intermon_capops_delete_remote_result__tx(b, NOP_CONT, msg_st->status, msg_st->st);
200 free(msg_st);
209 struct delete_remote_result_msg_st *msg_st; local
210 err = calloce(1, sizeof(*msg_st), &msg_st);
213 msg_st->queue_elem.cont = delete_remote_result__send;
214 msg_st->status = status;
215 msg_st
[all...]
/barrelfish-2018-10-04/lib/dma/client/
H A Ddma_client_channel.c208 static errval_t dma_client_channel_register_call_tx(struct txq_msg_st *msg_st) argument
210 struct svc_msg_st *st = (struct svc_msg_st *) msg_st;
212 return dma_register__call__tx(msg_st->queue->binding, TXQCONT(msg_st),
216 static errval_t dma_client_channel_deregister_call_tx(struct txq_msg_st *msg_st) argument
218 struct svc_msg_st *st = (struct svc_msg_st *) msg_st;
220 return dma_deregister_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
224 static errval_t dma_client_channel_memcpy_call_tx(struct txq_msg_st *msg_st) argument
226 struct svc_msg_st *st = (struct svc_msg_st *) msg_st;
361 struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl_chan->txq); local
[all...]

Completed in 154 milliseconds