You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

BaseDirCacheEditor.java 6.9KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201
  1. /*
  2. * Copyright (C) 2008, Google Inc.
  3. * Copyright (C) 2008, Shawn O. Pearce <spearce@spearce.org>
  4. * and other copyright owners as documented in the project's IP log.
  5. *
  6. * This program and the accompanying materials are made available
  7. * under the terms of the Eclipse Distribution License v1.0 which
  8. * accompanies this distribution, is reproduced below, and is
  9. * available at http://www.eclipse.org/org/documents/edl-v10.php
  10. *
  11. * All rights reserved.
  12. *
  13. * Redistribution and use in source and binary forms, with or
  14. * without modification, are permitted provided that the following
  15. * conditions are met:
  16. *
  17. * - Redistributions of source code must retain the above copyright
  18. * notice, this list of conditions and the following disclaimer.
  19. *
  20. * - Redistributions in binary form must reproduce the above
  21. * copyright notice, this list of conditions and the following
  22. * disclaimer in the documentation and/or other materials provided
  23. * with the distribution.
  24. *
  25. * - Neither the name of the Eclipse Foundation, Inc. nor the
  26. * names of its contributors may be used to endorse or promote
  27. * products derived from this software without specific prior
  28. * written permission.
  29. *
  30. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND
  31. * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
  32. * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  33. * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  34. * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
  35. * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  36. * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
  37. * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  38. * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
  39. * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
  40. * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  41. * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
  42. * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  43. */
  44. package org.eclipse.jgit.dircache;
  45. import java.io.IOException;
  46. /**
  47. * Generic update/editing support for {@link DirCache}.
  48. * <p>
  49. * The different update strategies extend this class to provide their own unique
  50. * services to applications.
  51. */
  52. abstract class BaseDirCacheEditor {
  53. /** The cache instance this editor updates during {@link #finish()}. */
  54. protected DirCache cache;
  55. /**
  56. * Entry table this builder will eventually replace into {@link #cache}.
  57. * <p>
  58. * Use {@link #fastAdd(DirCacheEntry)} or {@link #fastKeep(int, int)} to
  59. * make additions to this table. The table is automatically expanded if it
  60. * is too small for a new addition.
  61. * <p>
  62. * Typically the entries in here are sorted by their path names, just like
  63. * they are in the DirCache instance.
  64. */
  65. protected DirCacheEntry[] entries;
  66. /** Total number of valid entries in {@link #entries}. */
  67. protected int entryCnt;
  68. /**
  69. * Construct a new editor.
  70. *
  71. * @param dc
  72. * the cache this editor will eventually update.
  73. * @param ecnt
  74. * estimated number of entries the editor will have upon
  75. * completion. This sizes the initial entry table.
  76. */
  77. protected BaseDirCacheEditor(final DirCache dc, final int ecnt) {
  78. cache = dc;
  79. entries = new DirCacheEntry[ecnt];
  80. }
  81. /**
  82. * @return the cache we will update on {@link #finish()}.
  83. */
  84. public DirCache getDirCache() {
  85. return cache;
  86. }
  87. /**
  88. * Append one entry into the resulting entry list.
  89. * <p>
  90. * The entry is placed at the end of the entry list. The caller is
  91. * responsible for making sure the final table is correctly sorted.
  92. * <p>
  93. * The {@link #entries} table is automatically expanded if there is
  94. * insufficient space for the new addition.
  95. *
  96. * @param newEntry
  97. * the new entry to add.
  98. */
  99. protected void fastAdd(final DirCacheEntry newEntry) {
  100. if (entries.length == entryCnt) {
  101. final DirCacheEntry[] n = new DirCacheEntry[(entryCnt + 16) * 3 / 2];
  102. System.arraycopy(entries, 0, n, 0, entryCnt);
  103. entries = n;
  104. }
  105. entries[entryCnt++] = newEntry;
  106. }
  107. /**
  108. * Add a range of existing entries from the destination cache.
  109. * <p>
  110. * The entries are placed at the end of the entry list, preserving their
  111. * current order. The caller is responsible for making sure the final table
  112. * is correctly sorted.
  113. * <p>
  114. * This method copies from the destination cache, which has not yet been
  115. * updated with this editor's new table. So all offsets into the destination
  116. * cache are not affected by any updates that may be currently taking place
  117. * in this editor.
  118. * <p>
  119. * The {@link #entries} table is automatically expanded if there is
  120. * insufficient space for the new additions.
  121. *
  122. * @param pos
  123. * first entry to copy from the destination cache.
  124. * @param cnt
  125. * number of entries to copy.
  126. */
  127. protected void fastKeep(final int pos, int cnt) {
  128. if (entryCnt + cnt > entries.length) {
  129. final int m1 = (entryCnt + 16) * 3 / 2;
  130. final int m2 = entryCnt + cnt;
  131. final DirCacheEntry[] n = new DirCacheEntry[Math.max(m1, m2)];
  132. System.arraycopy(entries, 0, n, 0, entryCnt);
  133. entries = n;
  134. }
  135. cache.toArray(pos, entries, entryCnt, cnt);
  136. entryCnt += cnt;
  137. }
  138. /**
  139. * Finish this builder and update the destination {@link DirCache}.
  140. * <p>
  141. * When this method completes this builder instance is no longer usable by
  142. * the calling application. A new builder must be created to make additional
  143. * changes to the index entries.
  144. * <p>
  145. * After completion the DirCache returned by {@link #getDirCache()} will
  146. * contain all modifications.
  147. * <p>
  148. * <i>Note to implementors:</i> Make sure {@link #entries} is fully sorted
  149. * then invoke {@link #replace()} to update the DirCache with the new table.
  150. */
  151. public abstract void finish();
  152. /**
  153. * Update the DirCache with the contents of {@link #entries}.
  154. * <p>
  155. * This method should be invoked only during an implementation of
  156. * {@link #finish()}, and only after {@link #entries} is sorted.
  157. */
  158. protected void replace() {
  159. if (entryCnt < entries.length / 2) {
  160. final DirCacheEntry[] n = new DirCacheEntry[entryCnt];
  161. System.arraycopy(entries, 0, n, 0, entryCnt);
  162. entries = n;
  163. }
  164. cache.replace(entries, entryCnt);
  165. }
  166. /**
  167. * Finish, write, commit this change, and release the index lock.
  168. * <p>
  169. * If this method fails (returns false) the lock is still released.
  170. * <p>
  171. * This is a utility method for applications as the finish-write-commit
  172. * pattern is very common after using a builder to update entries.
  173. *
  174. * @return true if the commit was successful and the file contains the new
  175. * data; false if the commit failed and the file remains with the
  176. * old data.
  177. * @throws IllegalStateException
  178. * the lock is not held.
  179. * @throws IOException
  180. * the output file could not be created. The caller no longer
  181. * holds the lock.
  182. */
  183. public boolean commit() throws IOException {
  184. finish();
  185. cache.write();
  186. return cache.commit();
  187. }
  188. }