-o = options.Options('bup save', optspec)
-(opt, flags, extra) = o.parse(sys.argv[1:])
-
-git.check_repo_or_die()
-if not (opt.tree or opt.commit or opt.name):
- o.fatal("use one or more of -t, -c, -n")
-if not extra:
- o.fatal("no filenames given")
-
-opt.progress = (istty and not opt.quiet)
-opt.smaller = parse_num(opt.smaller or 0)
-
-is_reverse = os.environ.get('BUP_SERVER_REVERSE')
-if is_reverse and opt.remote:
- o.fatal("don't use -r in reverse mode; it's automatic")
-
-refname = opt.name and 'refs/heads/%s' % opt.name or None
-if opt.remote or is_reverse:
- cli = client.Client(opt.remote)
- oldref = refname and cli.read_ref(refname) or None
- w = cli.new_packwriter()
-else:
- cli = None
- oldref = refname and git.read_ref(refname) or None
- w = git.PackWriter()
-
-handle_ctrl_c()
-
-
-def eatslash(dir):
- if dir.endswith('/'):
- return dir[:-1]
- else:
- return dir
-
-
-parts = ['']
-shalists = [[]]
-
-def _push(part):
- assert(part)
- parts.append(part)
- shalists.append([])
-
-def _pop(force_tree):
- assert(len(parts) >= 1)
- part = parts.pop()
- shalist = shalists.pop()
- tree = force_tree or w.new_tree(shalist)
- if shalists:
- shalists[-1].append(('40000', part, tree))
- else: # this was the toplevel, so put it back for sanity
- shalists.append(shalist)
- return tree
-
-lastremain = None
-def progress_report(n):
- global count, subcount, lastremain
- subcount += n
- cc = count + subcount
- pct = total and (cc*100.0/total) or 0
- now = time.time()
- elapsed = now - tstart
- kps = elapsed and int(cc/1024./elapsed)
- kps_frac = 10 ** int(math.log(kps+1, 10) - 1)
- kps = int(kps/kps_frac)*kps_frac
- if cc:
- remain = elapsed*1.0/cc * (total-cc)
- else:
- remain = 0.0
- if (lastremain and (remain > lastremain)
- and ((remain - lastremain)/lastremain < 0.05)):
- remain = lastremain
- else:
- lastremain = remain
- hours = int(remain/60/60)
- mins = int(remain/60 - hours*60)
- secs = int(remain - hours*60*60 - mins*60)
- if elapsed < 30:
- remainstr = ''
- kpsstr = ''
- else:
- kpsstr = '%dk/s' % kps
- if hours:
- remainstr = '%dh%dm' % (hours, mins)
- elif mins:
- remainstr = '%dm%d' % (mins, secs)
- else:
- remainstr = '%ds' % secs
- progress('Saving: %.2f%% (%d/%dk, %d/%d files) %s %s\r'
- % (pct, cc/1024, total/1024, fcount, ftotal,
- remainstr, kpsstr))
-
-
-r = index.Reader(git.repo('bupindex'))
-
-def already_saved(ent):
- return ent.is_valid() and w.exists(ent.sha) and ent.sha
-
-def wantrecurse_pre(ent):
- return not already_saved(ent)
-
-def wantrecurse_during(ent):
- return not already_saved(ent) or ent.sha_missing()
-
-total = ftotal = 0
-if opt.progress:
- for (transname,ent) in r.filter(extra, wantrecurse=wantrecurse_pre):
- if not (ftotal % 10024):
- progress('Reading index: %d\r' % ftotal)
- exists = ent.exists()
- hashvalid = already_saved(ent)
- ent.set_sha_missing(not hashvalid)
- if not opt.smaller or ent.size < opt.smaller:
- if exists and not hashvalid:
- total += ent.size
- ftotal += 1
- progress('Reading index: %d, done.\n' % ftotal)
- hashsplit.progress_callback = progress_report
-
-tstart = time.time()
-count = subcount = fcount = 0
-lastskip_name = None
-lastdir = ''
-for (transname,ent) in r.filter(extra, wantrecurse=wantrecurse_during):
- (dir, file) = os.path.split(ent.name)
- exists = (ent.flags & index.IX_EXISTS)
- hashvalid = already_saved(ent)
- wasmissing = ent.sha_missing()
- oldsize = ent.size
- if opt.verbose:
- if not exists:
- status = 'D'
- elif not hashvalid:
- if ent.sha == index.EMPTY_SHA:
- status = 'A'
- else:
- status = 'M'
- else:
- status = ' '
- if opt.verbose >= 2:
- log('%s %-70s\n' % (status, ent.name))
- elif not stat.S_ISDIR(ent.mode) and lastdir != dir:
- if not lastdir.startswith(dir):
- log('%s %-70s\n' % (status, os.path.join(dir, '')))
- lastdir = dir
-
- if opt.progress:
- progress_report(0)
- fcount += 1
+b = bcgvbaf.Bcgvbaf('ohc fnir', bcgfcrp)
+(bcg, syntf, rkgen) = b.cnefr(flf.neti[1:])
+
+tvg.purpx_ercb_be_qvr()
+vs abg (bcg.gerr be bcg.pbzzvg be bcg.anzr):
+ b.sngny("hfr bar be zber bs -g, -p, -a")
+vs abg rkgen:
+ b.sngny("ab svyranzrf tvira")
+
+bcg.cebterff = (vfggl naq abg bcg.dhvrg)
+bcg.fznyyre = cnefr_ahz(bcg.fznyyre be 0)
+
+vf_erirefr = bf.raiveba.trg('OHC_FREIRE_ERIREFR')
+vs vf_erirefr naq bcg.erzbgr:
+ b.sngny("qba'g hfr -e va erirefr zbqr; vg'f nhgbzngvp")
+
+ersanzr = bcg.anzr naq 'ersf/urnqf/%f' % bcg.anzr be Abar
+vs bcg.erzbgr be vf_erirefr:
+ pyv = pyvrag.Pyvrag(bcg.erzbgr)
+ byqers = ersanzr naq pyv.ernq_ers(ersanzr) be Abar
+ j = pyv.arj_cnpxjevgre()
+ryfr:
+ pyv = Abar
+ byqers = ersanzr naq tvg.ernq_ers(ersanzr) be Abar
+ j = tvg.CnpxJevgre()
+
+unaqyr_pgey_p()
+
+
+qrs rngfynfu(qve):
+ vs qve.raqfjvgu('/'):
+ erghea qve[:-1]
+ ryfr:
+ erghea qve
+
+
+cnegf = ['']
+funyvfgf = [[]]
+
+qrs _chfu(cneg):
+ nffreg(cneg)
+ cnegf.nccraq(cneg)
+ funyvfgf.nccraq([])
+
+qrs _cbc(sbepr_gerr):
+ nffreg(yra(cnegf) >= 1)
+ cneg = cnegf.cbc()
+ funyvfg = funyvfgf.cbc()
+ gerr = sbepr_gerr be j.arj_gerr(funyvfg)
+ vs funyvfgf:
+ funyvfgf[-1].nccraq(('40000', cneg, gerr))
+ ryfr: # guvf jnf gur gbcyriry, fb chg vg onpx sbe fnavgl
+ funyvfgf.nccraq(funyvfg)
+ erghea gerr
+
+ynfgerznva = Abar
+qrs cebterff_ercbeg(a):
+ tybony pbhag, fhopbhag, ynfgerznva
+ fhopbhag += a
+ pp = pbhag + fhopbhag
+ cpg = gbgny naq (pp*100.0/gbgny) be 0
+ abj = gvzr.gvzr()
+ ryncfrq = abj - gfgneg
+ xcf = ryncfrq naq vag(pp/1024./ryncfrq)
+ xcf_senp = 10 ** vag(zngu.ybt(xcf+1, 10) - 1)
+ xcf = vag(xcf/xcf_senp)*xcf_senp
+ vs pp:
+ erznva = ryncfrq*1.0/pp * (gbgny-pp)
+ ryfr:
+ erznva = 0.0
+ vs (ynfgerznva naq (erznva > ynfgerznva)
+ naq ((erznva - ynfgerznva)/ynfgerznva < 0.05)):
+ erznva = ynfgerznva
+ ryfr:
+ ynfgerznva = erznva
+ ubhef = vag(erznva/60/60)
+ zvaf = vag(erznva/60 - ubhef*60)
+ frpf = vag(erznva - ubhef*60*60 - zvaf*60)
+ vs ryncfrq < 30:
+ erznvafge = ''
+ xcffge = ''
+ ryfr:
+ xcffge = '%qx/f' % xcf
+ vs ubhef:
+ erznvafge = '%qu%qz' % (ubhef, zvaf)
+ ryvs zvaf:
+ erznvafge = '%qz%q' % (zvaf, frpf)
+ ryfr:
+ erznvafge = '%qf' % frpf
+ cebterff('Fnivat: %.2s%% (%q/%qx, %q/%q svyrf) %f %f\e'
+ % (cpg, pp/1024, gbgny/1024, spbhag, sgbgny,
+ erznvafge, xcffge))
+
+
+e = vaqrk.Ernqre(tvg.ercb('ohcvaqrk'))
+
+qrs nyernql_fnirq(rag):
+ erghea rag.vf_inyvq() naq j.rkvfgf(rag.fun) naq rag.fun
+
+qrs jnagerphefr_cer(rag):
+ erghea abg nyernql_fnirq(rag)
+
+qrs jnagerphefr_qhevat(rag):
+ erghea abg nyernql_fnirq(rag) be rag.fun_zvffvat()
+
+gbgny = sgbgny = 0
+vs bcg.cebterff:
+ sbe (genafanzr,rag) va e.svygre(rkgen, jnagerphefr=jnagerphefr_cer):
+ vs abg (sgbgny % 10024):
+ cebterff('Ernqvat vaqrk: %q\e' % sgbgny)
+ rkvfgf = rag.rkvfgf()
+ unfuinyvq = nyernql_fnirq(rag)
+ rag.frg_fun_zvffvat(abg unfuinyvq)
+ vs abg bcg.fznyyre be rag.fvmr < bcg.fznyyre:
+ vs rkvfgf naq abg unfuinyvq:
+ gbgny += rag.fvmr
+ sgbgny += 1
+ cebterff('Ernqvat vaqrk: %q, qbar.\a' % sgbgny)
+ unfufcyvg.cebterff_pnyyonpx = cebterff_ercbeg
+
+gfgneg = gvzr.gvzr()
+pbhag = fhopbhag = spbhag = 0
+ynfgfxvc_anzr = Abar
+ynfgqve = ''
+sbe (genafanzr,rag) va e.svygre(rkgen, jnagerphefr=jnagerphefr_qhevat):
+ (qve, svyr) = bf.cngu.fcyvg(rag.anzr)
+ rkvfgf = (rag.syntf & vaqrk.VK_RKVFGF)
+ unfuinyvq = nyernql_fnirq(rag)
+ jnfzvffvat = rag.fun_zvffvat()
+ byqfvmr = rag.fvmr
+ vs bcg.ireobfr:
+ vs abg rkvfgf:
+ fgnghf = 'Q'
+ ryvs abg unfuinyvq:
+ vs rag.fun == vaqrk.RZCGL_FUN:
+ fgnghf = 'N'
+ ryfr:
+ fgnghf = 'Z'
+ ryfr:
+ fgnghf = ' '
+ vs bcg.ireobfr >= 2:
+ ybt('%f %-70f\a' % (fgnghf, rag.anzr))
+ ryvs abg fgng.F_VFQVE(rag.zbqr) naq ynfgqve != qve:
+ vs abg ynfgqve.fgnegfjvgu(qve):
+ ybt('%f %-70f\a' % (fgnghf, bf.cngu.wbva(qve, '')))
+ ynfgqve = qve
+
+ vs bcg.cebterff:
+ cebterff_ercbeg(0)
+ spbhag += 1