/brz/remove-bazaar : revision 0.200.586

1

2

3

#

4

# This program is free software; you can redistribute it and/or modify

5

# it under the terms of the GNU General Public License as published by

35

from bzrlib.decorators import (

36

needs_read_lock,

37

)

38

from bzrlib.revision import (

39

NULL_REVISION,

40

)

41

38

from bzrlib.trace import (

42

39

is_quiet,

43

40

mutter,

44

41

)

45

42

43

from bzrlib.plugins.git import (

44

get_rich_root_format,

45

)

46

from bzrlib.plugins.git.config import (

47

GitBranchConfig,

48

)

50

NoPushSupport,

51

NoSuchRef,

52

)

53

from bzrlib.plugins.git.refs import (

54

ref_to_branch_name,

55

extract_tags,

56

tag_name_to_ref,

57

)

58

59

from bzrlib.foreign import ForeignBranch

53

54

try:

55

from bzrlib.foreign import ForeignBranch

56

except ImportError:

57

class ForeignBranch(branch.Branch):

58

def __init__(self, mapping):

59

self.mapping = mapping

60

super(ForeignBranch, self).__init__()

61

62

63

def extract_tags(refs, mapping):

64

ret = {}

65

for k,v in refs.iteritems():

66

if k.startswith("refs/tags/") and not k.endswith("^{}"):

67

v = refs.get(k+"^{}", v)

68

ret[k[len("refs/tags/"):]] = mapping.revision_id_foreign_to_bzr(v)

69

return ret

60

70

61

71

62

72

class GitPullResult(branch.PullResult):

63

"""Result of a pull from a Git branch."""

64

73

65

74

def _lookup_revno(self, revid):

66

75

assert isinstance(revid, str), "was %r" % revid

85

94

86

95

def get_tag_dict(self):

87

96

ret = {}

88

for k,v in extract_tags(self.repository._git.get_refs()).iteritems():

89

try:

90

obj = self.repository._git[v]

91

except KeyError:

92

mutter("Tag %s points at unknown object %s, ignoring", v, obj)

93

continue

97

for k,v in self.repository._git.refs.as_dict("refs/tags").iteritems():

98

obj = self.repository._git.get_object(v)

94

99

while isinstance(obj, Tag):

95

100

v = obj.object[1]

96

obj = self.repository._git[v]

101

obj = self.repository._git.get_object(v)

97

102

if not isinstance(obj, Commit):

98

103

mutter("Tag %s points at object %r that is not a commit, "

99

104

"ignoring", k, obj)

100

105

continue

101

ret[k] = self.branch.lookup_foreign_revision_id(v)

106

ret[k] = self.branch.mapping.revision_id_foreign_to_bzr(v)

102

107

return ret

103

108

104

def _set_tag_dict(self, to_dict):

105

extra = set(self.repository._git.get_refs().keys())

106

for k, revid in to_dict.iteritems():

107

name = tag_name_to_ref(k)

108

if name in extra:

109

extra.remove(name)

110

self.set_tag(k, revid)

111

for name in extra:

112

if name.startswith("refs/tags/"):

113

del self.repository._git[name]

114

115

109

def set_tag(self, name, revid):

116

self.repository._git.refs[tag_name_to_ref(name)], _ = \

117

self.branch.lookup_bzr_revision_id(revid)

118

119

120

class DictTagDict(LocalGitTagDict):

121

122

def __init__(self, branch, tags):

123

super(DictTagDict, self).__init__(branch)

124

self._tags = tags

125

126

def get_tag_dict(self):

127

return self._tags

110

self.repository._git.refs["refs/tags/%s" % name], _ = \

111

self.branch.mapping.revision_id_bzr_to_foreign(revid)

128

112

129

113

130

114

class GitBranchFormat(branch.BranchFormat):

132

116

def get_format_description(self):

133

117

return 'Git Branch'

134

118

135

def network_name(self):

136

return "git"

137

138

119

