|
@@ -13,18 +13,28 @@ export default class EventsManager extends EventEmitter {
|
|
|
|
|
|
remove(traceId, code, signal, needDelete)
|
|
remove(traceId, code, signal, needDelete)
|
|
{
|
|
{
|
|
- if (this.specialEvents.has(traceId) && !needDelete && code === Codes.Success) return;
|
|
|
|
|
|
+ // if (this.specialEvents.has(traceId) && !needDelete && code === Codes.Success) return;
|
|
|
|
|
|
- this.events.get(traceId) && (
|
|
|
|
- this.emit(traceId, {code, data:signal}),
|
|
|
|
- this.events.delete(traceId),
|
|
|
|
- this.specialEvents.delete(traceId)
|
|
|
|
|
|
+ // this.events.get(traceId) && (
|
|
|
|
+ // this.emit(traceId, {code, data:signal}),
|
|
|
|
+ // this.events.delete(traceId),
|
|
|
|
+ // this.specialEvents.delete(traceId)
|
|
|
|
+ // )
|
|
|
|
+
|
|
|
|
+ // todo 写死数据纠正
|
|
|
|
+ if (this.specialEvents.has(this.traceId) && !needDelete && code === Codes.Success) return;
|
|
|
|
+
|
|
|
|
+ this.events.get(this.traceId) && (
|
|
|
|
+ this.emit(this.traceId, {code, data:signal}),
|
|
|
|
+ this.events.delete(this.traceId),
|
|
|
|
+ this.specialEvents.delete(this.traceId)
|
|
)
|
|
)
|
|
}
|
|
}
|
|
|
|
|
|
async track(e, t)
|
|
async track(e, t)
|
|
{
|
|
{
|
|
const traceId = e.traceId;
|
|
const traceId = e.traceId;
|
|
|
|
+ this.traceId = traceId // todo 写死数据纠正
|
|
|
|
|
|
this.emitTraceIdToDecoder(e);
|
|
this.emitTraceIdToDecoder(e);
|
|
|
|
|