if opt.noop or opt.copy:
cli = pack_writer = oldref = None
elif opt.remote or is_reverse:
- cli = client.Client(opt.remote, compression_level=opt.compress)
+ cli = client.Client(opt.remote)
oldref = refname and cli.read_ref(refname) or None
- pack_writer = cli.new_packwriter()
+ pack_writer = cli.new_packwriter(compression_level=opt.compress)
else:
cli = None
oldref = refname and git.read_ref(refname) or None
class Client:
- def __init__(self, remote, create=False, compression_level=1):
+ def __init__(self, remote, create=False):
self._busy = self.conn = None
self.sock = self.p = self.pout = self.pin = None
- self.compression_level = compression_level
is_reverse = os.environ.get('BUP_SERVER_REVERSE')
if is_reverse:
assert(not remote)
self.conn.write('%s\n' % ob)
return idx
- def new_packwriter(self):
+ def new_packwriter(self, compression_level = 1):
self.check_busy()
def _set_busy():
self._busy = 'receive-objects-v2'
onopen = _set_busy,
onclose = self._not_busy,
ensure_busy = self.ensure_busy,
- compression_level = self.compression_level)
+ compression_level = compression_level)
def read_ref(self, refname):
self.check_busy()
self._packopen = False
self._bwcount = 0
self._bwtime = time.time()
- self.compression_level = compression_level
def _open(self):
if not self._packopen: