| Line 1... |
Line 1... |
/**
|
/*
|
* @file
|
* Copyright 2018 Sergey Khabarov, sergeykhbr@gmail.com
|
* @copyright Copyright 2016 GNSS Sensor Ltd. All right reserved.
|
*
|
* @author Sergey Khabarov - sergeykhbr@gmail.com
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
* @brief Asynchronous queue with time markers.
|
* 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__
|
#ifndef __DEBUGGER_ASYNC_TQUEUE_H__
|
#define __DEBUGGER_ASYNC_TQUEUE_H__
|
#define __DEBUGGER_ASYNC_TQUEUE_H__
|
|
|
#include "api_types.h"
|
#include <api_types.h>
|
#include "iface.h"
|
#include <iface.h>
|
#include "attribute.h"
|
#include <attribute.h>
|
|
|
namespace debugger {
|
namespace debugger {
|
|
|
class AsyncTQueueType {
|
class AsyncTQueueType {
|
public:
|
public:
|
AsyncTQueueType();
|
AsyncTQueueType();
|
~AsyncTQueueType();
|
~AsyncTQueueType();
|
|
|
/** Thread safe method of the calbacks registration */
|
/** Power ON/OFF cycle */
|
void put(uint64_t time, IFace *cb);
|
void hardReset();
|
|
|
|
/** Thread safe method of the callbacks registration */
|
|
void put(AttributeType *item);
|
|
|
/** push registered to the main queue */
|
/** push registered to the main queue */
|
void pushPreQueued();
|
void pushPreQueued();
|
|
|
/** Reset proccessed counter at the begining of each iteration */
|
/** Reset proccessed counter at the begining of each iteration */
|
void initProc();
|
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'
|
* Get next registered interface with counter less or equal to 'step_cnt'
|
*/
|
*/
|
IFace *getNext(uint64_t step_cnt);
|
IFace *getNext(uint64_t step_cnt);
|
|
|
| Line 37... |
Line 67... |
enum QueueItemNames {
|
enum QueueItemNames {
|
Queue_Time,
|
Queue_Time,
|
Queue_IFace,
|
Queue_IFace,
|
Queue_Total
|
Queue_Total
|
};
|
};
|
AttributeType item_;
|
};
|
AttributeType stepQueue_;
|
|
AttributeType stepPreQueued_;
|
|
unsigned curIdx_;
|
class GuiAsyncTQueueType : public AsyncTQueueType {
|
unsigned preLen_;
|
public:
|
unsigned curLen_; // to avoid reallocation
|
GuiAsyncTQueueType();
|
mutex_def mutex_;
|
|
|
/** 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
|
} // namespace debugger
|
|
|
#endif // __DEBUGGER_ASYNC_TQUEUE_H__
|
#endif // __DEBUGGER_ASYNC_TQUEUE_H__
|