def supports_tags(self):

139

120

return True

140

121

141

def get_foreign_tests_branch_factory(self):

142

from bzrlib.plugins.git.tests.test_branch import ForeignTestsBranchFactory

143

return ForeignTestsBranchFactory()

144

145

122

def make_tags(self, branch):

146

123

if getattr(branch.repository, "get_refs", None) is not None:

147

124

from bzrlib.plugins.git.remote import RemoteGitTagDict

150

127

return LocalGitTagDict(branch)

151

128

152

129

153

class GitReadLock(object):

154

155

def __init__(self, unlock):

156

self.unlock = unlock

157

158

159

class GitWriteLock(object):

160

161

def __init__(self, unlock):

162

self.unlock = unlock

163

164

165

130

class GitBranch(ForeignBranch):

166

131

"""An adapter to git repositories for bzr Branch objects."""

167

132

168

def __init__(self, bzrdir, repository, ref, lockfiles, tagsdict=None):

133

def __init__(self, bzrdir, repository, name, lockfiles):

169

134

self.repository = repository

170

135

self._format = GitBranchFormat()

171

136

self.control_files = lockfiles

172

137

self.bzrdir = bzrdir

173

138

super(GitBranch, self).__init__(repository.get_mapping())

174

if tagsdict is not None:

175

self.tags = DictTagDict(self, tagsdict)

176

self.ref = ref

177

self.name = ref_to_branch_name(ref)

139

self.name = name

178

140

self._head = None

179

self.base = bzrdir.root_transport.base

180

181

def _get_checkout_format(self):

182

"""Return the most suitable metadir for a checkout of this branch.

183

Weaves are used if this branch's repository uses weaves.

184

"""

185

return bzrdir.format_registry.make_bzrdir("default")

186

187

def get_child_submit_format(self):

188

"""Return the preferred format of submissions to this branch."""

189

ret = self.get_config().get_user_option("child_submit_format")

190

if ret is not None:

191

return ret

192

return "git"

141

self.base = bzrdir.transport.base

193

142

194

143

def _get_nick(self, local=False, possible_master_transports=None):

195

144

"""Find the nick name for this branch.

196

145

197

146

:return: Branch nick

198

147

"""

199

return self.name or "HEAD"

148

return self.name

200

149

201

150

def _set_nick(self, nick):

202

151

raise NotImplementedError

204

153

nick = property(_get_nick, _set_nick)

205

154

206

155

def __repr__(self):

207

return "<%s(%r, %r)>" % (self.__class__.__name__, self.repository.base,

208

self.ref or "HEAD")

156

return "%s(%r, %r)" % (self.__class__.__name__, self.repository.base, self.name)

209

157

210

158

def generate_revision_history(self, revid, old_revid=None):

211

159

# FIXME: Check that old_revid is in the ancestry of revid

214

162

215

163

def lock_write(self):

216

164

self.control_files.lock_write()

217

return GitWriteLock(self.unlock)

218

165

219

166

def get_stacked_on_url(self):

220

167

# Git doesn't do stacking (yet...)

221

raise errors.UnstackableBranchFormat(self._format, self.base)

168

return None

222

169

223

170

def get_parent(self):

224

171

"""See Branch.get_parent()."""

231

178

232

179

def lock_read(self):

233

180

self.control_files.lock_read()

234

return GitReadLock(self.unlock)

235

181

236

182

def is_locked(self):

237

183

return self.control_files.is_locked()

247

193

# perhaps should escape this ?

248

194

if self.head is None:

249

195

return revision.NULL_REVISION

250

return self.lookup_foreign_revision_id(self.head)

196

return self.mapping.revision_id_foreign_to_bzr(self.head)

251

197

252

198

def _basic_push(self, target, overwrite=False, stop_revision=None):

253

199

return branch.InterBranch.get(self, target)._basic_push(

254

200

overwrite, stop_revision)

255

201

256

def lookup_foreign_revision_id(self, foreign_revid):

