mirror of
https://github.com/actiontech/dble.git
synced 2026-05-03 21:10:31 -05:00
[inner-2313] not record 'exit'
This commit is contained in:
@@ -143,12 +143,7 @@ public class RwTraceResult implements Cloneable {
|
||||
}
|
||||
}
|
||||
|
||||
public void setExit(long time) {
|
||||
long timeMs = System.currentTimeMillis();
|
||||
StatisticFrontendSqlEntry f = new StatisticFrontendSqlEntry(frontendInfo, time, timeMs,
|
||||
null, "exit", currentSession.getService().getTxId(), 0, 0,
|
||||
0, 0, time, timeMs);
|
||||
StatisticManager.getInstance().push(f);
|
||||
public void setExit() {
|
||||
reset();
|
||||
frontendInfo = null;
|
||||
}
|
||||
|
||||
@@ -65,7 +65,7 @@ public class RwTrackProbe extends AbstractTrackProbe {
|
||||
}
|
||||
|
||||
public void setExit() {
|
||||
sqlTracking(t -> t.setExit(System.nanoTime()));
|
||||
sqlTracking(t -> t.setExit());
|
||||
}
|
||||
|
||||
private void sqlTracking(Consumer<RwTraceResult> consumer) {
|
||||
|
||||
@@ -260,12 +260,7 @@ public class TraceResult implements Cloneable {
|
||||
}
|
||||
}
|
||||
|
||||
public void setExit(long time) {
|
||||
long timeMs = System.currentTimeMillis();
|
||||
StatisticFrontendSqlEntry f = new StatisticFrontendSqlEntry(frontendInfo, time, timeMs,
|
||||
null, "exit", currentSession.getShardingService().getTxId(), 0, 0,
|
||||
0, 0, time, timeMs);
|
||||
StatisticManager.getInstance().push(f);
|
||||
public void setExit() {
|
||||
reset();
|
||||
previous = null;
|
||||
frontendInfo = null;
|
||||
|
||||
@@ -162,7 +162,7 @@ public class TrackProbe extends AbstractTrackProbe {
|
||||
}
|
||||
|
||||
public void setExit() {
|
||||
sqlTracking(t -> t.setExit(System.nanoTime()));
|
||||
sqlTracking(t -> t.setExit());
|
||||
}
|
||||
|
||||
public void setBeginCommitTime() {
|
||||
|
||||
Reference in New Issue
Block a user