android/git-repo
1
Fork 0
mirror of https://gerrit.googlesource.com/git-repo synced 2024-12-21 07:16:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Change project.revision to revisionExpr and revisionId

Browse Source 
The revisionExpr field now holds an expression from the manifest,
such as "refs/heads/master", while revisionId holds the current
commit-ish SHA-1 of the revisionExpr.  Currently that is only
filled in if the manifest points directly to a SHA-1.

Signed-off-by: Shawn O. Pearce <sop@google.com>
This commit is contained in:
Shawn O. Pearce 2009-05-29 18:38:17 -07:00
parent 8ad8a0e61d
commit 3c8dea1f8d
5 changed files with 113 additions and 118 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
manifest_xml.py
View File

@ -27,7 +27,7 @@ LOCAL_MANIFEST_NAME = 'local_manifest.xml'
class _Default(object): class _Default(object):
"""Project defaults within the manifest.""" """Project defaults within the manifest."""
revision = None revisionExpr = None
remote = None remote = None
class _XmlRemote(object): class _XmlRemote(object):
@ -116,9 +116,9 @@ class XmlManifest(object):
if d.remote: if d.remote:
have_default = True have_default = True
e.setAttribute('remote', d.remote.name) e.setAttribute('remote', d.remote.name)
if d.revision: if d.revisionExpr:
have_default = True have_default = True
e.setAttribute('revision', d.revision) e.setAttribute('revision', d.revisionExpr)
if have_default: if have_default:
root.appendChild(e) root.appendChild(e)
root.appendChild(doc.createTextNode('')) root.appendChild(doc.createTextNode(''))
@ -138,12 +138,12 @@ class XmlManifest(object):
if peg_rev: if peg_rev:
if self.IsMirror: if self.IsMirror:
e.setAttribute('revision', e.setAttribute('revision',
p.bare_git.rev_parse(p.revision + '^0')) p.bare_git.rev_parse(p.revisionExpr + '^0'))
else: else:
e.setAttribute('revision', e.setAttribute('revision',
p.work_git.rev_parse(HEAD + '^0')) p.work_git.rev_parse(HEAD + '^0'))
elif not d.revision or p.revision != d.revision: elif not d.revisionExpr or p.revisionExpr != d.revisionExpr:
e.setAttribute('revision', p.revision) e.setAttribute('revision', p.revisionExpr)
for c in p.copyfiles: for c in p.copyfiles:
ce = doc.createElement('copyfile') ce = doc.createElement('copyfile')
@ -286,7 +286,8 @@ class XmlManifest(object):
gitdir = gitdir, gitdir = gitdir,
worktree = None, worktree = None,
relpath = None, relpath = None,
revision = m.revision) revisionExpr = m.revisionExpr,
revisionId = None)
self._projects[project.name] = project self._projects[project.name] = project
def _ParseRemote(self, node): def _ParseRemote(self, node):
@ -306,9 +307,9 @@ class XmlManifest(object):
""" """
d = _Default() d = _Default()
d.remote = self._get_remote(node) d.remote = self._get_remote(node)
d.revision = node.getAttribute('revision') d.revisionExpr = node.getAttribute('revision')
if d.revision == '': if d.revisionExpr == '':
d.revision = None d.revisionExpr = None
return d return d
def _ParseProject(self, node): def _ParseProject(self, node):
@ -325,10 +326,10 @@ class XmlManifest(object):
"no remote for project %s within %s" % \ "no remote for project %s within %s" % \
(name, self.manifestFile) (name, self.manifestFile)
revision = node.getAttribute('revision') revisionExpr = node.getAttribute('revision')
if not revision: if not revisionExpr:
revision = self._default.revision revisionExpr = self._default.revisionExpr
if not revision: if not revisionExpr:
raise ManifestParseError, \ raise ManifestParseError, \
"no revision for project %s within %s" % \ "no revision for project %s within %s" % \
(name, self.manifestFile) (name, self.manifestFile)
@ -355,7 +356,8 @@ class XmlManifest(object):
gitdir = gitdir, gitdir = gitdir,
worktree = worktree, worktree = worktree,
relpath = path, relpath = path,
revision = revision) revisionExpr = revisionExpr,
revisionId = None)
for n in node.childNodes: for n in node.childNodes:
if n.nodeName == 'copyfile': if n.nodeName == 'copyfile':

