Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 157) sorted by relevance

1234567

/xnu-10002.41.9/osfmk/tests/
H A Dktest.h49 void T_SYM(testskip)(const char * msg, ...);
51 void T_SYM(log)(const char * msg, ...);
56 void T_SYM(set_current_msg)(const char * msg, ...);
127 #define T_EXPECT_BLOCK2(type, fmt, cmp, lhs, rhs, msg, ...) do {\ argument
137 T_SYM(set_current_msg)(msg, ## __VA_ARGS__);\
141 #define T_ASSERT_BLOCK2(type, fmt, cmp, lhs, rhs, msg, ...) do {\ argument
142 T_EXPECT_BLOCK2(type, fmt, cmp, lhs, rhs, msg, ## __VA_ARGS__);\
185 #define T_SKIP(msg, ...) do {\ argument
187 T_SYM(testskip)(msg, ## __VA_ARGS__);\
207 #define T_LOG(msg, ...) do {\ argument
[all …]
H A Dktest_emit.c43 msg += ret;\
65 char * msg = ktest_output_buf; in ktest_emit_testbegin() local
72 ret = snprintf(msg, in ktest_emit_testbegin()
88 EMIT(ktest_output_buf, (int)(msg - ktest_output_buf)); in ktest_emit_testbegin()
94 char * msg = ktest_output_buf; in ktest_emit_testskip() local
100 ret = snprintf(msg, in ktest_emit_testskip()
112 ret = vsnprintf(msg, size, skip_msg, args); in ktest_emit_testskip()
115 ret = snprintf(msg, size, "\n"); in ktest_emit_testskip()
118 EMIT(ktest_output_buf, (int)(msg - ktest_output_buf)); in ktest_emit_testskip()
124 char * msg = ktest_output_buf; in ktest_emit_testend() local
[all …]
/xnu-10002.41.9/tests/
H A Dreply_port_defense_client.c70 } msg; in test_immovable_receive_right() local
75 msg.header.msgh_remote_port = server_port; in test_immovable_receive_right()
76 msg.header.msgh_local_port = MACH_PORT_NULL; in test_immovable_receive_right()
77 msg.header.msgh_bits = MACH_MSGH_BITS(MACH_MSG_TYPE_COPY_SEND, 0) | MACH_MSGH_BITS_COMPLEX; in test_immovable_receive_right()
78 msg.header.msgh_size = sizeof msg; in test_immovable_receive_right()
80 msg.body.msgh_descriptor_count = 1; in test_immovable_receive_right()
82 msg.desc.name = reply_port; in test_immovable_receive_right()
83 msg.desc.disposition = MACH_MSG_TYPE_MOVE_RECEIVE; in test_immovable_receive_right()
84 msg.desc.type = MACH_MSG_PORT_DESCRIPTOR; in test_immovable_receive_right()
86 kr = mach_msg_send(&msg.header); in test_immovable_receive_right()
[all …]
H A Dimm_pinned_control_port_crasher.c44 } msg; in attempt_send_immovable_port() local
46 msg.header.msgh_remote_port = server; in attempt_send_immovable_port()
47 msg.header.msgh_local_port = MACH_PORT_NULL; in attempt_send_immovable_port()
48 msg.header.msgh_bits = MACH_MSGH_BITS(MACH_MSG_TYPE_COPY_SEND, 0) | MACH_MSGH_BITS_COMPLEX; in attempt_send_immovable_port()
49 msg.header.msgh_size = sizeof msg; in attempt_send_immovable_port()
51 msg.body.msgh_descriptor_count = 1; in attempt_send_immovable_port()
53 msg.desc.name = port; in attempt_send_immovable_port()
54 msg.desc.disposition = disp; in attempt_send_immovable_port()
55 msg.desc.type = MACH_MSG_PORT_DESCRIPTOR; in attempt_send_immovable_port()
57 return mach_msg_send(&msg.header); in attempt_send_immovable_port()
[all …]
H A Dfd_send.c21 struct msghdr msg; in send_fd() local
27 msg.msg_name = 0; in send_fd()
28 msg.msg_namelen = 0; in send_fd()
29 msg.msg_iov = iovec; in send_fd()
30 msg.msg_iovlen = 1; in send_fd()
31 msg.msg_control = buf; in send_fd()
32 msg.msg_controllen = CMSG_SPACE(sizeof(int)); in send_fd()
34 cmsghdrp = CMSG_FIRSTHDR(&msg); in send_fd()
41 if (sendmsg(sock, &msg, 0) < 0) { in send_fd()
53 struct msghdr msg; in recv_fd() local
[all …]
H A Drecvmsg_x_ctrunc.c63 struct msghdr_x *msg; in send_packets() local
73 msg = &msgList[i]; in send_packets()
84 msg->msg_control = cmsgbuf[i]; in send_packets()
85 msg->msg_controllen = CMSG_SPACE(sizeof(int)); in send_packets()
91 msg->msg_control = cmsgbuf[i]; in send_packets()
92 msg->msg_controllen = CMSG_SPACE(sizeof(int)); in send_packets()
95 msg->msg_name = (void *)to; in send_packets()
96 msg->msg_namelen = to->sa_len; in send_packets()
97 msg->msg_iov = &iovarray[i]; in send_packets()
98 msg->msg_iovlen = 1; in send_packets()
[all …]
H A Drecvmsg_x_test.c56 struct msghdr msg = {}; in sendPackets() local
66 msg.msg_name = (void *)dst; in sendPackets()
67 msg.msg_namelen = dst->sa_len; in sendPackets()
68 msg.msg_iov = &vec; in sendPackets()
69 msg.msg_iovlen = 1; in sendPackets()
70 msg.msg_flags = 0; in sendPackets()
74 T_QUIET; T_EXPECT_POSIX_SUCCESS(n = sendmsg(s, &msg, 0), "sendmsg()"); in sendPackets()
109 struct msghdr_x *msg = &msgList[i]; in recvPackets_x() local
110 msg->msg_name = &srcAddrs[i]; in recvPackets_x()
111 msg->msg_namelen = sizeof(srcAddrs[i]); in recvPackets_x()
[all …]
H A Duipc_sosendcheck.c23 struct msghdr msg; in do_recv() local
27 memset(&msg, 0, sizeof(msg)); in do_recv()
30 msg.msg_iov = iov; in do_recv()
31 msg.msg_iovlen = 1; in do_recv()
32 ssize_t res = recvmsg(sk, &msg, 0); in do_recv()
55 struct msghdr msg; in do_send() local
66 memset(&msg, 0, sizeof(msg)); in do_send()
69 msg.msg_iov = iov; in do_send()
70 msg.msg_iovlen = 1; in do_send()
71 ssize_t res_sendmsg = sendmsg(sk, &msg, 0); in do_send()
H A Duipc_uaf.c38 struct msghdr msg = {}; in send_scm_rights() local
39 struct msg { in send_scm_rights() struct
43 struct msg ctrl_msg = {}; in send_scm_rights()
45 msg.msg_iov = &iov; in send_scm_rights()
46 msg.msg_iovlen = 1; in send_scm_rights()
47 msg.msg_control = &ctrl_msg; in send_scm_rights()
48 msg.msg_controllen = sizeof(ctrl_msg) - ((MAX_FDS / 2) * sizeof(ctrl_msg.fds[0])); in send_scm_rights()
51 ctrl_msg.cmsg.cmsg_len = msg.msg_controllen; in send_scm_rights()
54 struct msg overwrite_ctrl_msg = {}; in send_scm_rights()
62 overwrite_ctrl_msg.cmsg.cmsg_len = msg.msg_controllen; in send_scm_rights()
[all …]
H A Dvsock.c150 vsock_send(int socket, char *msg) in vsock_send() argument
152 T_ASSERT_NOTNULL(msg, "send message is not null"); in vsock_send()
153 ssize_t sent_bytes = send(socket, msg, strlen(msg), 0); in vsock_send()
154 T_ASSERT_EQ_LONG(strlen(msg), (unsigned long)sent_bytes, "sent all bytes"); in vsock_send()
539 char *msg = "This is test message.\n"; variable
542 vsock_send(socketA, msg);
554 vsock_send(socketB, msg);
565 char *msg = "This is test message.\n"; variable
568 vsock_send(socketA, msg);
571 vsock_send(socketB, msg);
[all …]
H A Dmach_exception_reply.c91 mach_msg_header_t *msg = (mach_msg_header_t *)msg_store; in handle_exceptions() local
101 bzero(msg, sizeof(msg_store)); in handle_exceptions()
103 msg->msgh_local_port = ePort; in handle_exceptions()
104 msg->msgh_size = MSG; in handle_exceptions()
105 kr = mach_msg_receive(msg); in handle_exceptions()
122 reply->hdr.msgh_remote_port = msg->msgh_remote_port; in handle_exceptions()
125 reply->hdr.msgh_id = msg->msgh_id + 100; in handle_exceptions()
140 reply->hdr.msgh_remote_port = msg->msgh_remote_port; in handle_exceptions()
143 reply->hdr.msgh_id = msg->msgh_id + 100; in handle_exceptions()
158 reply->hdr.msgh_remote_port = msg->msgh_remote_port; in handle_exceptions()
[all …]
H A Dbootstrap_msgfilter.c59 struct test_msg msg = { variable
69 kr = mach_msg(&msg.header, msg_opts, msg.header.msgh_size, sizeof(msg),
78 msg = (struct test_msg){
86 kr = mach_msg(&msg.header, msg_opts, msg.header.msgh_size, sizeof(msg),
H A Dsocket_0byte_udp_poll_58140856.c44 struct msghdr msg; in send_message() local
50 memset(&msg, 0, sizeof(msg)); in send_message()
52 msg.msg_name = &server.addr; in send_message()
53 msg.msg_namelen = sizeof(server.addr); in send_message()
57 msg.msg_iov = &iov; in send_message()
58 msg.msg_iovlen = 1; in send_message()
60 ssize_t r = sendmsg(fd, &msg, 0); in send_message()
H A Dunp_externalize_fd_alloc.c30 struct msghdr msg = {0}; variable
37 msg.msg_iov = iovec;
38 msg.msg_iovlen = 1;
39 msg.msg_control = buf;
40 msg.msg_controllen = CMSG_SPACE(sizeof(int));
42 cmsghdr = CMSG_FIRSTHDR(&msg);
50 sendmsg(sock[1], &msg, 0);
H A Dipc_mach_port.c85 struct one_port_msg msg = { in send_port() local
104 kr = mach_msg(&msg.header, MACH_SEND_MSG | MACH_SEND_TIMEOUT, in send_port()
105 msg.header.msgh_size, 0, MACH_PORT_NULL, 10000, 0); in send_port()
118 struct one_port_msg msg = { }; in receive_port() local
122 kr = mach_msg(&msg.header, MACH_RCV_MSG, 0, in receive_port()
123 sizeof(msg), rcv_port, 0, 0); in receive_port()
125 T_QUIET; T_ASSERT_EQ(msg.header.msgh_id, expected_id, "message id matches"); in receive_port()
126 T_QUIET; T_ASSERT_NE(msg.header.msgh_bits & MACH_MSGH_BITS_COMPLEX, 0, in receive_port()
128 T_QUIET; T_ASSERT_EQ(msg.body.msgh_descriptor_count, 1, "message has one right"); in receive_port()
129 T_QUIET; T_ASSERT_EQ((mach_msg_type_name_t)msg.port_descriptor.disposition, expected_disp, in receive_port()
[all …]
/xnu-10002.41.9/tests/ipc/
H A Dmach_msg2.c44 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()
[all …]
H A Dport_peek.c21 struct msg { struct
25 } msg; argument
34 send_size = sizeof(msg) - 128; /* minus trailer space */
36 msg.header.msgh_local_port = MACH_PORT_NULL;
37 msg.header.msgh_remote_port = port;
38 msg.header.msgh_id = outgoing_id;
39 msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_MAKE_SEND, 0, 0, 0);
40 msg.header.msgh_size = send_size;
42 kr = mach_msg(&msg.header, MACH_SEND_MSG, msg.header.msgh_size, 0,
65 kr = mach_msg(&msg.header, MACH_RCV_MSG, 0,
[all …]
/xnu-10002.41.9/osfmk/corecrypto/
H A Dcc_abort.c49 cc_abort(const char * msg) in cc_abort() argument
51 panic("%s", msg); in cc_abort()
59 cc_abort(const char * msg) in cc_abort() argument
61 sys_panic(msg); in cc_abort()
68 cc_abort(const char * msg) in cc_abort() argument
70 RTK_abort("%s", msg); in cc_abort()
76 void (*cc_abort_mock)(const char *msg);
81 cc_abort(CC_UNUSED const char *msg) in cc_abort() argument
85 cc_abort_mock(msg); in cc_abort()
H A Dcc_try_abort.c46 cc_try_abort(const char *msg) in cc_try_abort() argument
48 cc_abort(msg); in cc_try_abort()
58 cc_try_abort(CC_UNUSED const char *msg) in cc_try_abort() argument
65 cc_try_abort_if(bool condition, const char *msg) in cc_try_abort_if() argument
68 cc_try_abort(msg); in cc_try_abort_if()
/xnu-10002.41.9/osfmk/kern/
H A Dmach_node.c164 struct mach_node_server_register_msg msg; in mach_node_publish() local
166 msg.node_header.header.msgh_remote_port = bs_port; in mach_node_publish()
167 msg.node_header.header.msgh_size = sizeof(msg); in mach_node_publish()
168 msg.node_header.header.msgh_local_port = MACH_PORT_NULL; in mach_node_publish()
169 msg.node_header.header.msgh_voucher_port = MACH_PORT_NULL; in mach_node_publish()
170 msg.node_header.header.msgh_id = MACH_NODE_SERVER_MSG_ID; in mach_node_publish()
171 msg.node_header.node_id = node->info.node_id; in mach_node_publish()
172 msg.node_header.options = 0; in mach_node_publish()
173 msg.datamodel = node->info.datamodel; in mach_node_publish()
174 msg.byteorder = node->info.byteorder; in mach_node_publish()
[all …]
H A Dhost_notify.c144 mach_msg_header_t *msg, in host_notify_all() argument
180 msg->msgh_bits = in host_notify_all()
182 msg->msgh_local_port = MACH_PORT_NULL; in host_notify_all()
183 msg->msgh_voucher_port = MACH_PORT_NULL; in host_notify_all()
184 msg->msgh_id = host_notify_replyid[notify_type]; in host_notify_all()
192 msg->msgh_remote_port = port; in host_notify_all()
193 (void)mach_msg_send_from_kernel_proper(msg, msg_size); in host_notify_all()
200 __Request__host_calendar_changed_t msg; in host_notify_calendar_change() local
202 host_notify_all(HOST_NOTIFY_CALENDAR_CHANGE, &msg.Head, sizeof(msg)); in host_notify_calendar_change()
208 __Request__host_calendar_set_t msg; in host_notify_calendar_set() local
[all …]
H A Dmach_node_link.h130 void mnl_msg_free(mnl_msg_t msg, uint32_t flags);
133 #define MNL_MSG_VALID(msg) ((msg) != MNL_MSG_NULL) argument
135 #define MNL_MSG_PAYLOAD(msg) ((vm_offset_t)(msg) + MNL_MSG_SIZE) argument
232 mnl_msg_t msg,
259 mnl_msg_t msg,
/xnu-10002.41.9/bsd/kern/
H A Dkpi_socket.c722 sock_receive_internal(socket_t sock, struct msghdr *msg, mbuf_t *data, in sock_receive_internal() argument
730 UIO_STACKBUF(uio_buf, (msg != NULL) ? msg->msg_iovlen : 0); in sock_receive_internal()
736 auio = uio_createwithbuffer(((msg != NULL) ? msg->msg_iovlen : 0), in sock_receive_internal()
738 if (msg != NULL && data == NULL) { in sock_receive_internal()
740 struct iovec *tempp = msg->msg_iov; in sock_receive_internal()
742 for (i = 0; i < msg->msg_iovlen; i++) { in sock_receive_internal()
761 data, (msg && msg->msg_control) ? &control : NULL, &flags); in sock_receive_internal()
769 if (msg != NULL) { in sock_receive_internal()
770 msg->msg_flags = flags; in sock_receive_internal()
772 if (msg->msg_name != NULL) { in sock_receive_internal()
[all …]
/xnu-10002.41.9/osfmk/ipc/
H A Dflipc.c257 mach_msg_send_from_remote_kernel(mach_msg_header_t *msg, in mach_msg_send_from_remote_kernel() argument
264 mr = ipc_kmsg_get_from_kernel(msg, send_size, &kmsg); in mach_msg_send_from_remote_kernel()
499 mnl_msg_t msg, in flipc_msg_from_node() argument
507 assert(msg->sub == MACH_NODE_SUB_FLIPC); in flipc_msg_from_node()
508 mach_node_t node = mach_node_for_id_locked(msg->node_id, FALSE, FALSE); in flipc_msg_from_node()
511 switch (msg->cmd) { in flipc_msg_from_node()
513 flipc_cmd_ipc(msg, node, flags); in flipc_msg_from_node()
518 flipc_cmd_ack((flipc_ack_msg_t)msg, node, flags); in flipc_msg_from_node()
536 flipc_msg_free(mnl_msg_t msg, in flipc_msg_free() argument
539 switch (msg->cmd) { in flipc_msg_free()
[all …]
/xnu-10002.41.9/san/tools/
H A Dksancov.h383 …on(int fd, const char *bundle, ksancov_on_demand_operation_t op, struct ksancov_on_demand_msg *msg) in _ksancov_on_demand_operation() argument
387 msg->operation = op; in _ksancov_on_demand_operation()
388 strlcpy(msg->bundle, bundle, sizeof(msg->bundle)); in _ksancov_on_demand_operation()
390 ret = ioctl(fd, KSANCOV_IOC_ON_DEMAND, msg); in _ksancov_on_demand_operation()
406 struct ksancov_on_demand_msg msg; in ksancov_on_demand_get_gate() local
407 int ret = _ksancov_on_demand_operation(fd, bundle, KS_OD_GET_GATE, &msg); in ksancov_on_demand_get_gate()
409 *gate = msg.gate; in ksancov_on_demand_get_gate()
423 struct ksancov_on_demand_msg msg = {}; in ksancov_on_demand_set_gate() local
424 msg.gate = value; in ksancov_on_demand_set_gate()
425 return _ksancov_on_demand_operation(fd, bundle, KS_OD_SET_GATE, &msg); in ksancov_on_demand_set_gate()
[all …]

1234567