delete parts;
}
+void ArbitrationRound::generateParts() {
+ if (didGenerateParts) {
+ return;
+ }
+ parts = new Vector<Entry *>();
+ SetIterator<Abort *, Abort *> * abit = abortsBefore->iterator();
+ while(abit->hasNext())
+ parts->add((Entry *)abit->next());
+ delete abit;
+ if (commit != NULL) {
+ Vector<CommitPart *> * cParts = commit->getParts();
+ uint cPartsSize = cParts->size();
+ for(uint i=0; i < cPartsSize; i++) {
+ parts->add((Entry *)cParts->get(i));
+ }
+ }
+}
+
Vector<Entry *> *ArbitrationRound::getParts() {
return parts;
}
+void ArbitrationRound::removeParts(Vector<Entry *> *removeParts) {
+ parts->removeAll(removeParts);
+ didSendPart = true;
+}
+
+
bool ArbitrationRound::isDoneSending() {
if ((commit == NULL) && abortsBefore->isEmpty()) {
return true;