← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/store/weave.py

  • Committer: Robert Collins
  • Date: 2005-10-30 00:00:09 UTC
  • mfrom: (1185.16.134)
  • Revision ID: robertc@robertcollins.net-20051030000009-9db99a338a0dfdac
Merge from Martin.

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/store/weave.py
40
40
    """
41
41
    FILE_SUFFIX = '.weave'
42
42
 
43
 
    def __init__(self, transport, prefixed=False, precious=False,
44
 
                 dir_mode=None, file_mode=None):
45
 
        super(WeaveStore, self).__init__(transport,
46
 
                dir_mode=dir_mode, file_mode=file_mode,
47
 
                prefixed=prefixed, compressed=False)
 
43
    def __init__(self, transport, prefixed=False, precious=False):
 
44
        self._transport = transport
 
45
        self._prefixed = prefixed
48
46
        self._precious = precious
49
47
 
50
48
    def filename(self, file_id):
69
67
    def _put(self, file_id, f):
70
68
        if self._prefixed:
71
69
            try:
72
 
                self._transport.mkdir(hash_prefix(file_id), mode=self._dir_mode)
 
70
                self._transport.mkdir(hash_prefix(file_id))
73
71
            except FileExists:
74
72
                pass
75
 
        return self._transport.put(self.filename(file_id), f, mode=self._file_mode)
 
73
        return self._transport.put(self.filename(file_id), f)
76
74
 
77
75
    def get_weave(self, file_id, transaction):
78
76
        weave = transaction.map.find_weave(file_id)
82
80
        w = read_weave(self._get(file_id))
83
81
        transaction.map.add_weave(file_id, w)
84
82
        transaction.register_clean(w, precious=self._precious)
85
 
        # TODO: jam 20051219 This should check if there is a prelude
86
 
        #       which is already cached, and if so, should remove it
87
 
        #       But transaction doesn't seem to have a 'remove'
88
 
        #       One workaround would be to re-add the object with
89
 
        #       the PRELUDE marker.
90
 
        return w
91
 
 
92
 
    def get_weave_prelude(self, file_id, transaction):
93
 
        weave_id = file_id
94
 
        weave = transaction.map.find_weave(weave_id)
95
 
        if weave:
96
 
            mutter("cache hit in %s for %s", self, weave_id)
97
 
            return weave
98
 
        # We want transactions to also cache preludes if that
99
 
        # is all that we are loading. So we need a unique
100
 
        # identifier, so that someone who wants the whole text
101
 
        # won't get just the prelude
102
 
        weave_id = 'PRELUDE-' + file_id
103
 
        weave = transaction.map.find_weave(weave_id)
104
 
        if weave:
105
 
            mutter("cache hit in %s for %s", self, weave_id)
106
 
            return weave
107
 
        w = read_weave(self._get(file_id), prelude=True)
108
 
        transaction.map.add_weave(weave_id, w)
109
 
        transaction.register_clean(w, precious=self._precious)
110
83
        return w
111
84
 
112
85
    def get_lines(self, file_id, rev_id, transaction):
116
89
        w = self.get_weave(file_id, transaction)
117
90
        return w.get(w.lookup(rev_id))
118
91
    
119
 
    def get_weave_prelude_or_empty(self, file_id, transaction):
120
 
        """cheap version that reads the prelude but not the lines
121
 
        """
122
 
        try:
123
 
            return self.get_weave_prelude(file_id, transaction)
124
 
        except NoSuchFile:
125
 
            # We can cache here, because we know that there
126
 
            # is no complete object, since we got NoSuchFile
127
 
            weave = Weave(weave_name=file_id)
128
 
            transaction.map.add_weave(file_id, weave)
129
 
            transaction.register_clean(weave, precious=self._precious)
130
 
            return weave
131
 
 
132
92
    def get_weave_or_empty(self, file_id, transaction):
133
93
        """Return a weave, or an empty one if it doesn't exist.""" 
134
94
        try: