drivers/xeon_phi/interphi.c

218     struct txq_msg_st *msg_st = txq_msg_st_alloc(&mi->queue);
219     if (msg_st == NULL) {
223     msg_st->cleanup = NULL;
225     return msg_st;
263 static errval_t domain_wait_call_tx(struct txq_msg_st *msg_st)
265     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
269     return interphi_domain_wait_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
276 static errval_t domain_wait_response_tx(struct txq_msg_st *msg_st)
278     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
280     return interphi_domain_wait_response__tx(msg_st->queue->binding,
281                     TXQCONT(msg_st),
284                     msg_st->err);
290 static errval_t domain_lookup_call_tx(struct txq_msg_st *msg_st)
292     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
296     return interphi_domain_lookup_call__tx(msg_st->queue->binding,
297                                            TXQCONT(msg_st), st->args.domain.name,
303 static errval_t domain_lookup_response_tx(struct txq_msg_st *msg_st)
305     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
307     return interphi_domain_lookup_response__tx(msg_st->queue->binding,
308                     TXQCONT(msg_st),
309                     st->args.domain.domid, msg_st->err);
316 static errval_t domain_register_call_tx(struct txq_msg_st *msg_st)
318     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
322     return interphi_domain_register_call__tx(msg_st->queue->binding,
323                                              TXQCONT(msg_st),
330 static errval_t domain_register_response_tx(struct txq_msg_st *msg_st)
332     return interphi_domain_register_response__tx(msg_st->queue->binding,
333                     TXQCONT(msg_st), SYS_ERR_OK);
338 static errval_t spawn_response_tx(struct txq_msg_st *msg_st)
340     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
342     return interphi_spawn_response__tx(msg_st->queue->binding, TXQCONT(msg_st),
343                                        st->args.spawn_reply.domainid, msg_st->err);
346 static errval_t spawn_call_tx(struct txq_msg_st *msg_st)
348     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
350     return interphi_spawn_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
357 static errval_t spawn_with_cap_response_tx(struct txq_msg_st *msg_st)
359     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
361     return interphi_spawn_with_cap_response__tx(msg_st->queue->binding,
362                                                 TXQCONT(msg_st),
364                                                 msg_st->err);
367 static errval_t spawn_with_cap_call_tx(struct txq_msg_st *msg_st)
369     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
371     return interphi_spawn_with_cap_call__tx(msg_st->queue->binding,
372                                             TXQCONT(msg_st),
381 static errval_t kill_response_tx(struct txq_msg_st *msg_st)
383     return interphi_kill_response__tx(msg_st->queue->binding, TXQCONT(msg_st),
384                                       msg_st->err);
387 static errval_t kill_call_tx(struct txq_msg_st *msg_st)
389     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
391     return interphi_kill_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
395 static errval_t bootstrap_response_tx(struct txq_msg_st *msg_st)
397     return interphi_bootstrap_response__tx(msg_st->queue->binding,
398                                            TXQCONT(msg_st), msg_st->err);
401 static errval_t bootstrap_call_tx(struct txq_msg_st *msg_st)
403     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
405     return interphi_bootstrap_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
413 static errval_t chan_open_call_tx(struct txq_msg_st *msg_st)
415     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
417     return interphi_chan_open_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
424 static errval_t chan_open_response_tx(struct txq_msg_st *msg_st)
426     return interphi_chan_open_response__tx(msg_st->queue->binding,
427                                            TXQCONT(msg_st), msg_st->err);
430 static errval_t alloc_mem_call_tx(struct txq_msg_st *msg_st)
432     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
433     return interphi_alloc_mem_call__tx(msg_st->queue->binding, TXQCONT(msg_st),
437 static errval_t alloc_mem_response_tx(struct txq_msg_st *msg_st)
439     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
440     return interphi_alloc_mem_response__tx(msg_st->queue->binding, TXQCONT(msg_st),
467     struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue);
468     if (msg_st == NULL) {
472     msg_st->send = domain_wait_response_tx;
473     msg_st->cleanup = NULL;
475     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
479     msg_st->err = domain_wait(name, local_node, (void *)state, &st->args.domain.domid);
480     switch(err_no(msg_st->err)) {
483             txq_send(msg_st);
487             txq_msg_st_free(msg_st);
491             txq_send(msg_st);
528     struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue);
529     if (msg_st == NULL) {
533     msg_st->send = domain_lookup_response_tx;
534     msg_st->cleanup = NULL;
536     struct interphi_msg_st *st = (struct interphi_msg_st *)msg_st;
538     msg_st->err = domain_lookup(name, &st->args.domain.domid);
540     txq_send(msg_st);
577     struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue);
578     if (msg_st == NULL) {
582     msg_st->err = SYS_ERR_OK;
583     msg_st->send = domain_register_response_tx;
584     msg_st->cleanup = NULL;
586     msg_st->err = domain_register(name, domid);
588     txq_send(msg_st);
621     struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue);
622     if (msg_st == NULL) {
626     msg_st->send = spawn_response_tx;
627     msg_st->cleanup = NULL;
630     msg_st->err = spawn_cmdline_extract_argv((CONST_CAST)cmdline, length, argv, MAX_CMDLINE_ARGS);
631     if (err_is_fail(msg_st->err)) {
632         txq_send(msg_st);
637     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
644     msg_st->err = spawn_program(core, cmdline, argv, NULL, flags, domain);
645     if (err_is_ok(msg_st->err)) {
656     txq_send(msg_st);
688     struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue);
689     if (msg_st == NULL) {
693     msg_st->send = spawn_with_cap_response_tx;
694     msg_st->cleanup = NULL;
697     msg_st->err = spawn_cmdline_extract_argv((CONST_CAST)cmdline, length, argv, MAX_CMDLINE_ARGS);
698     if (err_is_fail(msg_st->err)) {
699         txq_send(msg_st);
704     struct interphi_msg_st *st = (struct interphi_msg_st *) msg_st;
707     msg_st->err = sysmem_cap_request(cap_base, cap_size_bits, &cap);
708     if (err_is_fail(msg_st->err)) {
709         txq_send(msg_st);
717     msg_st->err = cnode_create_l2(&argcn, &argcnref);
718     if (err_is_fail(msg_st->err)) {
720         txq_send(msg_st);
730     msg_st->err = spawn_program_with_caps(core, cmdline, argv, NULL, NULL_CAP,
732     if (err_is_ok(msg_st->err)) {
746     txq_send(msg_st);
773     struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue);
774     if (msg_st == NULL) {
778     msg_st->err = SYS_ERR_OK;
779     msg_st->send = kill_response_tx;
780     msg_st->cleanup = NULL;
785     msg_st->err = spawn_kill(*domain);
787     txq_send(msg_st);
817     struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue);
818     if (msg_st == NULL) {
822     msg_st->err = SYS_ERR_OK;
823     msg_st->send = bootstrap_response_tx;
824     msg_st->cleanup = NULL;
829         txq_send(msg_st);
833     msg_st->err = sysmem_cap_request(base, bits, &msg_frame);
834     if (err_is_fail(msg_st->err)) {
835         txq_send(msg_st);
841     msg_st->err = interphi_init_xphi(xid, phi, msg_frame, is_client);
843     txq_send(msg_st);
873     struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue);
874     if (msg_st == NULL) {
878     msg_st->send = chan_open_response_tx;
879     msg_st->cleanup = NULL;
900         msg_st->err = sysmem_cap_request(msgbase, msgbits, &msgcap);
901         if (err_is_fail(msg_st->err)) {
902             txq_send(msg_st);
907     msg_st->err = xeon_phi_service_open_channel(msgcap, type, target_did,
909     if (err_is_fail(msg_st->err)) {
910         DEBUG_ERR( msg_st->err, "Failed to open the channel!\n");
914     txq_send(msg_st);
938     struct txq_msg_st *msg_st = txq_msg_st_alloc(&local_node->msg->queue);
939     if (msg_st == NULL) {
950     msg_st->err = b->rpc_tx_vtbl.allocate(b, log2ceil(bytes), base, base + bytes,
952     if (err_is_fail(msg_st->err)) {
956     msg_st->err = msgerr;
957     if (err_is_fail(msg_st->err)) {
963     msg_st->err = cap_retype(mreg->cap, ramcap, 0, ObjType_Frame, bytes, 1);
968     struct interphi_msg_st *st = (struct interphi_msg_st*)msg_st;
973     msg_st->send = alloc_mem_response_tx;
974     msg_st->cleanup = NULL;
984     txq_send(msg_st);
1433     struct txq_msg_st *msg_st = rpc_preamble(mi);
1434     if (msg_st == NULL) {
1438     msg_st->send = bootstrap_call_tx;
1440     struct interphi_msg_st *svc_st = (struct interphi_msg_st *) msg_st;
1448     txq_send(msg_st);
1477     struct txq_msg_st *msg_st = rpc_preamble(mi);
1478     if (msg_st == NULL) {
1482     msg_st->send = spawn_call_tx;
1484     struct interphi_msg_st *svc_st = (struct interphi_msg_st *) msg_st;
1491     txq_send(msg_st);
1536     struct txq_msg_st *msg_st = rpc_preamble(mi);
1537     if (msg_st == NULL) {
1541     msg_st->send = spawn_with_cap_call_tx;
1543     struct interphi_msg_st *svc_st = (struct interphi_msg_st *) msg_st;
1559         txq_msg_st_free(msg_st);
1564     txq_send(msg_st);
1593     struct txq_msg_st *msg_st = rpc_preamble(mi);
1594     if (msg_st == NULL) {
1598     msg_st->send = kill_call_tx;
1600     struct interphi_msg_st *svc_st = (struct interphi_msg_st *) msg_st;
1604     txq_send(msg_st);
1642     struct txq_msg_st *msg_st = rpc_preamble(mi);
1643     if (msg_st == NULL) {
1647     struct interphi_msg_st *svc_st = (struct interphi_msg_st *) msg_st;
1655         txq_msg_st_free(msg_st);
1665         txq_msg_st_free(msg_st);
1679         msg_st->send = chan_open_call_tx;
1683         txq_msg_st_free(msg_st);
1687     txq_send(msg_st);
1716     struct txq_msg_st *msg_st = rpc_preamble(mi);
1717     if (msg_st == NULL) {
1720     msg_st->send = domain_register_call_tx;
1722     struct interphi_msg_st *svc_st = (struct interphi_msg_st *) msg_st;
1727     txq_send(msg_st);
1758     struct txq_msg_st *msg_st = rpc_preamble(mi);
1759     if (msg_st == NULL) {
1763     msg_st->send = domain_lookup_call_tx;
1765     struct interphi_msg_st *svc_st = (struct interphi_msg_st *) msg_st;
1769     txq_send(msg_st);
1805     struct txq_msg_st *msg_st = txq_msg_st_alloc(&mi->queue);
1806     if (msg_st == NULL) {
1811     msg_st->send = domain_wait_call_tx;
1812     msg_st->cleanup = NULL;
1814     struct interphi_msg_st *svc_st = (struct interphi_msg_st *) msg_st;
1819     txq_send(msg_st);
1850     struct txq_msg_st *msg_st = txq_msg_st_alloc(&mi->queue);
1851     if (msg_st == NULL) {
1856     msg_st->send = domain_wait_response_tx;
1857     msg_st->cleanup = NULL;
1858     msg_st->err = err;
1860     struct interphi_msg_st *svc_st = (struct interphi_msg_st *) msg_st;
1865     txq_send(msg_st);
1907     struct txq_msg_st *msg_st = rpc_preamble(mi);
1908     if (msg_st == NULL) {
1913     struct interphi_msg_st *svc_st = (struct interphi_msg_st *) msg_st;
1914     msg_st->send = alloc_mem_call_tx;
1918     txq_send(msg_st);