##// END OF EJS Templates
copies-rust: make the comparison aware of the revision being current merged...
marmoute -
r46771:7d99614b default
parent child Browse files
Show More
@@ -1,767 +1,795 b''
1 use crate::utils::hg_path::HgPath;
1 use crate::utils::hg_path::HgPath;
2 use crate::utils::hg_path::HgPathBuf;
2 use crate::utils::hg_path::HgPathBuf;
3 use crate::Revision;
3 use crate::Revision;
4 use crate::NULL_REVISION;
4 use crate::NULL_REVISION;
5
5
6 use im_rc::ordmap::DiffItem;
6 use im_rc::ordmap::DiffItem;
7 use im_rc::ordmap::Entry;
7 use im_rc::ordmap::Entry;
8 use im_rc::ordmap::OrdMap;
8 use im_rc::ordmap::OrdMap;
9
9
10 use std::cmp::Ordering;
10 use std::cmp::Ordering;
11 use std::collections::HashMap;
11 use std::collections::HashMap;
12 use std::convert::TryInto;
12 use std::convert::TryInto;
13
13
14 pub type PathCopies = HashMap<HgPathBuf, HgPathBuf>;
14 pub type PathCopies = HashMap<HgPathBuf, HgPathBuf>;
15
15
16 type PathToken = usize;
16 type PathToken = usize;
17
17
18 #[derive(Clone, Debug, PartialEq, Copy)]
18 #[derive(Clone, Debug, PartialEq, Copy)]
19 struct TimeStampedPathCopy {
19 struct TimeStampedPathCopy {
20 /// revision at which the copy information was added
20 /// revision at which the copy information was added
21 rev: Revision,
21 rev: Revision,
22 /// the copy source, (Set to None in case of deletion of the associated
22 /// the copy source, (Set to None in case of deletion of the associated
23 /// key)
23 /// key)
24 path: Option<PathToken>,
24 path: Option<PathToken>,
25 }
25 }
26
26
27 /// maps CopyDestination to Copy Source (+ a "timestamp" for the operation)
27 /// maps CopyDestination to Copy Source (+ a "timestamp" for the operation)
28 type TimeStampedPathCopies = OrdMap<PathToken, TimeStampedPathCopy>;
28 type TimeStampedPathCopies = OrdMap<PathToken, TimeStampedPathCopy>;
29
29
30 /// hold parent 1, parent 2 and relevant files actions.
30 /// hold parent 1, parent 2 and relevant files actions.
31 pub type RevInfo<'a> = (Revision, Revision, ChangedFiles<'a>);
31 pub type RevInfo<'a> = (Revision, Revision, ChangedFiles<'a>);
32
32
33 /// represent the files affected by a changesets
33 /// represent the files affected by a changesets
34 ///
34 ///
35 /// This hold a subset of mercurial.metadata.ChangingFiles as we do not need
35 /// This hold a subset of mercurial.metadata.ChangingFiles as we do not need
36 /// all the data categories tracked by it.
36 /// all the data categories tracked by it.
37 /// This hold a subset of mercurial.metadata.ChangingFiles as we do not need
37 /// This hold a subset of mercurial.metadata.ChangingFiles as we do not need
38 /// all the data categories tracked by it.
38 /// all the data categories tracked by it.
39 pub struct ChangedFiles<'a> {
39 pub struct ChangedFiles<'a> {
40 nb_items: u32,
40 nb_items: u32,
41 index: &'a [u8],
41 index: &'a [u8],
42 data: &'a [u8],
42 data: &'a [u8],
43 }
43 }
44
44
45 /// Represent active changes that affect the copy tracing.
45 /// Represent active changes that affect the copy tracing.
46 enum Action<'a> {
46 enum Action<'a> {
47 /// The parent ? children edge is removing a file
47 /// The parent ? children edge is removing a file
48 ///
48 ///
49 /// (actually, this could be the edge from the other parent, but it does
49 /// (actually, this could be the edge from the other parent, but it does
50 /// not matters)
50 /// not matters)
51 Removed(&'a HgPath),
51 Removed(&'a HgPath),
52 /// The parent ? children edge introduce copy information between (dest,
52 /// The parent ? children edge introduce copy information between (dest,
53 /// source)
53 /// source)
54 Copied(&'a HgPath, &'a HgPath),
54 Copied(&'a HgPath, &'a HgPath),
55 }
55 }
56
56
57 /// This express the possible "special" case we can get in a merge
57 /// This express the possible "special" case we can get in a merge
58 ///
58 ///
59 /// See mercurial/metadata.py for details on these values.
59 /// See mercurial/metadata.py for details on these values.
60 #[derive(PartialEq)]
60 #[derive(PartialEq)]
61 enum MergeCase {
61 enum MergeCase {
62 /// Merged: file had history on both side that needed to be merged
62 /// Merged: file had history on both side that needed to be merged
63 Merged,
63 Merged,
64 /// Salvaged: file was candidate for deletion, but survived the merge
64 /// Salvaged: file was candidate for deletion, but survived the merge
65 Salvaged,
65 Salvaged,
66 /// Normal: Not one of the two cases above
66 /// Normal: Not one of the two cases above
67 Normal,
67 Normal,
68 }
68 }
69
69
70 type FileChange<'a> = (u8, &'a HgPath, &'a HgPath);
70 type FileChange<'a> = (u8, &'a HgPath, &'a HgPath);
71
71
72 const EMPTY: &[u8] = b"";
72 const EMPTY: &[u8] = b"";
73 const COPY_MASK: u8 = 3;
73 const COPY_MASK: u8 = 3;
74 const P1_COPY: u8 = 2;
74 const P1_COPY: u8 = 2;
75 const P2_COPY: u8 = 3;
75 const P2_COPY: u8 = 3;
76 const ACTION_MASK: u8 = 28;
76 const ACTION_MASK: u8 = 28;
77 const REMOVED: u8 = 12;
77 const REMOVED: u8 = 12;
78 const MERGED: u8 = 8;
78 const MERGED: u8 = 8;
79 const SALVAGED: u8 = 16;
79 const SALVAGED: u8 = 16;
80
80
81 impl<'a> ChangedFiles<'a> {
81 impl<'a> ChangedFiles<'a> {
82 const INDEX_START: usize = 4;
82 const INDEX_START: usize = 4;
83 const ENTRY_SIZE: u32 = 9;
83 const ENTRY_SIZE: u32 = 9;
84 const FILENAME_START: u32 = 1;
84 const FILENAME_START: u32 = 1;
85 const COPY_SOURCE_START: u32 = 5;
85 const COPY_SOURCE_START: u32 = 5;
86
86
87 pub fn new(data: &'a [u8]) -> Self {
87 pub fn new(data: &'a [u8]) -> Self {
88 assert!(
88 assert!(
89 data.len() >= 4,
89 data.len() >= 4,
90 "data size ({}) is too small to contain the header (4)",
90 "data size ({}) is too small to contain the header (4)",
91 data.len()
91 data.len()
92 );
92 );
93 let nb_items_raw: [u8; 4] = (&data[0..=3])
93 let nb_items_raw: [u8; 4] = (&data[0..=3])
94 .try_into()
94 .try_into()
95 .expect("failed to turn 4 bytes into 4 bytes");
95 .expect("failed to turn 4 bytes into 4 bytes");
96 let nb_items = u32::from_be_bytes(nb_items_raw);
96 let nb_items = u32::from_be_bytes(nb_items_raw);
97
97
98 let index_size = (nb_items * Self::ENTRY_SIZE) as usize;
98 let index_size = (nb_items * Self::ENTRY_SIZE) as usize;
99 let index_end = Self::INDEX_START + index_size;
99 let index_end = Self::INDEX_START + index_size;
100
100
101 assert!(
101 assert!(
102 data.len() >= index_end,
102 data.len() >= index_end,
103 "data size ({}) is too small to fit the index_data ({})",
103 "data size ({}) is too small to fit the index_data ({})",
104 data.len(),
104 data.len(),
105 index_end
105 index_end
106 );
106 );
107
107
108 let ret = ChangedFiles {
108 let ret = ChangedFiles {
109 nb_items,
109 nb_items,
110 index: &data[Self::INDEX_START..index_end],
110 index: &data[Self::INDEX_START..index_end],
111 data: &data[index_end..],
111 data: &data[index_end..],
112 };
112 };
113 let max_data = ret.filename_end(nb_items - 1) as usize;
113 let max_data = ret.filename_end(nb_items - 1) as usize;
114 assert!(
114 assert!(
115 ret.data.len() >= max_data,
115 ret.data.len() >= max_data,
116 "data size ({}) is too small to fit all data ({})",
116 "data size ({}) is too small to fit all data ({})",
117 data.len(),
117 data.len(),
118 index_end + max_data
118 index_end + max_data
119 );
119 );
120 ret
120 ret
121 }
121 }
122
122
123 pub fn new_empty() -> Self {
123 pub fn new_empty() -> Self {
124 ChangedFiles {
124 ChangedFiles {
125 nb_items: 0,
125 nb_items: 0,
126 index: EMPTY,
126 index: EMPTY,
127 data: EMPTY,
127 data: EMPTY,
128 }
128 }
129 }
129 }
130
130
131 /// internal function to return an individual entry at a given index
131 /// internal function to return an individual entry at a given index
132 fn entry(&'a self, idx: u32) -> FileChange<'a> {
132 fn entry(&'a self, idx: u32) -> FileChange<'a> {
133 if idx >= self.nb_items {
133 if idx >= self.nb_items {
134 panic!(
134 panic!(
135 "index for entry is higher that the number of file {} >= {}",
135 "index for entry is higher that the number of file {} >= {}",
136 idx, self.nb_items
136 idx, self.nb_items
137 )
137 )
138 }
138 }
139 let flags = self.flags(idx);
139 let flags = self.flags(idx);
140 let filename = self.filename(idx);
140 let filename = self.filename(idx);
141 let copy_idx = self.copy_idx(idx);
141 let copy_idx = self.copy_idx(idx);
142 let copy_source = self.filename(copy_idx);
142 let copy_source = self.filename(copy_idx);
143 (flags, filename, copy_source)
143 (flags, filename, copy_source)
144 }
144 }
145
145
146 /// internal function to return the filename of the entry at a given index
146 /// internal function to return the filename of the entry at a given index
147 fn filename(&self, idx: u32) -> &HgPath {
147 fn filename(&self, idx: u32) -> &HgPath {
148 let filename_start;
148 let filename_start;
149 if idx == 0 {
149 if idx == 0 {
150 filename_start = 0;
150 filename_start = 0;
151 } else {
151 } else {
152 filename_start = self.filename_end(idx - 1)
152 filename_start = self.filename_end(idx - 1)
153 }
153 }
154 let filename_end = self.filename_end(idx);
154 let filename_end = self.filename_end(idx);
155 let filename_start = filename_start as usize;
155 let filename_start = filename_start as usize;
156 let filename_end = filename_end as usize;
156 let filename_end = filename_end as usize;
157 HgPath::new(&self.data[filename_start..filename_end])
157 HgPath::new(&self.data[filename_start..filename_end])
158 }
158 }
159
159
160 /// internal function to return the flag field of the entry at a given
160 /// internal function to return the flag field of the entry at a given
161 /// index
161 /// index
162 fn flags(&self, idx: u32) -> u8 {
162 fn flags(&self, idx: u32) -> u8 {
163 let idx = idx as usize;
163 let idx = idx as usize;
164 self.index[idx * (Self::ENTRY_SIZE as usize)]
164 self.index[idx * (Self::ENTRY_SIZE as usize)]
165 }
165 }
166
166
167 /// internal function to return the end of a filename part at a given index
167 /// internal function to return the end of a filename part at a given index
168 fn filename_end(&self, idx: u32) -> u32 {
168 fn filename_end(&self, idx: u32) -> u32 {
169 let start = (idx * Self::ENTRY_SIZE) + Self::FILENAME_START;
169 let start = (idx * Self::ENTRY_SIZE) + Self::FILENAME_START;
170 let end = (idx * Self::ENTRY_SIZE) + Self::COPY_SOURCE_START;
170 let end = (idx * Self::ENTRY_SIZE) + Self::COPY_SOURCE_START;
171 let start = start as usize;
171 let start = start as usize;
172 let end = end as usize;
172 let end = end as usize;
173 let raw = (&self.index[start..end])
173 let raw = (&self.index[start..end])
174 .try_into()
174 .try_into()
175 .expect("failed to turn 4 bytes into 4 bytes");
175 .expect("failed to turn 4 bytes into 4 bytes");
176 u32::from_be_bytes(raw)
176 u32::from_be_bytes(raw)
177 }
177 }
178
178
179 /// internal function to return index of the copy source of the entry at a
179 /// internal function to return index of the copy source of the entry at a
180 /// given index
180 /// given index
181 fn copy_idx(&self, idx: u32) -> u32 {
181 fn copy_idx(&self, idx: u32) -> u32 {
182 let start = (idx * Self::ENTRY_SIZE) + Self::COPY_SOURCE_START;
182 let start = (idx * Self::ENTRY_SIZE) + Self::COPY_SOURCE_START;
183 let end = (idx + 1) * Self::ENTRY_SIZE;
183 let end = (idx + 1) * Self::ENTRY_SIZE;
184 let start = start as usize;
184 let start = start as usize;
185 let end = end as usize;
185 let end = end as usize;
186 let raw = (&self.index[start..end])
186 let raw = (&self.index[start..end])
187 .try_into()
187 .try_into()
188 .expect("failed to turn 4 bytes into 4 bytes");
188 .expect("failed to turn 4 bytes into 4 bytes");
189 u32::from_be_bytes(raw)
189 u32::from_be_bytes(raw)
190 }
190 }
191
191
192 /// Return an iterator over all the `Action` in this instance.
192 /// Return an iterator over all the `Action` in this instance.
193 fn iter_actions(&self, parent: Parent) -> ActionsIterator {
193 fn iter_actions(&self, parent: Parent) -> ActionsIterator {
194 ActionsIterator {
194 ActionsIterator {
195 changes: &self,
195 changes: &self,
196 parent: parent,
196 parent: parent,
197 current: 0,
197 current: 0,
198 }
198 }
199 }
199 }
200
200
201 /// return the MergeCase value associated with a filename
201 /// return the MergeCase value associated with a filename
202 fn get_merge_case(&self, path: &HgPath) -> MergeCase {
202 fn get_merge_case(&self, path: &HgPath) -> MergeCase {
203 if self.nb_items == 0 {
203 if self.nb_items == 0 {
204 return MergeCase::Normal;
204 return MergeCase::Normal;
205 }
205 }
206 let mut low_part = 0;
206 let mut low_part = 0;
207 let mut high_part = self.nb_items;
207 let mut high_part = self.nb_items;
208
208
209 while low_part < high_part {
209 while low_part < high_part {
210 let cursor = (low_part + high_part - 1) / 2;
210 let cursor = (low_part + high_part - 1) / 2;
211 let (flags, filename, _source) = self.entry(cursor);
211 let (flags, filename, _source) = self.entry(cursor);
212 match path.cmp(filename) {
212 match path.cmp(filename) {
213 Ordering::Less => low_part = cursor + 1,
213 Ordering::Less => low_part = cursor + 1,
214 Ordering::Greater => high_part = cursor,
214 Ordering::Greater => high_part = cursor,
215 Ordering::Equal => {
215 Ordering::Equal => {
216 return match flags & ACTION_MASK {
216 return match flags & ACTION_MASK {
217 MERGED => MergeCase::Merged,
217 MERGED => MergeCase::Merged,
218 SALVAGED => MergeCase::Salvaged,
218 SALVAGED => MergeCase::Salvaged,
219 _ => MergeCase::Normal,
219 _ => MergeCase::Normal,
220 };
220 };
221 }
221 }
222 }
222 }
223 }
223 }
224 MergeCase::Normal
224 MergeCase::Normal
225 }
225 }
226 }
226 }
227
227
228 /// A struct responsible for answering "is X ancestors of Y" quickly
228 /// A struct responsible for answering "is X ancestors of Y" quickly
229 ///
229 ///
230 /// The structure will delegate ancestors call to a callback, and cache the
230 /// The structure will delegate ancestors call to a callback, and cache the
231 /// result.
231 /// result.
232 #[derive(Debug)]
232 #[derive(Debug)]
233 struct AncestorOracle<'a, A: Fn(Revision, Revision) -> bool> {
233 struct AncestorOracle<'a, A: Fn(Revision, Revision) -> bool> {
234 inner: &'a A,
234 inner: &'a A,
235 pairs: HashMap<(Revision, Revision), bool>,
235 pairs: HashMap<(Revision, Revision), bool>,
236 }
236 }
237
237
238 impl<'a, A: Fn(Revision, Revision) -> bool> AncestorOracle<'a, A> {
238 impl<'a, A: Fn(Revision, Revision) -> bool> AncestorOracle<'a, A> {
239 fn new(func: &'a A) -> Self {
239 fn new(func: &'a A) -> Self {
240 Self {
240 Self {
241 inner: func,
241 inner: func,
242 pairs: HashMap::default(),
242 pairs: HashMap::default(),
243 }
243 }
244 }
244 }
245
245
246 fn record_overwrite(&mut self, anc: Revision, desc: Revision) {
246 fn record_overwrite(&mut self, anc: Revision, desc: Revision) {
247 self.pairs.insert((anc, desc), true);
247 self.pairs.insert((anc, desc), true);
248 }
248 }
249
249
250 /// returns `true` if `anc` is an ancestors of `desc`, `false` otherwise
250 /// returns `true` if `anc` is an ancestors of `desc`, `false` otherwise
251 fn is_overwrite(&mut self, anc: Revision, desc: Revision) -> bool {
251 fn is_overwrite(&mut self, anc: Revision, desc: Revision) -> bool {
252 if anc > desc {
252 if anc > desc {
253 false
253 false
254 } else if anc == desc {
254 } else if anc == desc {
255 true
255 true
256 } else {
256 } else {
257 if let Some(b) = self.pairs.get(&(anc, desc)) {
257 if let Some(b) = self.pairs.get(&(anc, desc)) {
258 *b
258 *b
259 } else {
259 } else {
260 let b = (self.inner)(anc, desc);
260 let b = (self.inner)(anc, desc);
261 self.pairs.insert((anc, desc), b);
261 self.pairs.insert((anc, desc), b);
262 b
262 b
263 }
263 }
264 }
264 }
265 }
265 }
266 }
266 }
267
267
268 struct ActionsIterator<'a> {
268 struct ActionsIterator<'a> {
269 changes: &'a ChangedFiles<'a>,
269 changes: &'a ChangedFiles<'a>,
270 parent: Parent,
270 parent: Parent,
271 current: u32,
271 current: u32,
272 }
272 }
273
273
274 impl<'a> Iterator for ActionsIterator<'a> {
274 impl<'a> Iterator for ActionsIterator<'a> {
275 type Item = Action<'a>;
275 type Item = Action<'a>;
276
276
277 fn next(&mut self) -> Option<Action<'a>> {
277 fn next(&mut self) -> Option<Action<'a>> {
278 let copy_flag = match self.parent {
278 let copy_flag = match self.parent {
279 Parent::FirstParent => P1_COPY,
279 Parent::FirstParent => P1_COPY,
280 Parent::SecondParent => P2_COPY,
280 Parent::SecondParent => P2_COPY,
281 };
281 };
282 while self.current < self.changes.nb_items {
282 while self.current < self.changes.nb_items {
283 let (flags, file, source) = self.changes.entry(self.current);
283 let (flags, file, source) = self.changes.entry(self.current);
284 self.current += 1;
284 self.current += 1;
285 if (flags & ACTION_MASK) == REMOVED {
285 if (flags & ACTION_MASK) == REMOVED {
286 return Some(Action::Removed(file));
286 return Some(Action::Removed(file));
287 }
287 }
288 let copy = flags & COPY_MASK;
288 let copy = flags & COPY_MASK;
289 if copy == copy_flag {
289 if copy == copy_flag {
290 return Some(Action::Copied(file, source));
290 return Some(Action::Copied(file, source));
291 }
291 }
292 }
292 }
293 return None;
293 return None;
294 }
294 }
295 }
295 }
296
296
297 /// A small struct whose purpose is to ensure lifetime of bytes referenced in
297 /// A small struct whose purpose is to ensure lifetime of bytes referenced in
298 /// ChangedFiles
298 /// ChangedFiles
299 ///
299 ///
300 /// It is passed to the RevInfoMaker callback who can assign any necessary
300 /// It is passed to the RevInfoMaker callback who can assign any necessary
301 /// content to the `data` attribute. The copy tracing code is responsible for
301 /// content to the `data` attribute. The copy tracing code is responsible for
302 /// keeping the DataHolder alive at least as long as the ChangedFiles object.
302 /// keeping the DataHolder alive at least as long as the ChangedFiles object.
303 pub struct DataHolder<D> {
303 pub struct DataHolder<D> {
304 /// RevInfoMaker callback should assign data referenced by the
304 /// RevInfoMaker callback should assign data referenced by the
305 /// ChangedFiles struct it return to this attribute. The DataHolder
305 /// ChangedFiles struct it return to this attribute. The DataHolder
306 /// lifetime will be at least as long as the ChangedFiles one.
306 /// lifetime will be at least as long as the ChangedFiles one.
307 pub data: Option<D>,
307 pub data: Option<D>,
308 }
308 }
309
309
310 pub type RevInfoMaker<'a, D> =
310 pub type RevInfoMaker<'a, D> =
311 Box<dyn for<'r> Fn(Revision, &'r mut DataHolder<D>) -> RevInfo<'r> + 'a>;
311 Box<dyn for<'r> Fn(Revision, &'r mut DataHolder<D>) -> RevInfo<'r> + 'a>;
312
312
313 /// enum used to carry information about the parent → child currently processed
313 /// enum used to carry information about the parent → child currently processed
314 #[derive(Copy, Clone, Debug)]
314 #[derive(Copy, Clone, Debug)]
315 enum Parent {
315 enum Parent {
316 /// The `p1(x) → x` edge
316 /// The `p1(x) → x` edge
317 FirstParent,
317 FirstParent,
318 /// The `p2(x) → x` edge
318 /// The `p2(x) → x` edge
319 SecondParent,
319 SecondParent,
320 }
320 }
321
321
322 /// A small "tokenizer" responsible of turning full HgPath into lighter
322 /// A small "tokenizer" responsible of turning full HgPath into lighter
323 /// PathToken
323 /// PathToken
324 ///
324 ///
325 /// Dealing with small object, like integer is much faster, so HgPath input are
325 /// Dealing with small object, like integer is much faster, so HgPath input are
326 /// turned into integer "PathToken" and converted back in the end.
326 /// turned into integer "PathToken" and converted back in the end.
327 #[derive(Clone, Debug, Default)]
327 #[derive(Clone, Debug, Default)]
328 struct TwoWayPathMap {
328 struct TwoWayPathMap {
329 token: HashMap<HgPathBuf, PathToken>,
329 token: HashMap<HgPathBuf, PathToken>,
330 path: Vec<HgPathBuf>,
330 path: Vec<HgPathBuf>,
331 }
331 }
332
332
333 impl TwoWayPathMap {
333 impl TwoWayPathMap {
334 fn tokenize(&mut self, path: &HgPath) -> PathToken {
334 fn tokenize(&mut self, path: &HgPath) -> PathToken {
335 match self.token.get(path) {
335 match self.token.get(path) {
336 Some(a) => *a,
336 Some(a) => *a,
337 None => {
337 None => {
338 let a = self.token.len();
338 let a = self.token.len();
339 let buf = path.to_owned();
339 let buf = path.to_owned();
340 self.path.push(buf.clone());
340 self.path.push(buf.clone());
341 self.token.insert(buf, a);
341 self.token.insert(buf, a);
342 a
342 a
343 }
343 }
344 }
344 }
345 }
345 }
346
346
347 fn untokenize(&self, token: PathToken) -> &HgPathBuf {
347 fn untokenize(&self, token: PathToken) -> &HgPathBuf {
348 assert!(token < self.path.len(), format!("Unknown token: {}", token));
348 assert!(token < self.path.len(), format!("Unknown token: {}", token));
349 &self.path[token]
349 &self.path[token]
350 }
350 }
351 }
351 }
352
352
353 /// Same as mercurial.copies._combine_changeset_copies, but in Rust.
353 /// Same as mercurial.copies._combine_changeset_copies, but in Rust.
354 ///
354 ///
355 /// Arguments are:
355 /// Arguments are:
356 ///
356 ///
357 /// revs: all revisions to be considered
357 /// revs: all revisions to be considered
358 /// children: a {parent ? [childrens]} mapping
358 /// children: a {parent ? [childrens]} mapping
359 /// target_rev: the final revision we are combining copies to
359 /// target_rev: the final revision we are combining copies to
360 /// rev_info(rev): callback to get revision information:
360 /// rev_info(rev): callback to get revision information:
361 /// * first parent
361 /// * first parent
362 /// * second parent
362 /// * second parent
363 /// * ChangedFiles
363 /// * ChangedFiles
364 /// isancestors(low_rev, high_rev): callback to check if a revision is an
364 /// isancestors(low_rev, high_rev): callback to check if a revision is an
365 /// ancestor of another
365 /// ancestor of another
366 pub fn combine_changeset_copies<A: Fn(Revision, Revision) -> bool, D>(
366 pub fn combine_changeset_copies<A: Fn(Revision, Revision) -> bool, D>(
367 revs: Vec<Revision>,
367 revs: Vec<Revision>,
368 mut children_count: HashMap<Revision, usize>,
368 mut children_count: HashMap<Revision, usize>,
369 target_rev: Revision,
369 target_rev: Revision,
370 rev_info: RevInfoMaker<D>,
370 rev_info: RevInfoMaker<D>,
371 is_ancestor: &A,
371 is_ancestor: &A,
372 ) -> PathCopies {
372 ) -> PathCopies {
373 let mut all_copies = HashMap::new();
373 let mut all_copies = HashMap::new();
374 let mut oracle = AncestorOracle::new(is_ancestor);
374 let mut oracle = AncestorOracle::new(is_ancestor);
375
375
376 let mut path_map = TwoWayPathMap::default();
376 let mut path_map = TwoWayPathMap::default();
377
377
378 for rev in revs {
378 for rev in revs {
379 let mut d: DataHolder<D> = DataHolder { data: None };
379 let mut d: DataHolder<D> = DataHolder { data: None };
380 let (p1, p2, changes) = rev_info(rev, &mut d);
380 let (p1, p2, changes) = rev_info(rev, &mut d);
381
381
382 // We will chain the copies information accumulated for the parent with
382 // We will chain the copies information accumulated for the parent with
383 // the individual copies information the curent revision. Creating a
383 // the individual copies information the curent revision. Creating a
384 // new TimeStampedPath for each `rev` → `children` vertex.
384 // new TimeStampedPath for each `rev` → `children` vertex.
385 let mut copies: Option<TimeStampedPathCopies> = None;
385 let mut copies: Option<TimeStampedPathCopies> = None;
386 if p1 != NULL_REVISION {
386 if p1 != NULL_REVISION {
387 // Retrieve data computed in a previous iteration
387 // Retrieve data computed in a previous iteration
388 let parent_copies = get_and_clean_parent_copies(
388 let parent_copies = get_and_clean_parent_copies(
389 &mut all_copies,
389 &mut all_copies,
390 &mut children_count,
390 &mut children_count,
391 p1,
391 p1,
392 );
392 );
393 if let Some(parent_copies) = parent_copies {
393 if let Some(parent_copies) = parent_copies {
394 // combine it with data for that revision
394 // combine it with data for that revision
395 let vertex_copies = add_from_changes(
395 let vertex_copies = add_from_changes(
396 &mut path_map,
396 &mut path_map,
397 &mut oracle,
397 &mut oracle,
398 &parent_copies,
398 &parent_copies,
399 &changes,
399 &changes,
400 Parent::FirstParent,
400 Parent::FirstParent,
401 rev,
401 rev,
402 );
402 );
403 // keep that data around for potential later combination
403 // keep that data around for potential later combination
404 copies = Some(vertex_copies);
404 copies = Some(vertex_copies);
405 }
405 }
406 }
406 }
407 if p2 != NULL_REVISION {
407 if p2 != NULL_REVISION {
408 // Retrieve data computed in a previous iteration
408 // Retrieve data computed in a previous iteration
409 let parent_copies = get_and_clean_parent_copies(
409 let parent_copies = get_and_clean_parent_copies(
410 &mut all_copies,
410 &mut all_copies,
411 &mut children_count,
411 &mut children_count,
412 p2,
412 p2,
413 );
413 );
414 if let Some(parent_copies) = parent_copies {
414 if let Some(parent_copies) = parent_copies {
415 // combine it with data for that revision
415 // combine it with data for that revision
416 let vertex_copies = add_from_changes(
416 let vertex_copies = add_from_changes(
417 &mut path_map,
417 &mut path_map,
418 &mut oracle,
418 &mut oracle,
419 &parent_copies,
419 &parent_copies,
420 &changes,
420 &changes,
421 Parent::SecondParent,
421 Parent::SecondParent,
422 rev,
422 rev,
423 );
423 );
424
424
425 copies = match copies {
425 copies = match copies {
426 None => Some(vertex_copies),
426 None => Some(vertex_copies),
427 // Merge has two parents needs to combines their copy
427 // Merge has two parents needs to combines their copy
428 // information.
428 // information.
429 //
429 //
430 // If we got data from both parents, We need to combine
430 // If we got data from both parents, We need to combine
431 // them.
431 // them.
432 Some(copies) => Some(merge_copies_dict(
432 Some(copies) => Some(merge_copies_dict(
433 &path_map,
433 &path_map,
434 rev,
434 vertex_copies,
435 vertex_copies,
435 copies,
436 copies,
436 &changes,
437 &changes,
437 &mut oracle,
438 &mut oracle,
438 )),
439 )),
439 };
440 };
440 }
441 }
441 }
442 }
442 match copies {
443 match copies {
443 Some(copies) => {
444 Some(copies) => {
444 all_copies.insert(rev, copies);
445 all_copies.insert(rev, copies);
445 }
446 }
446 _ => {}
447 _ => {}
447 }
448 }
448 }
449 }
449
450
450 // Drop internal information (like the timestamp) and return the final
451 // Drop internal information (like the timestamp) and return the final
451 // mapping.
452 // mapping.
452 let tt_result = all_copies
453 let tt_result = all_copies
453 .remove(&target_rev)
454 .remove(&target_rev)
454 .expect("target revision was not processed");
455 .expect("target revision was not processed");
455 let mut result = PathCopies::default();
456 let mut result = PathCopies::default();
456 for (dest, tt_source) in tt_result {
457 for (dest, tt_source) in tt_result {
457 if let Some(path) = tt_source.path {
458 if let Some(path) = tt_source.path {
458 let path_dest = path_map.untokenize(dest).to_owned();
459 let path_dest = path_map.untokenize(dest).to_owned();
459 let path_path = path_map.untokenize(path).to_owned();
460 let path_path = path_map.untokenize(path).to_owned();
460 result.insert(path_dest, path_path);
461 result.insert(path_dest, path_path);
461 }
462 }
462 }
463 }
463 result
464 result
464 }
465 }
465
466
466 /// fetch previous computed information
467 /// fetch previous computed information
467 ///
468 ///
468 /// If no other children are expected to need this information, we drop it from
469 /// If no other children are expected to need this information, we drop it from
469 /// the cache.
470 /// the cache.
470 ///
471 ///
471 /// If parent is not part of the set we are expected to walk, return None.
472 /// If parent is not part of the set we are expected to walk, return None.
472 fn get_and_clean_parent_copies(
473 fn get_and_clean_parent_copies(
473 all_copies: &mut HashMap<Revision, TimeStampedPathCopies>,
474 all_copies: &mut HashMap<Revision, TimeStampedPathCopies>,
474 children_count: &mut HashMap<Revision, usize>,
475 children_count: &mut HashMap<Revision, usize>,
475 parent_rev: Revision,
476 parent_rev: Revision,
476 ) -> Option<TimeStampedPathCopies> {
477 ) -> Option<TimeStampedPathCopies> {
477 let count = children_count.get_mut(&parent_rev)?;
478 let count = children_count.get_mut(&parent_rev)?;
478 *count -= 1;
479 *count -= 1;
479 if *count == 0 {
480 if *count == 0 {
480 match all_copies.remove(&parent_rev) {
481 match all_copies.remove(&parent_rev) {
481 Some(c) => Some(c),
482 Some(c) => Some(c),
482 None => Some(TimeStampedPathCopies::default()),
483 None => Some(TimeStampedPathCopies::default()),
483 }
484 }
484 } else {
485 } else {
485 match all_copies.get(&parent_rev) {
486 match all_copies.get(&parent_rev) {
486 Some(c) => Some(c.clone()),
487 Some(c) => Some(c.clone()),
487 None => Some(TimeStampedPathCopies::default()),
488 None => Some(TimeStampedPathCopies::default()),
488 }
489 }
489 }
490 }
490 }
491 }
491
492
492 /// Combine ChangedFiles with some existing PathCopies information and return
493 /// Combine ChangedFiles with some existing PathCopies information and return
493 /// the result
494 /// the result
494 fn add_from_changes<A: Fn(Revision, Revision) -> bool>(
495 fn add_from_changes<A: Fn(Revision, Revision) -> bool>(
495 path_map: &mut TwoWayPathMap,
496 path_map: &mut TwoWayPathMap,
496 oracle: &mut AncestorOracle<A>,
497 oracle: &mut AncestorOracle<A>,
497 base_copies: &TimeStampedPathCopies,
498 base_copies: &TimeStampedPathCopies,
498 changes: &ChangedFiles,
499 changes: &ChangedFiles,
499 parent: Parent,
500 parent: Parent,
500 current_rev: Revision,
501 current_rev: Revision,
501 ) -> TimeStampedPathCopies {
502 ) -> TimeStampedPathCopies {
502 let mut copies = base_copies.clone();
503 let mut copies = base_copies.clone();
503 for action in changes.iter_actions(parent) {
504 for action in changes.iter_actions(parent) {
504 match action {
505 match action {
505 Action::Copied(path_dest, path_source) => {
506 Action::Copied(path_dest, path_source) => {
506 let dest = path_map.tokenize(path_dest);
507 let dest = path_map.tokenize(path_dest);
507 let source = path_map.tokenize(path_source);
508 let source = path_map.tokenize(path_source);
508 let entry;
509 let entry;
509 if let Some(v) = base_copies.get(&source) {
510 if let Some(v) = base_copies.get(&source) {
510 entry = match &v.path {
511 entry = match &v.path {
511 Some(path) => Some((*(path)).to_owned()),
512 Some(path) => Some((*(path)).to_owned()),
512 None => Some(source.to_owned()),
513 None => Some(source.to_owned()),
513 }
514 }
514 } else {
515 } else {
515 entry = Some(source.to_owned());
516 entry = Some(source.to_owned());
516 }
517 }
517 // Each new entry is introduced by the children, we
518 // Each new entry is introduced by the children, we
518 // record this information as we will need it to take
519 // record this information as we will need it to take
519 // the right decision when merging conflicting copy
520 // the right decision when merging conflicting copy
520 // information. See merge_copies_dict for details.
521 // information. See merge_copies_dict for details.
521 match copies.entry(dest) {
522 match copies.entry(dest) {
522 Entry::Vacant(slot) => {
523 Entry::Vacant(slot) => {
523 let ttpc = TimeStampedPathCopy {
524 let ttpc = TimeStampedPathCopy {
524 rev: current_rev,
525 rev: current_rev,
525 path: entry,
526 path: entry,
526 };
527 };
527 slot.insert(ttpc);
528 slot.insert(ttpc);
528 }
529 }
529 Entry::Occupied(mut slot) => {
530 Entry::Occupied(mut slot) => {
530 let mut ttpc = slot.get_mut();
531 let mut ttpc = slot.get_mut();
531 oracle.record_overwrite(ttpc.rev, current_rev);
532 oracle.record_overwrite(ttpc.rev, current_rev);
532 ttpc.rev = current_rev;
533 ttpc.rev = current_rev;
533 ttpc.path = entry;
534 ttpc.path = entry;
534 }
535 }
535 }
536 }
536 }
537 }
537 Action::Removed(deleted_path) => {
538 Action::Removed(deleted_path) => {
538 // We must drop copy information for removed file.
539 // We must drop copy information for removed file.
539 //
540 //
540 // We need to explicitly record them as dropped to
541 // We need to explicitly record them as dropped to
541 // propagate this information when merging two
542 // propagate this information when merging two
542 // TimeStampedPathCopies object.
543 // TimeStampedPathCopies object.
543 let deleted = path_map.tokenize(deleted_path);
544 let deleted = path_map.tokenize(deleted_path);
544 copies.entry(deleted).and_modify(|old| {
545 copies.entry(deleted).and_modify(|old| {
545 oracle.record_overwrite(old.rev, current_rev);
546 oracle.record_overwrite(old.rev, current_rev);
546 old.rev = current_rev;
547 old.rev = current_rev;
547 old.path = None;
548 old.path = None;
548 });
549 });
549 }
550 }
550 }
551 }
551 }
552 }
552 copies
553 copies
553 }
554 }
554
555
555 /// merge two copies-mapping together, minor and major
556 /// merge two copies-mapping together, minor and major
556 ///
557 ///
557 /// In case of conflict, value from "major" will be picked, unless in some
558 /// In case of conflict, value from "major" will be picked, unless in some
558 /// cases. See inline documentation for details.
559 /// cases. See inline documentation for details.
559 fn merge_copies_dict<A: Fn(Revision, Revision) -> bool>(
560 fn merge_copies_dict<A: Fn(Revision, Revision) -> bool>(
560 path_map: &TwoWayPathMap,
561 path_map: &TwoWayPathMap,
562 current_merge: Revision,
561 mut minor: TimeStampedPathCopies,
563 mut minor: TimeStampedPathCopies,
562 mut major: TimeStampedPathCopies,
564 mut major: TimeStampedPathCopies,
563 changes: &ChangedFiles,
565 changes: &ChangedFiles,
564 oracle: &mut AncestorOracle<A>,
566 oracle: &mut AncestorOracle<A>,
565 ) -> TimeStampedPathCopies {
567 ) -> TimeStampedPathCopies {
566 // This closure exist as temporary help while multiple developper are
568 // This closure exist as temporary help while multiple developper are
567 // actively working on this code. Feel free to re-inline it once this
569 // actively working on this code. Feel free to re-inline it once this
568 // code is more settled.
570 // code is more settled.
569 let mut cmp_value =
571 let mut cmp_value =
570 |dest: &PathToken,
572 |dest: &PathToken,
571 src_minor: &TimeStampedPathCopy,
573 src_minor: &TimeStampedPathCopy,
572 src_major: &TimeStampedPathCopy| {
574 src_major: &TimeStampedPathCopy| {
573 compare_value(
575 compare_value(
574 path_map, changes, oracle, dest, src_minor, src_major,
576 path_map,
577 current_merge,
578 changes,
579 oracle,
580 dest,
581 src_minor,
582 src_major,
575 )
583 )
576 };
584 };
577 if minor.is_empty() {
585 if minor.is_empty() {
578 major
586 major
579 } else if major.is_empty() {
587 } else if major.is_empty() {
580 minor
588 minor
581 } else if minor.len() * 2 < major.len() {
589 } else if minor.len() * 2 < major.len() {
582 // Lets says we are merging two TimeStampedPathCopies instance A and B.
590 // Lets says we are merging two TimeStampedPathCopies instance A and B.
583 //
591 //
584 // If A contains N items, the merge result will never contains more
592 // If A contains N items, the merge result will never contains more
585 // than N values differents than the one in A
593 // than N values differents than the one in A
586 //
594 //
587 // If B contains M items, with M > N, the merge result will always
595 // If B contains M items, with M > N, the merge result will always
588 // result in a minimum of M - N value differents than the on in
596 // result in a minimum of M - N value differents than the on in
589 // A
597 // A
590 //
598 //
591 // As a result, if N < (M-N), we know that simply iterating over A will
599 // As a result, if N < (M-N), we know that simply iterating over A will
592 // yield less difference than iterating over the difference
600 // yield less difference than iterating over the difference
593 // between A and B.
601 // between A and B.
594 //
602 //
595 // This help performance a lot in case were a tiny
603 // This help performance a lot in case were a tiny
596 // TimeStampedPathCopies is merged with a much larger one.
604 // TimeStampedPathCopies is merged with a much larger one.
597 for (dest, src_minor) in minor {
605 for (dest, src_minor) in minor {
598 let src_major = major.get(&dest);
606 let src_major = major.get(&dest);
599 match src_major {
607 match src_major {
600 None => major.insert(dest, src_minor),
608 None => major.insert(dest, src_minor),
601 Some(src_major) => {
609 Some(src_major) => {
602 match cmp_value(&dest, &src_minor, src_major) {
610 match cmp_value(&dest, &src_minor, src_major) {
603 MergePick::Any | MergePick::Major => None,
611 MergePick::Any | MergePick::Major => None,
604 MergePick::Minor => major.insert(dest, src_minor),
612 MergePick::Minor => major.insert(dest, src_minor),
605 }
613 }
606 }
614 }
607 };
615 };
608 }
616 }
609 major
617 major
610 } else if major.len() * 2 < minor.len() {
618 } else if major.len() * 2 < minor.len() {
611 // This use the same rational than the previous block.
619 // This use the same rational than the previous block.
612 // (Check previous block documentation for details.)
620 // (Check previous block documentation for details.)
613 for (dest, src_major) in major {
621 for (dest, src_major) in major {
614 let src_minor = minor.get(&dest);
622 let src_minor = minor.get(&dest);
615 match src_minor {
623 match src_minor {
616 None => minor.insert(dest, src_major),
624 None => minor.insert(dest, src_major),
617 Some(src_minor) => {
625 Some(src_minor) => {
618 match cmp_value(&dest, src_minor, &src_major) {
626 match cmp_value(&dest, src_minor, &src_major) {
619 MergePick::Any | MergePick::Minor => None,
627 MergePick::Any | MergePick::Minor => None,
620 MergePick::Major => minor.insert(dest, src_major),
628 MergePick::Major => minor.insert(dest, src_major),
621 }
629 }
622 }
630 }
623 };
631 };
624 }
632 }
625 minor
633 minor
626 } else {
634 } else {
627 let mut override_minor = Vec::new();
635 let mut override_minor = Vec::new();
628 let mut override_major = Vec::new();
636 let mut override_major = Vec::new();
629
637
630 let mut to_major = |k: &PathToken, v: &TimeStampedPathCopy| {
638 let mut to_major = |k: &PathToken, v: &TimeStampedPathCopy| {
631 override_major.push((k.clone(), v.clone()))
639 override_major.push((k.clone(), v.clone()))
632 };
640 };
633 let mut to_minor = |k: &PathToken, v: &TimeStampedPathCopy| {
641 let mut to_minor = |k: &PathToken, v: &TimeStampedPathCopy| {
634 override_minor.push((k.clone(), v.clone()))
642 override_minor.push((k.clone(), v.clone()))
635 };
643 };
636
644
637 // The diff function leverage detection of the identical subpart if
645 // The diff function leverage detection of the identical subpart if
638 // minor and major has some common ancestors. This make it very
646 // minor and major has some common ancestors. This make it very
639 // fast is most case.
647 // fast is most case.
640 //
648 //
641 // In case where the two map are vastly different in size, the current
649 // In case where the two map are vastly different in size, the current
642 // approach is still slowish because the iteration will iterate over
650 // approach is still slowish because the iteration will iterate over
643 // all the "exclusive" content of the larger on. This situation can be
651 // all the "exclusive" content of the larger on. This situation can be
644 // frequent when the subgraph of revision we are processing has a lot
652 // frequent when the subgraph of revision we are processing has a lot
645 // of roots. Each roots adding they own fully new map to the mix (and
653 // of roots. Each roots adding they own fully new map to the mix (and
646 // likely a small map, if the path from the root to the "main path" is
654 // likely a small map, if the path from the root to the "main path" is
647 // small.
655 // small.
648 //
656 //
649 // We could do better by detecting such situation and processing them
657 // We could do better by detecting such situation and processing them
650 // differently.
658 // differently.
651 for d in minor.diff(&major) {
659 for d in minor.diff(&major) {
652 match d {
660 match d {
653 DiffItem::Add(k, v) => to_minor(k, v),
661 DiffItem::Add(k, v) => to_minor(k, v),
654 DiffItem::Remove(k, v) => to_major(k, v),
662 DiffItem::Remove(k, v) => to_major(k, v),
655 DiffItem::Update { old, new } => {
663 DiffItem::Update { old, new } => {
656 let (dest, src_major) = new;
664 let (dest, src_major) = new;
657 let (_, src_minor) = old;
665 let (_, src_minor) = old;
658 match cmp_value(dest, src_minor, src_major) {
666 match cmp_value(dest, src_minor, src_major) {
659 MergePick::Major => to_minor(dest, src_major),
667 MergePick::Major => to_minor(dest, src_major),
660 MergePick::Minor => to_major(dest, src_minor),
668 MergePick::Minor => to_major(dest, src_minor),
661 // If the two entry are identical, no need to do
669 // If the two entry are identical, no need to do
662 // anything (but diff should not have yield them)
670 // anything (but diff should not have yield them)
663 MergePick::Any => unreachable!(),
671 MergePick::Any => unreachable!(),
664 }
672 }
665 }
673 }
666 };
674 };
667 }
675 }
668
676
669 let updates;
677 let updates;
670 let mut result;
678 let mut result;
671 if override_major.is_empty() {
679 if override_major.is_empty() {
672 result = major
680 result = major
673 } else if override_minor.is_empty() {
681 } else if override_minor.is_empty() {
674 result = minor
682 result = minor
675 } else {
683 } else {
676 if override_minor.len() < override_major.len() {
684 if override_minor.len() < override_major.len() {
677 updates = override_minor;
685 updates = override_minor;
678 result = minor;
686 result = minor;
679 } else {
687 } else {
680 updates = override_major;
688 updates = override_major;
681 result = major;
689 result = major;
682 }
690 }
683 for (k, v) in updates {
691 for (k, v) in updates {
684 result.insert(k, v);
692 result.insert(k, v);
685 }
693 }
686 }
694 }
687 result
695 result
688 }
696 }
689 }
697 }
690
698
691 /// represent the side that should prevail when merging two
699 /// represent the side that should prevail when merging two
692 /// TimeStampedPathCopies
700 /// TimeStampedPathCopies
693 enum MergePick {
701 enum MergePick {
694 /// The "major" (p1) side prevails
702 /// The "major" (p1) side prevails
695 Major,
703 Major,
696 /// The "minor" (p2) side prevails
704 /// The "minor" (p2) side prevails
697 Minor,
705 Minor,
698 /// Any side could be used (because they are the same)
706 /// Any side could be used (because they are the same)
699 Any,
707 Any,
700 }
708 }
701
709
702 /// decide which side prevails in case of conflicting values
710 /// decide which side prevails in case of conflicting values
703 #[allow(clippy::if_same_then_else)]
711 #[allow(clippy::if_same_then_else)]
704 fn compare_value<A: Fn(Revision, Revision) -> bool>(
712 fn compare_value<A: Fn(Revision, Revision) -> bool>(
705 path_map: &TwoWayPathMap,
713 path_map: &TwoWayPathMap,
714 current_merge: Revision,
706 changes: &ChangedFiles,
715 changes: &ChangedFiles,
707 oracle: &mut AncestorOracle<A>,
716 oracle: &mut AncestorOracle<A>,
708 dest: &PathToken,
717 dest: &PathToken,
709 src_minor: &TimeStampedPathCopy,
718 src_minor: &TimeStampedPathCopy,
710 src_major: &TimeStampedPathCopy,
719 src_major: &TimeStampedPathCopy,
711 ) -> MergePick {
720 ) -> MergePick {
712 if src_major.path == src_minor.path {
721 if src_major.rev == current_merge {
722 if src_minor.rev == current_merge {
723 if src_major.path.is_none() {
724 // We cannot get different copy information for both p1 and p2
725 // from the same revision. Unless this was a
726 // deletion
727 MergePick::Any
728 } else {
729 unreachable!();
730 }
731 } else {
732 // The last value comes the current merge, this value -will- win
733 // eventually.
734 MergePick::Major
735 }
736 } else if src_minor.rev == current_merge {
737 // The last value comes the current merge, this value -will- win
738 // eventually.
739 MergePick::Minor
740 } else if src_major.path == src_minor.path {
713 // we have the same value, but from other source;
741 // we have the same value, but from other source;
714 if src_major.rev == src_minor.rev {
742 if src_major.rev == src_minor.rev {
715 // If the two entry are identical, they are both valid
743 // If the two entry are identical, they are both valid
716 MergePick::Any
744 MergePick::Any
717 } else if oracle.is_overwrite(src_major.rev, src_minor.rev) {
745 } else if oracle.is_overwrite(src_major.rev, src_minor.rev) {
718 MergePick::Minor
746 MergePick::Minor
719 } else {
747 } else {
720 MergePick::Major
748 MergePick::Major
721 }
749 }
722 } else if src_major.rev == src_minor.rev {
750 } else if src_major.rev == src_minor.rev {
723 // We cannot get copy information for both p1 and p2 in the
751 // We cannot get copy information for both p1 and p2 in the
724 // same rev. So this is the same value.
752 // same rev. So this is the same value.
725 unreachable!(
753 unreachable!(
726 "conflict information from p1 and p2 in the same revision"
754 "conflict information from p1 and p2 in the same revision"
727 );
755 );
728 } else {
756 } else {
729 let dest_path = path_map.untokenize(*dest);
757 let dest_path = path_map.untokenize(*dest);
730 let action = changes.get_merge_case(dest_path);
758 let action = changes.get_merge_case(dest_path);
731 if src_major.path.is_none() && action == MergeCase::Salvaged {
759 if src_major.path.is_none() && action == MergeCase::Salvaged {
732 // If the file is "deleted" in the major side but was
760 // If the file is "deleted" in the major side but was
733 // salvaged by the merge, we keep the minor side alive
761 // salvaged by the merge, we keep the minor side alive
734 MergePick::Minor
762 MergePick::Minor
735 } else if src_minor.path.is_none() && action == MergeCase::Salvaged {
763 } else if src_minor.path.is_none() && action == MergeCase::Salvaged {
736 // If the file is "deleted" in the minor side but was
764 // If the file is "deleted" in the minor side but was
737 // salvaged by the merge, unconditionnaly preserve the
765 // salvaged by the merge, unconditionnaly preserve the
738 // major side.
766 // major side.
739 MergePick::Major
767 MergePick::Major
740 } else if action == MergeCase::Merged {
768 } else if action == MergeCase::Merged {
741 // If the file was actively merged, copy information
769 // If the file was actively merged, copy information
742 // from each side might conflict. The major side will
770 // from each side might conflict. The major side will
743 // win such conflict.
771 // win such conflict.
744 MergePick::Major
772 MergePick::Major
745 } else if oracle.is_overwrite(src_major.rev, src_minor.rev) {
773 } else if oracle.is_overwrite(src_major.rev, src_minor.rev) {
746 // If the minor side is strictly newer than the major
774 // If the minor side is strictly newer than the major
747 // side, it should be kept.
775 // side, it should be kept.
748 MergePick::Minor
776 MergePick::Minor
749 } else if src_major.path.is_some() {
777 } else if src_major.path.is_some() {
750 // without any special case, the "major" value win
778 // without any special case, the "major" value win
751 // other the "minor" one.
779 // other the "minor" one.
752 MergePick::Major
780 MergePick::Major
753 } else if oracle.is_overwrite(src_minor.rev, src_major.rev) {
781 } else if oracle.is_overwrite(src_minor.rev, src_major.rev) {
754 // the "major" rev is a direct ancestors of "minor",
782 // the "major" rev is a direct ancestors of "minor",
755 // any different value should
783 // any different value should
756 // overwrite
784 // overwrite
757 MergePick::Major
785 MergePick::Major
758 } else {
786 } else {
759 // major version is None (so the file was deleted on
787 // major version is None (so the file was deleted on
760 // that branch) and that branch is independant (neither
788 // that branch) and that branch is independant (neither
761 // minor nor major is an ancestors of the other one.)
789 // minor nor major is an ancestors of the other one.)
762 // We preserve the new
790 // We preserve the new
763 // information about the new file.
791 // information about the new file.
764 MergePick::Minor
792 MergePick::Minor
765 }
793 }
766 }
794 }
767 }
795 }
General Comments 0
You need to be logged in to leave comments. Login now