Subversion Repositories riscv_vhdl

/*
 *  Copyright 2018 Sergey Khabarov, sergeykhbr@gmail.com
 *
 *  Licensed under the Apache License, Version 2.0 (the "License");
 *  you may not use this file except in compliance with the License.
 *  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 */
 
#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();
 
    /** Power ON/OFF cycle */
    void hardReset();
 
    /** Thread safe method of the callbacks registration */
    void put(AttributeType *item);
 
    /** push registered to the main queue */
    void pushPreQueued();
 
    /** Reset proccessed counter at the begining of each iteration */
    void initProc();
 
 protected:
    AttributeType item_;
    AttributeType stepQueue_;
    AttributeType stepPreQueued_;
    unsigned curIdx_;
    unsigned preLen_;
    unsigned curLen_;    // to avoid reallocation
    mutex_def mutex_;
};
 
 
class ClockAsyncTQueueType : public AsyncTQueueType {
 public:
    ClockAsyncTQueueType();
 
    /** Thread safe method of the callbacks registration */
    void put(uint64_t time, IFace *cb);
 
    /**
     * 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
    };
};
 
 
class GuiAsyncTQueueType : public AsyncTQueueType {
 public:
    GuiAsyncTQueueType();
 
    /** Thread safe method of the callbacks registration */
    void put(IFace *src, AttributeType *cmd, bool silent);
    bool getNext(IFace **src, AttributeType &cmd, bool &silent);
    void remove(IFace *src);
 
 private:
    enum QueueItemNames {
        Queue_Source,
        Queue_Command,
        Queue_Silent,
        Queue_Total
    };
    int dbg_cnt_;
};
 
}  // namespace debugger
 
#endif  // __DEBUGGER_ASYNC_TQUEUE_H__