257

return self.repository.lookup_foreign_revision_id(foreign_revid,

258

self.mapping)

259

260

def lookup_bzr_revision_id(self, revid):

261

return self.repository.lookup_bzr_revision_id(

262

revid, mapping=self.mapping)

263

264

202

265

203

class LocalGitBranch(GitBranch):

266

204

"""A local Git branch."""

267

205

268

def __init__(self, bzrdir, repository, name, lockfiles, tagsdict=None):

269

super(LocalGitBranch, self).__init__(bzrdir, repository, name,

270

lockfiles, tagsdict)

271

refs = repository._git.get_refs()

272

if not (name in refs.keys() or "HEAD" in refs.keys()):

273

raise errors.NotBranchError(self.base)

206

def _get_checkout_format(self):

207

"""Return the most suitable metadir for a checkout of this branch.

208

Weaves are used if this branch's repository uses weaves.

209

"""

210

format = self.repository.bzrdir.checkout_metadir()

211

format.set_branch_format(self._format)

212

return format

274

213

275

214

def create_checkout(self, to_location, revision_id=None, lightweight=False,

276

215

accelerator_tree=None, hardlink=False):

279

218

t.ensure_base()

280

219

format = self._get_checkout_format()

281

220

checkout = format.initialize_on_transport(t)

282

from_branch = branch.BranchReferenceFormat().initialize(checkout,

221

from_branch = branch.BranchReferenceFormat().initialize(checkout,

283

222

self)

284

223

tree = checkout.create_workingtree(revision_id,

285

224

from_branch=from_branch, hardlink=hardlink)

286

225

return tree

287

226

else:

288

227

return self._create_heavyweight_checkout(to_location, revision_id,

289

hardlink)

228

hardlink)

290

229

291

def _create_heavyweight_checkout(self, to_location, revision_id=None,

230

def _create_heavyweight_checkout(self, to_location, revision_id=None,

292

231

hardlink=False):

293

232

"""Create a new heavyweight checkout of this branch.

294

233

298

237

:return: WorkingTree object of checkout.

299

238

"""

300

239

checkout_branch = bzrdir.BzrDir.create_branch_convenience(

301

to_location, force_new_tree=False)

240

to_location, force_new_tree=False, format=get_rich_root_format())

302

241

checkout = checkout_branch.bzrdir

303

242

checkout_branch.bind(self)

304

# pull up to the specified revision_id to set the initial

243

# pull up to the specified revision_id to set the initial

305

244

# branch tip correctly, and seed it with history.

306

245

checkout_branch.pull(self, stop_revision=revision_id)

307

246

return checkout.create_workingtree(revision_id, hardlink=hardlink)

316

255

317

256

def _get_head(self):

318

257

try:

319

return self.repository._git.ref(self.ref or "HEAD")

258

return self.repository._git.ref(self.name)

320

259

except KeyError:

321

260

return None

322

261

324

263

self.set_last_revision(revid)

325

264

326

265

def set_last_revision(self, revid):

327

(newhead, self.mapping) = self.repository.lookup_bzr_revision_id(revid)

266

(newhead, self.mapping) = self.mapping.revision_id_bzr_to_foreign(

267

revid)

328

268

self.head = newhead

329

269

330

270

def _set_head(self, value):

331

271

self._head = value

332

self.repository._git.refs[self.ref or "HEAD"] = self._head

272

self.repository._git.refs[self.name] = self._head

333

273

self._clear_cached_state()

334

274

335

275

head = property(_get_head, _set_head)

353

293

354

294

class GitBranchPullResult(branch.PullResult):

355

295

356

def __init__(self):

357

super(GitBranchPullResult, self).__init__()

358

self.new_git_head = None

359

self._old_revno = None

360

self._new_revno = None

361

362

296

def report(self, to_file):

363

297

if not is_quiet():

364

298

if self.old_revid == self.new_revid:

365

299

to_file.write('No revisions to pull.\n')

