1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44 package org.eclipse.jgit.revwalk;
45
46 import java.io.IOException;
47
48 import org.eclipse.jgit.errors.IncorrectObjectTypeException;
49 import org.eclipse.jgit.errors.MissingObjectException;
50
51
52
53
54 public class FIFORevQueue extends BlockRevQueue {
55 private Block head;
56
57 private Block tail;
58
59
60
61
62 public FIFORevQueue() {
63 super();
64 }
65
66 FIFORevQueue(Generator s) throws MissingObjectException,
67 IncorrectObjectTypeException, IOException {
68 super(s);
69 }
70
71
72 @Override
73 public void add(RevCommit c) {
74 Block b = tail;
75 if (b == null) {
76 b = free.newBlock();
77 b.add(c);
78 head = b;
79 tail = b;
80 return;
81 } else if (b.isFull()) {
82 b = free.newBlock();
83 tail.next = b;
84 tail = b;
85 }
86 b.add(c);
87 }
88
89
90
91
92
93
94
95 public void unpop(RevCommit c) {
96 Block b = head;
97 if (b == null) {
98 b = free.newBlock();
99 b.resetToMiddle();
100 b.add(c);
101 head = b;
102 tail = b;
103 return;
104 } else if (b.canUnpop()) {
105 b.unpop(c);
106 return;
107 }
108
109 b = free.newBlock();
110 b.resetToEnd();
111 b.unpop(c);
112 b.next = head;
113 head = b;
114 }
115
116
117 @Override
118 public RevCommit next() {
119 final Block b = head;
120 if (b == null)
121 return null;
122
123 final RevCommit c = b.pop();
124 if (b.isEmpty()) {
125 head = b.next;
126 if (head == null)
127 tail = null;
128 free.freeBlock(b);
129 }
130 return c;
131 }
132
133
134 @Override
135 public void clear() {
136 head = null;
137 tail = null;
138 free.clear();
139 }
140
141 @Override
142 boolean everbodyHasFlag(int f) {
143 for (Block b = head; b != null; b = b.next) {
144 for (int i = b.headIndex; i < b.tailIndex; i++)
145 if ((b.commits[i].flags & f) == 0)
146 return false;
147 }
148 return true;
149 }
150
151 @Override
152 boolean anybodyHasFlag(int f) {
153 for (Block b = head; b != null; b = b.next) {
154 for (int i = b.headIndex; i < b.tailIndex; i++)
155 if ((b.commits[i].flags & f) != 0)
156 return true;
157 }
158 return false;
159 }
160
161 void removeFlag(int f) {
162 final int not_f = ~f;
163 for (Block b = head; b != null; b = b.next) {
164 for (int i = b.headIndex; i < b.tailIndex; i++)
165 b.commits[i].flags &= not_f;
166 }
167 }
168
169
170 @Override
171 public String toString() {
172 final StringBuilder s = new StringBuilder();
173 for (Block q = head; q != null; q = q.next) {
174 for (int i = q.headIndex; i < q.tailIndex; i++)
175 describe(s, q.commits[i]);
176 }
177 return s.toString();
178 }
179 }