comicsansg/CubicSDR
comicsansg/CubicSDR
1
0
Fork 0
mirror of https://github.com/cjcliffe/CubicSDR.git synced 2024-11-26 13:48:38 -05:00
Code Issues Projects Releases Wiki Activity

comment index debugging

Browse Source
This commit is contained in:
Charles J. Cliffe 2016-06-08 22:08:14 -04:00
parent 1dba16b15f
commit 9c10e2baaf
1 changed files with 16 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/IOThread.h
View File

@ -24,15 +24,15 @@ class ReferenceCounter {
public: public:
void setIndex(int idx) { // void setIndex(int idx) {
std::lock_guard < std::recursive_mutex > lock(m_mutex); // std::lock_guard < std::recursive_mutex > lock(m_mutex);
index = idx; // index = idx;
} // }
int getIndex() { // int getIndex() {
std::lock_guard < std::recursive_mutex > lock(m_mutex); // std::lock_guard < std::recursive_mutex > lock(m_mutex);
return index; // return index;
} // }
void setRefCount(int rc) { void setRefCount(int rc) {
std::lock_guard < std::recursive_mutex > lock(m_mutex); std::lock_guard < std::recursive_mutex > lock(m_mutex);
@ -59,7 +59,8 @@ protected:
mutable std::recursive_mutex m_mutex; mutable std::recursive_mutex m_mutex;
private: private:
int index, refCount; int refCount;
// int index;
}; };
@ -76,7 +77,8 @@ public:
garbageRemoval.push_back(*i); garbageRemoval.push_back(*i);
} }
else { else {
std::cout << "Garbage in queue buffer idx #" << (*i)->getIndex() << ", " << (*i)->getRefCount() << " usage(s)" << std::endl; // std::cout << "Garbage in queue buffer idx #" << (*i)->getIndex() << ", " << (*i)->getRefCount() << " usage(s)" << std::endl;
std::cout << "Garbage in queue buffer with " << (*i)->getRefCount() << " usage(s)" << std::endl;
} }
} }
if ( garbageRemoval.size() ) { if ( garbageRemoval.size() ) {
@ -106,7 +108,7 @@ class ReBuffer {
public: public:
ReBuffer(std::string bufferId) : bufferId(bufferId) { ReBuffer(std::string bufferId) : bufferId(bufferId) {
indexCounter.store(0); // indexCounter.store(0);
} }
BufferType *getBuffer() { BufferType *getBuffer() {
@ -128,7 +130,7 @@ public:
outputBuffers.pop_back(); outputBuffers.pop_back();
delete ref; delete ref;
} }
buf->setIndex(indexCounter++); // buf->setIndex(indexCounter++);
return buf; return buf;
} }
@ -139,7 +141,7 @@ public:
buf = new BufferType(); buf = new BufferType();
buf->setRefCount(1); buf->setRefCount(1);
buf->setIndex(indexCounter++); // buf->setIndex(indexCounter++);
outputBuffers.push_back(buf); outputBuffers.push_back(buf);
return buf; return buf;
@ -168,7 +170,7 @@ public:
std::deque<BufferType*> outputBuffers; std::deque<BufferType*> outputBuffers;
typename std::deque<BufferType*>::iterator outputBuffersI; typename std::deque<BufferType*>::iterator outputBuffersI;
mutable std::mutex m_mutex; mutable std::mutex m_mutex;
std::atomic_int indexCounter; // std::atomic_int indexCounter;
}; };