-
Notifications
You must be signed in to change notification settings - Fork 53
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Complete rewrite with the following new features and fixes: - system-wide tracing - statistics contain process tree - fixed missing paths in the FileIO events - added registry handler for recording Windows Registry events (not enabled by default) - advanced filtering and an option to use only the selected set of event handlers
- Loading branch information
1 parent
f6308d9
commit c05ef43
Showing
71 changed files
with
6,351 additions
and
3,990 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -245,3 +245,5 @@ ModelManifest.xml | |
|
|
||
| # FAKE - F# Make | ||
| .fake/ | ||
|
|
||
| launchSettings.json | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Binary file not shown.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,33 @@ | ||
| module LowLevelDesign.WTrace.CommandLine | ||
|
|
||
| open System.Text.RegularExpressions | ||
|
|
||
| // from http://fssnip.net/8g/title/Yet-another-commandline-parser by Gennady Loskutov | ||
| // with my modifications | ||
|
|
||
| // parse command using regex | ||
| // if matched, return (command name, command value) as a tuple | ||
| let (|Command|_|) (s : string) = | ||
| let r = new Regex(@"^(?:-{1,2}|\/)(?<command>\?|\w+)[=:]*(?<value>.*)$", RegexOptions.IgnoreCase) | ||
| let m = r.Match(s) | ||
| if m.Success then Some (m.Groups.["command"].Value.ToLower(), m.Groups.["value"].Value) | ||
| else None | ||
|
|
||
| let parseArgs (flags : seq<string>) (args : seq<string>) = | ||
| args | ||
| |> Seq.scan (fun (sn : string, sv) arg -> | ||
| match arg with | ||
| | Command (n, v) when sn.Length <> 0 -> | ||
| // parse the command only if it's a command and we haven't | ||
| // passed the first free argument | ||
| if v.Length = 0 && flags |> Seq.contains(n) then | ||
| (n, "<flag>") // flag | ||
| elif n.Length = 0 then (sn, v) | ||
| else (n, v) | ||
| | v when sn.Length <> 0 && sv.Length <> 0 -> ("", v) | ||
| | v -> (sn, v)) ("<empty>", "<empty>") | ||
| |> Seq.skip 1 | ||
| |> Seq.groupBy (fun (n, _) -> n) | ||
| |> Seq.map (fun (n, s) -> (n, s |> Seq.map (fun (_, v) -> v) |> Seq.filter (fun i -> i.Length > 0) |> Seq.toList)) | ||
| |> Map.ofSeq | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,97 @@ | ||
| [<AutoOpen>] | ||
| module LowLevelDesign.WTrace.Globals | ||
|
|
||
| open System | ||
| open System.Diagnostics | ||
| open System.Reactive.Linq | ||
| open System.Runtime.CompilerServices | ||
|
|
||
| [<assembly: InternalsVisibleTo("wtrace.tests")>] do () | ||
|
|
||
| (* Constants *) | ||
|
|
||
| // The timeout for buffered observable - maximum amount of time that | ||
| // the buffered observable will wait for events | ||
| let eventBufferedObservableTimeout = TimeSpan.FromSeconds(0.5) | ||
|
|
||
| [<Literal>] | ||
| let invalidEventId = Int32.MinValue | ||
|
|
||
| (* Type aliases *) | ||
|
|
||
| type Debug = System.Diagnostics.Debug | ||
| type RxDisposable = System.Reactive.Disposables.Disposable | ||
|
|
||
| (* Class extensions *) | ||
|
|
||
| type TraceSource with | ||
| member this.TraceError (ex : Exception) = | ||
| this.TraceEvent(TraceEventType.Error, 0, ex.ToString()) | ||
|
|
||
| member this.TraceErrorMessage (msg) = | ||
| this.TraceEvent(TraceEventType.Error, 0, msg) | ||
|
|
||
| member this.TraceErrorWithMessage (msg, ex : Exception) = | ||
| this.TraceEvent(TraceEventType.Error, 0, sprintf "%s\nDETAILS: %s" msg (ex.ToString())) | ||
|
|
||
| member this.TraceWarning msg = | ||
| this.TraceEvent(TraceEventType.Warning, 0, msg) | ||
|
|
||
| member this.TraceWarningWithMessage (msg, ex : Exception) = | ||
| this.TraceEvent(TraceEventType.Error, 0, sprintf "%s\nDETAILS: %s" msg (ex.ToString())) | ||
|
|
||
| member this.TraceVerbose msg = | ||
| this.TraceEvent(TraceEventType.Verbose, 0, msg) | ||
|
|
||
|
|
||
| type Observable with | ||
| /// Creates an observable sequence from the specified Subscribe method implementation. | ||
| static member CreateEx (subscribe: IObserver<'T> -> unit -> unit) = | ||
| let subscribe o = | ||
| let m = subscribe o | ||
| Action(m) | ||
| Observable.Create(subscribe) | ||
|
|
||
| module ObservableEx = | ||
|
|
||
| let choose f source = | ||
| Observable.Create (fun (o : IObserver<_>) -> | ||
| FSharp.Control.Reactive.Observable.subscribeSafeWithCallbacks | ||
| (fun x -> ValueOption.iter o.OnNext (try f x with ex -> o.OnError ex; ValueNone)) | ||
| o.OnError | ||
| o.OnCompleted | ||
| source) | ||
|
|
||
| (* Operators and comp expressions *) | ||
|
|
||
| let result = ResultBuilder() | ||
|
|
||
| let (|?) lhs rhs = (if lhs = null then rhs else lhs) | ||
|
|
||
| let (===) a b = String.Equals(a, b, StringComparison.Ordinal) | ||
|
|
||
| let (>=<) a b = String.Equals(a, b, StringComparison.OrdinalIgnoreCase) | ||
|
|
||
| (* Global loggers *) | ||
|
|
||
| module Logger = | ||
|
|
||
| let Main = TraceSource("WTrace") | ||
| let Tracing = TraceSource("WTrace.Tracing") | ||
| let EtwTracing = TraceSource("WTrace.ETW.Tracing") | ||
| let EtwEvents = TraceSource("WTrace.ETW.Events") | ||
|
|
||
|
|
||
| module private H = | ||
|
|
||
| let all = [| Main; Tracing; EtwTracing; EtwEvents |] | ||
|
|
||
| do | ||
| // remove the default logger - it's heavy | ||
| H.all |> Seq.iter (fun s -> s.Listeners.Remove("Default")) | ||
|
|
||
| let initialize (level : SourceLevels, listeners : list<TraceListener>) = | ||
| H.all |> Seq.iter (fun s -> | ||
| s.Switch.Level <- level | ||
| listeners |> Seq.iter (s.Listeners.Add >> ignore)) | ||
|
|
Oops, something went wrong.