REDACTED-rig/src/workers/MultiWorker.cpp

/* XMRig
 * Copyright 2010      Jeff Garzik <jgarzik@pobox.com>
 * Copyright 2012-2014 pooler      <pooler@litecoinpool.org>
 * Copyright 2014      Lucas Jones <https://github.com/lucasjones>
 * Copyright 2014-2016 Wolf9466    <https://github.com/OhGodAPet>
 * Copyright 2016      Jay D Dee   <jayddee246@gmail.com>
 * Copyright 2016-2017 XMRig       <support@xmrig.com>
 * Copyright 2018      Sebastian Stolzenberg <https://github.com/sebastianstolzenberg>
 *
 *
 *   This program is free software: you can redistribute it and/or modify
 *   it under the terms of the GNU General Public License as published by
 *   the Free Software Foundation, either version 3 of the License, or
 *   (at your option) any later version.
 *
 *   This program is distributed in the hope that it will be useful,
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 *   GNU General Public License for more details.
 *
 *   You should have received a copy of the GNU General Public License
 *   along with this program. If not, see <http://www.gnu.org/licenses/>.
 */


#include <thread>
#include <log/Log.h>


#include "crypto/CryptoNight.h"
#include "workers/MultiWorker.h"
#include "workers/Workers.h"
#include "Mem.h"


class MultiWorker : public Worker
{
public:
    explicit MultiWorker(Handle *handle, size_t hashFactor);
    ~MultiWorker();

    void start() override;

private:
    bool resume(const Job &job);
    void consumeJob();
    void save(const Job &job);

    class State;

    uint8_t* m_hash;
    State *m_state;
    State *m_pausedState;
    size_t m_hashFactor;

    ScratchPadMem scratchPadMem;
    ScratchPad* scratchPads[MAX_NUM_HASH_BLOCKS];
};

class MultiWorker::State
{
public:
  State(size_t hashMultiplier)
  {
      nonces = new uint32_t[hashMultiplier];
      blob = new uint8_t[84 * hashMultiplier];

      for(size_t i=0; i<hashMultiplier; ++i) {
          nonces[i] = 0;
      }
  }

  ~State() {
      delete[] blob;
      delete[] nonces;
  }

  Job job;
  uint32_t* nonces;
  uint8_t* blob;
};


MultiWorker::MultiWorker(Handle *handle, size_t hashFactor)
    : Worker(handle),
      m_hash(new uint8_t[32 * hashFactor]),
      m_state(new MultiWorker::State(hashFactor)),
      m_pausedState(new MultiWorker::State(hashFactor)),
      m_hashFactor(hashFactor)
{
    scratchPadMem = Mem::create(scratchPads, m_id);
}

MultiWorker::~MultiWorker()
{
    delete[] m_hash;
    delete m_state;
    delete m_pausedState;

    Mem::release(scratchPads, scratchPadMem, m_id);
}

void MultiWorker::start()
{
    const size_t memory  = scratchPadMem.realSize / 1048576;

    if (Options::i()->colors()) {
        LOG_INFO(WHITE_BOLD("Starting thread ") GREEN_BOLD("%zu/%zu") " affined to core: " GREEN_BOLD("#%d") " -> huge pages:" GREEN_BOLD(" %s%zu/%zu") " scratchpad: " CYAN_BOLD("%zu.0 MB"),
            m_id+1, Options::i()->threads(), m_affinedCpu,
                 (scratchPadMem.hugePages == scratchPadMem.pages ? "\x1B[1;32m" : (scratchPadMem.hugePages == 0 ? "\x1B[1;31m" : "\x1B[1;33m")),
                  scratchPadMem.hugePages, scratchPadMem.pages, memory);
    }
    else {
        LOG_INFO("Starting thread %zu/%zu affined to core: #%d -> huge pages: %zu/%zu scratchpad: %zu.0 MB",
                         m_id+1, Options::i()->threads(), m_affinedCpu, scratchPadMem.hugePages, scratchPadMem.pages, memory);
    }

    while (Workers::sequence() > 0) {
        if (Workers::isPaused()) {
            do {
                std::this_thread::sleep_for(std::chrono::milliseconds(200));
            }
            while (Workers::isPaused());

            if (Workers::sequence() == 0) {
                break;
            }

            consumeJob();
        }

        while (!Workers::isOutdated(m_sequence)) {
            if ((m_count & 0xF) == 0) {
                storeStats();
            }

            m_count += m_hashFactor;

            for (size_t i=0; i < m_hashFactor; ++i) {
                *Job::nonce(m_state->blob + i * m_state->job.size()) = ++m_state->nonces[i];
            }

            CryptoNight::hash(m_hashFactor, Options::i()->asmOptimization(), m_state->job.powVariant(), m_state->blob, m_state->job.size(), m_hash, scratchPads);

            for (size_t i=0; i < m_hashFactor; ++i) {
                if (*reinterpret_cast<uint64_t *>(m_hash + 24 + i * 32) < m_state->job.target()) {
                    Workers::submit(JobResult(m_state->job.poolId(), m_state->job.id(), m_state->nonces[i], m_hash + i * 32,
                                              m_state->job.diff()), m_id);
                }
            }

            std::this_thread::yield();
        }

        consumeJob();
    }
}

bool MultiWorker::resume(const Job &job)
{
    if (m_state->job.poolId() == -1 && job.poolId() >= 0 && job.id() == m_pausedState->job.id()) {
        *m_state = *m_pausedState;
        return true;
    }

    return false;
}

void MultiWorker::consumeJob()
{
    Job job = Workers::job();
    m_sequence = Workers::sequence();
    if (m_state->job == job) {
        return;
    }

    save(job);

    if (resume(job)) {
        return;
    }

    m_state->job = std::move(job);

    for (size_t i=0; i < m_hashFactor; ++i) {
        memcpy(m_state->blob + i * m_state->job.size(), m_state->job.blob(), m_state->job.size());
        if (m_state->job.isNicehash()) {
            m_state->nonces[i] = (*Job::nonce(m_state->blob + i * m_state->job.size()) & 0xff000000U) +
                                 (0xffffffU / (m_threads * Mem::hashFactor()) * (m_id + i * m_threads));
        }
        else {
            m_state->nonces[i] = std::numeric_limits<uint32_t>::max() / (m_threads *
                Mem::hashFactor()) *
                                 (m_id + i * m_threads);
        }
    }
}

void MultiWorker::save(const Job &job)
{
    if (job.poolId() == -1 && m_state->job.poolId() >= 0) {
        *m_pausedState = *m_state;
    }
}

Worker* createMultiWorker(Handle *handle, size_t hashFactor) {
    return new MultiWorker(handle, hashFactor);
}