Skip to content
This repository was archived by the owner on Aug 7, 2025. It is now read-only.

Commit 876120c

Browse files
author
Naman Nandan
committed
refactor access specifiers
1 parent e0b4e48 commit 876120c

File tree

2 files changed

+7
-8
lines changed

2 files changed

+7
-8
lines changed

frontend/server/src/main/java/org/pytorch/serve/metrics/MetricCollector.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,12 @@
2020
public class MetricCollector implements Runnable {
2121

2222
private static final Logger logger = LoggerFactory.getLogger(MetricCollector.class);
23+
24+
private static final MetricCache METRIC_CACHE = MetricCache.getInstance();
2325
private ConfigManager configManager;
24-
private MetricCache metricCache;
2526

2627
public MetricCollector(ConfigManager configManager) {
2728
this.configManager = configManager;
28-
this.metricCache = MetricCache.getInstance();
2929
}
3030

3131
@Override
@@ -79,15 +79,15 @@ public void run() {
7979
if (metric == null) {
8080
logger.warn("Parse metrics failed: " + line);
8181
} else {
82-
if (this.metricCache.getMetricFrontend(metric.getMetricName()) != null) {
82+
if (METRIC_CACHE.getMetricFrontend(metric.getMetricName()) != null) {
8383
try {
8484
List<String> dimensionValues = new ArrayList<String>();
8585
for (Dimension dimension : metric.getDimensions()) {
8686
dimensionValues.add(dimension.getValue());
8787
}
8888
// Frontend metrics by default have the last dimension as hostname
8989
dimensionValues.add(metric.getHostName());
90-
this.metricCache
90+
METRIC_CACHE
9191
.getMetricFrontend(metric.getMetricName())
9292
.addOrUpdate(
9393
dimensionValues,

frontend/server/src/main/java/org/pytorch/serve/wlm/WorkerLifeCycle.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -238,7 +238,7 @@ private static final class ReaderThread extends Thread {
238238
Pattern.compile("^(INFO > )?(\\[PID])(\\d+)$");
239239
private static final Logger loggerModelOutput =
240240
LoggerFactory.getLogger(ConfigManager.MODEL_LOGGER);
241-
private final MetricCache metricCache;
241+
private static final MetricCache METRIC_CACHE = MetricCache.getInstance();
242242
private InputStream is;
243243
private boolean error;
244244
private WorkerLifeCycle lifeCycle;
@@ -249,7 +249,6 @@ public ReaderThread(String name, InputStream is, boolean error, WorkerLifeCycle
249249
this.is = is;
250250
this.error = error;
251251
this.lifeCycle = lifeCycle;
252-
this.metricCache = MetricCache.getInstance();
253252
}
254253

255254
public void terminate() {
@@ -270,14 +269,14 @@ public void run() {
270269
logger.info("result={}, pattern={}", result, matcher.group(2));
271270
Metric parsedMetric = Metric.parse(matcher.group(3));
272271
if (parsedMetric != null) {
273-
if (this.metricCache.getMetricBackend(parsedMetric.getMetricName())
272+
if (METRIC_CACHE.getMetricBackend(parsedMetric.getMetricName())
274273
!= null) {
275274
try {
276275
List<String> dimensionValues = new ArrayList<String>();
277276
for (Dimension dimension : parsedMetric.getDimensions()) {
278277
dimensionValues.add(dimension.getValue());
279278
}
280-
this.metricCache
279+
METRIC_CACHE
281280
.getMetricBackend(parsedMetric.getMetricName())
282281
.addOrUpdate(
283282
dimensionValues,

0 commit comments

Comments
 (0)