src/ceph/qa/workunits/fs/multiclient_sync_read_eof.py

   1 #!/usr/bin/python
   2
   3 import argparse
   4 import os
   5 import sys
   6 import time
   7
   8 def main():
   9     parser = argparse.ArgumentParser()
  10     parser.add_argument('mnt1')
  11     parser.add_argument('mnt2')
  12     parser.add_argument('fn')
  13     args = parser.parse_args()
  14
  15     open(os.path.join(args.mnt1, args.fn), 'w')
  16     f1 = open(os.path.join(args.mnt1, args.fn), 'r+')
  17     f2 = open(os.path.join(args.mnt2, args.fn), 'r+')
  18
  19     f1.write('foo')
  20     f1.flush()
  21     a = f2.read(3)
  22     print('got "%s"' % a)
  23     assert a == 'foo'
  24     f2.write('bar')
  25     f2.flush()
  26     a = f1.read(3)
  27     print('got "%s"' % a)
  28     assert a == 'bar'
  29
  30     ## test short reads
  31     f1.write('short')
  32     f1.flush()
  33     a = f2.read(100)
  34     print('got "%s"' % a)
  35     assert a == 'short'
  36     f2.write('longer')
  37     f2.flush()
  38     a = f1.read(1000)
  39     print('got "%s"' % a)
  40     assert a == 'longer'
  41
  42     print('ok')
  43
  44 main()