lib/bup/t/tclient.py

   1 import sys, os, time, random, subprocess
   2 from bup import client, git, hashsplit
   3 from wvtest import *
   4
   5 def randbytes(sz):
   6     s = ''
   7     for i in xrange(sz):
   8         s += chr(random.randrange(0,256))
   9     return s
  10
  11 s1 = randbytes(10000)
  12 s2 = randbytes(10000)
  13
  14 @wvtest
  15 def test_server_split_with_indexes():
  16     os.environ['BUP_MAIN_EXE'] = '../../../bup'
  17     os.environ['BUP_DIR'] = bupdir = 'buptest_tclient.tmp'
  18     subprocess.call(['rm', '-rf', bupdir])
  19     git.init_repo(bupdir)
  20     lw = git.PackWriter()
  21     c = client.Client(bupdir, create=True)
  22     rw = c.new_packwriter()
  23
  24     lw.new_blob(s1)
  25     lw.close()
  26
  27     rw.new_blob(s2)
  28     rw.breakpoint()
  29     rw.new_blob(s1)
  30
  31
  32 @wvtest
  33 def test_midx_refreshing():
  34     os.environ['BUP_MAIN_EXE'] = bupmain = '../../../bup'
  35     os.environ['BUP_DIR'] = bupdir = 'buptest_tmidx.tmp'
  36     subprocess.call(['rm', '-rf', bupdir])
  37     git.init_repo(bupdir)
  38     lw = git.PackWriter()
  39     lw.new_blob(s1)
  40     lw.breakpoint()
  41     lw.new_blob(s2)
  42     del lw
  43     pi = git.PackIdxList(bupdir + '/objects/pack')
  44     WVPASSEQ(len(pi.packs), 2)
  45     pi.refresh()
  46     WVPASSEQ(len(pi.packs), 2)
  47     subprocess.call([bupmain, 'midx', '-f'])
  48     pi.refresh()
  49     WVPASSEQ(len(pi.packs), 1)
  50     pi.refresh(skip_midx=True)
  51     WVPASSEQ(len(pi.packs), 2)
  52     pi.refresh(skip_midx=False)
  53     WVPASSEQ(len(pi.packs), 1)