Subversion Repositories riscv_vhdl

/**

 * @file

 * @copyright  Copyright 2016 GNSS Sensor Ltd. All right reserved.

 * @author     Sergey Khabarov - sergeykhbr@gmail.com

 * @brief      Thread interface declaration.

 */

#ifndef __DEBUGGER_ITHREAD_H__

#define __DEBUGGER_ITHREAD_H__

#include <iface.h>

#include <api_core.h>

namespace debugger {

static const char *const IFACE_THREAD = "IThread";

class IThread : public IFace {

 public:

    IThread() : IFace(IFACE_THREAD) {

        AttributeType t1;

        RISCV_generate_name(&t1);

        RISCV_event_create(&loopEnable_, t1.to_string());

        threadInit_.Handle = 0;

    }

    /** create and start seperate thread */

    virtual bool run() {

        threadInit_.func = reinterpret_cast<lib_thread_func>(runThread);

        threadInit_.args = this;

        RISCV_thread_create(&threadInit_);

        if (threadInit_.Handle) {

            RISCV_event_set(&loopEnable_);

        }

        return loopEnable_.state;

    }

    /** @brief Stop and join thread */

    virtual void stop() {

        RISCV_event_clear(&loopEnable_);

        if (threadInit_.Handle) {

            RISCV_thread_join(threadInit_.Handle, 50000);

        }

        threadInit_.Handle = 0;

    }

    /** check thread status */

    virtual bool isEnabled() { return loopEnable_.state; }

    /** Pass data from the parent thread */

    virtual void setExtArgument(void *args) {}

 protected:

    /** working cycle function */

    virtual void busyLoop() =0;

    static void runThread(void *arg) {

        reinterpret_cast<IThread *>(arg)->busyLoop();

    }

 protected:

    event_def loopEnable_;

    LibThreadType threadInit_;

};

}  // namespace debugger

#endif  // __DEBUGGER_ITHREAD_H__