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

import argparse
import os
import sys
import time

def main():
    parser = argparse.ArgumentParser()
    parser.add_argument('mnt1')
    parser.add_argument('mnt2')
    parser.add_argument('fn')
    args = parser.parse_args()

    open(os.path.join(args.mnt1, args.fn), 'w')
    f1 = open(os.path.join(args.mnt1, args.fn), 'r+')
    f2 = open(os.path.join(args.mnt2, args.fn), 'r+')

    f1.write('foo')
    f1.flush()
    a = f2.read(3)
    print('got "%s"' % a)
    assert a == 'foo'
    f2.write('bar')
    f2.flush()
    a = f1.read(3)
    print('got "%s"' % a)
    assert a == 'bar'

    ## test short reads
    f1.write('short')
    f1.flush()
    a = f2.read(100)
    print('got "%s"' % a)
    assert a == 'short'
    f2.write('longer')
    f2.flush()
    a = f1.read(1000)
    print('got "%s"' % a)
    assert a == 'longer'

    print('ok')

main()