natas_hw
/
mps-coderules
mirror of https://github.com/JetBrains/mps-coderules
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add some more profiling blocks.

This commit is contained in:
Fedor Isakov 2019-09-28 12:58:07 +02:00
parent 38e71db7e8
commit 04164e1039
2 changed files with 47 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
reactor/Core/src/jetbrains/mps/logic/reactor/core/internal/ControllerImpl.kt
View File

@ -96,9 +96,14 @@ internal class ControllerImpl (
state.processActivated(this, occ, NORMAL())
override fun offerMatch(match: RuleMatchEx, inStatus: FeedbackStatus) : FeedbackStatus =
inStatus.then { checkMatchPreconditions(match, it) }
.also { trace.trying(match) }
.then { processGuard(match, it) }
profiler.profile<FeedbackStatus>("offerMatch") {
inStatus
.then { checkMatchPreconditions(match, it) }
.also { trace.trying(match) }
.then { processGuard(match, it) }
}
private fun checkMatchPreconditions(match: RuleMatchEx, inStatus: FeedbackStatus) : FeedbackStatus {
val context = Context(inStatus, match.logicalContext(), match.rule().uniqueTag(), trace)

53
reactor/Core/src/jetbrains/mps/logic/reactor/core/internal/ProcessingStateImpl.kt
View File

@ -229,7 +229,12 @@ internal class ProcessingStateImpl(private var dispatchingFront: Dispatcher.Disp
trace.reactivate(active)
}
this.dispatchingFront = dispatchingFront.expand(active)
profiler.profile("dispatch_${active.constraint().symbol()}") {
this.dispatchingFront = dispatchingFront.expand(active)
}
val matches = dispatchingFront.matches().toList()
val newCurrentMatches =
@ -264,21 +269,41 @@ internal class ProcessingStateImpl(private var dispatchingFront: Dispatcher.Disp
if (operational) action(this) else this
private fun processMatch(controller: Controller, match: RuleMatchEx, inStatus: FeedbackStatus) : FeedbackStatus =
controller.offerMatch(match, inStatus)
.let { when (it) {
is FeedbackStatus.ABORTED -> { // guard is not satisfied
trace.reject(match)
return it.recover() // return from the enclosing method
profiler.profile<FeedbackStatus>("processMatch") {
} is FeedbackStatus.FAILED -> { // guard failed
return it.recover() // return from the enclosing method
controller.offerMatch(match, inStatus)
.let {
when (it) {
is FeedbackStatus.ABORTED -> { // guard is not satisfied
trace.reject(match)
return it.recover() // return from the enclosing method
} else -> it
} }
.also { trace.trigger(match) }
.also { accept(controller, match) }
.then { controller.processBody(match, it) }
.also { trace.finish(match) }
}
is FeedbackStatus.FAILED -> { // guard failed
return it.recover() // return from the enclosing method
}
else -> it
}
}
.also { trace.trigger(match) }
.also {
profiler.profile("accept") {
accept(controller, match)
}
}
.then {
profiler.profile<FeedbackStatus>("processBody") {
controller.processBody(match, it)
}
}
.also { trace.finish(match) }
}
private fun accept(controller: Controller, match: RuleMatchEx) {