summaryrefslogtreecommitdiffstats
path: root/src/ceph/qa/workunits/fs/misc/filelock_deadlock.py
blob: 3ebc9777bd25ebb43b004757095515c1cd6e8771 (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
#!/usr/bin/python

import errno
import fcntl
import os
import signal
import struct
import time


def handler(signum, frame):
    pass


def lock_two(f1, f2):
    lockdata = struct.pack('hhllhh', fcntl.F_WRLCK, 0, 0, 10, 0, 0)
    fcntl.fcntl(f1, fcntl.F_SETLKW, lockdata)
    time.sleep(10)

    # don't wait forever
    signal.signal(signal.SIGALRM, handler)
    signal.alarm(10)
    exitcode = 0
    try:
        fcntl.fcntl(f2, fcntl.F_SETLKW, lockdata)
    except IOError as e:
        if e.errno == errno.EDEADLK:
            exitcode = 1
        elif e.errno == errno.EINTR:
            exitcode = 2
        else:
            exitcode = 3
    os._exit(exitcode)


def main():
    pid1 = os.fork()
    if pid1 == 0:
        f1 = open("testfile1", 'w')
        f2 = open("testfile2", 'w')
        lock_two(f1, f2)

    pid2 = os.fork()
    if pid2 == 0:
        f1 = open("testfile2", 'w')
        f2 = open("testfile3", 'w')
        lock_two(f1, f2)

    pid3 = os.fork()
    if pid3 == 0:
        f1 = open("testfile3", 'w')
        f2 = open("testfile1", 'w')
        lock_two(f1, f2)

    deadlk_count = 0
    i = 0
    while i < 3:
        pid, status = os.wait()
        exitcode = status >> 8
        if exitcode == 1:
            deadlk_count += 1
        elif exitcode != 0:
            raise RuntimeError("unexpect exit code of child")
        i += 1

    if deadlk_count != 1:
        raise RuntimeError("unexpect count of EDEADLK")

    print('ok')


main()