lib/xeon_phi/xeon_phi_client.c

215 static errval_t domain_init_call_tx(struct txq_msg_st *msg_st)
217     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
219     return xeon_phi_domain_init_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
225 static errval_t domain_register_call_tx(struct txq_msg_st *msg_st)
227     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
229     return xeon_phi_domain_register_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
233 static errval_t domain_lookup_call_tx(struct txq_msg_st *msg_st)
235     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
237     return xeon_phi_domain_lookup_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
241 static errval_t domain_wait_call_tx(struct txq_msg_st *msg_st)
243     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
245     return xeon_phi_domain_wait_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
250 static errval_t spawn_call_tx(struct txq_msg_st *msg_st)
252     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
253     return xeon_phi_spawn_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
259 static errval_t spawn_with_cap_call_tx(struct txq_msg_st *msg_st)
261     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
262     return xeon_phi_spawn_with_cap_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
270 static errval_t kill_call_tx(struct txq_msg_st *msg_st)
272     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
273     return xeon_phi_kill_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
277 static errval_t chan_open_request_call_tx(struct txq_msg_st *msg_st)
279     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
280     return xeon_phi_chan_open_request_call__tx(msg_st->queue->binding,
281                                                TXQCONT(msg_st), st->args.open.xid,
288 static errval_t dma_register_call_tx(struct txq_msg_st *msg_st)
290     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
291     return xeon_phi_dma_register_call__tx(msg_st->queue->binding,
292                                           TXQCONT(msg_st),
296 static errval_t dma_memcpy_call_tx(struct txq_msg_st *msg_st)
298     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
299     return xeon_phi_dma_memcpy_call__tx(msg_st->queue->binding,
300                                           TXQCONT(msg_st),
306 static errval_t get_nodeid_call_tx(struct txq_msg_st *msg_st)
308     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
309     return xeon_phi_get_nodeid_call__tx(msg_st->queue->binding,
310                                         TXQCONT(msg_st),
314 static errval_t chan_open_response_tx(struct txq_msg_st *msg_st)
316     return xeon_phi_chan_open_response__tx(msg_st->queue->binding, TXQCONT(msg_st),
317                                            msg_st->err);
320 static errval_t alloc_mem_call_tx(struct txq_msg_st *msg_st)
322     struct xphi_msg_st *st = (struct xphi_msg_st *) msg_st;
323     return xeon_phi_alloc_mem_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
528     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
529     if (msg_st == NULL) {
533     msg_st->cleanup = NULL;
534     msg_st->send = chan_open_response_tx;
535     msg_st->err = XEON_PHI_ERR_CLIENT_OPEN_REJECT;
538         msg_st->err = client_cb.open(domain, usrdata, msgframe, type);
541     txq_send(msg_st);
576     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
577     if (msg_st == NULL) {
582     msg_st->cleanup = NULL;
583     msg_st->send = domain_init_call_tx;
585     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
595     txq_send(msg_st);
803     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
804     if (msg_st == NULL) {
830     msg_st->cleanup = NULL;
834         msg_st->send = spawn_call_tx;
837         msg_st->send = spawn_with_cap_call_tx;
842     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
850     txq_send(msg_st);
905     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
906     if (msg_st == NULL) {
911     msg_st->cleanup = NULL;
912     msg_st->send = kill_call_tx;
914     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
921     txq_send(msg_st);
983     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
984     if (msg_st == NULL) {
989     msg_st->cleanup = NULL;
993     msg_st->send = chan_open_request_call_tx;
995     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
1003     txq_send(msg_st);
1048     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
1049     if (msg_st == NULL) {
1054     msg_st->cleanup = NULL;
1058     msg_st->send = domain_lookup_call_tx;
1060     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
1064     txq_send(msg_st);
1127     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
1128     if (msg_st == NULL) {
1134     msg_st->cleanup = NULL;
1138     msg_st->send = domain_wait_call_tx;
1140     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
1144     txq_send(msg_st);
1197     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
1198     if (msg_st == NULL) {
1203     msg_st->cleanup = NULL;
1204     msg_st->send = domain_register_call_tx;
1206     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
1214     txq_send(msg_st);
1278     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
1279     if (msg_st == NULL) {
1284     msg_st->cleanup = NULL;
1288     msg_st->send = get_nodeid_call_tx;
1290     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
1294     txq_send(msg_st);
1336     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
1337     if (msg_st == NULL) {
1342     msg_st->cleanup = NULL;
1346     msg_st->send = dma_register_call_tx;
1348     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
1352     txq_send(msg_st);
1391     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
1392     if (msg_st == NULL) {
1397     msg_st->cleanup = NULL;
1399     msg_st->send = dma_memcpy_call_tx;
1401     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
1407     txq_send(msg_st);
1447     struct txq_msg_st *msg_st = txq_msg_st_alloc(&cl->txq);
1448     if (msg_st == NULL) {
1453     msg_st->cleanup = NULL;
1457     msg_st->send = alloc_mem_call_tx;
1459     struct xphi_msg_st *svc_st = (struct xphi_msg_st *) msg_st;
1463     txq_send(msg_st);