1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
/* klaar@ida
pintos -v -k -T 180 --fs-disk=2 --qemu -p ../examples/create_file -a create_file -p ../examples/create_remove_file -a cr_rm_file -p ../examples/dir_stress -a dir_stress -- -f -q run dir_stress
*/
#include <stdio.h>
#include <syscall.h>
#define CREATORS 20 /* no of procs to concurrently create files */
#define LOADERS 11 /* no of procs to create/remove */
#define CYCLES 100 /* how many create/remove cycles to do */
#define TRIES 20 /* how many tries to create duplicates */
#define BUFSIZE 40 /* exec cmd line buffer */
int main(void)
{
char buffer[BUFSIZE];
int creator_pid[CREATORS];
int loader_pid[LOADERS];
int exit_status = 0;
int i, n;
/* put some load on the directory */
for (i = 0; i < LOADERS; ++i)
{
snprintf(buffer, BUFSIZE, "cr_rm_file load.%d %d", i, CYCLES);
loader_pid[i] = exec(buffer);
}
for (n = 0; n < TRIES; ++n)
{
int success_count = 0;
int crash_count = 0;
int fail_count = 0;
/* set up processes to simultaneously create same file */
for (i = 0; i < CREATORS; ++i)
{
snprintf(buffer, BUFSIZE, "create_file file.%d", n);
creator_pid[i] = exec(buffer);
}
/* all creators will wait for this file to appear */
create("go", 1);
/* wait for creators to finish */
for (i = 0; i < CREATORS; ++i)
{
int r = wait(creator_pid[i]);
success_count += (r == 0);
crash_count += (r == -1);
fail_count += (r == 1);
}
remove("go");
/* clean up the created file */
snprintf(buffer, BUFSIZE, "file.%d", n);
remove(buffer);
/* only one creator should succed */
if (success_count != 1)
{
printf("ERROR: %d files with same name created\n",
success_count);
exit_status = -1;
}
if (crash_count != 0)
{
printf("ERROR: %d creator processes crashed\n",
crash_count);
exit_status = -1;
}
if (fail_count != (CREATORS - 1))
{
printf("ERROR: %d creator processes failed\n",
fail_count);
exit_status = -1;
}
}
for (i = 0; i < LOADERS; ++i)
{
int result = wait( loader_pid[i] );
if ( result != 0 )
{
printf("ERROR: loader %d finished with code %d\n",
loader_pid[i], result);
exit_status = -1;
}
}
return exit_status;
}
|
