Home
last modified time | relevance | path

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

123456

/xnu-8020.101.4/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 …]
H A Dktest.c63 ktest_testskip(const char * msg, ...) in ktest_testskip() argument
69 va_start(args, msg); in ktest_testskip()
70 ktest_emit_testskip(msg, args); in ktest_testskip()
75 ktest_log(const char * msg, ...) in ktest_log() argument
81 va_start(args, msg); in ktest_log()
82 ktest_emit_log(msg, args); in ktest_log()
/xnu-8020.101.4/bsd/nfs/
H A Dnfs_lock.c363 nfs_lockd_send_request(LOCKD_MSG *msg, int interruptable) in nfs_lockd_send_request() argument
379 msg->lm_version, in nfs_lockd_send_request()
380 msg->lm_flags, in nfs_lockd_send_request()
381 msg->lm_xid, in nfs_lockd_send_request()
382 msg->lm_fl.l_start, in nfs_lockd_send_request()
383 msg->lm_fl.l_len, in nfs_lockd_send_request()
384 msg->lm_fl.l_pid, in nfs_lockd_send_request()
385 msg->lm_fl.l_type, in nfs_lockd_send_request()
386 msg->lm_fl.l_whence, in nfs_lockd_send_request()
387 (uint32_t *)&msg->lm_addr, in nfs_lockd_send_request()
[all …]
H A Dkrpc_subr.c386 struct msghdr msg; in krpc_call() local
392 bzero(&msg, sizeof(msg)); in krpc_call()
394 msg.msg_name = NULL; in krpc_call()
395 msg.msg_namelen = 0; in krpc_call()
397 msg.msg_name = mbuf_data(nam); in krpc_call()
403 msg.msg_namelen = (uint32_t)mbuf_len(nam); in krpc_call()
405 error = sock_sendmbuf(so, &msg, m, 0, 0); in krpc_call()
437 bzero(&msg, sizeof(msg)); in krpc_call()
438 msg.msg_iov = &aio; in krpc_call()
439 msg.msg_iovlen = 1; in krpc_call()
[all …]
/xnu-8020.101.4/tests/
H A Dimm_pinned_control_port_crasher.c38 } msg; in attempt_send_immovable_port() local
40 msg.header.msgh_remote_port = server; in attempt_send_immovable_port()
41 msg.header.msgh_local_port = MACH_PORT_NULL; in attempt_send_immovable_port()
42 msg.header.msgh_bits = MACH_MSGH_BITS(MACH_MSG_TYPE_COPY_SEND, 0) | MACH_MSGH_BITS_COMPLEX; in attempt_send_immovable_port()
43 msg.header.msgh_size = sizeof msg; in attempt_send_immovable_port()
45 msg.body.msgh_descriptor_count = 1; in attempt_send_immovable_port()
47 msg.desc.name = port; in attempt_send_immovable_port()
48 msg.desc.disposition = disp; in attempt_send_immovable_port()
49 msg.desc.type = MACH_MSG_PORT_DESCRIPTOR; in attempt_send_immovable_port()
51 return mach_msg_send(&msg.header); in attempt_send_immovable_port()
[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 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 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(msg.port_descriptor.disposition, expected_disp, in receive_port()
[all …]
H A Dkqueue_port_tests.c23 mach_msg_base_t msg = { in send() local
29 .msgh_size = sizeof(msg), in send()
33 kr = mach_msg(&msg.header, MACH_SEND_MSG | MACH_SEND_TIMEOUT, in send()
34 msg.header.msgh_size, 0, MACH_PORT_NULL, 10000, 0); in send()
42 mach_msg_base_t msg = { in receive() local
46 .msgh_size = sizeof(msg), in receive()
50 return mach_msg(&msg.header, MACH_RCV_MSG | MACH_RCV_TIMEOUT, in receive()
51 0, msg.header.msgh_size, rcv_port, 5000, 0); in receive()
/xnu-8020.101.4/osfmk/kern/
H A Dmach_node.c165 struct mach_node_server_register_msg msg; in mach_node_publish() local
167 msg.node_header.header.msgh_remote_port = bs_port; in mach_node_publish()
168 msg.node_header.header.msgh_size = sizeof(msg); in mach_node_publish()
169 msg.node_header.header.msgh_local_port = MACH_PORT_NULL; in mach_node_publish()
170 msg.node_header.header.msgh_voucher_port = MACH_PORT_NULL; in mach_node_publish()
171 msg.node_header.header.msgh_id = MACH_NODE_SERVER_MSG_ID; in mach_node_publish()
172 msg.node_header.node_id = node->info.node_id; in mach_node_publish()
173 msg.node_header.options = 0; in mach_node_publish()
174 msg.datamodel = node->info.datamodel; in mach_node_publish()
175 msg.byteorder = node->info.byteorder; in mach_node_publish()
[all …]
H A Dhost_notify.c135 mach_msg_header_t *msg, in host_notify_all() argument
152 msg->msgh_bits = in host_notify_all()
154 msg->msgh_local_port = MACH_PORT_NULL; in host_notify_all()
155 msg->msgh_voucher_port = MACH_PORT_NULL; in host_notify_all()
156 msg->msgh_id = host_notify_replyid[notify_type]; in host_notify_all()
167 msg->msgh_remote_port = port; in host_notify_all()
169 (void)mach_msg_send_from_kernel_proper(msg, msg_size); in host_notify_all()
181 __Request__host_calendar_changed_t msg; in host_notify_calendar_change() local
183 host_notify_all(HOST_NOTIFY_CALENDAR_CHANGE, &msg.Head, sizeof(msg)); in host_notify_calendar_change()
189 __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,
H A Dipc_mig.c110 mach_msg_header_t *msg, in mach_msg_send_from_kernel_proper() argument
115 return kernel_mach_msg_send(msg, send_size, option, timeout_val, NULL); in mach_msg_send_from_kernel_proper()
120 mach_msg_header_t *msg, in mach_msg_send_from_kernel_with_options() argument
125 return kernel_mach_msg_send(msg, send_size, option, timeout_val, NULL); in mach_msg_send_from_kernel_with_options()
174 mach_msg_header_t *msg, in kernel_mach_msg_send() argument
189 mr = ipc_kmsg_get_from_kernel(msg, send_size, &kmsg); in kernel_mach_msg_send()
246 mach_msg_header_t *msg, in mach_msg_rpc_from_kernel_proper() argument
250 return kernel_mach_msg_rpc(msg, send_size, rcv_size, TRUE, NULL); in mach_msg_rpc_from_kernel_proper()
255 mach_msg_header_t *msg, in kernel_mach_msg_rpc() argument
268 assert(msg->msgh_local_port == MACH_PORT_NULL); in kernel_mach_msg_rpc()
[all …]
/xnu-8020.101.4/bsd/kern/
H A Dkpi_socket.c720 sock_receive_internal(socket_t sock, struct msghdr *msg, mbuf_t *data, in sock_receive_internal() argument
728 uio_stackbuf_t uio_buf[UIO_SIZEOF((msg != NULL) ? msg->msg_iovlen : 0)]; in sock_receive_internal()
734 auio = uio_createwithbuffer(((msg != NULL) ? msg->msg_iovlen : 0), in sock_receive_internal()
736 if (msg != NULL && data == NULL) { in sock_receive_internal()
738 struct iovec *tempp = msg->msg_iov; in sock_receive_internal()
740 for (i = 0; i < msg->msg_iovlen; i++) { in sock_receive_internal()
759 data, (msg && msg->msg_control) ? &control : NULL, &flags); in sock_receive_internal()
767 if (msg != NULL) { in sock_receive_internal()
768 msg->msg_flags = flags; in sock_receive_internal()
770 if (msg->msg_name != NULL) { in sock_receive_internal()
[all …]
/xnu-8020.101.4/osfmk/corecrypto/
H A Dcc_abort.c48 cc_abort(const char * msg) in cc_abort() argument
50 panic("%s", msg); in cc_abort()
58 cc_abort(const char * msg) in cc_abort() argument
60 sys_panic(msg); in cc_abort()
67 cc_abort(const char * msg) in cc_abort() argument
69 RTK_abort("%s", msg); in cc_abort()
76 cc_abort(const char * msg CC_UNUSED) in cc_abort()
/xnu-8020.101.4/osfmk/ipc/
H A Dflipc.c258 mach_msg_send_from_remote_kernel(mach_msg_header_t *msg, in mach_msg_send_from_remote_kernel() argument
265 mr = ipc_kmsg_get_from_kernel(msg, send_size, &kmsg); in mach_msg_send_from_remote_kernel()
500 mnl_msg_t msg, in flipc_msg_from_node() argument
508 assert(msg->sub == MACH_NODE_SUB_FLIPC); in flipc_msg_from_node()
509 mach_node_t node = mach_node_for_id_locked(msg->node_id, FALSE, FALSE); in flipc_msg_from_node()
512 switch (msg->cmd) { in flipc_msg_from_node()
514 flipc_cmd_ipc(msg, node, flags); in flipc_msg_from_node()
519 flipc_cmd_ack((flipc_ack_msg_t)msg, node, flags); in flipc_msg_from_node()
537 flipc_msg_free(mnl_msg_t msg, in flipc_msg_free() argument
540 switch (msg->cmd) { in flipc_msg_free()
[all …]
/xnu-8020.101.4/libsyscall/mach/
H A Dmach_msg.c63 extern int proc_importance_assertion_begin_with_msg(mach_msg_header_t * msg, mach_msg_trailer_t * t…
66 #define MACH_MSG_TRAP(msg, opt, ssize, rsize, rname, to, not) \ argument
67 mach_msg_trap((msg), (opt), (ssize), (rsize), (rname), (to), (not))
97 mach_msg_header_t *msg, in mach_msg() argument
119 mr = MACH_MSG_TRAP(msg, option & ~LIBMACH_OPTIONS, in mach_msg()
128 mr = MACH_MSG_TRAP(msg, in mach_msg()
137 mr = MACH_MSG_TRAP(msg, in mach_msg()
165 mach_msg_header_t *msg, in mach_msg_overwrite() argument
189 mr = mach_msg_overwrite_trap(msg, option & ~LIBMACH_OPTIONS, in mach_msg_overwrite()
198 mr = mach_msg_overwrite_trap(msg, in mach_msg_overwrite()
[all …]
/xnu-8020.101.4/security/
H A Dmac_sysv_msg.c78 mac_sysvmsg_label_init(struct msg *msgptr) in mac_sysvmsg_label_init()
86 mac_sysvmsg_label(struct msg *msgptr) in mac_sysvmsg_label()
107 struct msg *msgptr) in mac_sysvmsg_label_associate()
120 mac_sysvmsg_label_recycle(struct msg *msgptr) in mac_sysvmsg_label_recycle()
132 mac_sysvmsq_check_enqueue(kauth_cred_t cred, struct msg *msgptr, in mac_sysvmsq_check_enqueue()
151 mac_sysvmsq_check_msgrcv(kauth_cred_t cred, struct msg *msgptr) in mac_sysvmsq_check_msgrcv()
168 mac_sysvmsq_check_msgrmid(kauth_cred_t cred, struct msg *msgptr) in mac_sysvmsq_check_msgrmid()

123456