170
project.py
View File

@ -228,14 +228,23 @@ class Project(object):
gitdir, gitdir,
worktree, worktree,
relpath, relpath,
revision): revisionExpr,
revisionId):
self.manifest = manifest self.manifest = manifest
self.name = name self.name = name
self.remote = remote self.remote = remote
self.gitdir = gitdir self.gitdir = gitdir
self.worktree = worktree self.worktree = worktree
self.relpath = relpath self.relpath = relpath
self.revision = revision self.revisionExpr = revisionExpr
if revisionId is None \
and revisionExpr \
and IsId(revisionExpr):
self.revisionId = revisionExpr
else:
self.revisionId = revisionId
self.snapshots = {} self.snapshots = {}
self.copyfiles = [] self.copyfiles = []
self.config = GitConfig.ForRepository( self.config = GitConfig.ForRepository(
@ -605,6 +614,23 @@ class Project(object):
for file in self.copyfiles: for file in self.copyfiles:
file._Copy() file._Copy()
def GetRevisionId(self, all=None):
if self.revisionId:
return self.revisionId
rem = self.GetRemote(self.remote.name)
rev = rem.ToLocal(self.revisionExpr)
if all is not None and rev in all:
return all[rev]
try:
return self.bare_git.rev_parse('--verify', '%s^0' % rev)
except GitError:
raise ManifestInvalidRevisionError(
'revision %s in %s not found' % (self.revisionExpr,
self.name))
def Sync_LocalHalf(self, syncbuf): def Sync_LocalHalf(self, syncbuf):
"""Perform only the local IO portion of the sync process. """Perform only the local IO portion of the sync process.
Network access is not required. Network access is not required.
@ -613,19 +639,7 @@ class Project(object):
all = self.bare_ref.all all = self.bare_ref.all
self.CleanPublishedCache(all) self.CleanPublishedCache(all)
rem = self.GetRemote(self.remote.name) revid = self.GetRevisionId(all)
rev = rem.ToLocal(self.revision)
if rev in all:
revid = all[rev]
elif IsId(rev):
revid = rev
else:
try:
revid = self.bare_git.rev_parse('--verify', '%s^0' % rev)
except GitError:
raise ManifestInvalidRevisionError(
'revision %s in %s not found' % (self.revision, self.name))
head = self.work_git.GetHead() head = self.work_git.GetHead()
if head.startswith(R_HEADS): if head.startswith(R_HEADS):
branch = head[len(R_HEADS):] branch = head[len(R_HEADS):]
@ -649,11 +663,11 @@ class Project(object):
# #
return return
lost = self._revlist(not_rev(rev), HEAD) lost = self._revlist(not_rev(revid), HEAD)
if lost: if lost:
syncbuf.info(self, "discarding %d commits", len(lost)) syncbuf.info(self, "discarding %d commits", len(lost))
try: try:
self._Checkout(rev, quiet=True) self._Checkout(revid, quiet=True)
except GitError, e: except GitError, e:
syncbuf.fail(self, e) syncbuf.fail(self, e)
return return
@ -666,9 +680,8 @@ class Project(object):
return return
branch = self.GetBranch(branch) branch = self.GetBranch(branch)
merge = branch.LocalMerge
if not merge: if not branch.LocalMerge:
# The current branch has no tracking configuration. # The current branch has no tracking configuration.
# Jump off it to a deatched HEAD. # Jump off it to a deatched HEAD.
# #
@ -676,17 +689,17 @@ class Project(object):
"leaving %s; does not track upstream", "leaving %s; does not track upstream",
branch.name) branch.name)
try: try:
self._Checkout(rev, quiet=True) self._Checkout(revid, quiet=True)
except GitError, e: except GitError, e:
syncbuf.fail(self, e) syncbuf.fail(self, e)
return return
self._CopyFiles() self._CopyFiles()
return return
upstream_gain = self._revlist(not_rev(HEAD), rev) upstream_gain = self._revlist(not_rev(HEAD), revid)
pub = self.WasPublished(branch.name, all) pub = self.WasPublished(branch.name, all)
if pub: if pub:
not_merged = self._revlist(not_rev(rev), pub) not_merged = self._revlist(not_rev(revid), pub)
if not_merged: if not_merged:
if upstream_gain: if upstream_gain:
# The user has published this branch and some of those # The user has published this branch and some of those
@ -703,24 +716,15 @@ class Project(object):
# strict subset. We can fast-forward safely. # strict subset. We can fast-forward safely.
# #
def _doff(): def _doff():
self._FastForward(rev) self._FastForward(revid)
self._CopyFiles() self._CopyFiles()
syncbuf.later1(self, _doff) syncbuf.later1(self, _doff)
return return
# If the upstream switched on us, warn the user.
#
if merge != rev:
syncbuf.info(self, "manifest switched %s...%s", merge, rev)
# Examine the local commits not in the remote. Find the # Examine the local commits not in the remote. Find the
# last one attributed to this user, if any. # last one attributed to this user, if any.
# #
local_changes = self._revlist( local_changes = self._revlist(not_rev(revid), HEAD, format='%H %ce')
not_rev(merge),
HEAD,
format='%H %ce')
last_mine = None last_mine = None
cnt_mine = 0 cnt_mine = 0
for commit in local_changes: for commit in local_changes:
@ -738,6 +742,19 @@ class Project(object):
syncbuf.fail(self, _DirtyError()) syncbuf.fail(self, _DirtyError())
return return
# If the upstream switched on us, warn the user.
#
if branch.merge != self.revisionExpr:
if branch.merge and self.revisionExpr:
syncbuf.info(self,
'manifest switched %s...%s',
branch.merge,
self.revisionExpr)
elif branch.merge:
syncbuf.info(self,
'manifest no longer tracks %s',
branch.merge)
if cnt_mine < len(local_changes): if cnt_mine < len(local_changes):
# Upstream rebased. Not everything in HEAD # Upstream rebased. Not everything in HEAD
# was created by this user. # was created by this user.
@ -746,25 +763,25 @@ class Project(object):
"discarding %d commits removed from upstream", "discarding %d commits removed from upstream",
len(local_changes) - cnt_mine) len(local_changes) - cnt_mine)
branch.remote = rem branch.remote = self.GetRemote(self.remote.name)
branch.merge = self.revision branch.merge = self.revisionExpr
branch.Save() branch.Save()
if cnt_mine > 0: if cnt_mine > 0:
def _dorebase(): def _dorebase():
self._Rebase(upstream = '%s^1' % last_mine, onto = rev) self._Rebase(upstream = '%s^1' % last_mine, onto = revid)
self._CopyFiles() self._CopyFiles()
syncbuf.later2(self, _dorebase) syncbuf.later2(self, _dorebase)
elif local_changes: elif local_changes:
try: try:
self._ResetHard(rev) self._ResetHard(revid)
self._CopyFiles() self._CopyFiles()
except GitError, e: except GitError, e:
syncbuf.fail(self, e) syncbuf.fail(self, e)
return return
else: else:
def _doff(): def _doff():
self._FastForward(rev) self._FastForward(revid)
self._CopyFiles() self._CopyFiles()
syncbuf.later1(self, _doff) syncbuf.later1(self, _doff)
@ -786,7 +803,7 @@ class Project(object):
if GitCommand(self, cmd, bare=True).Wait() != 0: if GitCommand(self, cmd, bare=True).Wait() != 0:
return None return None
return DownloadedChange(self, return DownloadedChange(self,
remote.ToLocal(self.revision), self.GetRevisionId(),
change_id, change_id,
patch_id, patch_id,
self.bare_git.rev_parse('FETCH_HEAD')) self.bare_git.rev_parse('FETCH_HEAD'))
@ -810,15 +827,8 @@ class Project(object):
branch = self.GetBranch(name) branch = self.GetBranch(name)
branch.remote = self.GetRemote(self.remote.name) branch.remote = self.GetRemote(self.remote.name)
branch.merge = self.revision branch.merge = self.revisionExpr
revid = self.GetRevisionId(all)
rev = branch.LocalMerge
if rev in all:
revid = all[rev]
elif IsId(rev):
revid = rev
else:
revid = None
if head.startswith(R_HEADS): if head.startswith(R_HEADS):
try: try:
@ -839,7 +849,7 @@ class Project(object):
return True return True
if GitCommand(self, if GitCommand(self,
['checkout', '-b', branch.name, rev], ['checkout', '-b', branch.name, revid],
capture_stdout = True, capture_stdout = True,
capture_stderr = True).Wait() == 0: capture_stderr = True).Wait() == 0:
branch.Save() branch.Save()
@ -900,19 +910,12 @@ class Project(object):
# #
head = all[head] head = all[head]
rev = self.GetRemote(self.remote.name).ToLocal(self.revision) revid = self.GetRevisionId(all)
if rev in all: if head == revid:
revid = all[rev]
elif IsId(rev):
revid = rev
else:
revid = None
if revid and head == revid:
_lwrite(os.path.join(self.worktree, '.git', HEAD), _lwrite(os.path.join(self.worktree, '.git', HEAD),
'%s\n' % revid) '%s\n' % revid)
else: else:
self._Checkout(rev, quiet=True) self._Checkout(revid, quiet=True)
return GitCommand(self, return GitCommand(self,
['branch', '-D', name], ['branch', '-D', name],
@ -931,7 +934,7 @@ class Project(object):
if cb is None or name != cb: if cb is None or name != cb:
kill.append(name) kill.append(name)
rev = self.GetRemote(self.remote.name).ToLocal(self.revision) rev = self.GetRevisionId(left)
if cb is not None \ if cb is not None \
and not self._revlist(HEAD + '...' + rev) \ and not self._revlist(HEAD + '...' + rev) \
and not self.IsDirty(consider_untracked = False): and not self.IsDirty(consider_untracked = False):
@ -1081,25 +1084,26 @@ class Project(object):
def _InitMRef(self): def _InitMRef(self):
if self.manifest.branch: if self.manifest.branch:
msg = 'manifest set to %s' % self.revision self._InitAnyMRef(R_M + self.manifest.branch)
ref = R_M + self.manifest.branch
def _InitMirrorHead(self):
self._InitAnyMRef(self, HEAD)
def _InitAnyMRef(self, ref):
cur = self.bare_ref.symref(ref) cur = self.bare_ref.symref(ref)
if IsId(self.revision): if self.revisionId:
if cur != '' or self.bare_ref.get(ref) != self.revision: if cur != '' or self.bare_ref.get(ref) != self.revisionId:
dst = self.revision + '^0' msg = 'manifest set to %s' % self.revisionId
dst = self.revisionId + '^0'
self.bare_git.UpdateRef(ref, dst, message = msg, detach = True) self.bare_git.UpdateRef(ref, dst, message = msg, detach = True)
else: else:
remote = self.GetRemote(self.remote.name) remote = self.GetRemote(self.remote.name)
dst = remote.ToLocal(self.revision) dst = remote.ToLocal(self.revisionExpr)
if cur != dst: if cur != dst:
msg = 'manifest set to %s' % self.revisionExpr
self.bare_git.symbolic_ref('-m', msg, ref, dst) self.bare_git.symbolic_ref('-m', msg, ref, dst)
def _InitMirrorHead(self):
dst = self.GetRemote(self.remote.name).ToLocal(self.revision)
msg = 'manifest set to %s' % self.revision
self.bare_git.SetHead(dst, message=msg)
def _InitWorkTree(self): def _InitWorkTree(self):
dotgit = os.path.join(self.worktree, '.git') dotgit = os.path.join(self.worktree, '.git')
if not os.path.exists(dotgit): if not os.path.exists(dotgit):
@ -1125,14 +1129,11 @@ class Project(object):
else: else:
raise raise
rev = self.GetRemote(self.remote.name).ToLocal(self.revision) _lwrite(os.path.join(dotgit, HEAD), '%s\n' % self.GetRevisionId())
rev = self.bare_git.rev_parse('%s^0' % rev)
_lwrite(os.path.join(dotgit, HEAD), '%s\n' % rev)
cmd = ['read-tree', '--reset', '-u'] cmd = ['read-tree', '--reset', '-u']
cmd.append('-v') cmd.append('-v')
cmd.append('HEAD') cmd.append(HEAD)
if GitCommand(self, cmd).Wait() != 0: if GitCommand(self, cmd).Wait() != 0:
raise GitError("cannot initialize work tree") raise GitError("cannot initialize work tree")
self._CopyFiles() self._CopyFiles()
@ -1433,7 +1434,8 @@ class MetaProject(Project):
worktree = worktree, worktree = worktree,
remote = RemoteSpec('origin'), remote = RemoteSpec('origin'),
relpath = '.repo/%s' % name, relpath = '.repo/%s' % name,
revision = 'refs/heads/master') revisionExpr = 'refs/heads/master',
revisionId = None)
def PreSync(self): def PreSync(self):
if self.Exists: if self.Exists:
@ -1441,7 +1443,8 @@ class MetaProject(Project):
if cb: if cb:
base = self.GetBranch(cb).merge base = self.GetBranch(cb).merge
if base: if base:
self.revision = base self.revisionExpr = base
self.revisionId = None
@property @property
def LastFetch(self): def LastFetch(self):
@ -1455,16 +1458,11 @@ class MetaProject(Project):
def HasChanges(self): def HasChanges(self):
"""Has the remote received new commits not yet checked out? """Has the remote received new commits not yet checked out?
""" """
if not self.remote or not self.revision: if not self.remote or not self.revisionExpr:
return False return False
all = self.bare_ref.all all = self.bare_ref.all
rev = self.GetRemote(self.remote.name).ToLocal(self.revision) revid = self.GetRevisionId(all)
if rev in all:
revid = all[rev]
else:
revid = rev
head = self.work_git.GetHead() head = self.work_git.GetHead()
if head.startswith(R_HEADS): if head.startswith(R_HEADS):
try: try:
@ -1474,6 +1472,6 @@ class MetaProject(Project):
if revid == head: if revid == head:
return False return False
elif self._revlist(not_rev(HEAD), rev): elif self._revlist(not_rev(HEAD), revid):
return True return True
return False return False

