1 | #include "../common/tdb_private.h"
|
---|
2 | #include "../common/io.c"
|
---|
3 | #include "../common/tdb.c"
|
---|
4 | #include "../common/lock.c"
|
---|
5 | #include "../common/freelist.c"
|
---|
6 | #include "../common/traverse.c"
|
---|
7 | #include "../common/transaction.c"
|
---|
8 | #include "../common/error.c"
|
---|
9 | #include "../common/open.c"
|
---|
10 | #include "../common/check.c"
|
---|
11 | #include "../common/hash.c"
|
---|
12 | #include "../common/mutex.c"
|
---|
13 | #include "tap-interface.h"
|
---|
14 | #include <stdlib.h>
|
---|
15 | #include <sys/types.h>
|
---|
16 | #include <sys/wait.h>
|
---|
17 | #include <poll.h>
|
---|
18 | #include <stdarg.h>
|
---|
19 |
|
---|
20 | static TDB_DATA key, data;
|
---|
21 |
|
---|
22 | static void log_void(struct tdb_context *tdb, enum tdb_debug_level level,
|
---|
23 | const char *fmt, ...)
|
---|
24 | {
|
---|
25 | }
|
---|
26 |
|
---|
27 | static void log_fn(struct tdb_context *tdb, enum tdb_debug_level level,
|
---|
28 | const char *fmt, ...)
|
---|
29 | {
|
---|
30 | va_list ap;
|
---|
31 | va_start(ap, fmt);
|
---|
32 | vfprintf(stderr, fmt, ap);
|
---|
33 | va_end(ap);
|
---|
34 | }
|
---|
35 |
|
---|
36 | static int do_child(int fd)
|
---|
37 | {
|
---|
38 | struct tdb_context *tdb;
|
---|
39 | unsigned int log_count;
|
---|
40 | struct tdb_logging_context log_ctx = { log_fn, &log_count };
|
---|
41 | struct tdb_logging_context nolog_ctx = { log_void, NULL };
|
---|
42 | char c;
|
---|
43 |
|
---|
44 | read(fd, &c, 1);
|
---|
45 |
|
---|
46 | tdb = tdb_open_ex("mutex-openflags2.tdb", 0,
|
---|
47 | TDB_DEFAULT,
|
---|
48 | O_RDWR|O_CREAT, 0755, &nolog_ctx, NULL);
|
---|
49 | ok((tdb == NULL) && (errno == EINVAL), "TDB_DEFAULT without "
|
---|
50 | "TDB_MUTEX_LOCKING should fail with EINVAL - %d", errno);
|
---|
51 |
|
---|
52 | tdb = tdb_open_ex("mutex-openflags2.tdb", 0,
|
---|
53 | TDB_CLEAR_IF_FIRST,
|
---|
54 | O_RDWR|O_CREAT, 0755, &nolog_ctx, NULL);
|
---|
55 | ok((tdb == NULL) && (errno == EINVAL), "TDB_CLEAR_IF_FIRST without "
|
---|
56 | "TDB_MUTEX_LOCKING should fail with EINVAL - %d", errno);
|
---|
57 |
|
---|
58 | tdb = tdb_open_ex("mutex-openflags2.tdb", 0,
|
---|
59 | TDB_CLEAR_IF_FIRST |
|
---|
60 | TDB_MUTEX_LOCKING |
|
---|
61 | TDB_INTERNAL,
|
---|
62 | O_RDWR|O_CREAT, 0755, &nolog_ctx, NULL);
|
---|
63 | ok((tdb == NULL) && (errno == EINVAL), "TDB_MUTEX_LOCKING with "
|
---|
64 | "TDB_INTERNAL should fail with EINVAL - %d", errno);
|
---|
65 |
|
---|
66 | tdb = tdb_open_ex("mutex-openflags2.tdb", 0,
|
---|
67 | TDB_CLEAR_IF_FIRST |
|
---|
68 | TDB_MUTEX_LOCKING |
|
---|
69 | TDB_NOMMAP,
|
---|
70 | O_RDWR|O_CREAT, 0755, &nolog_ctx, NULL);
|
---|
71 | ok((tdb == NULL) && (errno == EINVAL), "TDB_MUTEX_LOCKING with "
|
---|
72 | "TDB_NOMMAP should fail with EINVAL - %d", errno);
|
---|
73 |
|
---|
74 | tdb = tdb_open_ex("mutex-openflags2.tdb", 0,
|
---|
75 | TDB_CLEAR_IF_FIRST |
|
---|
76 | TDB_MUTEX_LOCKING,
|
---|
77 | O_RDONLY, 0755, &nolog_ctx, NULL);
|
---|
78 | ok((tdb != NULL), "TDB_MUTEX_LOCKING with "
|
---|
79 | "O_RDONLY should work - %d", errno);
|
---|
80 | tdb_close(tdb);
|
---|
81 |
|
---|
82 | tdb = tdb_open_ex("mutex-openflags2.tdb", 0,
|
---|
83 | TDB_CLEAR_IF_FIRST |
|
---|
84 | TDB_MUTEX_LOCKING,
|
---|
85 | O_RDWR|O_CREAT, 0755, &log_ctx, NULL);
|
---|
86 | ok((tdb != NULL), "TDB_MUTEX_LOCKING with TDB_CLEAR_IF_FIRST"
|
---|
87 | "TDB_NOMMAP should work - %d", errno);
|
---|
88 |
|
---|
89 | return 0;
|
---|
90 | }
|
---|
91 |
|
---|
92 | /* The code should barf on TDBs created with rwlocks. */
|
---|
93 | int main(int argc, char *argv[])
|
---|
94 | {
|
---|
95 | struct tdb_context *tdb;
|
---|
96 | unsigned int log_count;
|
---|
97 | struct tdb_logging_context log_ctx = { log_fn, &log_count };
|
---|
98 | struct tdb_logging_context nolog_ctx = { log_void, NULL };
|
---|
99 | int ret, status;
|
---|
100 | pid_t child, wait_ret;
|
---|
101 | int pipefd[2];
|
---|
102 | char c = 0;
|
---|
103 | bool runtime_support;
|
---|
104 |
|
---|
105 | runtime_support = tdb_runtime_check_for_robust_mutexes();
|
---|
106 |
|
---|
107 | ret = pipe(pipefd);
|
---|
108 | ok1(ret == 0);
|
---|
109 |
|
---|
110 | key.dsize = strlen("hi");
|
---|
111 | key.dptr = discard_const_p(uint8_t, "hi");
|
---|
112 | data.dsize = strlen("world");
|
---|
113 | data.dptr = discard_const_p(uint8_t, "world");
|
---|
114 |
|
---|
115 | tdb = tdb_open_ex("mutex-openflags2.tdb", 0,
|
---|
116 | TDB_INCOMPATIBLE_HASH|
|
---|
117 | TDB_MUTEX_LOCKING,
|
---|
118 | O_RDWR|O_CREAT, 0755, &nolog_ctx, NULL);
|
---|
119 | ok((tdb == NULL) && (errno == EINVAL), "TDB_MUTEX_LOCKING without "
|
---|
120 | "TDB_CLEAR_IF_FIRST should fail with EINVAL - %d", errno);
|
---|
121 |
|
---|
122 | if (!runtime_support) {
|
---|
123 | tdb = tdb_open_ex("mutex-openflags2.tdb", 0,
|
---|
124 | TDB_CLEAR_IF_FIRST|
|
---|
125 | TDB_MUTEX_LOCKING,
|
---|
126 | O_RDWR|O_CREAT, 0755, &nolog_ctx, NULL);
|
---|
127 | ok((tdb == NULL) && (errno == ENOSYS), "TDB_MUTEX_LOCKING without "
|
---|
128 | "runtime support should fail with ENOSYS - %d", errno);
|
---|
129 |
|
---|
130 | skip(1, "No robust mutex support");
|
---|
131 | return exit_status();
|
---|
132 | }
|
---|
133 |
|
---|
134 | child = fork();
|
---|
135 | if (child == 0) {
|
---|
136 | return do_child(pipefd[0]);
|
---|
137 | }
|
---|
138 |
|
---|
139 | tdb = tdb_open_ex("mutex-openflags2.tdb", 0,
|
---|
140 | TDB_CLEAR_IF_FIRST|
|
---|
141 | TDB_MUTEX_LOCKING,
|
---|
142 | O_RDWR|O_CREAT, 0755, &log_ctx, NULL);
|
---|
143 | ok((tdb != NULL), "tdb_open_ex with mutexes should succeed");
|
---|
144 |
|
---|
145 | write(pipefd[1], &c, 1);
|
---|
146 |
|
---|
147 | wait_ret = wait(&status);
|
---|
148 | ok((wait_ret == child) && (status == 0),
|
---|
149 | "child should have exited correctly");
|
---|
150 |
|
---|
151 | diag("done");
|
---|
152 | return exit_status();
|
---|
153 | }
|
---|