Home
last modified time | relevance | path

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

12345678

/xnu-12377.81.4/osfmk/tests/
H A Dktest.h50 void T_SYM(testskip)(const char * msg, ...);
52 void T_SYM(log)(const char * msg, ...);
57 void T_SYM(set_current_msg)(const char * msg, ...);
128 #define T_EXPECT_BLOCK2(type, fmt, cmp, lhs, rhs, msg, ...) do {\ argument
138 T_SYM(set_current_msg)(msg, ## __VA_ARGS__);\
142 #define T_ASSERT_BLOCK2(type, fmt, cmp, lhs, rhs, msg, ...) do {\ argument
143 T_EXPECT_BLOCK2(type, fmt, cmp, lhs, rhs, msg, ## __VA_ARGS__);\
186 #define T_SKIP(msg, ...) do {\ argument
188 T_SYM(testskip)(msg, ## __VA_ARGS__);\
208 #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-12377.81.4/tests/
H A Dtcp_invalid_address.c41 uint64_t msg = malloc(0x2000); in send_msg() local
43 *(uint64_t*)(msg + 0x200) = 0; in send_msg()
44 *(uint32_t*)(msg + 0x208) = 0; in send_msg()
45 *(uint64_t*)(msg + 0x210) = msg; in send_msg()
46 *(uint64_t*)msg = 0; in send_msg()
47 *(uint64_t*)(msg + 8) = 0; in send_msg()
48 *(uint64_t*)(msg + 0x218) = 1; in send_msg()
49 *(uint64_t*)(msg + 0x220) = (msg + 0x40); in send_msg()
50 *(uint64_t*)(msg + 0x40) = 0xa8; in send_msg()
51 *(uint32_t*)(msg + 0x48) = 0x3a; in send_msg()
[all …]
H A Dreply_port_defense_client.c161 } msg; in test_immovable_receive_right() local
166 msg.header.msgh_remote_port = server_port; in test_immovable_receive_right()
167 msg.header.msgh_local_port = MACH_PORT_NULL; in test_immovable_receive_right()
168 msg.header.msgh_bits = MACH_MSGH_BITS(MACH_MSG_TYPE_COPY_SEND, 0) | MACH_MSGH_BITS_COMPLEX; in test_immovable_receive_right()
169 msg.header.msgh_size = sizeof msg; in test_immovable_receive_right()
171 msg.body.msgh_descriptor_count = 1; in test_immovable_receive_right()
173 msg.desc.name = reply_port; in test_immovable_receive_right()
174 msg.desc.disposition = MACH_MSG_TYPE_MOVE_RECEIVE; in test_immovable_receive_right()
175 msg.desc.type = MACH_MSG_PORT_DESCRIPTOR; in test_immovable_receive_right()
176 kr = mach_msg_send(&msg.header); in test_immovable_receive_right()
[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 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_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 Darm_mte_mach_msg.c117 ipc_complex_ool_message msg; in send_ool_memory() local
118 bzero(&msg, sizeof(ipc_complex_ool_message)); in send_ool_memory()
132 msg.header = hdr; in send_ool_memory()
133 msg.body.msgh_descriptor_count = 1; in send_ool_memory()
134 msg.dsc = dsc; in send_ool_memory()
140 kern_return_t kr = mach_msg(&msg.header, MACH_SEND_MSG, msg.header.msgh_size, in send_ool_memory()
336 ipc_complex_ool_message msg; in receive_ool_memory() local
338 kern_return_t kr = mach_msg(&msg.header, MACH_RCV_MSG, 0, sizeof(msg), in receive_ool_memory()
342 switch (msg.dsc.copy) { in receive_ool_memory()
350 uint64_t *received_data = (uint64_t*) msg.dsc.address; in receive_ool_memory()
[all …]
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.c361 char *msg = "This is test message.\n"; variable
364 vsock_send(socketA, msg);
376 vsock_send(socketB, msg);
388 char *msg = "This is test message.\n"; variable
391 vsock_send(socketA, msg);
394 vsock_send(socketB, msg);
404 ssize_t sent_bytes = send(socketB, msg, strlen(msg), 0);
410 T_ASSERT_EQ_LONG(strlen(msg), (unsigned long)read_bytes, "read all bytes");
422 char *msg = "This is test message.\n"; variable
426 vsock_send(socketA, 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.c60 struct test_msg msg = { variable
70 kr = mach_msg(&msg.header, msg_opts, msg.header.msgh_size, sizeof(msg),
79 msg = (struct test_msg){
87 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()
/xnu-12377.81.4/tests/ipc/
H A Dmach_msg_transport.c102 mach_msg_header_t *msg, in t_receive() argument
107 return mach_msg2(msg, opts, *msg, 0, size, name, 0, 0); in t_receive()
114 mach_msg_header_t *msg, in t_send() argument
118 mach_msg_size_t size = (mach_msg_size_t)((char *)upto - (char *)msg); in t_send()
122 msg->msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_COPY_SEND, 0, 0, 0); in t_send()
123 msg->msgh_size = size; in t_send()
124 msg->msgh_remote_port = dest; in t_send()
125 msg->msgh_local_port = MACH_PORT_NULL; in t_send()
126 msg->msgh_voucher_port = MACH_PORT_NULL; in t_send()
127 msg->msgh_id = 42; in t_send()
[all …]
H A Dmach_msg2.c45 inline_message_t msg; member
67 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((void *)msg, in do_msg_rcv()
207 …T_QUIET; T_EXPECT_EQ(msg->data, (uint64_t)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 Dimm_pinned_control_port_crasher.c46 } msg; in attempt_send_immovable_port() local
48 msg.header.msgh_remote_port = server; in attempt_send_immovable_port()
49 msg.header.msgh_local_port = MACH_PORT_NULL; in attempt_send_immovable_port()
50 msg.header.msgh_bits = MACH_MSGH_BITS(MACH_MSG_TYPE_COPY_SEND, 0) | MACH_MSGH_BITS_COMPLEX; in attempt_send_immovable_port()
51 msg.header.msgh_size = sizeof msg; in attempt_send_immovable_port()
53 msg.body.msgh_descriptor_count = 1; in attempt_send_immovable_port()
55 msg.desc.name = port; in attempt_send_immovable_port()
56 msg.desc.disposition = disp; in attempt_send_immovable_port()
57 msg.desc.type = MACH_MSG_PORT_DESCRIPTOR; in attempt_send_immovable_port()
59 return mach_msg_send(&msg.header); in attempt_send_immovable_port()
[all …]
H A Dipc_utils.c64 ipc_single_port_msg_t msg = { in ipc_send_port() local
82 return ipc_send_message(&msg.header); in ipc_send_port()
88 ipc_receive_msg_t msg; in ipc_receive_port() local
91 kr = ipc_receive_message(destination, &msg, sizeof(ipc_receive_msg_t)); in ipc_receive_port()
93 if (msg.header.msgh_id == 0x1001 && msg.body.msgh_descriptor_count == 1) { in ipc_receive_port()
94 *port = msg.data.single.port.name; in ipc_receive_port()
113 ipc_port_array_msg_t msg = { in ipc_send_port_array() local
133 return ipc_send_message(&msg.header); in ipc_send_port_array()
140 ipc_receive_msg_t msg; in ipc_receive_port_array() local
143 kr = ipc_receive_message(destination, &msg, sizeof(ipc_receive_msg_t)); in ipc_receive_port_array()
[all …]
H A Dport_peek.c22 struct msg { struct
26 } msg; argument
35 send_size = sizeof(msg) - 128; /* minus trailer space */
37 msg.header.msgh_local_port = MACH_PORT_NULL;
38 msg.header.msgh_remote_port = port;
39 msg.header.msgh_id = outgoing_id;
40 msg.header.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_MAKE_SEND, 0, 0, 0);
41 msg.header.msgh_size = send_size;
43 kr = mach_msg(&msg.header, MACH_SEND_MSG, msg.header.msgh_size, 0,
66 kr = mach_msg(&msg.header, MACH_RCV_MSG, 0,
[all …]
/xnu-12377.81.4/tests/unit/mocks/
H A Ddt_proxy.h43 void (*t_assert_true)(bool cond, const char *msg);
44 void (*t_assert_notnull)(void *ptr, const char *msg);
45 void (*t_assert_posix_zero)(int v, const char *msg);
46 void (*t_log)(const char *msg);
47 void (*t_log_fmtstr)(const char *fmt, const char *msg);
48 void (*t_fail)(const char *msg);
63 #define PT_ASSERT_TRUE(cond, msg) do { if (dt_proxy) { dt_proxy->t_assert_true((cond), #cond msg)… argument
64 #define PT_ASSERT_TRUE_S(cond, msg) do { if (dt_proxy) { dt_proxy->t_assert_true((cond), msg); } } … argument
65 #define PT_ASSERT_NOTNULL(ptr, msg) do { if (dt_proxy) { dt_proxy->t_assert_notnull((ptr), msg); } … argument
66 #define PT_ASSERT_POSIX_ZERO(v, msg) do { if (dt_proxy) { dt_proxy->t_assert_posix_zero((v), msg); … argument
[all …]
H A Ddt_proxy.c34 pt_assert_true(bool cond, const char *msg) in pt_assert_true() argument
36 T_ASSERT_TRUE(cond, "%s", msg); in pt_assert_true()
39 pt_assert_notnull(void *ptr, const char *msg) in pt_assert_notnull() argument
41 T_ASSERT_NOTNULL(ptr, "%s", msg); in pt_assert_notnull()
44 pt_assert_posix_zero(int v, const char *msg) in pt_assert_posix_zero() argument
46 T_ASSERT_POSIX_ZERO(v, "%s", msg); in pt_assert_posix_zero()
49 pt_log(const char *msg) in pt_log() argument
51 T_LOG("%s", msg); in pt_log()
54 pt_log_fmtstr(const char* fmt, const char *msg) in pt_log_fmtstr() argument
56 T_LOG(fmt, msg); in pt_log_fmtstr()
[all …]
/xnu-12377.81.4/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()
/xnu-12377.81.4/bsd/kern/
H A Dkpi_socket.c714 sock_receive_internal(socket_t sock, struct msghdr *msg, mbuf_t *data, in sock_receive_internal() argument
722 UIO_STACKBUF(uio_buf, (msg != NULL) ? msg->msg_iovlen : 0); in sock_receive_internal()
728 auio = uio_createwithbuffer(((msg != NULL) ? msg->msg_iovlen : 0), in sock_receive_internal()
730 if (msg != NULL && data == NULL) { in sock_receive_internal()
733 msg->msg_iov, in sock_receive_internal()
734 sizeof(struct iovec) * msg->msg_iovlen); in sock_receive_internal()
736 for (i = 0; i < msg->msg_iovlen; i++) { in sock_receive_internal()
755 data, (msg && msg->msg_control) ? &control : NULL, &flags); in sock_receive_internal()
763 if (msg != NULL) { in sock_receive_internal()
764 msg->msg_flags = flags; in sock_receive_internal()
[all …]
/xnu-12377.81.4/osfmk/kern/
H A Dhost_notify.c149 mach_msg_header_t *msg, in host_notify_all() argument
185 msg->msgh_bits = in host_notify_all()
187 msg->msgh_local_port = MACH_PORT_NULL; in host_notify_all()
188 msg->msgh_voucher_port = MACH_PORT_NULL; in host_notify_all()
189 msg->msgh_id = host_notify_replyid[notify_type]; in host_notify_all()
197 msg->msgh_remote_port = port; in host_notify_all()
198 (void)mach_msg_send_from_kernel(msg, msg_size); in host_notify_all()
205 __Request__host_calendar_changed_t msg; in host_notify_calendar_change() local
207 host_notify_all(HOST_NOTIFY_CALENDAR_CHANGE, &msg.Head, sizeof(msg)); in host_notify_calendar_change()
213 __Request__host_calendar_set_t msg; in host_notify_calendar_set() local
[all …]
H A Dipc_mig.c112 mach_msg_header_t *msg, in mach_msg_send_from_kernel() argument
117 return kernel_mach_msg_send(msg, send_size, option, timeout_val, NULL); in mach_msg_send_from_kernel()
122 mach_msg_header_t *msg, in mach_msg_send_from_kernel_with_options() argument
127 return kernel_mach_msg_send(msg, send_size, option, timeout_val, NULL); in mach_msg_send_from_kernel_with_options()
176 mach_msg_header_t *msg, in kernel_mach_msg_send() argument
192 mr = ipc_kmsg_get_from_kernel(msg, send_size, option, &kmsg); in kernel_mach_msg_send()
204 mach_msg_header_t *msg, in mach_msg_send_from_kernel_proper() argument
215 mr = ipc_kmsg_get_from_kernel(msg, send_size, option, &kmsg); in mach_msg_send_from_kernel_proper()
335 mach_msg_header_t *msg, in kernel_mach_msg_rpc_common() argument
352 assert(msg->msgh_local_port == MACH_PORT_NULL); in kernel_mach_msg_rpc_common()
[all …]

12345678