from XRootD import client
from XRootD.client.flags import OpenFlags
from threading import Thread
from env import *

class TestThread(Thread):
  def __init__(self, file, id):
    Thread.__init__(self)
    self.file = file
    self.id = id
  def run(self):
    self.file.open(smallfile, OpenFlags.DELETE)
    assert self.file.is_open()

    s, _ = self.file.write(smallbuffer)
    assert s.ok

    print '+++ thread %d says: %s' % (self.id, self.file.read())

    for line in self.file:
      print '+++ thread %d says: %s' % (self.id, line)

    self.file.close()

def test_threads():
  f = client.File()
#   f.open(smallfile, OpenFlags.DELETE)
#   assert f.is_open()
#   f.write(smallbuffer)

  for i in xrange(3):
    tt = TestThread(f, i)
    tt.start()
    tt.join()

#   f.close()