Skip to content

Commit 7a52758

Browse files
committed
Fixed some errors and warnings on GCC/clang.
1 parent c897cbd commit 7a52758

3 files changed

Lines changed: 3 additions & 6 deletions

File tree

benchmarks/src/BenchmarkRandom.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414
#include "BenchmarkBase.h"
1515
#include "react/common/Types.h"
1616

17+
#include "react/Domain.h"
1718
#include "react/Signal.h"
1819

1920
using namespace react;

include/react/common/Concurrency.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff 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>

include/react/detail/ReactiveInput.h

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff 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

0 commit comments

Comments
 (0)