Lines Matching refs:msg

45 	inline_message_t msg;  member
67 mach_msg_header_t *msg; member
164 inline_message_t *msg; in do_msg_rcv() local
179 msg = (inline_message_t *)data_vec[0].msgv_data; in do_msg_rcv()
181 msg = (inline_message_t *)&message_buffer; in do_msg_rcv()
195 kr = mach_msg(msg, in do_msg_rcv()
208 T_QUIET; T_EXPECT_EQ(msg->data, MESSAGE_DATA_BYTES, "message should carry correct value"); in do_msg_rcv()
209 T_QUIET; T_EXPECT_EQ(msg->header.msgh_remote_port, send_port, "port name should match"); in do_msg_rcv()
210 T_QUIET; T_EXPECT_EQ(msg->header.msgh_local_port, msg_rcv_port, "port name should match"); in do_msg_rcv()
211 T_QUIET; T_EXPECT_EQ(msg->header.msgh_id, 4141, "ID should match"); in do_msg_rcv()
253 data_vecs[MACH_MSGV_IDX_MSG].msgv_data = (mach_vm_address_t)configs.msg; in send_msg()
265 *(configs.msg), data_count, 0, MACH_PORT_NULL, in send_msg()
269 kr = mach_msg2(configs.msg, MACH64_SEND_MSG | MACH64_SEND_MQ_CALL | configs.send_options, in send_msg()
270 *(configs.msg), configs.msg_size, 0, MACH_PORT_NULL, in send_msg()
274 kr = mach_msg(configs.msg, MACH_SEND_MSG, configs.msg_size, 0, 0, 0, 0); in send_msg()
290 inline_message_t msg; variable
318 msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND,
320 msg.header.msgh_size = sizeof(inline_message_t);
321 msg.header.msgh_remote_port = rcv_port;
322 msg.header.msgh_local_port = send_port;
323 msg.header.msgh_id = 4141;
324 msg.header.msgh_voucher_port = MACH_PORT_NULL;
326 msg.data = MESSAGE_DATA_BYTES;
345 send_configs.msg = (mach_msg_header_t *)&msg;
361 send_configs.msg = (mach_msg_header_t *)&msg;
374 send_configs.msg = (mach_msg_header_t *)&msg;
387 send_configs.msg = (mach_msg_header_t *)&msg;
400 send_configs.msg = (mach_msg_header_t *)&msg;
433 buffer.msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND,
435 buffer.msg.header.msgh_size = sizeof(inline_message_t);
436 buffer.msg.header.msgh_remote_port = sr_port;
437 buffer.msg.header.msgh_local_port = sr_port;
438 buffer.msg.header.msgh_id = 4141;
439 buffer.msg.header.msgh_voucher_port = MACH_PORT_NULL;
440 buffer.msg.data = MESSAGE_DATA_BYTES;
445 data_vec[0].msgv_data = (mach_vm_address_t)&buffer.msg;
455 buffer.msg.header, 2, 2, sr_port, 0, 0);
459 buffer.msg.header, 1, 1, sr_port, 0, 0);
468 buffer.msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND,
470 buffer.msg.header.msgh_size = sizeof(inline_message_t);
471 buffer.msg.header.msgh_remote_port = sr_port;
472 buffer.msg.header.msgh_local_port = sr_port;
473 buffer.msg.header.msgh_id = 4141;
474 buffer.msg.header.msgh_voucher_port = MACH_PORT_NULL;
475 buffer.msg.data = MESSAGE_DATA_BYTES;
479 buffer.msg.header, 2, 1, sr_port, 0, 0);
482 buffer.msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND,
484 buffer.msg.header.msgh_size = sizeof(inline_message_t);
485 buffer.msg.header.msgh_remote_port = sr_port;
486 buffer.msg.header.msgh_local_port = sr_port;
487 buffer.msg.header.msgh_id = 4141;
488 buffer.msg.header.msgh_voucher_port = MACH_PORT_NULL;
489 buffer.msg.data = MESSAGE_DATA_BYTES;
493 data_vec[0].msgv_rcv_addr = (mach_vm_address_t)&rcv_buffer.msg;
497 buffer.msg.header, 1, 2, sr_port, 0, 0);
501 T_EXPECT_EQ(rcv_buffer.msg.header.msgh_id, 4141, "msgh_id in rcv_buffer should match");
508 mach_msg_header_t *msg = (mach_msg_header_t *)kev->ext[0]; in workloop_cb() local
517 aux_buffer_t *aux = (aux_buffer_t *)((uintptr_t)msg + msg_size); in workloop_cb()
581 buffer.msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND,
583 buffer.msg.header.msgh_size = sizeof(inline_message_t);
584 buffer.msg.header.msgh_remote_port = sr_port;
585 buffer.msg.header.msgh_local_port = sr_port;
586 buffer.msg.header.msgh_id = 4141;
587 buffer.msg.header.msgh_voucher_port = MACH_PORT_NULL;
588 buffer.msg.data = MESSAGE_DATA_BYTES;
593 data_vec[0].msgv_data = (mach_vm_address_t)&buffer.msg;
606 buffer.msg.header, 2, 0, sr_port, 0, 0);