Subversion Repositories riscv_vhdl

/**

 * @file

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

 * @author     Sergey Khabarov - sergeykhbr@gmail.com

 * @brief      Asynchronous queue with time markers.

 */

#ifndef __DEBUGGER_ASYNC_TQUEUE_H__

#define __DEBUGGER_ASYNC_TQUEUE_H__

#include "api_types.h"

#include "iface.h"

#include "attribute.h"

namespace debugger {

class AsyncTQueueType {

public:

    AsyncTQueueType();

    ~AsyncTQueueType();

    /** Thread safe method of the calbacks registration */

    void put(uint64_t time, IFace *cb);

    /** push registered to the main queue */

    void pushPreQueued();

    /** Reset proccessed counter at the begining of each iteration */

    void initProc();

    /**

     * Get next registered interface with counter less or equal to 'step_cnt'

     */

    IFace *getNext(uint64_t step_cnt);

private:

    enum QueueItemNames {

        Queue_Time,

        Queue_IFace,

        Queue_Total

    };

    AttributeType item_;

    AttributeType stepQueue_;

    AttributeType stepPreQueued_;

    unsigned curIdx_;

    unsigned preLen_;

    unsigned curLen_;    // to avoid reallocation

    mutex_def mutex_;

};

}  // namespace debugger

#endif  // __DEBUGGER_ASYNC_TQUEUE_H__