This is an automated email from the ASF dual-hosted git repository.
carryxyh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new 6b589f0 Modify MetadataReportRetry ThreadName (#3550)
6b589f0 is described below
commit 6b589f0d5aa7f414b62cdd5765a914e071ccd628
Author: cvictory <[email protected]>
AuthorDate: Fri Feb 22 21:03:17 2019 +0800
Modify MetadataReportRetry ThreadName (#3550)
* fix: rename the thread name from DubboRegistryFailedRetryTimer to
DubboMetadataReportRetryTimer in MetadataReportRetry
---
.../org/apache/dubbo/metadata/support/AbstractMetadataReport.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/support/AbstractMetadataReport.java
b/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/support/AbstractMetadataReport.java
index 6080fa5..95b44f4 100644
---
a/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/support/AbstractMetadataReport.java
+++
b/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/support/AbstractMetadataReport.java
@@ -62,7 +62,7 @@ public abstract class AbstractMetadataReport implements
MetadataReport {
// Log output
protected final Logger logger = LoggerFactory.getLogger(getClass());
- // Local disk cache, where the special key value.registries records the
list of registry centers, and the others are the list of notified service
providers
+ // Local disk cache, where the special key value.registries records the
list of metadata centers, and the others are the list of notified service
providers
final Properties properties = new Properties();
private final ExecutorService reportCacheExecutor =
Executors.newFixedThreadPool(1, new
NamedThreadFactory("DubboSaveMetadataReport", true));
final Map<MetadataIdentifier, Object> allMetadataReports = new
ConcurrentHashMap<>(4);
@@ -336,7 +336,7 @@ public abstract class AbstractMetadataReport implements
MetadataReport {
class MetadataReportRetry {
protected final Logger logger = LoggerFactory.getLogger(getClass());
- final ScheduledExecutorService retryExecutor =
Executors.newScheduledThreadPool(0, new
NamedThreadFactory("DubboRegistryFailedRetryTimer", true));
+ final ScheduledExecutorService retryExecutor =
Executors.newScheduledThreadPool(0, new
NamedThreadFactory("DubboMetadataReportRetryTimer", true));
volatile ScheduledFuture retryScheduledFuture;
AtomicInteger retryCounter = new AtomicInteger(0);
// retry task schedule period
@@ -358,7 +358,7 @@ public abstract class AbstractMetadataReport implements
MetadataReport {
retryScheduledFuture =
retryExecutor.scheduleWithFixedDelay(new Runnable() {
@Override
public void run() {
- // Check and connect to the registry
+ // Check and connect to the metadata
try {
int times = retryCounter.incrementAndGet();
logger.info("start to retry task for
metadata report. retry times:" + times);