6
subcmds/forall.py
View File

@ -160,10 +160,8 @@ terminal and are not redirected.
setenv('REPO_PROJECT', project.name) setenv('REPO_PROJECT', project.name)
setenv('REPO_PATH', project.relpath) setenv('REPO_PATH', project.relpath)
setenv('REPO_REMOTE', project.remote.name) setenv('REPO_REMOTE', project.remote.name)
setenv('REPO_LREV', project\ setenv('REPO_LREV', project.GetRevisionId())
.GetRemote(project.remote.name)\ setenv('REPO_RREV', project.revisionExpr)
.ToLocal(project.revision))
setenv('REPO_RREV', project.revision)
if mirror: if mirror:
setenv('GIT_DIR', project.gitdir) setenv('GIT_DIR', project.gitdir)

6
subcmds/init.py
View File

@ -113,12 +113,12 @@ to update the working directory files.
m._InitGitDir() m._InitGitDir()
if opt.manifest_branch: if opt.manifest_branch:
m.revision = opt.manifest_branch m.revisionExpr = opt.manifest_branch
else: else:
m.revision = 'refs/heads/master' m.revisionExpr = 'refs/heads/master'
else: else:
if opt.manifest_branch: if opt.manifest_branch:
m.revision = opt.manifest_branch m.revisionExpr = opt.manifest_branch
else: else:
m.PreSync() m.PreSync()

7
subcmds/sync.py
View File

@ -207,17 +207,14 @@ def _VerifyTag(project):
warning: Cannot automatically authenticate repo.""" warning: Cannot automatically authenticate repo."""
return True return True
remote = project.GetRemote(project.remote.name)
ref = remote.ToLocal(project.revision)
try: try:
cur = project.bare_git.describe(ref) cur = project.bare_git.describe(project.GetRevisionId())
except GitError: except GitError:
cur = None cur = None
if not cur \ if not cur \
or re.compile(r'^.*-[0-9]{1,}-g[0-9a-f]{1,}$').match(cur): or re.compile(r'^.*-[0-9]{1,}-g[0-9a-f]{1,}$').match(cur):
rev = project.revision rev = project.revisionExpr
if rev.startswith(R_HEADS): if rev.startswith(R_HEADS):
rev = rev[len(R_HEADS):] rev = rev[len(R_HEADS):]