1
# Copyright (C) 2010 Jelmer Vernooij <jelmer@samba.org>
3
# This program is free software; you can redistribute it and/or modify
4
# it under the terms of the GNU General Public License as published by
5
# the Free Software Foundation; either version 2 of the License, or
6
# (at your option) any later version.
8
# This program is distributed in the hope that it will be useful,
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11
# GNU General Public License for more details.
13
# You should have received a copy of the GNU General Public License
14
# along with this program; if not, write to the Free Software
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17
"""A Git repository implementation that uses a Bazaar transport."""
19
from cStringIO import StringIO
21
from dulwich.errors import (
25
from dulwich.objects import (
28
from dulwich.object_store import (
32
from dulwich.pack import (
42
from dulwich.repo import (
50
read_packed_refs_with_peeled,
55
from bzrlib.errors import (
62
class TransportRefsContainer(RefsContainer):
63
"""Refs container that reads refs from a transport."""
65
def __init__(self, transport):
66
self.transport = transport
67
self._packed_refs = None
68
self._peeled_refs = None
71
return "%s(%r)" % (self.__class__.__name__, self.transport)
73
def _ensure_dir_exists(self, path):
74
for n in range(path.count("/")):
75
dirname = "/".join(path.split("/")[:n+1])
77
self.transport.mkdir(dirname)
81
def subkeys(self, base):
84
iter_files = self.transport.clone(base).iter_files_recursive()
85
keys.update(("%s/%s" % (base, refname)).strip("/") for
86
refname in iter_files if check_ref_format("%s/%s" % (base, refname)))
87
except (TransportNotPossible, NoSuchFile):
89
for key in self.get_packed_refs():
90
if key.startswith(base):
91
keys.add(key[len(base):].strip("/"))
96
if self.transport.has("HEAD"):
99
iter_files = list(self.transport.clone("refs").iter_files_recursive())
100
for filename in iter_files:
101
refname = "refs/%s" % filename
102
if check_ref_format(refname):
104
except (TransportNotPossible, NoSuchFile):
106
keys.update(self.get_packed_refs())
109
def get_packed_refs(self):
110
"""Get contents of the packed-refs file.
112
:return: Dictionary mapping ref names to SHA1s
114
:note: Will return an empty dictionary when no packed-refs file is
117
# TODO: invalidate the cache on repacking
118
if self._packed_refs is None:
119
# set both to empty because we want _peeled_refs to be
120
# None if and only if _packed_refs is also None.
121
self._packed_refs = {}
122
self._peeled_refs = {}
124
f = self.transport.get("packed-refs")
128
first_line = iter(f).next().rstrip()
129
if (first_line.startswith("# pack-refs") and " peeled" in
131
for sha, name, peeled in read_packed_refs_with_peeled(f):
132
self._packed_refs[name] = sha
134
self._peeled_refs[name] = peeled
137
for sha, name in read_packed_refs(f):
138
self._packed_refs[name] = sha
141
return self._packed_refs
143
def get_peeled(self, name):
144
"""Return the cached peeled value of a ref, if available.
146
:param name: Name of the ref to peel
147
:return: The peeled value of the ref. If the ref is known not point to a
148
tag, this will be the SHA the ref refers to. If the ref may point to
149
a tag, but no cached information is available, None is returned.
151
self.get_packed_refs()
152
if self._peeled_refs is None or name not in self._packed_refs:
153
# No cache: no peeled refs were read, or this ref is loose
155
if name in self._peeled_refs:
156
return self._peeled_refs[name]
161
def read_loose_ref(self, name):
162
"""Read a reference file and return its contents.
164
If the reference file a symbolic reference, only read the first line of
165
the file. Otherwise, only read the first 40 bytes.
167
:param name: the refname to read, relative to refpath
168
:return: The contents of the ref file, or None if the file does not
170
:raises IOError: if any other error occurs
173
f = self.transport.get(name)
177
header = f.read(len(SYMREF))
179
# Read only the first line
180
return header + iter(f).next().rstrip("\r\n")
182
# Read only the first 40 bytes
183
return header + f.read(40-len(SYMREF))
187
def _remove_packed_ref(self, name):
188
if self._packed_refs is None:
190
# reread cached refs from disk, while holding the lock
192
self._packed_refs = None
193
self.get_packed_refs()
195
if name not in self._packed_refs:
198
del self._packed_refs[name]
199
if name in self._peeled_refs:
200
del self._peeled_refs[name]
201
f = self.transport.open_write_stream("packed-refs")
203
write_packed_refs(f, self._packed_refs, self._peeled_refs)
207
def set_symbolic_ref(self, name, other):
208
"""Make a ref point at another ref.
210
:param name: Name of the ref to set
211
:param other: Name of the ref to point at
213
self._check_refname(name)
214
self._check_refname(other)
215
self._ensure_dir_exists(name)
216
self.transport.put_bytes(name, SYMREF + other + '\n')
218
def set_if_equals(self, name, old_ref, new_ref):
219
"""Set a refname to new_ref only if it currently equals old_ref.
221
This method follows all symbolic references, and can be used to perform
222
an atomic compare-and-swap operation.
224
:param name: The refname to set.
225
:param old_ref: The old sha the refname must refer to, or None to set
227
:param new_ref: The new sha the refname will refer to.
228
:return: True if the set was successful, False otherwise.
231
realname, _ = self._follow(name)
234
self._ensure_dir_exists(realname)
235
self.transport.put_bytes(realname, new_ref+"\n")
238
def add_if_new(self, name, ref):
239
"""Add a new reference only if it does not already exist.
241
This method follows symrefs, and only ensures that the last ref in the
242
chain does not exist.
244
:param name: The refname to set.
245
:param ref: The new sha the refname will refer to.
246
:return: True if the add was successful, False otherwise.
249
realname, contents = self._follow(name)
250
if contents is not None:
254
self._check_refname(realname)
255
self._ensure_dir_exists(realname)
256
self.transport.put_bytes(realname, ref+"\n")
259
def remove_if_equals(self, name, old_ref):
260
"""Remove a refname only if it currently equals old_ref.
262
This method does not follow symbolic references. It can be used to
263
perform an atomic compare-and-delete operation.
265
:param name: The refname to delete.
266
:param old_ref: The old sha the refname must refer to, or None to delete
268
:return: True if the delete was successful, False otherwise.
270
self._check_refname(name)
273
self.transport.delete(name)
276
self._remove_packed_ref(name)
280
class TransportRepo(BaseRepo):
282
def __init__(self, transport):
283
self.transport = transport
285
if self.transport.has(".git/%s" % OBJECTDIR):
287
self._controltransport = self.transport.clone('.git')
288
elif self.transport.has_any(["info/refs", OBJECTDIR, REFSDIR]):
290
self._controltransport = self.transport
292
raise NotGitRepository(self.transport)
294
raise NotGitRepository(self.transport)
295
object_store = TransportObjectStore(
296
self._controltransport.clone(OBJECTDIR))
297
super(TransportRepo, self).__init__(object_store,
298
TransportRefsContainer(self._controltransport))
300
def get_named_file(self, path):
301
"""Get a file from the control dir with a specific name.
303
Although the filename should be interpreted as a filename relative to
304
the control dir in a disk-baked Repo, the object returned need not be
305
pointing to a file in that location.
307
:param path: The path to the file, relative to the control dir.
308
:return: An open file object, or None if the file does not exist.
311
return self._controltransport.get(path.lstrip('/'))
315
def index_path(self):
316
"""Return the path to the index file."""
317
return self._controltransport.local_abspath(INDEX_FILENAME)
319
def open_index(self):
320
"""Open the index for this repository."""
321
from dulwich.index import Index
322
if not self.has_index():
323
raise NoIndexPresent()
324
return Index(self.index_path())
327
"""Check if an index is present."""
328
# Bare repos must never have index files; non-bare repos may have a
329
# missing index file, which is treated as empty.
333
return "<TransportRepo for %r>" % self.transport
336
class TransportObjectStore(PackBasedObjectStore):
337
"""Git-style object store that exists on disk."""
339
def __init__(self, transport):
340
"""Open an object store.
342
:param transport: Transport to open data from
344
super(TransportObjectStore, self).__init__()
345
self.transport = transport
346
self.pack_transport = self.transport.clone(PACKDIR)
348
def _pack_cache_stale(self):
351
def _pack_names(self):
353
f = self.transport.get('info/packs')
355
return self.pack_transport.list_dir(".")
358
for line in f.readlines():
359
line = line.rstrip("\n")
362
(kind, name) = line.split(" ", 1)
368
def _load_packs(self):
370
for name in self._pack_names():
371
if name.startswith("pack-") and name.endswith(".pack"):
373
size = self.pack_transport.stat(name).st_size
374
except TransportNotPossible:
375
# FIXME: This reads the whole pack file at once
376
f = self.pack_transport.get(name)
378
pd = PackData(name, StringIO(contents), size=len(contents))
380
pd = PackData(name, self.pack_transport.get(name),
382
idxname = name.replace(".pack", ".idx")
383
idx = load_pack_index_file(idxname, self.pack_transport.get(idxname))
384
pack = Pack.from_objects(pd, idx)
388
def _iter_loose_objects(self):
389
for base in self.transport.list_dir('.'):
392
for rest in self.transport.list_dir(base):
395
def _split_loose_object(self, sha):
396
return (sha[:2], sha[2:])
398
def _remove_loose_object(self, sha):
399
path = '%s/%s' % self._split_loose_object(sha)
400
self.transport.delete(path)
402
def _get_loose_object(self, sha):
403
path = '%s/%s' % self._split_loose_object(sha)
405
return ShaFile.from_file(self.transport.get(path))
409
def add_object(self, obj):
410
"""Add a single object to this object store.
412
:param obj: Object to add
414
(dir, file) = self._split_loose_object(obj.id)
416
self.transport.mkdir(dir)
419
path = "%s/%s" % (dir, file)
420
if self.transport.has(path):
421
return # Already there, no need to write again
422
self.transport.put_bytes(path, obj.as_legacy_object())
424
def move_in_pack(self, f):
425
"""Move a specific file containing a pack into the pack directory.
427
:note: The file should be on the same file system as the
430
:param path: Path to the pack file.
433
p = PackData(None, f, len(f.getvalue()))
434
entries = p.sorted_entries()
435
basename = "pack-%s" % iter_sha1(entry[0] for entry in entries)
437
self.pack_transport.put_file(basename + ".pack", f)
438
idxfile = self.pack_transport.open_write_stream(basename + ".idx")
440
write_pack_index_v2(idxfile, entries, p.get_stored_checksum())
443
idxfile = self.pack_transport.get(basename + ".idx")
444
idx = load_pack_index_file(basename+".idx", idxfile)
445
final_pack = Pack.from_objects(p, idx)
446
self._add_known_pack(final_pack)
449
def add_thin_pack(self):
450
"""Add a new thin pack to this object store.
452
Thin packs are packs that contain deltas with parents that exist
455
from cStringIO import StringIO
458
if len(f.getvalue()) > 0:
459
return self.move_in_thin_pack(f)
464
def move_in_thin_pack(self, f):
465
"""Move a specific file containing a pack into the pack directory.
467
:note: The file should be on the same file system as the
470
:param path: Path to the pack file.
473
data = ThinPackData.from_file(self.get_raw, f, len(f.getvalue()))
474
idx = MemoryPackIndex(data.sorted_entries(), data.get_stored_checksum())
475
p = Pack.from_objects(data, idx)
477
pack_sha = idx.objects_sha1()
479
datafile = self.pack_transport.open_write_stream("pack-%s.pack" % pack_sha)
481
entries, data_sum = write_pack_data(datafile, ((o, None) for o in p.iterobjects()), len(p))
485
idxfile = self.pack_transport.open_write_stream("pack-%s.idx" % pack_sha)
487
write_pack_index_v2(idxfile, data.sorted_entries(), data_sum)
490
final_pack = Pack("pack-%s" % pack_sha)
491
self._add_known_pack(final_pack)
497
"""Add a new pack to this object store.
499
:return: Fileobject to write to and a commit function to
500
call when the pack is finished.
502
from cStringIO import StringIO
505
if len(f.getvalue()) > 0:
506
return self.move_in_pack(f)
512
def init(cls, transport):
513
transport.mkdir('info')
514
transport.mkdir(PACKDIR)
515
return cls(transport)
added
removed
transportgit.py
