| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -30,24 +30,24 @@ matrix: | |||
| 30 | 30 | packages: | |
| 31 | 31 | - g++-6 | |
| 32 | 32 | env: COMPILER=g++-6 | |
| 33 | - # - compiler: clang | ||
| 34 | - # addons: | ||
| 35 | - # apt: | ||
| 36 | - # sources: | ||
| 37 | - # - ubuntu-toolchain-r-test | ||
| 38 | - # - llvm-toolchain-precise-3.6 | ||
| 39 | - # packages: | ||
| 40 | - # - clang-3.6 | ||
| 41 | - # env: COMPILER=clang++-3.6 | ||
| 42 | - # - compiler: clang | ||
| 43 | - # addons: | ||
| 44 | - # apt: | ||
| 45 | - # sources: | ||
| 46 | - # - ubuntu-toolchain-r-test | ||
| 47 | - # - llvm-toolchain-precise-3.7 | ||
| 48 | - # packages: | ||
| 49 | - # - clang-3.7 | ||
| 50 | - # env: COMPILER=clang++-3.7 | ||
| 33 | + - compiler: clang | ||
| 34 | + addons: | ||
| 35 | + apt: | ||
| 36 | + sources: | ||
| 37 | + - ubuntu-toolchain-r-test | ||
| 38 | + - llvm-toolchain-precise-3.7 | ||
| 39 | + packages: | ||
| 40 | + - clang-3.7 | ||
| 41 | + env: COMPILER=clang++-3.7 | ||
| 42 | + - compiler: clang | ||
| 43 | + addons: | ||
| 44 | + apt: | ||
| 45 | + sources: | ||
| 46 | + - ubuntu-toolchain-r-test | ||
| 47 | + - llvm-toolchain-precise-3.8 | ||
| 48 | + packages: | ||
| 49 | + - clang-3.8 | ||
| 50 | + env: COMPILER=clang++-3.8 | ||
| 51 | 51 | ||
| 52 | 52 | before_install: | |
| 53 | 53 | - if [ "$TRAVIS_OS_NAME" == "linux" ]; then | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -25,12 +25,12 @@ namespace PerfTests | |||
| 25 | 25 | const auto expectedCount = m_myRunnable->sequence->value() + m_iterations; | |
| 26 | 26 | m_myRunnable->reset(latch, expectedCount); | |
| 27 | 27 | ||
| 28 | - auto consumerTask = m_taskScheduler->scheduleAndStart(std::move(std::packaged_task< void() >([this] { m_myRunnable->run(); }))); | ||
| 28 | + auto consumerTask = m_taskScheduler->scheduleAndStart(std::packaged_task< void() >([this] { m_myRunnable->run(); })); | ||
| 29 | 29 | stopwatch.start(); | |
| 30 | 30 | ||
| 31 | 31 | auto sequencer = m_sequencer; | |
| 32 | 32 | ||
| 33 | - auto producerTask = m_taskScheduler->scheduleAndStart(std::move(std::packaged_task< void() >([this, sequencer, latch] | ||
| 33 | + auto producerTask = m_taskScheduler->scheduleAndStart(std::packaged_task< void() >([this, sequencer, latch] | ||
| 34 | 34 | { | |
| 35 | 35 | auto& s = *sequencer; | |
| 36 | 36 | for (std::int64_t i = 0; i < m_iterations; ++i) | |
@@ -40,7 +40,7 @@ namespace PerfTests | |||
| 40 | 40 | } | |
| 41 | 41 | ||
| 42 | 42 | latch->waitOne(); | |
| 43 | - }))); | ||
| 43 | + })); | ||
| 44 | 44 | ||
| 45 | 45 | producerTask.wait(); | |
| 46 | 46 | stopwatch.stop(); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -58,7 +58,7 @@ namespace PerfTests | |||
| 58 | 58 | for (auto i = 0; i < m_numEventProcessors; ++i) | |
| 59 | 59 | { | |
| 60 | 60 | m_handlers[i]->reset(latch, m_batchEventProcessors[i]->sequence()->value() + m_iterations); | |
| 61 | - processorTasks.push_back(std::move(m_executor->execute([this, i] { m_batchEventProcessors[i]->run(); }))); | ||
| 61 | + processorTasks.push_back(m_executor->execute([this, i] { m_batchEventProcessors[i]->run(); })); | ||
| 62 | 62 | } | |
| 63 | 63 | ||
| 64 | 64 | auto& rb = *m_ringBuffer; | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -79,7 +79,6 @@ namespace PerfTests | |||
| 79 | 79 | { | |
| 80 | 80 | auto t1 = Stopwatch::getTimestamp(); | |
| 81 | 81 | ||
| 82 | - auto nano = std::chrono::nanoseconds(t1 - m_t0); | ||
| 83 | 82 | m_latencyRecorder->record(LatencyTestSession::convertStopwatchTicksToNano((double)(t1 - m_t0))); | |
| 84 | 83 | ||
| 85 | 84 | if (data.value < m_maxEvents) | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -38,9 +38,9 @@ namespace PerfTests | |||
| 38 | 38 | for (auto i = 0; i < m_numPublishers; ++i) | |
| 39 | 39 | { | |
| 40 | 40 | auto index = i; | |
| 41 | - futures[i] = m_scheduler->scheduleAndStart(std::move(std::packaged_task< void() >([this, index] { m_valuePublishers[index](m_cyclicBarrier, m_ringBuffer, m_iterations); }))); | ||
| 41 | + futures[i] = m_scheduler->scheduleAndStart(std::packaged_task< void() >([this, index] { m_valuePublishers[index](m_cyclicBarrier, m_ringBuffer, m_iterations); })); | ||
| 42 | 42 | } | |
| 43 | - auto processorTask = m_scheduler->scheduleAndStart(std::move(std::packaged_task< void() >([this] { m_batchEventProcessor->run(); }))); | ||
| 43 | + auto processorTask = m_scheduler->scheduleAndStart(std::packaged_task< void() >([this] { m_batchEventProcessor->run(); })); | ||
| 44 | 44 | ||
| 45 | 45 | stopwatch.start(); | |
| 46 | 46 | m_cyclicBarrier->signal(); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -35,7 +35,7 @@ namespace PerfTests | |||
| 35 | 35 | for (auto i = 0; i < m_numPublishers; ++i) | |
| 36 | 36 | { | |
| 37 | 37 | auto index = i; | |
| 38 | - futures[i] = std::move(std::async(std::launch::async, [this, index] { m_valuePublishers[index]->run(); })); | ||
| 38 | + futures[i] = std::async(std::launch::async, [this, index] { m_valuePublishers[index]->run(); }); | ||
| 39 | 39 | } | |
| 40 | 40 | ||
| 41 | 41 | for (auto&& processor : m_workProcessors) | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -15,8 +15,7 @@ namespace Tests | |||
| 15 | 15 | { | |
| 16 | 16 | struct Translator : public IEventTranslator< LongEvent > | |
| 17 | 17 | { | |
| 18 | - explicit Translator(EventPublisherFixture& fixture) | ||
| 19 | - : m_fixture(fixture) | ||
| 18 | + explicit Translator(EventPublisherFixture&) | ||
| 20 | 19 | { | |
| 21 | 20 | } | |
| 22 | 21 | ||
@@ -25,8 +24,6 @@ namespace Tests | |||
| 25 | 24 | eventData.value = sequence + 29; | |
| 26 | 25 | } | |
| 27 | 26 | ||
| 28 | - private: | ||
| 29 | - EventPublisherFixture& m_fixture; | ||
| 30 | 27 | }; | |
| 31 | 28 | ||
| 32 | 29 | EventPublisherFixture() | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -16,10 +16,10 @@ namespace Tests | |||
| 16 | 16 | if (!m_ignoreExecutions) | |
| 17 | 17 | { | |
| 18 | 18 | std::packaged_task< void() > task(command); | |
| 19 | - result = std::move(task.get_future()); | ||
| 19 | + result = task.get_future(); | ||
| 20 | 20 | ||
| 21 | 21 | std::lock_guard< decltype(m_mutex) > lock(m_mutex); | |
| 22 | - m_threads.push_back(std::move(boost::thread(std::move(task)))); | ||
| 22 | + m_threads.push_back(boost::thread(std::move(task))); | ||
| 23 | 23 | } | |
| 24 | 24 | ||
| 25 | 25 | return result; | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -539,7 +539,7 @@ namespace Disruptor | |||
| 539 | 539 | if (batchStartsAt + batchSize > argumentCount) | |
| 540 | 540 | { | |
| 541 | 541 | DISRUPTOR_THROW_ARGUMENT_EXCEPTION("A batchSize of: " << batchSize << | |
| 542 | - " with batchStartsAt of: " + batchStartsAt << | ||
| 542 | + " with batchStartsAt of: " << batchStartsAt << | ||
| 543 | 543 | " will overrun the available number of arguments: " << (argumentCount - batchStartsAt)); | |
| 544 | 544 | } | |
| 545 | 545 | } | |
| Back | FazBrowse Home | New Git URL |
0 commit comments