Lines Matching refs:msg_st
121 static errval_t chan_open_call_tx(struct txq_msg_st* msg_st)
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)
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)
140 return xeon_phi_kill_response__tx(msg_st->queue->binding, TXQCONT(msg_st),
141 msg_st->err);
144 static errval_t spawn_with_cap_response_tx(struct txq_msg_st* msg_st)
146 struct xphi_svc_msg_st *xphi_st = (struct xphi_svc_msg_st *) msg_st;
148 return xeon_phi_spawn_with_cap_response__tx(msg_st->queue->binding,
149 TXQCONT(msg_st),
151 msg_st->err);
154 static errval_t spawn_response_tx(struct txq_msg_st* msg_st)
156 struct xphi_svc_msg_st *xphi_st = (struct xphi_svc_msg_st *) msg_st;
158 return xeon_phi_spawn_response__tx(msg_st->queue->binding, TXQCONT(msg_st),
159 xphi_st->args.spawn.domainid, msg_st->err);
162 static errval_t domain_init_response_tx(struct txq_msg_st* msg_st)
164 return xeon_phi_domain_init_response__tx(msg_st->queue->binding, TXQCONT(msg_st),
165 msg_st->err);
168 static errval_t domain_register_response_tx(struct txq_msg_st* msg_st)
170 return xeon_phi_domain_register_response__tx(msg_st->queue->binding,
171 TXQCONT(msg_st), msg_st->err);
174 static errval_t domain_lookup_response_tx(struct txq_msg_st* msg_st)
176 struct xphi_svc_msg_st *st = (struct xphi_svc_msg_st *) msg_st;
177 return xeon_phi_domain_lookup_response__tx(msg_st->queue->binding,
178 TXQCONT(msg_st),
179 st->args.domain.domid, msg_st->err);
182 static errval_t domain_wait_response_tx(struct txq_msg_st* msg_st)
184 struct xphi_svc_msg_st *st = (struct xphi_svc_msg_st *) msg_st;
186 return xeon_phi_domain_wait_response__tx(msg_st->queue->binding, TXQCONT(msg_st),
187 st->args.domain.domid, msg_st->err);
205 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue);
206 if (msg_st == NULL) {
210 msg_st->send = domain_lookup_response_tx;
211 msg_st->cleanup = NULL;
213 struct xphi_svc_msg_st *st = (struct xphi_svc_msg_st *) msg_st;
215 msg_st->err = interphi_domain_lookup(&phi->topology[phi->id], (CONST_CAST)name,
217 txq_send(msg_st);
229 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue);
230 if (msg_st == NULL) {
236 msg_st->err = interphi_domain_wait(&phi->topology[phi->id], (CONST_CAST)name, svc_st);
237 if (err_is_fail(msg_st->err)) {
238 txq_send(msg_st);
251 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue);
252 if (msg_st == NULL) {
256 msg_st->send = domain_register_response_tx;
257 msg_st->cleanup = NULL;
264 msg_st->err = interphi_domain_register(&phi->topology[phi->id], name, domid);
266 msg_st->err = domain_register(name, domid);
268 txq_send(msg_st);
286 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue);
287 if (msg_st == NULL) {
291 msg_st->send = domain_init_response_tx;
292 msg_st->cleanup = NULL;
295 msg_st->err = XEON_PHI_ERR_CLIENT_REGISTER;
296 txq_send(msg_st);
303 msg_st->err = interphi_domain_register(&phi->topology[phi->id], svc_st->name,
309 msg_st->err = domain_register(svc_st->name, svc_st->domainid);
312 txq_send(msg_st);
338 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue);
339 if (msg_st == NULL) {
343 msg_st->send = chan_open_request_response_tx;
344 msg_st->cleanup = NULL;
351 msg_st->err = interphi_chan_open(node, domain, svc_st->domainid, usrdata,
354 txq_send(msg_st);
363 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue);
364 if (msg_st == NULL) {
368 msg_st->send = kill_response_tx;
369 msg_st->cleanup = NULL;
377 msg_st->err = interphi_kill(node, domainid);
379 txq_send(msg_st);
394 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue);
395 if (msg_st == NULL) {
399 msg_st->send = spawn_with_cap_response_tx;
400 msg_st->cleanup = NULL;
402 struct xphi_svc_msg_st *xphi_st = (struct xphi_svc_msg_st *) msg_st;
409 msg_st->err = interphi_spawn_with_cap(node, core, (CONST_CAST)cmdline, length,
412 txq_send(msg_st);
426 struct txq_msg_st *msg_st = txq_msg_st_alloc(&svc_st->queue);
427 if (msg_st == NULL) {
431 msg_st->send = spawn_response_tx;
432 msg_st->cleanup = NULL;
434 struct xphi_svc_msg_st *xphi_st = (struct xphi_svc_msg_st *) msg_st;
441 msg_st->err = interphi_spawn(node, core, (CONST_CAST)cmdline, length, flags,
443 txq_send(msg_st);
587 struct txq_msg_st *msg_st = txq_msg_st_alloc(&st->queue);
588 if (msg_st == NULL) {
592 msg_st->send = chan_open_call_tx;
593 msg_st->cleanup = NULL;
595 struct xphi_svc_msg_st *xphi_st = (struct xphi_svc_msg_st *) msg_st;
602 txq_send(msg_st);
620 struct txq_msg_st *msg_st = txq_msg_st_alloc(&st->queue);
621 if (msg_st == NULL) {
625 msg_st->send = domain_wait_response_tx;
626 msg_st->cleanup = NULL;
628 struct xphi_svc_msg_st *xphi_st = (struct xphi_svc_msg_st *) msg_st;
632 txq_send(msg_st);