/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/repository.py

  • Committer: John Arbash Meinel
  • Date: 2010-03-25 17:09:53 UTC
  • mto: This revision was merged to the branch mainline in revision 5116.
  • Revision ID: john@arbash-meinel.com-20100325170953-s6qzmwap7mg0frcx
Workaround a strange bug about the file closing before it is read.

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/repository.py
40
40
    lru_cache,
41
41
    osutils,
42
42
    revision as _mod_revision,
43
 
    static_tuple,
44
43
    symbol_versioning,
45
44
    trace,
46
45
    tsort,
860
859
        # versioned roots do not change unless the tree found a change.
861
860
 
862
861
 
863
 
class RepositoryWriteLockResult(object):
864
 
    """The result of write locking a repository.
865
 
 
866
 
    :ivar repository_token: The token obtained from the underlying lock, or
867
 
        None.
868
 
    :ivar unlock: A callable which will unlock the lock.
869
 
    """
870
 
 
871
 
    def __init__(self, unlock, repository_token):
872
 
        self.repository_token = repository_token
873
 
        self.unlock = unlock
874
 
 
875
 
 
876
862
######################################################################
877
863
# Repositories
878
864
 
879
865
 
880
 
class Repository(_RelockDebugMixin, bzrdir.ControlComponent):
 
866
class Repository(_RelockDebugMixin):
881
867
    """Repository holding history for one or more branches.
882
868
 
883
869
    The repository holds and retrieves historical information including
1304
1290
 
1305
1291
        :param _format: The format of the repository on disk.
1306
1292
        :param a_bzrdir: The BzrDir of the repository.
 
1293
 
 
1294
        In the future we will have a single api for all stores for
 
1295
        getting file texts, inventories and revisions, then
 
1296
        this construct will accept instances of those things.
1307
1297
        """
1308
 
        # In the future we will have a single api for all stores for
1309
 
        # getting file texts, inventories and revisions, then
1310
 
        # this construct will accept instances of those things.
1311
1298
        super(Repository, self).__init__()
1312
1299
        self._format = _format
1313
1300
        # the following are part of the public API for Repository:
1328
1315
        # rather copying them?
1329
1316
        self._safe_to_return_from_cache = False
1330
1317
 
1331
 
    @property
1332
 
    def user_transport(self):
1333
 
        return self.bzrdir.user_transport
1334
 
 
1335
 
    @property
1336
 
    def control_transport(self):
1337
 
        return self._transport
1338
 
 
1339
1318
    def __repr__(self):
1340
1319
        if self._fallback_repositories:
