TraceSource.ts
188 lines
| 4.4 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r9 | import * as format from '../text/format' | ||
|
cin
|
r10 | import { argumentNotNull } from '../safe'; | ||
|
cin
|
r23 | import { Observable } from '../Observable' | ||
|
cin
|
r14 | import { IDestroyable } from '../interfaces'; | ||
|
cin
|
r22 | |||
| export const DebugLevel = 400; | ||||
| export const LogLevel = 300; | ||||
| export const WarnLevel = 200; | ||||
| export const ErrorLevel = 100; | ||||
| export const SilentLevel = 0; | ||||
| export class TraceEvent { | ||||
| readonly source: TraceSource; | ||||
| readonly level: Number; | ||||
| readonly arg: any; | ||||
| constructor(source: TraceSource, level: Number, arg: any) { | ||||
| this.source = source; | ||||
| this.level = level; | ||||
| this.arg = arg; | ||||
| } | ||||
| } | ||||
|
cin
|
r9 | |||
|
cin
|
r10 | class Registry { | ||
| static readonly instance = new Registry(); | ||||
| private _registry: object = new Object(); | ||||
| private _listeners: object = new Object(); | ||||
| private _nextCookie: number = 1; | ||||
|
cin
|
r9 | |||
|
cin
|
r10 | get(id: any): TraceSource { | ||
| argumentNotNull(id, "id"); | ||||
| if (this._registry[id]) | ||||
| return this._registry[id]; | ||||
|
cin
|
r9 | |||
|
cin
|
r10 | var source = new TraceSource(id); | ||
| this._registry[id] = source; | ||||
| this._onNewSource(source); | ||||
| return source; | ||||
|
cin
|
r9 | } | ||
|
cin
|
r10 | add(id: any, source: TraceSource) { | ||
| argumentNotNull(id, "id"); | ||||
| argumentNotNull(source, "source"); | ||||
| this._registry[id] = source; | ||||
| this._onNewSource(source); | ||||
| } | ||||
| _onNewSource(source: TraceSource) { | ||||
| for (let i in this._listeners) | ||||
| this._listeners[i].call(null, source); | ||||
| } | ||||
|
cin
|
r14 | on(handler: (source: TraceSource) => void): IDestroyable { | ||
|
cin
|
r10 | argumentNotNull(handler, "handler"); | ||
| var me = this; | ||||
| var cookie = this._nextCookie++; | ||||
| this._listeners[cookie] = handler; | ||||
| for (let i in this._registry) | ||||
| handler(this._registry[i]); | ||||
| return { | ||||
| destroy() { | ||||
| delete me._listeners[cookie]; | ||||
| } | ||||
| }; | ||||
|
cin
|
r9 | } | ||
| } | ||||
|
cin
|
r22 | export class TraceSource { | ||
|
cin
|
r9 | readonly id: any | ||
| level: number | ||||
|
cin
|
r22 | readonly events: Observable<TraceEvent> | ||
| _notifyNext: (arg: TraceEvent) => void | ||||
|
cin
|
r9 | constructor(id: any) { | ||
|
cin
|
r22 | |||
|
cin
|
r9 | this.id = id || new Object(); | ||
|
cin
|
r22 | this.events = new Observable((next) => { | ||
| this._notifyNext = next; | ||||
| }) | ||||
|
cin
|
r9 | } | ||
|
cin
|
r10 | protected emit(level: number, arg: any) { | ||
|
cin
|
r15 | this._notifyNext(new TraceEvent(this, level, arg)); | ||
|
cin
|
r9 | } | ||
| isDebugEnabled() { | ||||
|
cin
|
r22 | return this.level >= DebugLevel; | ||
|
cin
|
r9 | } | ||
|
cin
|
r10 | debug(msg: string, ...args: any[]) { | ||
|
cin
|
r22 | if (this.isEnabled(DebugLevel)) | ||
|
cin
|
r35 | this.emit(DebugLevel, format.apply(null, arguments)); | ||
|
cin
|
r9 | } | ||
| isLogEnabled() { | ||||
|
cin
|
r22 | return this.level >= LogLevel; | ||
|
cin
|
r9 | } | ||
|
cin
|
r10 | log(msg: string, ...args: any[]) { | ||
|
cin
|
r22 | if (this.isEnabled(LogLevel)) | ||
|
cin
|
r35 | this.emit(LogLevel, format.apply(null, arguments)); | ||
|
cin
|
r9 | } | ||
| isWarnEnabled() { | ||||
|
cin
|
r22 | return this.level >= WarnLevel; | ||
|
cin
|
r9 | } | ||
|
cin
|
r10 | warn(msg: string, ...args: any[]) { | ||
|
cin
|
r22 | if (this.isEnabled(WarnLevel)) | ||
|
cin
|
r35 | this.emit(WarnLevel, format.apply(null, arguments)); | ||
|
cin
|
r9 | } | ||
|
cin
|
r12 | /** | ||
| * returns true if errors will be recorded. | ||||
| */ | ||||
|
cin
|
r9 | isErrorEnabled() { | ||
|
cin
|
r22 | return this.level >= ErrorLevel; | ||
|
cin
|
r9 | } | ||
|
cin
|
r12 | /** | ||
| * Traces a error. | ||||
| * | ||||
| * @param msg the message. | ||||
| * @param args parameters which will be substituted in the message. | ||||
| */ | ||||
|
cin
|
r10 | error(msg: string, ...args: any[]) { | ||
|
cin
|
r22 | if (this.isEnabled(ErrorLevel)) | ||
|
cin
|
r35 | this.emit(ErrorLevel, format.apply(null, arguments)); | ||
|
cin
|
r10 | } | ||
|
cin
|
r12 | /** | ||
| * Checks whether the specified level is enabled for this | ||||
| * trace source. | ||||
| * | ||||
| * @param level the trace level which should be checked. | ||||
| */ | ||||
|
cin
|
r10 | isEnabled(level: number) { | ||
| return (this.level >= level); | ||||
| } | ||||
|
cin
|
r12 | /** | ||
| * Traces a raw event, passing data as it is to the underlying listeners | ||||
| * | ||||
| * @param level the level of the event | ||||
| * @param arg the data of the event, can be a simple string or any object. | ||||
| */ | ||||
|
cin
|
r10 | traceEvent(level: number, arg: any) { | ||
| if (this.isEnabled(level)) | ||||
| this.emit(level, arg); | ||||
| } | ||||
|
cin
|
r12 | /** | ||
| * Register the specified handler to be called for every new and already | ||||
| * created trace source. | ||||
| * | ||||
| * @param handler the handler which will be called for each trace source | ||||
| */ | ||||
|
cin
|
r14 | static on(handler: (source: TraceSource) => void) { | ||
|
cin
|
r11 | return Registry.instance.on(handler); | ||
|
cin
|
r10 | } | ||
|
cin
|
r12 | /** | ||
| * Creates or returns already created trace source for the specified id. | ||||
| * | ||||
| * @param id the id for the trace source | ||||
| */ | ||||
|
cin
|
r10 | static get(id: any) { | ||
| return Registry.instance.get(id); | ||||
|
cin
|
r9 | } | ||
| } | ||||