Skip to content

Commit

Permalink
fixed the comments
Browse files Browse the repository at this point in the history
  • Loading branch information
tigershi committed Aug 2, 2023
1 parent 1182c84 commit cc3e48f
Showing 1 changed file with 6 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -58,8 +58,7 @@ public class SourceRequestCron {


public final static long SECOND = 1000;

private static boolean recovedDir = false;
private static boolean recoveredDir = false;

@PostConstruct
public void initSendFile() {
Expand Down Expand Up @@ -92,7 +91,7 @@ public void initSendFile() {
}

logger.info("end recover the remained resource!!");
recovedDir = true;
recoveredDir = true;
}


Expand Down Expand Up @@ -175,12 +174,12 @@ private void recoverDirectory(File file) {

@Scheduled(cron = "${remote.source.schedule.cron}")
public void lauchInstructToSync() {
if (!recovedDir){
if (!recoveredDir){
return;
}

try {
if(configs.getRecordApiVersion().equalsIgnoreCase("s3") ) {
if(configs.getRecordApiVersion().equalsIgnoreCase("s3")) {
TaskSysnQueues.InstructTasks.put(instructS3);
}else {
TaskSysnQueues.InstructTasks.put(instructV1);
Expand All @@ -196,7 +195,7 @@ public void lauchInstructToSync() {
public void syncToInternali18nManager() {

Set<RecordModel> set = new HashSet<RecordModel>();
while (!TaskSysnQueues.SendComponentTasks.isEmpty() && recovedDir) {
while (!TaskSysnQueues.SendComponentTasks.isEmpty() && recoveredDir) {
logger.info("begin synch local component Model to VIP i18n");
RecordModel record = TaskSysnQueues.SendComponentTasks.poll();
set.add(record);
Expand Down Expand Up @@ -250,7 +249,7 @@ private boolean writeLocalResource(RecordModel record) {
@Scheduled(fixedDelay = SECOND * 2)
public void syncSourcefromRemoteToLocal() {

while (!TaskSysnQueues.InstructTasks.isEmpty() ) {
while (!TaskSysnQueues.InstructTasks.isEmpty()) {
String doneVerion = TaskSysnQueues.InstructTasks.poll();
if(instructS3.equals(doneVerion)) {
doRecordApiS3();
Expand Down

0 comments on commit cc3e48f

Please sign in to comment.