correct typos

This commit is contained in:
Francis Dong
2021-01-19 17:17:45 +08:00
committed by hongqiaowei
parent 2b61771f11
commit f4132c8207
3 changed files with 10 additions and 11 deletions

View File

@@ -32,7 +32,6 @@ import java.util.concurrent.locks.ReentrantReadWriteLock;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import we.stats.BlockType;
import we.util.Utils;
/**

View File

@@ -71,7 +71,7 @@ public class ResourceStat {
return timeSlots.get(timeSlotId);
} else {
TimeSlot timeSlot = new TimeSlot(timeSlotId);
timeSlot.setPeakConcurrentReqeusts(this.concurrentRequests.get());
timeSlot.setPeakConcurrentRequests(this.concurrentRequests.get());
TimeSlot old = timeSlots.putIfAbsent(timeSlotId, timeSlot);
if (old != null) {
return old;
@@ -203,8 +203,8 @@ public class ResourceStat {
TimeSlot timeSlot = timeSlots.get(i);
min = timeSlot.getMin() < min ? timeSlot.getMin() : min;
max = timeSlot.getMax() > max ? timeSlot.getMax() : max;
peakConcurrences = timeSlot.getPeakConcurrentReqeusts() > peakConcurrences
? timeSlot.getPeakConcurrentReqeusts()
peakConcurrences = timeSlot.getPeakConcurrentRequests() > peakConcurrences
? timeSlot.getPeakConcurrentRequests()
: peakConcurrences;
totalReqs = totalReqs + timeSlot.getCounter().get();
totalRt = totalRt + timeSlot.getTotalRt().get();

View File

@@ -64,7 +64,7 @@ public class TimeSlot {
/**
* Peak concurrent requests
*/
private long peakConcurrentReqeusts;
private long peakConcurrentRequests;
/**
* Block requests <br/>
@@ -109,8 +109,8 @@ public class TimeSlot {
* @param concurrentRequests Current concurrent requests
*/
public synchronized void updatePeakConcurrentReqeusts(long concurrentRequests) {
peakConcurrentReqeusts = concurrentRequests > peakConcurrentReqeusts ? concurrentRequests
: peakConcurrentReqeusts;
peakConcurrentRequests = concurrentRequests > peakConcurrentRequests ? concurrentRequests
: peakConcurrentRequests;
}
public void setId(long id) {
@@ -149,12 +149,12 @@ public class TimeSlot {
this.totalRt = totalRt;
}
public long getPeakConcurrentReqeusts() {
return peakConcurrentReqeusts;
public long getPeakConcurrentRequests() {
return peakConcurrentRequests;
}
public void setPeakConcurrentReqeusts(long peakConcurrentReqeusts) {
this.peakConcurrentReqeusts = peakConcurrentReqeusts;
public void setPeakConcurrentRequests(long peakConcurrentRequests) {
this.peakConcurrentRequests = peakConcurrentRequests;
}
public AtomicLong getErrors() {