1*4f1223e8SApple OSS Distributions #include <stdlib.h>
2*4f1223e8SApple OSS Distributions
3*4f1223e8SApple OSS Distributions #include <pthread.h>
4*4f1223e8SApple OSS Distributions #include <sys/kern_control.h>
5*4f1223e8SApple OSS Distributions #include <sys/socket.h>
6*4f1223e8SApple OSS Distributions #include <sys/sys_domain.h>
7*4f1223e8SApple OSS Distributions #include <unistd.h>
8*4f1223e8SApple OSS Distributions
9*4f1223e8SApple OSS Distributions #include <darwintest.h>
10*4f1223e8SApple OSS Distributions
11*4f1223e8SApple OSS Distributions /* we should win the race in this window: */
12*4f1223e8SApple OSS Distributions #define NTRIES 200000
13*4f1223e8SApple OSS Distributions
14*4f1223e8SApple OSS Distributions static void *
connect_race(void * data)15*4f1223e8SApple OSS Distributions connect_race(void *data)
16*4f1223e8SApple OSS Distributions {
17*4f1223e8SApple OSS Distributions int *ps = data;
18*4f1223e8SApple OSS Distributions struct sockaddr_ctl sc = {
19*4f1223e8SApple OSS Distributions .sc_id = 1 /* com.apple.flow-divert */
20*4f1223e8SApple OSS Distributions };
21*4f1223e8SApple OSS Distributions int n;
22*4f1223e8SApple OSS Distributions
23*4f1223e8SApple OSS Distributions for (n = 0; n < NTRIES; ++n) {
24*4f1223e8SApple OSS Distributions connect(*ps, (const struct sockaddr *)&sc, sizeof(sc));
25*4f1223e8SApple OSS Distributions }
26*4f1223e8SApple OSS Distributions
27*4f1223e8SApple OSS Distributions return NULL;
28*4f1223e8SApple OSS Distributions }
29*4f1223e8SApple OSS Distributions
30*4f1223e8SApple OSS Distributions T_DECL(flow_div_doubleconnect_55917185, "Bad error path in double-connect for flow_divert_kctl_connect", T_META_TAG_VM_PREFERRED)
31*4f1223e8SApple OSS Distributions {
32*4f1223e8SApple OSS Distributions int s = -1;
33*4f1223e8SApple OSS Distributions int tmp_s;
34*4f1223e8SApple OSS Distributions struct sockaddr_ctl sc = {
35*4f1223e8SApple OSS Distributions .sc_id = 1 /* com.apple.flow-divert */
36*4f1223e8SApple OSS Distributions };
37*4f1223e8SApple OSS Distributions pthread_t t;
38*4f1223e8SApple OSS Distributions int n;
39*4f1223e8SApple OSS Distributions
40*4f1223e8SApple OSS Distributions T_SETUPBEGIN;
41*4f1223e8SApple OSS Distributions T_ASSERT_POSIX_ZERO(pthread_create(&t, NULL, connect_race, &s), NULL);
42*4f1223e8SApple OSS Distributions T_SETUPEND;
43*4f1223e8SApple OSS Distributions
44*4f1223e8SApple OSS Distributions for (n = 0; n < NTRIES; ++n) {
45*4f1223e8SApple OSS Distributions T_ASSERT_POSIX_SUCCESS(tmp_s = socket(AF_SYSTEM, SOCK_DGRAM, SYSPROTO_CONTROL), NULL);
46*4f1223e8SApple OSS Distributions
47*4f1223e8SApple OSS Distributions /*
48*4f1223e8SApple OSS Distributions * this bind will fail, but that's ok because it initialises
49*4f1223e8SApple OSS Distributions * kctl:
50*4f1223e8SApple OSS Distributions */
51*4f1223e8SApple OSS Distributions bind(tmp_s, (const struct sockaddr *)&sc, sizeof(sc));
52*4f1223e8SApple OSS Distributions
53*4f1223e8SApple OSS Distributions /* this is what we're racing the other thread for: */
54*4f1223e8SApple OSS Distributions s = tmp_s;
55*4f1223e8SApple OSS Distributions connect(s, (const struct sockaddr *)&sc, sizeof(sc));
56*4f1223e8SApple OSS Distributions
57*4f1223e8SApple OSS Distributions T_ASSERT_POSIX_SUCCESS(close(s), NULL);
58*4f1223e8SApple OSS Distributions s = -1;
59*4f1223e8SApple OSS Distributions }
60*4f1223e8SApple OSS Distributions
61*4f1223e8SApple OSS Distributions T_ASSERT_POSIX_ZERO(pthread_join(t, NULL), NULL);
62*4f1223e8SApple OSS Distributions T_PASS("flow_divert_kctl_connect race didn't trigger panic");
63*4f1223e8SApple OSS Distributions }
64