|
|
|
@ -149,8 +149,8 @@ class Core {
|
|
|
|
|
boolean group = true;
|
|
|
|
|
Log.i(folder.name + " executing operations=" + ops.size());
|
|
|
|
|
while (retry < LOCAL_RETRY_MAX && ops.size() > 0 &&
|
|
|
|
|
state.batchCanRun(folder.id, priority, sequence) &&
|
|
|
|
|
state.isRunning() && ifolder.isOpen()) {
|
|
|
|
|
state.isRunning() &&
|
|
|
|
|
state.batchCanRun(folder.id, priority, sequence)) {
|
|
|
|
|
TupleOperationEx op = ops.get(0);
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
@ -3471,6 +3471,10 @@ class Core {
|
|
|
|
|
void reset() {
|
|
|
|
|
recoverable = true;
|
|
|
|
|
lastActivity = null;
|
|
|
|
|
resetBatches();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void resetBatches() {
|
|
|
|
|
synchronized (this) {
|
|
|
|
|
for (FolderPriority key : sequence.keySet()) {
|
|
|
|
|
batch.put(key, sequence.get(key));
|
|
|
|
|