scottk/wlan-cloud-ucentralsec
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git synced 2025-11-02 19:57:46 +00:00
Code Issues Packages Projects Releases 10 Wiki Activity

Framework update

Browse Source
This commit is contained in:
stephb9959
2022-04-23 23:11:42 -07:00
parent 8cd7a99c55
commit dd138314b9
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/framework/MicroService.h
View File

@@ -1159,8 +1159,13 @@ namespace OpenWifi {
template <typename T> class FIFO {
public:
explicit FIFO(uint32_t Size) {
Buffer_->reserve(Size);
explicit FIFO(uint32_t Size) :
Size_(Size) {
Buffer_ = new T [Size_];
}
~FIFO() {
delete [] Buffer_;
}
mutable Poco::BasicEvent<bool> Writable_;
@@ -1173,8 +1178,8 @@ namespace OpenWifi {
return false;
}
t = (*Buffer_)[Read_++];
if (Read_ == Buffer_->capacity()) {
t = Buffer_[Read_++];
if (Read_ == Size_) {
Read_ = 0;
}
Used_--;
@@ -1188,12 +1193,8 @@ namespace OpenWifi {
{
std::lock_guard M(Mutex_);
if(Used_==Buffer_->capacity()) {
Buffer_->reserve( Buffer_->size()+100 );
}
(*Buffer_)[Write_++] = t;
if (Write_ == Buffer_->capacity()) {
Buffer_[Write_++] = t;
if (Write_ == Size_) {
Write_ = 0;
}
Used_++;
@@ -1213,11 +1214,12 @@ namespace OpenWifi {
private:
std::recursive_mutex Mutex_;
uint32_t Size_=0;
uint32_t Read_=0;
uint32_t Write_=0;
uint32_t Used_=0;
uint32_t MaxEverUsed_=0;
std::unique_ptr<std::vector<T>> Buffer_=std::make_unique<std::vector<T>>();
T * Buffer_ = nullptr;
};
template <class Record, typename KeyType = std::string, int Size=256, int Expiry=60000> class RecordCache {