Loading...
tests/kqueue_nesting.c xnu-12377.101.15 /dev/null
--- xnu/xnu-12377.101.15/tests/kqueue_nesting.c
+++ /dev/null
@@ -1,79 +0,0 @@
-#include <unistd.h>
-#include <pthread.h>
-#include <errno.h>
-
-#include <sys/event.h>
-#include <mach/mach.h>
-#include <mach/mach_port.h>
-
-#include <Block.h>
-#include <darwintest.h>
-
-T_DECL(kqueue_nesting_level, "rdar://100277117 (Reduce kqueue nesting level so that we don't overflow kernel stack)")
-{
-	// Create a port and register a knote for it on a kqueue
-	mach_port_t port = MACH_PORT_NULL;
-	kern_return_t kr = mach_port_allocate(mach_task_self(), MACH_PORT_RIGHT_RECEIVE, &port);
-	T_ASSERT_MACH_SUCCESS(kr, "allocating a port with a receive right");
-
-	int port_kq = kqueue();
-	struct kevent_qos_s event = {
-		.ident = port,
-		.filter = EVFILT_MACHPORT,
-		.flags = EV_ADD | EV_ENABLE,
-		.qos = 0x00,
-		.udata = 0x66666666,
-		.fflags = MACH_RCV_MSG,
-		.xflags = 0,
-		.data = 0,
-		.ext = {},
-	};
-	int nevents = kevent_qos(port_kq, &event, 1, NULL, 0, NULL, NULL, 0);
-	T_EXPECT_EQ(nevents, 0, NULL);
-
-	// Register the other kqueues
-	int child_kq = port_kq;
-
-	for (size_t i = 0; i < 1000; i++) {
-		int kq = kqueue();
-		struct kevent_qos_s kq_read_event = {
-			.ident = child_kq,
-			.filter = EVFILT_READ,
-			.flags = EV_ADD | EV_ENABLE,
-			.qos = 0x00,
-			.udata = 0x66666666,
-			.fflags = 0x00,
-			.xflags = 0x00,
-			.data = 0,
-			.ext = {},
-		};
-
-		nevents = kevent_qos(kq, &kq_read_event, 1, NULL, 0, NULL, NULL, 0);
-		// This kevent may sometimes fail after we exceed the limit enforced by the
-		// kernel in which case, we'd just have created kqueues but not set up any
-		// knotes on them.
-		//
-		// On old-OSes prior to rdar://100277117, this would always succeed and then
-		// we'd panic when we send a message
-		child_kq = kq;
-	}
-
-	// Send a message to the port and activate the first kqueue
-	struct {
-		mach_msg_header_t header;
-		uint64_t data;
-	} message = {
-		.header = {
-			.msgh_remote_port = port,
-			.msgh_local_port = MACH_PORT_NULL,
-			.msgh_voucher_port = MACH_PORT_NULL,
-			.msgh_size = sizeof(message),
-			.msgh_id = 0x88888888,
-			.msgh_bits = MACH_MSGH_BITS_SET(MACH_MSG_TYPE_MAKE_SEND_ONCE, 0, 0, 0),
-		},
-		.data = 0x8888888888888,
-	};
-
-	kr = mach_msg(&message.header, MACH_SEND_MSG, sizeof(message), 0, MACH_PORT_NULL, MACH_MSG_TIMEOUT_NONE, MACH_PORT_NULL);
-	T_ASSERT_MACH_SUCCESS(kr, "mach_msg(SEND)");
-}