blob: 60145b28a0fce2dd6fc0b3b6ac4025f1ab0f8a4e (
plain)
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
|
#include <stdio.h>
#include <unistd.h>
#include "Rts.h"
#include "RtsAPI.h"
#include "rts_pause_lock.h"
// Although we expect errors rather than deadlock, we don't want a failed test
// to be a deadlocked test. Hence we use this as a 1 second timeout mechanism.
void assertDoneAfterOneSecond(int * done)
{
sleep(1);
if (!*done)
{
printf("Deadlock detected.");
exit(1);
}
}
void lockThenPause (int * done) {
printf("Locking...");
Capability * lockCap = rts_lock();
printf("Locked\n");
printf("Pausing...");
PauseToken * token = rts_pause();
Capability * pauseCap = pauseTokenCapability(token);
printf("Paused\n");
printf("Resuming...");
rts_resume(token);
printf("Resumed\n");
printf("Unlocking...");
rts_unlock(lockCap);
printf("Unlocked\n");
*done = 1;
}
void pauseThenLock (int * done) {
printf("Pausing...");
PauseToken * token = rts_pause();
Capability * pauseCap = pauseTokenCapability(token);
printf("Paused\n");
printf("Locking...");
Capability * lockCap = rts_lock();
printf("Locked\n");
printf("Unlocking...");
rts_unlock(lockCap);
printf("Unlocked\n");
printf("Resuming...");
rts_resume(token);
printf("Resumed\n");
*done = 1;
}
void doublePause (int * done) {
printf("Pausing...");
PauseToken * tokenA = rts_pause();
Capability * pauseCapA = pauseTokenCapability(tokenA);
printf("Paused\n");
printf("Pausing...");
PauseToken * tokenB = rts_pause();
Capability * pauseCapB = pauseTokenCapability(tokenB);
printf("Paused\n");
printf("Resuming...");
rts_resume(tokenA);
printf("Resuming\n");
printf("Resuming...");
rts_resume(tokenB);
printf("Resumed\n");
*done = 1;
}
|
