14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17
"""Stores are the main data-storage mechanism for Bazaar-NG.
18
Stores are the main data-storage mechanism for Bazaar-NG.
19
20
A store is a simple write-once container indexed by a universally
20
unique ID, which is typically the SHA-1 of the content."""
22
__copyright__ = "Copyright (C) 2005 Canonical Ltd."
23
__author__ = "Martin Pool <mbp@canonical.com>"
25
24
import os, tempfile, types, osutils, gzip, errno
26
25
from stat import ST_SIZE
27
26
from StringIO import StringIO
28
from trace import mutter
27
from bzrlib.errors import BzrError
28
from bzrlib.trace import mutter
30
31
######################################################################
60
61
TODO: Atomic add by writing to a temporary file and renaming.
62
TODO: Perhaps automatically transform to/from XML in a method?
63
Would just need to tell the constructor what class to
66
TODO: Even within a simple disk store like this, we could
67
gzip the files. But since many are less than one disk
68
block, that might not help a lot.
63
In bzr 0.0.5 and earlier, files within the store were marked
64
readonly on disk. This is no longer done but existing stores need
72
68
def __init__(self, basedir):
73
"""ImmutableStore constructor."""
74
69
self._basedir = basedir
76
71
def _path(self, id):
72
if '\\' in id or '/' in id:
73
raise ValueError("invalid store id %r" % id)
77
74
return os.path.join(self._basedir, id)
79
76
def __repr__(self):
83
80
"""Add contents of a file into the store.
85
82
f -- An open file, or file-like object."""
86
# FIXME: Only works on smallish files
87
# TODO: Can be optimized by copying at the same time as
83
# FIXME: Only works on files that will fit in memory
85
from bzrlib.atomicfile import AtomicFile
89
87
mutter("add store entry %r" % (fileid))
90
88
if isinstance(f, types.StringTypes):
95
93
p = self._path(fileid)
96
94
if os.access(p, os.F_OK) or os.access(p + '.gz', os.F_OK):
97
bailout("store %r already contains id %r" % (self._basedir, fileid))
95
raise BzrError("store %r already contains id %r" % (self._basedir, fileid))
100
f = gzip.GzipFile(p + '.gz', 'wb')
101
os.chmod(p + '.gz', 0444)
101
af = AtomicFile(fn, 'wb')
104
gf = gzip.GzipFile(mode='wb', fileobj=af)
114
def copy_multi(self, other, ids, permit_failure=False):
115
"""Copy texts for ids from other into self.
117
If an id is present in self, it is skipped.
119
Returns (count_copied, failed), where failed is a collection of ids
120
that could not be copied.
122
pb = bzrlib.ui.ui_factory.progress_bar()
124
pb.update('preparing to copy')
125
to_copy = [id for id in ids if id not in self]
126
if isinstance(other, ImmutableStore):
127
return self.copy_multi_immutable(other, to_copy, pb)
132
pb.update('copy', count, len(to_copy))
133
if not permit_failure:
134
self.add(other[id], id)
143
if not permit_failure:
144
assert count == len(to_copy)
148
def copy_multi_immutable(self, other, to_copy, pb, permit_failure=False):
149
from shutil import copyfile
154
other_p = other._path(id)
158
if e.errno == errno.ENOENT:
159
if not permit_failure:
160
copyfile(other_p+".gz", p+".gz")
163
copyfile(other_p+".gz", p+".gz")
165
if e.errno == errno.ENOENT:
173
pb.update('copy', count, len(to_copy))
174
assert count == len(to_copy)
110
179
def __contains__(self, fileid):
126
195
def __len__(self):
127
196
return len(os.listdir(self._basedir))
129
199
def __getitem__(self, fileid):
130
200
"""Returns a file reading from a particular entry."""
131
201
p = self._path(fileid)
133
203
return gzip.GzipFile(p + '.gz', 'rb')
134
204
except IOError, e:
135
if e.errno == errno.ENOENT:
205
if e.errno != errno.ENOENT:
211
if e.errno != errno.ENOENT:
214
raise IndexError(fileid)
140
217
def total_size(self):
141
218
"""Return (count, bytes)
added
removed
bzrlib/store.py
