| @@ -24,6 +24,8 class Repository::Mercurial < Repository | |||
|
|
24 | 24 | attr_protected :root_url |
|
|
25 | 25 | validates_presence_of :url |
|
|
26 | 26 | |
|
|
27 | FETCH_AT_ONCE = 100 # number of changesets to fetch at once | |
|
|
28 | ||
|
|
27 | 29 | def self.scm_adapter_class |
|
|
28 | 30 | Redmine::Scm::Adapters::MercurialAdapter |
|
|
29 | 31 | end |
| @@ -94,38 +96,24 class Repository::Mercurial < Repository | |||
|
|
94 | 96 | end |
|
|
95 | 97 | |
|
|
96 | 98 | def fetch_changesets |
|
|
97 | scm_info = scm.info | |
|
|
98 | if scm_info | |
|
|
99 | # latest revision found in database | |
|
|
100 | db_revision = latest_changeset ? latest_changeset.revision.to_i : -1 | |
|
|
101 | # latest revision in the repository | |
|
|
102 | latest_revision = scm_info.lastrev | |
|
|
103 | return if latest_revision.nil? | |
|
|
104 | scm_revision = latest_revision.identifier.to_i | |
|
|
105 | if db_revision < scm_revision | |
|
|
106 | logger.debug "Fetching changesets for repository #{url}" if logger && logger.debug? | |
|
|
107 | identifier_from = db_revision + 1 | |
|
|
108 | while (identifier_from <= scm_revision) | |
|
|
109 | # loads changesets by batches of 100 | |
|
|
110 | identifier_to = [identifier_from + 99, scm_revision].min | |
|
|
111 | revisions = scm.revisions('', identifier_from, identifier_to, :with_paths => true) | |
|
|
112 | transaction do | |
|
|
113 | revisions.each do |revision| | |
|
|
114 | changeset = Changeset.create(:repository => self, | |
|
|
115 | :revision => revision.revision, | |
|
|
116 | :scmid => revision.scmid, | |
|
|
117 | :committer => revision.author, | |
|
|
118 | :committed_on => revision.time, | |
|
|
119 | :comments => revision.message) | |
|
|
120 | ||
|
|
121 | revision.paths.each do |change| | |
|
|
122 | changeset.create_change(change) | |
|
|
123 | end | |
|
|
124 | end | |
|
|
125 | end unless revisions.nil? | |
|
|
126 | identifier_from = identifier_to + 1 | |
|
|
99 | scm_rev = scm.info.lastrev.revision.to_i | |
|
|
100 | db_rev = latest_changeset ? latest_changeset.revision.to_i : -1 | |
|
|
101 | return unless db_rev < scm_rev # already up-to-date | |
|
|
102 | ||
|
|
103 | logger.debug "Fetching changesets for repository #{url}" if logger | |
|
|
104 | (db_rev + 1).step(scm_rev, FETCH_AT_ONCE) do |i| | |
|
|
105 | transaction do | |
|
|
106 | scm.each_revision('', i, [i + FETCH_AT_ONCE - 1, scm_rev].min) do |re| | |
|
|
107 | cs = Changeset.create(:repository => self, | |
|
|
108 | :revision => re.revision, | |
|
|
109 | :scmid => re.scmid, | |
|
|
110 | :committer => re.author, | |
|
|
111 | :committed_on => re.time, | |
|
|
112 | :comments => re.message) | |
|
|
113 | re.paths.each { |e| cs.create_change(e) } | |
|
|
127 | 114 | end |
|
|
128 | 115 | end |
|
|
129 | 116 | end |
|
|
117 | self | |
|
|
130 | 118 | end |
|
|
131 | 119 | end |
General Comments 0
You need to be logged in to leave comments.
Login now