|
1 | 1 | package org.tron.core.db.backup;
|
2 | 2 |
|
| 3 | +import static org.tron.core.db.backup.BackupDbUtil.STATE.BAKEDONE; |
| 4 | +import static org.tron.core.db.backup.BackupDbUtil.STATE.BAKEDTWO; |
| 5 | + |
3 | 6 | import java.util.List;
|
4 | 7 | import lombok.Getter;
|
5 |
| -import lombok.Setter; |
6 | 8 | import lombok.extern.slf4j.Slf4j;
|
7 | 9 | import org.rocksdb.RocksDBException;
|
8 | 10 | import org.springframework.beans.factory.annotation.Autowired;
|
@@ -78,16 +80,16 @@ private void setBackupState(int status) {
|
78 | 80 | private void switchBackupState() {
|
79 | 81 | switch (STATE.valueOf(getBackupState())) {
|
80 | 82 | case BAKINGONE:
|
81 |
| - setBackupState(STATE.BAKEDONE.getStatus()); |
| 83 | + setBackupState(BAKEDONE.getStatus()); |
82 | 84 | break;
|
83 | 85 | case BAKEDONE:
|
84 |
| - setBackupState(STATE.BAKEDTWO.getStatus()); |
| 86 | + setBackupState(BAKEDTWO.getStatus()); |
85 | 87 | break;
|
86 | 88 | case BAKINGTWO:
|
87 |
| - setBackupState(STATE.BAKEDTWO.getStatus()); |
| 89 | + setBackupState(BAKEDTWO.getStatus()); |
88 | 90 | break;
|
89 | 91 | case BAKEDTWO:
|
90 |
| - setBackupState(STATE.BAKEDONE.getStatus()); |
| 92 | + setBackupState(BAKEDONE.getStatus()); |
91 | 93 | break;
|
92 | 94 | default:
|
93 | 95 | break;
|
@@ -130,6 +132,10 @@ public void doBackup(BlockCapsule block) {
|
130 | 132 | }
|
131 | 133 | } catch (RocksDBException e) {
|
132 | 134 | logger.warn("backup db error");
|
| 135 | + } |
| 136 | + STATE state = STATE.valueOf(getBackupState()); |
| 137 | + if (state == BAKEDONE || state == BAKEDTWO) { |
| 138 | + |
133 | 139 | }
|
134 | 140 | logger.info("current block number is {}, backup all store use {} ms!", block.getNum(),
|
135 | 141 | System.currentTimeMillis() - t1);
|
|
0 commit comments