Lines Matching refs:msg

44 	inline_message_t msg;  member
66 mach_msg_header_t *msg; member
163 inline_message_t *msg; in do_msg_rcv() local
178 msg = (inline_message_t *)data_vec[0].msgv_data; in do_msg_rcv()
180 msg = (inline_message_t *)&message_buffer; in do_msg_rcv()
194 kr = mach_msg(msg, in do_msg_rcv()
207 T_QUIET; T_EXPECT_EQ(msg->data, MESSAGE_DATA_BYTES, "message should carry correct value"); in do_msg_rcv()
208 T_QUIET; T_EXPECT_EQ(msg->header.msgh_remote_port, send_port, "port name should match"); in do_msg_rcv()
209 T_QUIET; T_EXPECT_EQ(msg->header.msgh_local_port, msg_rcv_port, "port name should match"); in do_msg_rcv()
210 T_QUIET; T_EXPECT_EQ(msg->header.msgh_id, 4141, "ID should match"); in do_msg_rcv()
252 data_vecs[MACH_MSGV_IDX_MSG].msgv_data = (mach_vm_address_t)configs.msg; in send_msg()
264 *(configs.msg), data_count, 0, MACH_PORT_NULL, in send_msg()
268 kr = mach_msg2(configs.msg, MACH64_SEND_MSG | MACH64_SEND_MQ_CALL | configs.send_options, in send_msg()
269 *(configs.msg), configs.msg_size, 0, MACH_PORT_NULL, in send_msg()
273 kr = mach_msg(configs.msg, MACH_SEND_MSG, configs.msg_size, 0, 0, 0, 0); in send_msg()
289 inline_message_t msg; variable
317 msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND,
319 msg.header.msgh_size = sizeof(inline_message_t);
320 msg.header.msgh_remote_port = rcv_port;
321 msg.header.msgh_local_port = send_port;
322 msg.header.msgh_id = 4141;
323 msg.header.msgh_voucher_port = MACH_PORT_NULL;
325 msg.data = MESSAGE_DATA_BYTES;
344 send_configs.msg = (mach_msg_header_t *)&msg;
360 send_configs.msg = (mach_msg_header_t *)&msg;
373 send_configs.msg = (mach_msg_header_t *)&msg;
386 send_configs.msg = (mach_msg_header_t *)&msg;
399 send_configs.msg = (mach_msg_header_t *)&msg;
432 buffer.msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND,
434 buffer.msg.header.msgh_size = sizeof(inline_message_t);
435 buffer.msg.header.msgh_remote_port = sr_port;
436 buffer.msg.header.msgh_local_port = sr_port;
437 buffer.msg.header.msgh_id = 4141;
438 buffer.msg.header.msgh_voucher_port = MACH_PORT_NULL;
439 buffer.msg.data = MESSAGE_DATA_BYTES;
444 data_vec[0].msgv_data = (mach_vm_address_t)&buffer.msg;
454 buffer.msg.header, 2, 2, sr_port, 0, 0);
458 buffer.msg.header, 1, 1, sr_port, 0, 0);
467 buffer.msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND,
469 buffer.msg.header.msgh_size = sizeof(inline_message_t);
470 buffer.msg.header.msgh_remote_port = sr_port;
471 buffer.msg.header.msgh_local_port = sr_port;
472 buffer.msg.header.msgh_id = 4141;
473 buffer.msg.header.msgh_voucher_port = MACH_PORT_NULL;
474 buffer.msg.data = MESSAGE_DATA_BYTES;
478 buffer.msg.header, 2, 1, sr_port, 0, 0);
481 buffer.msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND,
483 buffer.msg.header.msgh_size = sizeof(inline_message_t);
484 buffer.msg.header.msgh_remote_port = sr_port;
485 buffer.msg.header.msgh_local_port = sr_port;
486 buffer.msg.header.msgh_id = 4141;
487 buffer.msg.header.msgh_voucher_port = MACH_PORT_NULL;
488 buffer.msg.data = MESSAGE_DATA_BYTES;
492 data_vec[0].msgv_rcv_addr = (mach_vm_address_t)&rcv_buffer.msg;
496 buffer.msg.header, 1, 2, sr_port, 0, 0);
500 T_EXPECT_EQ(rcv_buffer.msg.header.msgh_id, 4141, "msgh_id in rcv_buffer should match");
507 mach_msg_header_t *msg = (mach_msg_header_t *)kev->ext[0]; in workloop_cb() local
516 aux_buffer_t *aux = (aux_buffer_t *)((uintptr_t)msg + msg_size); in workloop_cb()
580 buffer.msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND,
582 buffer.msg.header.msgh_size = sizeof(inline_message_t);
583 buffer.msg.header.msgh_remote_port = sr_port;
584 buffer.msg.header.msgh_local_port = sr_port;
585 buffer.msg.header.msgh_id = 4141;
586 buffer.msg.header.msgh_voucher_port = MACH_PORT_NULL;
587 buffer.msg.data = MESSAGE_DATA_BYTES;
592 data_vec[0].msgv_data = (mach_vm_address_t)&buffer.msg;
605 buffer.msg.header, 2, 0, sr_port, 0, 0);