/barrelfish-2018-10-04/usr/drivers/xeon_phi/ |
H A D | xphi_service.c | 121 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 D | interphi.c | 194 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 D | dma_service.c | 83 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 D | dma_mgr_svc.c | 67 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 D | xomp_gateway.c | 162 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 D | xomp_gateway_client.c | 77 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 D | xomp_worker.c | 307 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 D | xomp_master.c | 247 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 D | xeon_phi_client.c | 197 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 D | bomp_thread.c | 76 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 D | move.c | 47 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 D | copy.c | 79 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 D | capsend.c | 77 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 D | delete.c | 185 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 D | dma_client_channel.c | 208 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...] |