1 /* 2 * Copyright (c) 2019 Apple Computer, Inc. All rights reserved. 3 * 4 * @APPLE_OSREFERENCE_LICENSE_HEADER_START@ 5 * 6 * This file contains Original Code and/or Modifications of Original Code 7 * as defined in and that are subject to the Apple Public Source License 8 * Version 2.0 (the 'License'). You may not use this file except in 9 * compliance with the License. The rights granted to you under the License 10 * may not be used to create, or enable the creation or redistribution of, 11 * unlawful or unlicensed copies of an Apple operating system, or to 12 * circumvent, violate, or enable the circumvention or violation of, any 13 * terms of an Apple operating system software license agreement. 14 * 15 * Please obtain a copy of the License at 16 * http://www.opensource.apple.com/apsl/ and read it before using this file. 17 * 18 * The Original Code and all software distributed under the License are 19 * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER 20 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, 21 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, 22 * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. 23 * Please see the License for the specific language governing rights and 24 * limitations under the License. 25 * 26 * @APPLE_OSREFERENCE_LICENSE_HEADER_END@ 27 */ 28 29 #include <darwintest.h> 30 #include <darwintest_multiprocess.h> 31 #include <stdio.h> 32 #include <unistd.h> 33 #include <sys/wait.h> 34 #include <pthread.h> 35 #include <stdlib.h> 36 #include <signal.h> 37 #include <dispatch/dispatch.h> 38 #include <fcntl.h> 39 #include <string.h> 40 #include <errno.h> 41 42 T_GLOBAL_META(T_META_RADAR_COMPONENT_NAME("xnu"), 43 T_META_RADAR_COMPONENT_VERSION("kevent")); 44 45 T_DECL(pipe_noblock_kevent, 46 "Set a pipe and no block and setup EVFLT_WRITE kevent on it and make sure it does not fire when the pipe is full") 47 { 48 int fd[2], write_fd; 49 dispatch_queue_t dq1 = dispatch_queue_create("com.apple.test.pipe_noblock_kevent.queue", DISPATCH_QUEUE_SERIAL); 50 51 pipe(fd); 52 write_fd = fd[1]; 53 __block int iter = 1; 54 55 /* Make sure the pipe is No block */ 56 fcntl(write_fd, F_SETFL, (O_NONBLOCK)); 57 58 dispatch_source_t write_source = dispatch_source_create(DISPATCH_SOURCE_TYPE_WRITE, (uintptr_t)write_fd, 0, dq1); 59 dispatch_source_set_event_handler(write_source, ^{ 60 unsigned long length = dispatch_source_get_data(write_source); 61 62 T_LOG("Iteration: %d, Length available: %lu\n", iter++, length); 63 64 char buf[512] = "deadbeef"; 65 ssize_t rv = write(write_fd, buf, 512); 66 T_EXPECT_POSIX_SUCCESS(rv, "write success"); 67 if (rv < 0) { 68 T_FAIL("Write should have succeeded but failed with error %ld", rv); 69 T_END; 70 } 71 }); 72 73 dispatch_resume(write_source); 74 75 T_LOG("Arming a timer for 15 seconds to exit, assuming kevent will block before that"); 76 dispatch_after(dispatch_time(DISPATCH_TIME_NOW, 15 * NSEC_PER_SEC), dispatch_get_main_queue(), ^{ 77 T_LOG("PASS: Kevent blocked as expected in the EVFLT_WRITE"); 78 T_END; 79 }); 80 81 dispatch_main(); 82 } 83