1341
1320
            return '%s(%r, fallback_repositories=%r)' % (
1389
1368
        data during reads, and allows a 'write_group' to be obtained. Write
1390
1369
        groups must be used for actual data insertion.
1391
1370
 
1392
 
        A token should be passed in if you know that you have locked the object
1393
 
        some other way, and need to synchronise this object's state with that
1394
 
        fact.
1395
 
 
1396
 
        XXX: this docstring is duplicated in many places, e.g. lockable_files.py
1397
 
 
1398
1371
        :param token: if this is already locked, then lock_write will fail
1399
1372
            unless the token matches the existing lock.
1400
1373
        :returns: a token if this instance supports tokens, otherwise None.
1403
1376
        :raises MismatchedToken: if the specified token doesn't match the token
1404
1377
            of the existing lock.
1405
1378
        :seealso: start_write_group.
1406
 
        :return: A RepositoryWriteLockResult.
 
1379
 
 
1380
        A token should be passed in if you know that you have locked the object
 
1381
        some other way, and need to synchronise this object's state with that
 
1382
        fact.
 
1383
 
 
1384
        XXX: this docstring is duplicated in many places, e.g. lockable_files.py
1407
1385
        """
1408
1386
        locked = self.is_locked()
1409
 
        token = self.control_files.lock_write(token=token)
 
1387
        result = self.control_files.lock_write(token=token)
1410
1388
        if not locked:
1411
1389
            self._warn_if_deprecated()
1412
1390
            self._note_lock('w')
1414
1392
                # Writes don't affect fallback repos
1415
1393
                repo.lock_read()
1416
1394
            self._refresh_data()
1417
 
        return RepositoryWriteLockResult(self.unlock, token)
 
1395
        return result
1418
1396
 
1419
1397
    def lock_read(self):
1420
 
        """Lock the repository for read operations.
1421
 
 
1422
 
        :return: An object with an unlock method which will release the lock
1423
 
            obtained.
1424
 
        """
1425
1398
        locked = self.is_locked()
1426
1399
        self.control_files.lock_read()
1427
1400
        if not locked:
1430
1403
            for repo in self._fallback_repositories:
1431
1404
                repo.lock_read()
1432
1405
            self._refresh_data()
1433
 
        return self
1434
1406
 
1435
1407
    def get_physical_lock_status(self):
1436
1408
        return self.control_files.get_physical_lock_status()
1496
1468
 
1497
1469
        # now gather global repository information
1498
1470
        # XXX: This is available for many repos regardless of listability.
1499
 
        if self.user_transport.listable():
 
1471
        if self.bzrdir.root_transport.listable():
1500
1472
            # XXX: do we want to __define len__() ?
1501
1473
            # Maybe the versionedfiles object should provide a different
1502
1474
            # method to get the number of keys.
1534
1506
 
1535
1507
        ret = []
1536
1508
        for branches, repository in bzrdir.BzrDir.find_bzrdirs(
1537
 
                self.user_transport, evaluate=Evaluator()):
 
1509
                self.bzrdir.root_transport, evaluate=Evaluator()):
1538
1510
            if branches is not None:
1539
1511
                ret.extend(branches)
1540
1512
            if not using and repository is not None:
2608
2580
            keys = tsort.topo_sort(parent_map)
2609
2581
        return [None] + list(keys)
2610
2582
 
2611
 
    def pack(self, hint=None, clean_obsolete_packs=False):
 
2583
    def pack(self, hint=None):
2612
2584
        """Compress the data within the repository.
2613
2585
 
2614
2586
        This operation only makes sense for some repository types. For other
2624
2596
            obtained from the result of commit_write_group(). Out of
2625
2597
            date hints are simply ignored, because concurrent operations
2626
2598
            can obsolete them rapidly.
2627
 
 
2628
 
        :param clean_obsolete_packs: Clean obsolete packs immediately after
2629
 
            the pack operation.
2630
2599
        """
2631
2600
 
2632
2601
    def get_transaction(self):
2657
2626
    def _make_parents_provider(self):
2658
2627
        return self
2659
2628
 
2660
 
    @needs_read_lock
2661
 
    def get_known_graph_ancestry(self, revision_ids):
2662
 
        """Return the known graph for a set of revision ids and their ancestors.
2663
 
        """
2664
 
        st = static_tuple.StaticTuple
2665
 
        revision_keys = [st(r_id).intern() for r_id in revision_ids]
2666
 
        known_graph = self.revisions.get_known_graph_ancestry(revision_keys)
2667
 
        return graph.GraphThunkIdsToKeys(known_graph)
2668
 
 
2669
2629
    def get_graph(self, other_repository=None):
2670
2630
        """Return the graph walker for this repository format"""
2671
2631
        parents_provider = self._make_parents_provider()
3073
3033
    # Is the format experimental ?
3074
3034
    experimental = False
3075
3035
 
3076
 
    def __repr__(self):
3077
 
        return "%s()" % self.__class__.__name__
 
3036
    def __str__(self):
 
3037
        return "<%s>" % self.__class__.__name__
3078
3038
 
3079
3039
    def __eq__(self, other):
3080
3040
        # format objects are generally stateless
3198
3158
        """
3199
3159
        raise NotImplementedError(self.open)
3200
3160
 
3201
 
    def _run_post_repo_init_hooks(self, repository, a_bzrdir, shared):
3202
 
        from bzrlib.bzrdir import BzrDir, RepoInitHookParams
3203
 
        hooks = BzrDir.hooks['post_repo_init']
3204
 
        if not hooks:
3205
 
            return
3206
 
        params = RepoInitHookParams(repository, self, a_bzrdir, shared)
3207
 
        for hook in hooks:
3208
 
            hook(params)
3209
 
 
3210
3161
 
3211
3162
class MetaDirRepositoryFormat(RepositoryFormat):
3212
3163
    """Common base class for the new repositories using the metadir layout."""
3421
3372
        :return: None.
3422
3373
        """
3423
3374
        ui.ui_factory.warn_experimental_format_fetch(self)
3424
 
        from bzrlib.fetch import RepoFetcher
3425
 
        # See <https://launchpad.net/bugs/456077> asking for a warning here
3426
 
        if self.source._format.network_name() != self.target._format.network_name():
3427
 
            ui.ui_factory.show_user_warning('cross_format_fetch',
3428
 
                from_format=self.source._format,
3429
 
                to_format=self.target._format)
3430
 
        f = RepoFetcher(to_repository=self.target,
 
3375
        f = _mod_fetch.RepoFetcher(to_repository=self.target,
3431
3376
                               from_repository=self.source,
3432
3377
                               last_revision=revision_id,
3433
3378
                               fetch_spec=fetch_spec,
4011
3956
        """See InterRepository.fetch()."""
4012
3957
        if fetch_spec is not None:
4013
3958
            raise AssertionError("Not implemented yet...")
 
3959
        # See <https://launchpad.net/bugs/456077> asking for a warning here
 
3960
        #
 
3961
        # nb this is only active for local-local fetches; other things using
 
3962
        # streaming.
 
3963
        ui.ui_factory.warn_cross_format_fetch(self.source._format,
 
3964
            self.target._format)
4014
3965
        ui.ui_factory.warn_experimental_format_fetch(self)
4015
3966
        if (not self.source.supports_rich_root()
4016
3967
            and self.target.supports_rich_root()):
4018
3969
            self._revision_id_to_root_id = {}
4019
3970
        else:
4020
3971
            self._converting_to_rich_root = False
4021
 
        # See <https://launchpad.net/bugs/456077> asking for a warning here
4022
 
        if self.source._format.network_name() != self.target._format.network_name():
4023
 
            ui.ui_factory.show_user_warning('cross_format_fetch',
4024
 
                from_format=self.source._format,
4025
 
                to_format=self.target._format)
4026
3972
        revision_ids = self.target.search_missing_revision_ids(self.source,
4027
3973
            revision_id, find_ghosts=find_ghosts).get_keys()
4028
3974
        if not revision_ids:
4311
4257
                    self._extract_and_insert_inventories(
4312
4258
                        substream, src_serializer)
4313
4259
            elif substream_type == 'inventory-deltas':
 
4260
                ui.ui_factory.warn_cross_format_fetch(src_format,
 
4261
                    self.target_repo._format)
4314
4262
                self._extract_and_insert_inventory_deltas(
4315
4263
                    substream, src_serializer)
4316
4264
            elif substream_type == 'chk_bytes':