File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1414#include " BenchmarkBase.h"
1515#include " react/common/Types.h"
1616
17+ #include " react/Domain.h"
1718#include " react/Signal.h"
1819
1920using namespace react ;
Original file line number Diff line number Diff line change @@ -86,7 +86,7 @@ class WaitingStateBase : public IWaitingState
8686 auto Run (F&& func) -> decltype(func(false ))
8787 {// mutex_
8888 std::lock_guard<std::mutex> scopedLock (mutex_);
89- return func (blocked_ );
89+ return func (isWaiting_ );
9090 }// ~mutex_
9191
9292 template <typename F>
Original file line number Diff line number Diff line change @@ -692,8 +692,6 @@ class InputManager :
692692 void processAsyncQueue ()
693693 {
694694 AsyncItem item;
695-
696- TurnFlagsT savedFlags = 0 ;
697695
698696 std::vector<WaitingStatePtrT> waitingStatePtrs;
699697
@@ -732,13 +730,11 @@ class InputManager :
732730 item.Func ();
733731
734732 // Merged sync inputs that arrived while this item was queued
735- // Commented out, because thats no longer possible
736- // tr.RunMergedInputs();
733+ tr.RunMergedInputs ();
737734
738735 // Save data, item might be re-used for next input
739736 if (item.WaitingStatePtr != nullptr )
740737 waitingStatePtrs.push_back (std::move (item.WaitingStatePtr ));
741- savedFlags = item.Flags ;
742738
743739 // If the current item supports merging, try to add more mergeable inputs
744740 // to this turn
You can’t perform that action at this time.
0 commit comments