366

elif self.new_git_head is not None:

367

to_file.write('Now on revision %d (git sha: %s).\n' %

300

else:

301

to_file.write('Now on revision %d (git sha: %s).\n' %

368

302

(self.new_revno, self.new_git_head))

369

else:

370

to_file.write('Now on revision %d.\n' % (self.new_revno,))

371

303

self._show_tag_conficts(to_file)

372

304

373

def _lookup_revno(self, revid):

374

assert isinstance(revid, str), "was %r" % revid

375

# Try in source branch first, it'll be faster

376

try:

377

return self.source_branch.revision_id_to_revno(revid)

378

except errors.NoSuchRevision:

379

# FIXME: Check using graph.find_distance_to_null() ?

380

return self.target_branch.revision_id_to_revno(revid)

381

382

def _get_old_revno(self):

383

if self._old_revno is not None:

384

return self._old_revno

385

return self._lookup_revno(self.old_revid)

386

387

def _set_old_revno(self, revno):

388

self._old_revno = revno

389

390

old_revno = property(_get_old_revno, _set_old_revno)

391

392

def _get_new_revno(self):

393

if self._new_revno is not None:

394

return self._new_revno

395

return self._lookup_revno(self.new_revid)

396

397

def _set_new_revno(self, revno):

398

self._new_revno = revno

399

400

new_revno = property(_get_new_revno, _set_new_revno)

401

402

305

403

306

class GitBranchPushResult(branch.BranchPushResult):

404

307

423

326

class InterFromGitBranch(branch.GenericInterBranch):

424

327

"""InterBranch implementation that pulls from Git into bzr."""

425

328

426

@staticmethod

427

def _get_branch_formats_to_test():

428

return []

429

430

@classmethod

431

def _get_interrepo(self, source, target):

432

return repository.InterRepository.get(source.repository,

433

target.repository)

434

435

@classmethod

436

def is_compatible(cls, source, target):

437

return (isinstance(source, GitBranch) and

438

not isinstance(target, GitBranch) and

439

(getattr(cls._get_interrepo(source, target), "fetch_objects", None) is not None))

440

441

def _update_revisions(self, stop_revision=None, overwrite=False,

442

graph=None, limit=None):

443

"""Like InterBranch.update_revisions(), but with additions.

444

445

Compared to the `update_revisions()` below, this function takes a

446

`limit` argument that limits how many git commits will be converted

447

and returns the new git head.

448

"""

449

interrepo = self._get_interrepo(self.source, self.target)

329

@classmethod

330

def is_compatible(self, source, target):

331

return (isinstance(source, GitBranch) and

332

not isinstance(target, GitBranch))

333

334

def update_revisions(self, stop_revision=None, overwrite=False,

335

graph=None):

336

"""See InterBranch.update_revisions()."""

337

interrepo = repository.InterRepository.get(self.source.repository,

338

self.target.repository)

339

self._head = None

340

self._last_revid = None

450

341

def determine_wants(heads):

451

if self.source.ref is not None and not self.source.ref in heads:

452

raise NoSuchRef(self.source.ref, heads.keys())

342

if not self.source.name in heads:

343

raise NoSuchRef(self.source.name, heads.keys())

453

344

if stop_revision is not None:

454

345

self._last_revid = stop_revision

455

head, mapping = self.source.repository.lookup_bzr_revision_id(

346

self._head, mapping = self.source.repository.lookup_git_revid(

456

347

stop_revision)

457

348

else:

458

if self.source.ref is not None:

459

head = heads[self.source.ref]

460

else:

461

head = heads["HEAD"]

462

self._last_revid = self.source.lookup_foreign_revision_id(head)

349

self._head = heads[self.source.name]

350

self._last_revid = \

351

self.source.mapping.revision_id_foreign_to_bzr(self._head)

463

352

if self.target.repository.has_revision(self._last_revid):

464

353

return []

465

return [head]

466

pack_hint, head, refs = interrepo.fetch_objects(

467

determine_wants, self.source.mapping, limit=limit)

468

if (pack_hint is not None and

469

self.target.repository._format.pack_compresses):

470

self.target.repository.pack(hint=pack_hint)

471

if head is not None:

472

self._last_revid = self.source.lookup_foreign_revision_id(head)

354

return [self._head]

355

interrepo.fetch_objects(determine_wants, self.source.mapping)

473

356

if overwrite:

474

357

prev_last_revid = None

475

358

else:

476

359

prev_last_revid = self.target.last_revision()

477

self.target.generate_revision_history(self._last_revid,

478

prev_last_revid)

479

return head

480

481

def update_revisions(self, stop_revision=None, overwrite=False,

482

graph=None):

483

"""See InterBranch.update_revisions()."""

484

self._update_revisions(stop_revision, overwrite, graph)

360

self.target.generate_revision_history(self._last_revid, prev_last_revid)

485

361

486

362

def pull(self, overwrite=False, stop_revision=None,

487

363

possible_transports=None, _hook_master=None, run_hooks=True,

488

_override_hook_target=None, local=False, limit=None):

364

_override_hook_target=None, local=False):

489

365

"""See Branch.pull.

490

366

491

367

:param _hook_master: Private parameter - set the branch to

495

371

so it should not run its hooks.

496

372

:param _override_hook_target: Private parameter - set the branch to be

497

373

supplied as the target_branch to pull hooks.

498

:param limit: Only import this many revisons. `None`, the default,

499

means import all revisions.

500

374

"""

501

375

# This type of branch can't be bound.

502

376

if local:

512

386

# We assume that during 'pull' the target repository is closer than

513

387

# the source one.

514

388

graph = self.target.repository.get_graph(self.source.repository)

515

(result.old_revno, result.old_revid) = \

389

result.old_revno, result.old_revid = \

516

390

self.target.last_revision_info()

517

result.new_git_head = self._update_revisions(

518

stop_revision, overwrite=overwrite, graph=graph, limit=limit)

391

self.update_revisions(stop_revision, overwrite=overwrite,

392

graph=graph)

393

result.new_git_head = self._head

519

394

result.tag_conflicts = self.source.tags.merge_to(self.target.tags,

520

395

overwrite)

521

(result.new_revno, result.new_revid) = \

522

self.target.last_revision_info()

396

result.new_revno, result.new_revid = self.target.last_revision_info()

523

397

if _hook_master:

524

398

result.master_branch = _hook_master

525

399

result.local_branch = result.target_branch

539

413

result.target_branch = self.target

540

414

graph = self.target.repository.get_graph(self.source.repository)

541

415

result.old_revno, result.old_revid = self.target.last_revision_info()

542

result.new_git_head = self._update_revisions(

543

stop_revision, overwrite=overwrite, graph=graph)

416

self.update_revisions(stop_revision, overwrite=overwrite,

417

graph=graph)

418

result.new_git_head = self._head

544

419

result.tag_conflicts = self.source.tags.merge_to(self.target.tags,

545

420

overwrite)

546

421

result.new_revno, result.new_revid = self.target.last_revision_info()

554

429

class InterGitLocalRemoteBranch(InterGitBranch):

555

430

"""InterBranch that copies from a local to a remote git branch."""

556

431

557

@staticmethod

558

def _get_branch_formats_to_test():

559

return []

560

561

432

@classmethod

562

433

def is_compatible(self, source, target):

563

434

from bzrlib.plugins.git.remote import RemoteGitBranch

564

return (isinstance(source, LocalGitBranch) and

435

return (isinstance(source, LocalGitBranch) and

565

436

isinstance(target, RemoteGitBranch))

566

437

567

438

def _basic_push(self, overwrite=False, stop_revision=None):

568

from dulwich.protocol import ZERO_SHA

569

439

result = GitBranchPushResult()

570

440

result.source_branch = self.source

571

441

result.target_branch = self.target

573

443

stop_revision = self.source.last_revision()

574

444

# FIXME: Check for diverged branches

575

445

def get_changed_refs(old_refs):

576

result.old_revid = self.target.lookup_foreign_revision_id(old_refs.get(self.target.ref, ZERO_SHA))

577

refs = { self.target.ref: self.source.repository.lookup_bzr_revision_id(stop_revision)[0] }

446

result.old_revid = self.target.mapping.revision_id_foreign_to_bzr(old_refs.get("refs/heads/master", "0" * 40))

447

refs = { "refs/heads/master": self.source.repository.lookup_git_revid(stop_revision)[0] }

578

448

result.new_revid = stop_revision

579

449

for name, sha in self.source.repository._git.refs.as_dict("refs/tags").iteritems():

580

refs[tag_name_to_ref(name)] = sha

450

refs["refs/tags/%s" % name] = sha

581

451

return refs

582

self.target.repository.send_pack(get_changed_refs,

583

self.source.repository._git.object_store.generate_pack_contents)

452

self.target.repository.send_pack(get_changed_refs,

453

self.source.repository._git.object_store.generate_pack_contents)

584

454

return result

585

455

586

456

587

457

class InterGitRemoteLocalBranch(InterGitBranch):

588

458

"""InterBranch that copies from a remote to a local git branch."""

589

459

590

@staticmethod

591

def _get_branch_formats_to_test():

592

return []

593

594

460

@classmethod

595

461

def is_compatible(self, source, target):

596

462

from bzrlib.plugins.git.remote import RemoteGitBranch

597

return (isinstance(source, RemoteGitBranch) and

463

return (isinstance(source, RemoteGitBranch) and

598

464

isinstance(target, LocalGitBranch))

599

465

600

466

def _basic_push(self, overwrite=False, stop_revision=None):

609

475

return result

610

476

611

477

def update_tags(self, refs):

612

for name, v in extract_tags(refs).iteritems():

613

revid = self.target.lookup_foreign_revision_id(v)

478

for name, revid in extract_tags(refs, self.target.mapping).iteritems():

614

479

self.target.tags.set_tag(name, revid)

615

480

616

481

def update_refs(self, stop_revision=None):

617

interrepo = repository.InterRepository.get(self.source.repository,

482

interrepo = repository.InterRepository.get(self.source.repository,

618

483

self.target.repository)

619

484

if stop_revision is None:

620

refs = interrepo.fetch(branches=["HEAD"])

621

stop_revision = self.target.lookup_foreign_revision_id(refs["HEAD"])

485

refs = interrepo.fetch_refs(branches=["HEAD"])

486

stop_revision = self.target.mapping.revision_id_foreign_to_bzr(refs["HEAD"])

622

487

else:

623

refs = interrepo.fetch(revision_id=stop_revision)

488

refs = interrepo.fetch_refs(revision_id=stop_revision)

624

489

return refs, stop_revision

625

490

626

def pull(self, stop_revision=None, overwrite=False,

627

possible_transports=None, run_hooks=True,local=False):

491

def pull(self, stop_revision=None, overwrite=False,

492

possible_transports=None, local=False):

628

493

# This type of branch can't be bound.

629

494

if local:

630

495

raise errors.LocalRequiresBoundBranch()

638

503

result.new_revid = self.target.last_revision()

639

504

return result

640

505

641

642

class InterToGitBranch(branch.GenericInterBranch):

506

507

class InterToGitBranch(branch.InterBranch):

643

508

"""InterBranch implementation that pulls from Git into bzr."""

644

509

645

def __init__(self, source, target):

646

super(InterToGitBranch, self).__init__(source, target)

647

self.interrepo = repository.InterRepository.get(source.repository,

648

target.repository)

649

650

@staticmethod

651

def _get_branch_formats_to_test():

652

return []

653

654

510

@classmethod

655

511

def is_compatible(self, source, target):

656

return (not isinstance(source, GitBranch) and

512

return (not isinstance(source, GitBranch) and

657

513

isinstance(target, GitBranch))

658

514

659

515

def update_revisions(self, *args, **kwargs):

660

516

raise NoPushSupport()

661

517

662

def _get_new_refs(self, stop_revision=None):

518

def push(self, overwrite=True, stop_revision=None,

519

_override_hook_source_branch=None):

520

raise NoPushSupport()

521

522

def lossy_push(self, stop_revision=None):

523

result = GitBranchPushResult()

524

result.source_branch = self.source

525

result.target_branch = self.target

526

result.old_revid = self.target.last_revision()

663

527

if stop_revision is None:

664

528

stop_revision = self.source.last_revision()

665

assert type(stop_revision) is str

666

main_ref = self.target.ref or "refs/heads/master"

667

refs = { main_ref: (None, stop_revision) }

529

# FIXME: Check for diverged branches

530

refs = { "refs/heads/master": stop_revision }

668

531

for name, revid in self.source.tags.get_tag_dict().iteritems():

669

532

if self.source.repository.has_revision(revid):

670

refs[tag_name_to_ref(name)] = (None, revid)

671

return refs, main_ref

672

673

def pull(self, overwrite=False, stop_revision=None, local=False,

674

possible_transports=None):

675

from dulwich.protocol import ZERO_SHA

676

result = GitBranchPullResult()

677

result.source_branch = self.source

678

result.target_branch = self.target

679

new_refs, main_ref = self._get_new_refs(stop_revision)

680

def update_refs(old_refs):

681

refs = dict(old_refs)

682

# FIXME: Check for diverged branches

683

refs.update(new_refs)

684

return refs

685

old_refs, new_refs = self.interrepo.fetch_refs(update_refs)

686

result.old_revid = self.target.lookup_foreign_revision_id(

687

old_refs.get(main_ref, ZERO_SHA))

688

result.new_revid = new_refs[main_ref]

689

return result

690

691

def push(self, overwrite=False, stop_revision=None,

692

_override_hook_source_branch=None):

693

from dulwich.protocol import ZERO_SHA

694

result = GitBranchPushResult()

695

result.source_branch = self.source

696

result.target_branch = self.target

697

new_refs, main_ref = self._get_new_refs(stop_revision)

698

def update_refs(old_refs):

699

refs = dict(old_refs)

700

# FIXME: Check for diverged branches

701

refs.update(new_refs)

702

return refs

703

old_refs, new_refs = self.interrepo.fetch_refs(update_refs)

704

(result.old_revid, old_sha1) = old_refs.get(main_ref, (ZERO_SHA, NULL_REVISION))

705

if result.old_revid is None:

706

result.old_revid = self.target.lookup_foreign_revision_id(old_sha1)

707

result.new_revid = new_refs[main_ref]

708

return result

709

710

def lossy_push(self, stop_revision=None):

711

result = GitBranchPushResult()

712

result.source_branch = self.source

713

result.target_branch = self.target

714

new_refs, main_ref = self._get_new_refs(stop_revision)

715

def update_refs(old_refs):

716

refs = dict(old_refs)

717

# FIXME: Check for diverged branches

718

refs.update(new_refs)

719

return refs

720

result.revidmap, old_refs, new_refs = self.interrepo.dfetch_refs(

721

update_refs)

722

result.old_revid = old_refs.get(self.target.ref, (None, NULL_REVISION))[1]

723

result.new_revid = new_refs[main_ref][1]

533

refs["refs/tags/%s" % name] = revid

534

revidmap, new_refs = self.target.repository.dfetch_refs(

535

self.source.repository, refs)

536

if revidmap != {}:

537

self.target.generate_revision_history(revidmap[stop_revision])

538

result.new_revid = revidmap[stop_revision]

539

else:

540

result.new_revid = result.old_revid

541

result.revidmap = revidmap

724

542

return result

725

543

726

544