Skip to content

Commit 1a8eefd

Browse files
committed
fix snapshot backup
1 parent 8def135 commit 1a8eefd

File tree

3 files changed

+9
-2
lines changed

3 files changed

+9
-2
lines changed

pom.xml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,7 @@
7979
<metrics.version>4.0.2</metrics.version>
8080
<commons-io.version>2.4</commons-io.version>
8181
<jetty.version>[9.4.17.v20190418,9.4.19.v20190610]</jetty.version>
82+
<rocksdbjni.version>6.4.6</rocksdbjni.version>
8283
<main.user.dir>${user.dir}</main.user.dir>
8384
<argLine>-Dnetwork_interface_denylist=docker0</argLine>
8485
</properties>
@@ -343,6 +344,11 @@
343344
<version>${powermock.version}</version>
344345
<scope>test</scope>
345346
</dependency>
347+
<dependency>
348+
<groupId>org.rocksdb</groupId>
349+
<artifactId>rocksdbjni</artifactId>
350+
<version>${rocksdbjni.version}</version>
351+
</dependency>
346352
</dependencies>
347353
</dependencyManagement>
348354

server/server/data/src/main/java/com/alipay/sofa/registry/server/data/bootstrap/DataServerBeanConfiguration.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -418,6 +418,7 @@ public List<IDataChangeNotifier> dataChangeNotifiers() {
418418
list.add(sessionServerNotifier());
419419
list.add(tempPublisherNotifier());
420420
list.add(backUpNotifier());
421+
list.add(snapshotBackUpNotifier());
421422
return list;
422423
}
423424

server/server/data/src/main/java/com/alipay/sofa/registry/server/data/renew/LocalDataServerCleanHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,9 +94,9 @@ public LocalDataServerCleanHandler() {
9494
*/
9595
public void reset() {
9696
synchronized (LocalDataServerCleanHandler.class) {
97-
if (EVENT_QUEUE.isEmpty() && task != null) {
97+
EVENT_QUEUE.clear();
98+
if (task != null) {
9899
task.stop();
99-
EVENT_QUEUE.clear();
100100
}
101101
}
102102
EVENT_QUEUE.add(new DelayItem<>(new LocalCleanTask(), dataServerConfig

0 commit comments

Comments
 (0)